Skip to content

Commit

Permalink
v1.8.1 adding amqp target
Browse files Browse the repository at this point in the history
  • Loading branch information
@liornabat
liornabat committed Mar 18, 2024
1 parent 7920779 commit d458816
Show file tree
Hide file tree
Showing 11 changed files with 158 additions and 75 deletions.
4 changes: 3 additions & 1 deletion Taskfile.yml
View file
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,7 @@ version: '3'

vars:
BINARY_NAME: kubemq-targets
VERSION: v1.8.0
VERSION: v1.8.1
REPO_GCP: europe-docker.pkg.dev/kubemq/images
REPO_DOCKERHUB: kubemq
tasks:
Expand All @@ -26,6 +26,8 @@ tasks:
GOOS: '{{OS}}'
GOARCH: '{{ARCH}}'
cmds:
- go mod tidy
- go mod vendor
- go build -tags container -o "{{.BINARY_NAME}}.exe" -ldflags "-X main.version={{.VERSION}}"
test:
cmds:
Expand Down
4 changes: 1 addition & 3 deletions go.mod
View file
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,7 @@ module github.com/kubemq-io/kubemq-targets

go 1.20

replace github.com/Azure/azure-service-bus-go => github.com/Azure/azure-service-bus-go v0.10.3
//replace github.com/Azure/azure-service-bus-go => github.com/Azure/azure-service-bus-go v0.10.3

require (
cloud.google.com/go v0.110.8 // indirect
Expand All @@ -13,7 +13,6 @@ require (
cloud.google.com/go/spanner v1.50.0
cloud.google.com/go/storage v1.33.0
firebase.google.com/go/v4 v4.12.1
github.com/Azure/azure-event-hubs-go/v3 v3.3.0
github.com/Azure/azure-pipeline-go v0.2.3
github.com/Azure/azure-sdk-for-go v46.1.0+incompatible // indirect
github.com/Azure/azure-service-bus-go v0.10.3
Expand Down Expand Up @@ -125,7 +124,6 @@ require (
github.com/jcmturner/rpc/v2 v2.0.3 // indirect
github.com/jmespath/go-jmespath v0.4.0 // indirect
github.com/josharian/intern v1.0.0 // indirect
github.com/jpillora/backoff v1.0.0 // indirect
github.com/kballard/go-shellquote v0.0.0-20180428030007-95032a82bc51 // indirect
github.com/klauspost/compress v1.17.0 // indirect
github.com/kubemq-io/protobuf v1.3.1 // indirect
Expand Down
110 changes: 110 additions & 0 deletions logs/kubemq-targets.log
View file
Original file line number Diff line number Diff line change
Expand Up @@ -55079,3 +55079,113 @@ caused by: context canceled {"source": "target-1"}
2023-10-15T13:45:18.324+0300 INFO connection: 1, grpc queue client downstream connected {"source": "binding-target-1"}
2023-10-15T13:45:19.336+0300 INFO binding: target-1, started successfully {"source": "binding-target-1"}
2023-10-15T13:45:25.950+0300 INFO kubemq targets connectors stopped {"source": "kubemq-targets"}
2024-03-18T10:03:38.848+0200 INFO generated manifest.json completed {"source": "kubemq-targets"}
2024-03-18T11:13:39.670+0200 INFO generated manifest.json completed {"source": "kubemq-targets"}
2024-03-18T12:06:31.433+0200 INFO starting kubemq targets connectors version: {"source": "kubemq-targets"}
2024-03-18T12:06:31.439+0200 INFO 1 bindings loaded {"source": "config"}
2024-03-18T12:06:31.451+0200 ERROR failed to initialized binding, error loading target conntector on binding kubemq-query-amqp, error dialing active, SASL PLAIN auth failed with code 0x1: {"source": "binding-service"}
2024-03-18T12:06:32.456+0200 ERROR failed to initialized binding: kubemq-query-amqp, attempt: 1, error: error loading target conntector on binding kubemq-query-amqp, error dialing active, SASL PLAIN auth failed with code 0x1: {"source": "binding-service"}
2024-03-18T12:06:33.477+0200 ERROR failed to initialized binding: kubemq-query-amqp, attempt: 2, error: error loading target conntector on binding kubemq-query-amqp, error dialing active, SASL PLAIN auth failed with code 0x1: {"source": "binding-service"}
2024-03-18T12:06:34.491+0200 ERROR failed to initialized binding: kubemq-query-amqp, attempt: 3, error: error loading target conntector on binding kubemq-query-amqp, error dialing active, SASL PLAIN auth failed with code 0x1: {"source": "binding-service"}
2024-03-18T12:06:35.500+0200 ERROR failed to initialized binding: kubemq-query-amqp, attempt: 4, error: error loading target conntector on binding kubemq-query-amqp, error dialing active, SASL PLAIN auth failed with code 0x1: {"source": "binding-service"}
2024-03-18T12:06:36.529+0200 ERROR failed to initialized binding: kubemq-query-amqp, attempt: 5, error: error loading target conntector on binding kubemq-query-amqp, error dialing active, SASL PLAIN auth failed with code 0x1: {"source": "binding-service"}
2024-03-18T12:06:37.549+0200 ERROR failed to initialized binding: kubemq-query-amqp, attempt: 6, error: error loading target conntector on binding kubemq-query-amqp, error dialing active, SASL PLAIN auth failed with code 0x1: {"source": "binding-service"}
2024-03-18T12:06:38.566+0200 ERROR failed to initialized binding: kubemq-query-amqp, attempt: 7, error: error loading target conntector on binding kubemq-query-amqp, error dialing active, SASL PLAIN auth failed with code 0x1: {"source": "binding-service"}
2024-03-18T12:06:39.579+0200 ERROR failed to initialized binding: kubemq-query-amqp, attempt: 8, error: error loading target conntector on binding kubemq-query-amqp, error dialing active, SASL PLAIN auth failed with code 0x1: {"source": "binding-service"}
2024-03-18T12:06:40.594+0200 ERROR failed to initialized binding: kubemq-query-amqp, attempt: 9, error: error loading target conntector on binding kubemq-query-amqp, error dialing active, SASL PLAIN auth failed with code 0x1: {"source": "binding-service"}
2024-03-18T12:06:41.614+0200 ERROR failed to initialized binding: kubemq-query-amqp, attempt: 10, error: error loading target conntector on binding kubemq-query-amqp, error dialing active, SASL PLAIN auth failed with code 0x1: {"source": "binding-service"}
2024-03-18T12:06:42.638+0200 ERROR failed to initialized binding: kubemq-query-amqp, attempt: 11, error: error loading target conntector on binding kubemq-query-amqp, error dialing active, SASL PLAIN auth failed with code 0x1: {"source": "binding-service"}
2024-03-18T12:06:43.658+0200 ERROR failed to initialized binding: kubemq-query-amqp, attempt: 12, error: error loading target conntector on binding kubemq-query-amqp, error dialing active, SASL PLAIN auth failed with code 0x1: {"source": "binding-service"}
2024-03-18T12:06:44.674+0200 ERROR failed to initialized binding: kubemq-query-amqp, attempt: 13, error: error loading target conntector on binding kubemq-query-amqp, error dialing active, SASL PLAIN auth failed with code 0x1: {"source": "binding-service"}
2024-03-18T12:06:45.689+0200 ERROR failed to initialized binding: kubemq-query-amqp, attempt: 14, error: error loading target conntector on binding kubemq-query-amqp, error dialing active, SASL PLAIN auth failed with code 0x1: {"source": "binding-service"}
2024-03-18T12:06:46.704+0200 ERROR failed to initialized binding: kubemq-query-amqp, attempt: 15, error: error loading target conntector on binding kubemq-query-amqp, error dialing active, SASL PLAIN auth failed with code 0x1: {"source": "binding-service"}
2024-03-18T12:07:22.295+0200 INFO starting kubemq targets connectors version: {"source": "kubemq-targets"}
2024-03-18T12:07:22.300+0200 INFO 1 bindings loaded {"source": "config"}
2024-03-18T12:07:22.355+0200 INFO binding: kubemq-query-amqp target: initialized successfully {"source": "binding-kubemq-query-amqp"}
2024-03-18T12:07:22.360+0200 INFO binding: kubemq-query-amqp source initialized successfully {"source": "binding-kubemq-query-amqp"}
2024-03-18T12:07:22.360+0200 INFO binding: kubemq-query-amqp, initialized successfully {"source": "binding-kubemq-query-amqp"}
2024-03-18T12:07:22.360+0200 INFO binding: kubemq-query-amqp, started successfully {"source": "binding-kubemq-query-amqp"}
2024-03-18T12:07:41.193+0200 ERROR retry 0 failed, error: error parsing address name, value of key address cannot be empty {"source": "binding-kubemq-query-amqp"}
2024-03-18T12:08:53.947+0200 INFO kubemq targets connectors stopped {"source": "kubemq-targets"}
2024-03-18T12:08:58.427+0200 INFO starting kubemq targets connectors version: {"source": "kubemq-targets"}
2024-03-18T12:08:58.434+0200 INFO 1 bindings loaded {"source": "config"}
2024-03-18T12:08:58.506+0200 INFO binding: kubemq-query-amqp target: initialized successfully {"source": "binding-kubemq-query-amqp"}
2024-03-18T12:08:58.514+0200 INFO binding: kubemq-query-amqp source initialized successfully {"source": "binding-kubemq-query-amqp"}
2024-03-18T12:08:58.514+0200 INFO binding: kubemq-query-amqp, initialized successfully {"source": "binding-kubemq-query-amqp"}
2024-03-18T12:08:58.514+0200 INFO binding: kubemq-query-amqp, started successfully {"source": "binding-kubemq-query-amqp"}
2024-03-18T12:09:03.680+0200 ERROR retry 0 failed, error: error parsing address name, value of key address cannot be empty {"source": "binding-kubemq-query-amqp"}
2024-03-18T12:09:57.701+0200 INFO kubemq targets connectors stopped {"source": "kubemq-targets"}
2024-03-18T12:10:02.248+0200 INFO starting kubemq targets connectors version: {"source": "kubemq-targets"}
2024-03-18T12:10:02.254+0200 INFO 1 bindings loaded {"source": "config"}
2024-03-18T12:10:02.315+0200 INFO binding: kubemq-query-amqp target: initialized successfully {"source": "binding-kubemq-query-amqp"}
2024-03-18T12:10:02.319+0200 INFO binding: kubemq-query-amqp source initialized successfully {"source": "binding-kubemq-query-amqp"}
2024-03-18T12:10:02.319+0200 INFO binding: kubemq-query-amqp, initialized successfully {"source": "binding-kubemq-query-amqp"}
2024-03-18T12:10:02.319+0200 INFO binding: kubemq-query-amqp, started successfully {"source": "binding-kubemq-query-amqp"}
2024-03-18T12:10:07.230+0200 ERROR retry 0 failed, error: error parsing address name, value of key address cannot be empty {"source": "binding-kubemq-query-amqp"}
2024-03-18T12:10:54.340+0200 ERROR retry 0 failed, error: error parsing address name, value of key address cannot be empty {"source": "binding-kubemq-query-amqp"}
2024-03-18T12:11:16.392+0200 ERROR retry 0 failed, error: error parsing address name, value of key address cannot be empty {"source": "binding-kubemq-query-amqp"}
2024-03-18T12:20:53.982+0200 INFO kubemq targets connectors stopped {"source": "kubemq-targets"}
2024-03-18T12:20:59.694+0200 INFO starting kubemq targets connectors version: {"source": "kubemq-targets"}
2024-03-18T12:20:59.699+0200 INFO 1 bindings loaded {"source": "config"}
2024-03-18T12:20:59.762+0200 INFO binding: kubemq-query-amqp target: initialized successfully {"source": "binding-kubemq-query-amqp"}
2024-03-18T12:20:59.766+0200 INFO binding: kubemq-query-amqp source initialized successfully {"source": "binding-kubemq-query-amqp"}
2024-03-18T12:20:59.767+0200 INFO binding: kubemq-query-amqp, initialized successfully {"source": "binding-kubemq-query-amqp"}
2024-03-18T12:20:59.767+0200 INFO binding: kubemq-query-amqp, started successfully {"source": "binding-kubemq-query-amqp"}
2024-03-18T12:21:32.223+0200 ERROR retry 0 failed, error: error parsing address name, value of key address cannot be empty {"source": "binding-kubemq-query-amqp"}
2024-03-18T12:26:39.436+0200 INFO kubemq targets connectors stopped {"source": "kubemq-targets"}
2024-03-18T12:26:44.325+0200 INFO starting kubemq targets connectors version: {"source": "kubemq-targets"}
2024-03-18T12:26:44.331+0200 INFO 1 bindings loaded {"source": "config"}
2024-03-18T12:26:44.389+0200 INFO binding: kubemq-query-amqp target: initialized successfully {"source": "binding-kubemq-query-amqp"}
2024-03-18T12:26:44.395+0200 INFO binding: kubemq-query-amqp source initialized successfully {"source": "binding-kubemq-query-amqp"}
2024-03-18T12:26:44.395+0200 INFO binding: kubemq-query-amqp, initialized successfully {"source": "binding-kubemq-query-amqp"}
2024-03-18T12:26:44.395+0200 INFO binding: kubemq-query-amqp, started successfully {"source": "binding-kubemq-query-amqp"}
2024-03-18T12:26:57.281+0200 ERROR retry 0 failed, error: error parsing address name, value of key address cannot be empty {"source": "binding-kubemq-query-amqp"}
2024-03-18T12:27:41.788+0200 INFO kubemq targets connectors stopped {"source": "kubemq-targets"}
2024-03-18T12:27:46.009+0200 INFO starting kubemq targets connectors version: {"source": "kubemq-targets"}
2024-03-18T12:27:46.015+0200 INFO 1 bindings loaded {"source": "config"}
2024-03-18T12:27:46.069+0200 INFO binding: kubemq-query-amqp target: initialized successfully {"source": "binding-kubemq-query-amqp"}
2024-03-18T12:27:46.074+0200 INFO binding: kubemq-query-amqp source initialized successfully {"source": "binding-kubemq-query-amqp"}
2024-03-18T12:27:46.074+0200 INFO binding: kubemq-query-amqp, initialized successfully {"source": "binding-kubemq-query-amqp"}
2024-03-18T12:27:46.074+0200 INFO binding: kubemq-query-amqp, started successfully {"source": "binding-kubemq-query-amqp"}
2024-03-18T12:27:54.767+0200 ERROR retry 0 failed, error: error parsing address name, value of key address cannot be empty {"source": "binding-kubemq-query-amqp"}
2024-03-18T12:29:44.779+0200 INFO kubemq targets connectors stopped {"source": "kubemq-targets"}
2024-03-18T12:29:50.061+0200 INFO starting kubemq targets connectors version: {"source": "kubemq-targets"}
2024-03-18T12:29:50.066+0200 INFO 1 bindings loaded {"source": "config"}
2024-03-18T12:29:50.129+0200 INFO binding: kubemq-query-amqp target: initialized successfully {"source": "binding-kubemq-query-amqp"}
2024-03-18T12:29:50.136+0200 INFO binding: kubemq-query-amqp source initialized successfully {"source": "binding-kubemq-query-amqp"}
2024-03-18T12:29:50.136+0200 INFO binding: kubemq-query-amqp, initialized successfully {"source": "binding-kubemq-query-amqp"}
2024-03-18T12:29:50.136+0200 INFO binding: kubemq-query-amqp, started successfully {"source": "binding-kubemq-query-amqp"}
2024-03-18T12:29:58.292+0200 ERROR retry 0 failed, error: error parsing address name, value of key address cannot be empty {"source": "binding-kubemq-query-amqp"}
2024-03-18T13:04:39.857+0200 INFO kubemq targets connectors stopped {"source": "kubemq-targets"}
2024-03-18T13:04:45.295+0200 INFO starting kubemq targets connectors version: {"source": "kubemq-targets"}
2024-03-18T13:04:45.301+0200 INFO 1 bindings loaded {"source": "config"}
2024-03-18T13:04:45.363+0200 INFO binding: kubemq-query-amqp target: initialized successfully {"source": "binding-kubemq-query-amqp"}
2024-03-18T13:04:45.369+0200 INFO binding: kubemq-query-amqp source initialized successfully {"source": "binding-kubemq-query-amqp"}
2024-03-18T13:04:45.369+0200 INFO binding: kubemq-query-amqp, initialized successfully {"source": "binding-kubemq-query-amqp"}
2024-03-18T13:04:45.369+0200 INFO binding: kubemq-query-amqp, started successfully {"source": "binding-kubemq-query-amqp"}
2024-03-18T15:09:00.859+0200 INFO kubemq targets connectors stopped {"source": "kubemq-targets"}
2024-03-18T15:09:06.603+0200 INFO starting kubemq targets connectors version: {"source": "kubemq-targets"}
2024-03-18T15:09:06.608+0200 INFO 1 bindings loaded {"source": "config"}
2024-03-18T15:09:06.670+0200 INFO binding: kubemq-query-amqp target: initialized successfully {"source": "binding-kubemq-query-amqp"}
2024-03-18T15:09:06.674+0200 INFO binding: kubemq-query-amqp source initialized successfully {"source": "binding-kubemq-query-amqp"}
2024-03-18T15:09:06.674+0200 INFO binding: kubemq-query-amqp, initialized successfully {"source": "binding-kubemq-query-amqp"}
2024-03-18T15:09:06.674+0200 INFO binding: kubemq-query-amqp, started successfully {"source": "binding-kubemq-query-amqp"}
2024-03-18T15:10:51.582+0200 ERROR retry 0 failed, error: error parsing address name, value of key address cannot be empty {"source": "binding-kubemq-query-amqp"}
2024-03-18T15:12:22.224+0200 INFO kubemq targets connectors stopped {"source": "kubemq-targets"}
2024-03-18T15:12:27.025+0200 INFO starting kubemq targets connectors version: {"source": "kubemq-targets"}
2024-03-18T15:12:27.030+0200 INFO 1 bindings loaded {"source": "config"}
2024-03-18T15:12:27.090+0200 INFO binding: kubemq-query-amqp target: initialized successfully {"source": "binding-kubemq-query-amqp"}
2024-03-18T15:12:27.094+0200 INFO binding: kubemq-query-amqp source initialized successfully {"source": "binding-kubemq-query-amqp"}
2024-03-18T15:12:27.094+0200 INFO binding: kubemq-query-amqp, initialized successfully {"source": "binding-kubemq-query-amqp"}
2024-03-18T15:12:27.094+0200 INFO binding: kubemq-query-amqp, started successfully {"source": "binding-kubemq-query-amqp"}
2024-03-18T15:12:39.349+0200 ERROR retry 0 failed, error: error parsing address name, value of key address cannot be empty {"source": "binding-kubemq-query-amqp"}
2024-03-18T15:13:56.590+0200 INFO kubemq targets connectors stopped {"source": "kubemq-targets"}
2024-03-18T15:14:01.192+0200 INFO starting kubemq targets connectors version: {"source": "kubemq-targets"}
2024-03-18T15:14:01.198+0200 INFO 1 bindings loaded {"source": "config"}
2024-03-18T15:14:01.259+0200 INFO binding: kubemq-query-amqp target: initialized successfully {"source": "binding-kubemq-query-amqp"}
2024-03-18T15:14:01.263+0200 INFO binding: kubemq-query-amqp source initialized successfully {"source": "binding-kubemq-query-amqp"}
2024-03-18T15:14:01.263+0200 INFO binding: kubemq-query-amqp, initialized successfully {"source": "binding-kubemq-query-amqp"}
2024-03-18T15:14:01.263+0200 INFO binding: kubemq-query-amqp, started successfully {"source": "binding-kubemq-query-amqp"}
2024-03-18T15:16:52.587+0200 INFO kubemq targets connectors stopped {"source": "kubemq-targets"}
2024-03-18T15:18:13.089+0200 INFO generated manifest.json completed {"source": "kubemq-targets"}
2024-03-18T15:22:47.073+0200 INFO generated manifest.json completed {"source": "kubemq-targets"}
2 changes: 1 addition & 1 deletion targets-manifest-hash.txt
View file
Original file line number Diff line number Diff line change
@@ -1 +1 @@
f20bd9e620e0c5838f8886f9b551a3a4ef6ac4c6c6177fd7bf41995b200f1f06
1adc3bc8a5089d524ccdaf89f07bb43046c2eace710581bb3e5d11fa7d8486d0
2 changes: 1 addition & 1 deletion targets-manifest.json
View file

Large diffs are not rendered by default.

3 changes: 1 addition & 2 deletions targets/messaging/amqp/README.md
View file
Original file line number Diff line number Diff line change
Expand Up @@ -85,8 +85,7 @@ Example:
{
"metadata": {
"address": "some-address",
"durable": true,
"priority": 1,
"durable": true
},
"data": "U0VMRUNUIGlkLHRpdGxlLGNvbnRlbnQgRlJPTSBwb3N0Ow=="
}
Expand Down
1 change: 1 addition & 0 deletions targets/messaging/amqp/client.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -90,6 +90,7 @@ func (c *Client) connect(ctx context.Context) error {
}

func (c *Client) Do(ctx context.Context, req *types.Request) (*types.Response, error) {
fmt.Println(req)
meta, err := parseMetadata(req.Metadata)
if err != nil {
return nil, err
Expand Down
2 changes: 1 addition & 1 deletion targets/messaging/amqp/client_test.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,7 @@ func TestClient_Init(t *testing.T) {
Name: "messaging-amqp",
Kind: "messaging.amqp",
Properties: map[string]string{
"url": "amqp://localhost:5672/",
"url": "amqp://192.168.50.95:5672/",
"username": "artemis",
"password": "simetraehcapa",
},
Expand Down
28 changes: 14 additions & 14 deletions targets/messaging/amqp/connector.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -22,33 +22,33 @@ func Connector() *common.Connector {
).
AddProperty(
common.NewProperty().
SetKind("bool").
SetName("skip_insecure").
SetDescription("Set skip TLS Certificate verification").
SetKind("string").
SetName("username").
SetDescription("Set AMQP username").
SetMust(false).
SetDefault("false"),
SetDefault(""),
).
AddProperty(
common.NewProperty().
SetKind("multilines").
SetName("ca_cert").
SetDescription("Set TLS CA Certificate").
SetKind("string").
SetName("password").
SetDescription("Set AMQP password").
SetMust(false).
SetDefault(""),
).
AddProperty(
common.NewProperty().
SetKind("string").
SetName("username").
SetDescription("Set AMQP username").
SetKind("bool").
SetName("skip_insecure").
SetDescription("(SSL) Set skip TLS Certificate verification").
SetMust(false).
SetDefault(""),
SetDefault("false"),
).
AddProperty(
common.NewProperty().
SetKind("string").
SetName("password").
SetDescription("Set AMQP password").
SetKind("multilines").
SetName("ca_cert").
SetDescription("(SSL) Set TLS CA Certificate").
SetMust(false).
SetDefault(""),
)
Expand Down
Loading

0 comments on commit d458816

Please sign in to comment.