Skip to content
This repository has been archived by the owner on Aug 30, 2019. It is now read-only.

Commit

Permalink
Clean minor nitpicks
Browse files Browse the repository at this point in the history
  • Loading branch information
LotharSee committed Dec 20, 2017
1 parent 1e367ac commit 33b1bab
Show file tree
Hide file tree
Showing 3 changed files with 3 additions and 4 deletions.
3 changes: 0 additions & 3 deletions agent/receiver_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -36,9 +36,6 @@ func NewTestReceiverFromConfig(conf *config.AgentConfig) *HTTPReceiver {
serviceChan := make(chan model.ServicesMetadata, 50)
receiver := NewHTTPReceiver(conf, dynConf, rawTraceChan, serviceChan)

receiver.traces = rawTraceChan
receiver.services = serviceChan

return receiver
}

Expand Down
2 changes: 1 addition & 1 deletion model/trace.proto
Original file line number Diff line number Diff line change
Expand Up @@ -8,5 +8,5 @@ message APITrace {
uint64 traceID = 1;
repeated Span spans = 2;
int64 startTime = 6;
int64 endTime = 7;
int64 endTime = 7;
}
2 changes: 2 additions & 0 deletions writer/trace_writer.go
Original file line number Diff line number Diff line change
Expand Up @@ -134,6 +134,8 @@ func (w *TraceWriter) Flush() {
}
atomic.AddInt64(&w.stats.Bytes, int64(len(serialized)))

// TODO: benchmark and pick the right encoding

headers := map[string]string{
languageHeaderKey: strings.Join(info.Languages(), "|"),
"Content-Type": "application/x-protobuf",
Expand Down

0 comments on commit 33b1bab

Please sign in to comment.