eventgate_client_go

Documentation

Index

• type Client
  • 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 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

Types

type Client

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

Client is a eventgate gRPC client

func NewClient

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

NewClient creates a new gRPC eventgate client

func (*Client) Receive

func (c *Client) Receive(ctx context.Context, in *eventgate.ReceiveRequest, fn func(even *eventgate.CloudEvent) bool) error

func (*Client) Request

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

func (*Client) Send

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

type Opt

type Opt func(o *Options)

Opt is a single configuration option

func WithIDToken

func WithIDToken(idToken bool) Opt

WithIDToken makes the client use the oauth id token(if it exists) instead of the oauth access token

func WithLogging

func WithLogging(logging, logPayload bool) Opt

WithLogging registers a logging middleware

func WithMetrics

func WithMetrics(metrics bool) Opt

WithMetrics registers prometheus metrics

func WithTokenSource

func WithTokenSource(tokenSource oauth2.TokenSource) Opt

WithTokenSource uses oauth token add an authorization header to every outbound request

func WithTransportCreds

func WithTransportCreds(creds credentials.TransportCredentials) Opt

WithTransportCreds adds transport credentials to the client

type Options

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

Options holds configuration options