Method init

api/connection.go:127–154

init takes care of actually establishing the connection to the gRPC server. If the connection is already established, this is a no-op. This function is go-routine safe, because potentially multiple callers could access this at the same time.

()

// this is a no-op. This function is go-routine safe, because potentially multiple callers could access this at the same
// time.
func (conn *RPCConnection[T]) init() (err error) {
	if conn == nil {
		return errors.New("RPC connection not configured")
	}

	// Check, if we already have a valid client connection. We use a read-only lock for a faster access.
	conn.m.RLock()
	if conn.cc != nil && conn.cc.GetState() != connectivity.Shutdown {
		defer conn.m.RUnlock()
		return nil
	}

	// If we arrive at this point we need to exchange our read-only lock for a write lock, since we are creating a new
	// connection and will write to the client conn property.
	conn.m.RUnlock()
	conn.m.Lock()
	defer conn.m.Unlock()

	// Establish a connection to the specified gRPC service
	conn.cc, err = grpc.NewClient(conn.Target,
		DefaultGrpcDialOptions(conn.Target, conn, conn.Opts...)...,
	)
	if err != nil {
		return fmt.Errorf("could not connect to gPRC target %q: %w", conn.Target, err)
	}

	return nil
}