eventgate_client_go

Feb 11, 2021

Changes in this version

type Client

+ func (c *Client) GetObject(ctx context.Context, in *eventgate.ObjectRef) error

+ func (c *Client) SearchEvents(ctx context.Context, in *eventgate.SearchOpts) (*eventgate.Events, error)

+ func (c *Client) SetObject(ctx context.Context, in *eventgate.Object) error

+ func (c *Client) StreamEvents(ctx context.Context, in *eventgate.StreamOpts, ...) error

Feb 10, 2021

Changes in this version

type Client

+ func (c *Client) Close() error

Feb 9, 2021

Changes in this version

type Client

+ func (c *Client) History(ctx context.Context, in *eventgate.HistoryOpts) (*eventgate.Events, error)

Feb 2, 2021

Changes in this version

+ type Client struct

+ func NewClient(ctx context.Context, target string, opts ...Opt) (*Client, error)

+ func (c *Client) Receive(ctx context.Context, in *eventgate.ReceiveRequest, ...) error

+ func (c *Client) Request(ctx context.Context, in *eventgate.CloudEventInput) (*eventgate.CloudEvent, error)

+ func (c *Client) Send(ctx context.Context, in *eventgate.CloudEventInput) error

+ type Opt func(o *Options)

+ func WithIDToken(idToken bool) Opt

+ func WithLogging(logging, logPayload bool) Opt

+ func WithMetrics(metrics bool) Opt

+ func WithTokenSource(tokenSource oauth2.TokenSource) Opt

+ func WithTransportCreds(creds credentials.TransportCredentials) Opt

+ type Options struct