v2

Documentation

Index

• type Client
  • func NewClient(ctx context.Context, cfg *config.Connection) (*Client, error)
  • func (c *Client) Close() error
  • func (c *Client) Ping(ctx context.Context) (*grpc.ServerInfo, error)
  • func (c *Client) SendEvent(ctx context.Context, event *events.Event) error
  • func (c *Client) SendEventStore(ctx context.Context, event *events_store.EventStore) error
  • func (c *Client) SubscribeToEvents(ctx context.Context, subscription *events.EventsSubscription) error
  • func (c *Client) SubscribeToEventsStore(ctx context.Context, subscription *events_store.EventStoreSubscription) error

Types

type Client

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

func NewClient

func NewClient(ctx context.Context, cfg *config.Connection) (*Client, error)

func (*Client) Close

func (c *Client) Close() error

func (*Client) Ping

func (c *Client) Ping(ctx context.Context) (*grpc.ServerInfo, error)

func (*Client) SendEvent

func (c *Client) SendEvent(ctx context.Context, event *events.Event) error

func (*Client) SendEventStore

func (c *Client) SendEventStore(ctx context.Context, event *events_store.EventStore) error

func (*Client) SubscribeToEvents

func (c *Client) SubscribeToEvents(ctx context.Context, subscription *events.EventsSubscription) error

func (*Client) SubscribeToEventsStore

func (c *Client) SubscribeToEventsStore(ctx context.Context, subscription *events_store.EventStoreSubscription) error