| 19 | ) |
| 20 | |
| 21 | type Forwarder struct { |
| 22 | cfg Config |
| 23 | logger log.Logger |
| 24 | connections map[string]*grpc.ClientConn |
| 25 | clients map[string]ptraceotlp.GRPCClient |
| 26 | initialized bool |
| 27 | mu *sync.RWMutex |
| 28 | } |
| 29 | |
| 30 | func NewForwarder(cfg Config, logger log.Logger) (*Forwarder, error) { |
| 31 | if err := cfg.Validate(); err != nil { |
nothing calls this directly
no outgoing calls
no test coverage detected