Skip to content
This repository was archived by the owner on Nov 7, 2022. It is now read-only.

Commit f46d8b4

Browse files
author
Bogdan Drutu
authored
Remove unused functionality for multi receivers. (#413)
1 parent 029c342 commit f46d8b4

1 file changed

Lines changed: 0 additions & 63 deletions

File tree

receiver/receiver.go

Lines changed: 0 additions & 63 deletions
Original file line numberDiff line numberDiff line change
@@ -18,7 +18,6 @@ import (
1818
"context"
1919

2020
"github.com/census-instrumentation/opencensus-service/data"
21-
"github.com/census-instrumentation/opencensus-service/internal"
2221
_ "github.com/census-instrumentation/opencensus-service/internal/compression/grpc" // load in supported grpc compression encodings
2322
)
2423

@@ -74,65 +73,3 @@ type MetricsReceiverAcknowledgement struct {
7473
SavedMetrics uint64
7574
DroppedMetrics uint64
7675
}
77-
78-
// MultiTraceReceiver wraps multiple trace receivers in a single one.
79-
func MultiTraceReceiver(trs ...TraceReceiver) TraceReceiver {
80-
return traceReceivers(trs)
81-
}
82-
83-
type traceReceivers []TraceReceiver
84-
85-
func (trs traceReceivers) StartTraceReception(ctx context.Context, destination TraceReceiverSink) error {
86-
var errs []error
87-
for _, tr := range trs {
88-
err := tr.StartTraceReception(ctx, destination)
89-
if err != nil {
90-
errs = append(errs, err)
91-
}
92-
}
93-
94-
return internal.CombineErrors(errs)
95-
}
96-
97-
func (trs traceReceivers) StopTraceReception(ctx context.Context) error {
98-
var errs []error
99-
for _, tr := range trs {
100-
err := tr.StopTraceReception(ctx)
101-
if err != nil {
102-
errs = append(errs, err)
103-
}
104-
}
105-
106-
return internal.CombineErrors(errs)
107-
}
108-
109-
// MultiMetricsReceiver wraps multiple metrics receivers in a single one.
110-
func MultiMetricsReceiver(mrs ...MetricsReceiver) MetricsReceiver {
111-
return metricsReceivers(mrs)
112-
}
113-
114-
type metricsReceivers []MetricsReceiver
115-
116-
func (mrs metricsReceivers) StartMetricsReception(ctx context.Context, destination MetricsReceiverSink) error {
117-
var errs []error
118-
for _, mr := range mrs {
119-
err := mr.StartMetricsReception(ctx, destination)
120-
if err != nil {
121-
errs = append(errs, err)
122-
}
123-
}
124-
125-
return internal.CombineErrors(errs)
126-
}
127-
128-
func (mrs metricsReceivers) StopMetricsReception(ctx context.Context) error {
129-
var errs []error
130-
for _, mr := range mrs {
131-
err := mr.StopMetricsReception(ctx)
132-
if err != nil {
133-
errs = append(errs, err)
134-
}
135-
}
136-
137-
return internal.CombineErrors(errs)
138-
}

0 commit comments

Comments
 (0)