eventgate_client_go

package

v0.1.0 Latest Latest Go to latest Published: Feb 11, 2021 License: Apache-2.0 Imports: 14 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/autom8ter/eventgate

Links

Open Source Insights

Documentation ¶

Index ¶

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

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

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) Close ¶ added in v0.0.22

func (c *Client) Close() error

Close closes the gRPC client connection

func (*Client) GetObject ¶ added in v0.1.0

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

GetObject gets the current state value of an object

func (*Client) SearchEvents ¶ added in v0.1.0

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

SearchEvents returns an array of immutable historical events from a given channel.

func (*Client) SetObject ¶ added in v0.1.0

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

Set sets the current state value of an object, adds it to the event log, then broadcast the event to all interested consumers

func (*Client) StreamEvents ¶ added in v0.1.0

func (c *Client) StreamEvents(ctx context.Context, in *eventgate.StreamOpts, fn func(even *eventgate.Event) bool) error

StreamEvents creates an event stream/subscription to a given channel until fn returns false OR the context cancels.

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

Source Files ¶

View all Source files

client.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL