Method Invoke

api/connection.go:89–104

Invoke implements [grpc.ClientConnInterface].

(ctx context.Context, method string, args interface{}, reply interface{}, opts ...grpc.CallOption)

// Invoke implements [grpc.ClientConnInterface].
func (conn *RPCConnection[T]) Invoke(ctx context.Context, method string, args interface{}, reply interface{}, opts ...grpc.CallOption) (err error) {
	// Make sure, this connection is established
	err = conn.init()
	if err != nil {
		return
	}

	// Then, just forward the request to the embedded client conn
	err = conn.cc.Invoke(ctx, method, args, reply, opts...)
	if errors.Is(err, io.EOF) || errors.Is(err, io.ErrUnexpectedEOF) {
		log.Debugf("Caught EOF while invoking method %s, forcing connection to reconnect on next call", method)
		conn.ForceReconnect()
	}

	return
}

// NewStream implements [grpc.ClientConnInterface].
func (conn *RPCConnection[T]) NewStream(ctx context.Context, desc *grpc.StreamDesc, method string, opts ...grpc.CallOption) (stream grpc.ClientStream, err error) {