nats

package

v1.2.11 Latest Latest Go to latest Published: Mar 8, 2023 License: MIT Imports: 5 Imported by: 1

Details

This section is empty.

This section is empty.

This section is empty.

type BasicAuthOptions struct {
	Username string
	Password string
}

BasicAuthOptions contains options regarding to basic authentication.

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

Client provides a shell for the env client

func New(nodes []string, bucket string, opts ...Option) (*Client, error)

New returns a new client

func (c *Client) Close()

Close is only meant to fulfill the easykv.ReadWatcher interface. Does nothing.

func (c *Client) GetValues(keys []string) (map[string]string, error)

GetValues is used to lookup all keys with a prefix. Several prefixes can be specified in the keys array.

func (c *Client) WatchPrefix(ctx context.Context, prefix string, opts ...easykv.WatchOption) (uint64, error)

WatchPrefix

type Option func(*Options)

Option configures the nats client.

func WithBasicAuth(b BasicAuthOptions) Option

WithBasicAuth enables the basic authentication and sets the username and password.

func WithCredentials(c string) Option

WithCredentials enables the NATS 2.0 and NATS NGS compatible user credentials and sets the path to the credentials file

func WithToken(t string) Option

WithToken enables the token authentication and sets the token.

type Options struct {
	Nodes []string
	Auth  BasicAuthOptions
	Token string
	Creds string
}

Options contains all values that are needed to connect to nats.