Function NewForwarder

modules/distributor/forwarder/otlpgrpc/forwarder.go:30–43

(cfg Config, logger log.Logger)

}

func NewForwarder(cfg Config, logger log.Logger) (*Forwarder, error) {
	if err := cfg.Validate(); err != nil {
		return nil, fmt.Errorf("failed to validate config: %w", err)
	}

	return &Forwarder{
		cfg:         cfg,
		logger:      logger,
		connections: make(map[string]*grpc.ClientConn),
		clients:     make(map[string]ptraceotlp.GRPCClient),
		initialized: false,
		mu:          &sync.RWMutex{},
	}, nil
}

// Dial creates client connections and clients based on config.
// Dial is expected to be called only once.