grpc

Documentation

Index

• type Client
  • func New(ctx context.Context, opts *option.Options) (*Client, error)
  • func (c *Client) Close() error
  • func (c *Client) ReceiveCommand(ctx context.Context, channel string, group string, ...) error
  • func (c *Client) ReceiveEvent(ctx context.Context, channel string, group string, ...) error
  • func (c *Client) ReceiveEventStore(ctx context.Context, channel string, group string, ...) error
  • func (c *Client) ReceiveQuery(ctx context.Context, channel string, group string, ...) error
  • func (c *Client) SendCommand(ctx context.Context, channel string, m *transport.Message, ...) error
  • func (c *Client) SendEvent(ctx context.Context, channel string, m *transport.Message) error
  • func (c *Client) SendEventStore(ctx context.Context, channel string, m *transport.Message) error
  • func (c *Client) SendQuery(ctx context.Context, channel string, m *transport.Message, ...) (*transport.Message, error)

Types

type Client

type Client struct {
	// contains filtered or unexported fields
}

Client

func New

func New(ctx context.Context, opts *option.Options) (*Client, error)

New - create new client

func (*Client) Close

func (c *Client) Close() error

Close - close client connection

func (*Client) ReceiveCommand

func (c *Client) ReceiveCommand(ctx context.Context, channel string, group string, rxCh chan *transport.Message, errCh chan error) error

ReceiveCommand - start receiving command messages

func (*Client) ReceiveEvent

func (c *Client) ReceiveEvent(ctx context.Context, channel string, group string, rxCh chan *transport.Message, errCh chan error) error

ReceiveEvent - start receiving event messages

func (*Client) ReceiveEventStore

func (c *Client) ReceiveEventStore(ctx context.Context, channel string, group string, rxCh chan *transport.Message, errCh chan error) error

ReceiveEventStore - start receiving events store messages

func (*Client) ReceiveQuery

func (c *Client) ReceiveQuery(ctx context.Context, channel string, group string, rxCh chan *transport.Message, errCh chan error) error

ReceiveQuery - start receiving query messages

func (*Client) SendCommand

func (c *Client) SendCommand(ctx context.Context, channel string, m *transport.Message, timeout time.Duration) error

Send Command - send command message

func (*Client) SendEvent

func (c *Client) SendEvent(ctx context.Context, channel string, m *transport.Message) error

SendEvent - send event message

func (*Client) SendEventStore

func (c *Client) SendEventStore(ctx context.Context, channel string, m *transport.Message) error

SendEventStore - send event store message

func (*Client) SendQuery

func (c *Client) SendQuery(ctx context.Context, channel string, m *transport.Message, timeout time.Duration) (*transport.Message, error)

Send Query - send query message