(logger log.Logger, fn forwardFunc, o overrides.Interface)
| 62 | } |
| 63 | |
| 64 | func newGeneratorForwarder(logger log.Logger, fn forwardFunc, o overrides.Interface) *generatorForwarder { |
| 65 | rf := &generatorForwarder{ |
| 66 | logger: logger, |
| 67 | queues: make(map[string]*queue.Queue[*request]), |
| 68 | mutex: sync.RWMutex{}, |
| 69 | forwardFunc: fn, |
| 70 | o: o, |
| 71 | overridesInterval: time.Minute, |
| 72 | shutdown: make(chan interface{}), |
| 73 | } |
| 74 | |
| 75 | rf.Service = services.NewIdleService(rf.start, rf.stop) |
| 76 | |
| 77 | return rf |
| 78 | } |
| 79 | |
| 80 | // SendTraces queues up traces to be sent to the metrics-generators |
| 81 | func (f *generatorForwarder) SendTraces(ctx context.Context, tenantID string, keys []uint32, traces []*rebatchedTrace) { |
no outgoing calls