Documentation ¶ Index ¶ type Client func (c *Client) Close() error func (c *Client) Commit(ctx context.Context) error func (c *Client) Ping(context.Context) error func (c *Client) Poll(ctx context.Context) ([]*event.Event, error) func (c *Client) Publish(context.Context, *event.Event) error Constants ¶ This section is empty. Variables ¶ This section is empty. Functions ¶ This section is empty. Types ¶ type Client ¶ type Client struct{} Client Implements a no-op messaging client. Useful if a non-nil messaging client is required func (*Client) Close ¶ func (c *Client) Close() error func (*Client) Commit ¶ func (c *Client) Commit(ctx context.Context) error func (*Client) Ping ¶ func (c *Client) Ping(context.Context) error func (*Client) Poll ¶ func (c *Client) Poll(ctx context.Context) ([]*event.Event, error) func (*Client) Publish ¶ func (c *Client) Publish(context.Context, *event.Event) error Source Files ¶ View all Source files client.go Click to show internal directories. Click to hide internal directories.