client

Documentation

Index

• Variables
• type Client
  • func New(uid string, clientOptions ...Option) *Client
  • func (c *Client) Close(timeout time.Duration) error
  • func (c *Client) ConfigureSampler(ctx context.Context, samplerResource, samplerName string, ...) error
  • func (c *Client) Connect(serverAddr string) error
  • func (c *Client) Errors() chan error
  • func (c *Client) ListSamplers(ctx context.Context) ([]*control.Sampler, error)
  • func (c *Client) State() State
  • func (c *Client) StateChanges() chan State
  • func (c *Client) UID() control.ClientUID
• type Option
  • func WihKeepAliveMaxPeriod(t time.Duration) Option
  • func WithAuthBearer(token string) Option
  • func WithBlock() Option
  • func WithConnTimeout(t time.Duration) Option
  • func WithLogger(l logging.Logger) Option
  • func WithResponseTimeout(t time.Duration) Option
  • func WithServerReqsQueueLen(l int) Option
  • func WithTLS() Option
  • func WithTLSCACert(path string) Option
• type State
  • func NewStateFromStreamState(st stream.State) State
  • func (s State) String() string

Variables

var ErrConnectionFailure = stream.ErrConnectionFailure

var ErrRegistrationFailure = stream.ErrRegistrationFailure

Types

type Client

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

func New

func New(uid string, clientOptions ...Option) *Client

func (*Client) Close

func (c *Client) Close(timeout time.Duration) error

func (*Client) ConfigureSampler

func (c *Client) ConfigureSampler(ctx context.Context, samplerResource, samplerName string, update *control.SamplerConfigUpdate) error

ConfigureSampler sends a configuration to a sampler

func (*Client) Connect

func (c *Client) Connect(serverAddr string) error

func (*Client) Errors

func (c *Client) Errors() chan error

func (*Client) ListSamplers

func (c *Client) ListSamplers(ctx context.Context) ([]*control.Sampler, error)

func (*Client) State

func (c *Client) State() State

func (*Client) StateChanges

func (c *Client) StateChanges() chan State

func (*Client) UID

func (c *Client) UID() control.ClientUID

type Option

type Option interface {
	// contains filtered or unexported methods
}

func WihKeepAliveMaxPeriod

func WihKeepAliveMaxPeriod(t time.Duration) Option

func WithAuthBearer

func WithAuthBearer(token string) Option

func WithBlock

func WithBlock() Option

func WithConnTimeout

func WithConnTimeout(t time.Duration) Option

func WithLogger

func WithLogger(l logging.Logger) Option

func WithResponseTimeout

func WithResponseTimeout(t time.Duration) Option

func WithServerReqsQueueLen

func WithServerReqsQueueLen(l int) Option

func WithTLS

func WithTLS() Option

func WithTLSCACert

func WithTLSCACert(path string) Option

type State

type State int

const (
	Unknown State = iota
	Unregistered
	Registered
)

func NewStateFromStreamState

func NewStateFromStreamState(st stream.State) State

func (State) String

func (s State) String() string