Method Dial

modules/distributor/forwarder/otlpgrpc/forwarder.go:47–72

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

(ctx context.Context, opts ...grpc.DialOption)

// Dial creates client connections and clients based on config.
// Dial is expected to be called only once.
func (f *Forwarder) Dial(ctx context.Context, opts ...grpc.DialOption) error {
	f.mu.Lock()
	defer f.mu.Unlock()

	if f.initialized {
		return errors.New("already initialized")
	}

	connections := make(map[string]*grpc.ClientConn)
	clients := make(map[string]ptraceotlp.GRPCClient, len(f.cfg.Endpoints))
	for _, endpoint := range f.cfg.Endpoints {
		client, conn, err := f.newTraceOTLPGRPCClientAndConn(ctx, endpoint, f.cfg.TLS, opts...)
		if err != nil {
			return fmt.Errorf("failed to create new trace otlp grpc client: %w", err)
		}

		connections[endpoint] = conn
		clients[endpoint] = client
	}

	f.connections = connections
	f.clients = clients
	f.initialized = true

	return nil
}

func (f *Forwarder) ForwardTraces(ctx context.Context, traces ptrace.Traces) error {
	req := ptraceotlp.NewExportRequestFromTraces(traces)