rest

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)
• type Response

Types

type Client

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

func New

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

func (*Client) Close

func (c *Client) Close() error

func (*Client) ReceiveCommand

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

func (*Client) ReceiveEvent

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

func (*Client) ReceiveEventStore

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

func (*Client) ReceiveQuery

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

func (*Client) SendCommand

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

func (*Client) SendEvent

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

func (*Client) SendEventStore

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

func (*Client) SendQuery

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

type Response

type Response struct {
	Node        string          `json:"node"`
	Error       bool            `json:"error"`
	ErrorString string          `json:"error_string"`
	Data        json.RawMessage `json:"data"`
}