client

Documentation

Index

• func Join[ResponseType proto.Message](ctx context.Context, c *RPCClient, rpc string, topic []string) (bus.Subscription[ResponseType], error)
• func JoinQueue[ResponseType proto.Message](ctx context.Context, c *RPCClient, rpc string, topic []string) (bus.Subscription[ResponseType], error)
• func OpenStream[SendType, RecvType proto.Message](ctx context.Context, c *RPCClient, rpc string, topic []string, ...) (psrpc.ClientStream[SendType, RecvType], error)
• func RequestMulti[ResponseType proto.Message](ctx context.Context, c *RPCClient, rpc string, topic []string, ...) (rChan <-chan *psrpc.Response[ResponseType], err error)
• func RequestSingle[ResponseType proto.Message](ctx context.Context, c *RPCClient, rpc string, topic []string, ...) (response ResponseType, err error)
• type RPCClient
  • func NewRPCClient(sd *info.ServiceDefinition, b bus.MessageBus, opts ...psrpc.ClientOption) (*RPCClient, error)
  • func NewRPCClientWithStreams(sd *info.ServiceDefinition, b bus.MessageBus, opts ...psrpc.ClientOption) (*RPCClient, error)
  • func (c *RPCClient) Close()

Functions

func Join

func Join[ResponseType proto.Message](
	ctx context.Context,
	c *RPCClient,
	rpc string,
	topic []string,
) (bus.Subscription[ResponseType], error)

func JoinQueue

func JoinQueue[ResponseType proto.Message](
	ctx context.Context,
	c *RPCClient,
	rpc string,
	topic []string,
) (bus.Subscription[ResponseType], error)

func OpenStream

func OpenStream[SendType, RecvType proto.Message](
	ctx context.Context,
	c *RPCClient,
	rpc string,
	topic []string,
	opts ...psrpc.RequestOption,
) (psrpc.ClientStream[SendType, RecvType], error)

func RequestMulti

func RequestMulti[ResponseType proto.Message](
	ctx context.Context,
	c *RPCClient,
	rpc string,
	topic []string,
	request proto.Message,
	opts ...psrpc.RequestOption,
) (rChan <-chan *psrpc.Response[ResponseType], err error)

func RequestSingle

func RequestSingle[ResponseType proto.Message](
	ctx context.Context,
	c *RPCClient,
	rpc string,
	topic []string,
	request proto.Message,
	opts ...psrpc.RequestOption,
) (response ResponseType, err error)

Types

type RPCClient

type RPCClient struct {
	*info.ServiceDefinition
	psrpc.ClientOpts
	// contains filtered or unexported fields
}

func NewRPCClient

func NewRPCClient(
	sd *info.ServiceDefinition,
	b bus.MessageBus,
	opts ...psrpc.ClientOption,
) (*RPCClient, error)

func NewRPCClientWithStreams

func NewRPCClientWithStreams(
	sd *info.ServiceDefinition,
	b bus.MessageBus,
	opts ...psrpc.ClientOption,
) (*RPCClient, error)

func (*RPCClient) Close

func (c *RPCClient) Close()