Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

[WIP] Add RabbitMQ source + target support #179

Draft
wants to merge 36 commits into
base: master
Choose a base branch
from
Draft
Changes from 1 commit
Commits
Show all changes
36 commits
Select commit Hold shift + click to select a range
3ae1054
Allow configuration from a file (closes #105)
adatzer Mar 15, 2022
04f0845
Change tls configurations to b64 env vars (closes #177)
TiganeteaRobert Jul 1, 2022
5e33f19
Use Snyk test to block release if there are vulnerabilities (closes #…
TiganeteaRobert May 11, 2022
16b8d30
Extend filtering to use custom data (closes #176)
TiganeteaRobert Apr 28, 2022
1308b67
Add telemetry (closes #124)
TiganeteaRobert May 20, 2022
b23eacc
Remove AWS Lambda and GCP Cloudfunctions builds (closes #140)
TiganeteaRobert Jun 10, 2022
3d8e979
Fail tests on NewConfig error (closes #145)
adatzer Apr 2, 2022
90d5766
Add custom transformation layer (closes #146)
adatzer Apr 7, 2022
2e131ba
Make anything that doesn't need to be exported private (closes #111)
TiganeteaRobert Jun 10, 2022
0ef135f
Revamp unit testing project-wide (closes #129)
colmsnowplow Jun 16, 2022
174eb69
Fix bug in makefile that prevents integration-down from completing (c…
colmsnowplow Jun 28, 2022
705f5ab
Bump analytics SDK version to v0.3.0 (closes #131)
colmsnowplow Jun 29, 2022
f269e04
Bump to Go 1.18 (closes #163)
colmsnowplow Jul 1, 2022
0a37d58
Resolve CI caching errors (closes #164)
colmsnowplow Jul 1, 2022
e43fa76
Rationalise transformations and transformation config (closes #169)
TiganeteaRobert Jul 19, 2022
eab236d
Fix latency reporting with no transformations (closes #108)
colmsnowplow Jul 4, 2022
8b005fa
Make setting of EventHub Partition Key configurable (closes #148)
colmsnowplow Jul 4, 2022
14f0731
Cleanup Makefile (closes #112)
colmsnowplow Jul 5, 2022
94f0859
Fix typo in statsd reporting (closes #158)
colmsnowplow Jul 5, 2022
61ab768
Allow env var configuration of updated transformation config (closes …
colmsnowplow Jul 21, 2022
08522b7
Fix import order (closes #175)
colmsnowplow Jul 22, 2022
539542d
Bump dependencies (closes #120)
colmsnowplow Jul 22, 2022
b6e8777
Prepared for release
colmsnowplow Jul 22, 2022
2b27287
Only delete temp dir after other resources are stopped
colmsnowplow Jul 27, 2022
1162b57
Rename EnableTelemetry to DisableTelemetry
colmsnowplow Jul 27, 2022
c1c68ef
Make telemetry.disable actually disable telemetry
colmsnowplow Jul 27, 2022
b5d5a1a
Use the appVersion constant for telemetry applicationVersion
colmsnowplow Jul 27, 2022
f4d55c1
Add RabbitMQ as a source option
jbeemster Jul 28, 2022
1cc1e41
Add RabbitMQ as a target option
jbeemster Jul 28, 2022
e96c124
Add basic tests
jbeemster Jul 28, 2022
0f36f0e
Update rabbitmq.go
jbeemster Jul 28, 2022
bdb8a17
Ensure queues are durable
jbeemster Jul 28, 2022
90a81c1
Add pre-fetch + persistent messages
jbeemster Jul 28, 2022
cc0ffcf
Add fanout to source + destination
jbeemster Jul 28, 2022
6db53df
Tweaks
jbeemster Jul 28, 2022
93cbc7d
Add new TODO
jbeemster Jul 28, 2022
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
Fix typo in statsd reporting (closes #158)
colmsnowplow committed Jul 22, 2022
commit 94f085953eb4972d6c4f23879aa3c89c9e3122d4
2 changes: 1 addition & 1 deletion pkg/statsreceiver/statsd.go
Original file line number Diff line number Diff line change
@@ -113,6 +113,6 @@ func (s *statsDStatsReceiver) Send(b *models.ObserverBuffer) {
s.client.Incr("oversized_message_failed", b.OversizedMsgFailed)
s.client.Incr("invalid_message_sent", b.InvalidMsgSent)
s.client.Incr("invalid_message_failed", b.InvalidMsgFailed)
s.client.PrecisionTiming("latency_proccesing_max", b.MaxProcLatency)
s.client.PrecisionTiming("latency_processing_max", b.MaxProcLatency)
s.client.PrecisionTiming("latency_message_max", b.MaxMsgLatency)
}