-
Notifications
You must be signed in to change notification settings - Fork 113
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
Add GCP Cloud PubSub reporter #159
Add GCP Cloud PubSub reporter #159
Conversation
# Conflicts: # go.mod # go.sum
# Conflicts: # go.mod # go.sum
I will use stubReporter. Working on in now. |
I introduce stubReporter and stubClient. |
@@ -1,25 +1,31 @@ | |||
module github.com/openzipkin/zipkin-go | |||
|
|||
require ( |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I see many dependencies being added, did you try go mod tidy
?
var resultMsg = make(chan reporterResult) | ||
|
||
// Reporter implements Reporter by publishing spans to a GCP gcppubsub. | ||
type Reporter struct { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I am curious about this being exported. Can't this be private?
|
||
const defaultPubSubTopic = "defaultTopic" | ||
|
||
var resultMsg = make(chan reporterResult) |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Just out of curiosity, why this is not part of the struct that entirely uses it? Also, could we rename it into resultMsgC
otherwise it is the easiest to understand what happens in line 104.
Any feedback @basvanbeek ? |
What
Why