client

Documentation

Index

• Constants
• type Client
  • func Connect(ctx context.Context, endpoint string, opts ...Option) (*Client, error)
  • func (c *Client) Close() error
  • func (c *Client) OnConnectionClosed(listener func(context.Context, *proto.ShutdownRequest) error)
  • func (c *Client) OnDataStoreTestConnectionRequest(listener func(context.Context, *proto.DataStoreConnectionTestRequest) error)
  • func (c *Client) OnOTLPConnectionTest(listener func(context.Context, *proto.OTLPConnectionTestRequest) error)
  • func (c *Client) OnPollingRequest(listener func(context.Context, *proto.PollingRequest) error)
  • func (c *Client) OnStopRequest(listener func(context.Context, *proto.StopRequest) error)
  • func (c *Client) OnTriggerRequest(listener func(context.Context, *proto.TriggerRequest) error)
  • func (c *Client) SendDataStoreConnectionResult(ctx context.Context, response *proto.DataStoreConnectionTestResponse) error
  • func (c *Client) SendOTLPConnectionResult(ctx context.Context, response *proto.OTLPConnectionTestResponse) error
  • func (c *Client) SendTrace(ctx context.Context, pollingResponse *proto.PollingResponse) error
  • func (c *Client) SendTriggerResponse(ctx context.Context, response *proto.TriggerResponse) error
  • func (c *Client) SessionConfiguration() *SessionConfig
  • func (c *Client) Start(ctx context.Context) error
  • func (c *Client) WaitUntilDisconnected()
• type Config
• type Option
  • func WithAPIKey(apiKey string) Option
  • func WithAgentName(name string) Option
  • func WithLogger(logger *zap.Logger) Option
  • func WithPingPeriod(period time.Duration) Option
• type SessionConfig

Constants

const (
	ReconnectRetryAttempts     = 6
	ReconnectRetryAttemptDelay = 1 * time.Second
)

Types

type Client

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

func Connect

func Connect(ctx context.Context, endpoint string, opts ...Option) (*Client, error)

func (*Client) Close

func (c *Client) Close() error

func (*Client) OnConnectionClosed

func (c *Client) OnConnectionClosed(listener func(context.Context, *proto.ShutdownRequest) error)

func (*Client) OnDataStoreTestConnectionRequest

func (c *Client) OnDataStoreTestConnectionRequest(listener func(context.Context, *proto.DataStoreConnectionTestRequest) error)

func (*Client) OnOTLPConnectionTest

func (c *Client) OnOTLPConnectionTest(listener func(context.Context, *proto.OTLPConnectionTestRequest) error)

func (*Client) OnPollingRequest

func (c *Client) OnPollingRequest(listener func(context.Context, *proto.PollingRequest) error)

func (*Client) OnStopRequest

func (c *Client) OnStopRequest(listener func(context.Context, *proto.StopRequest) error)

func (*Client) OnTriggerRequest

func (c *Client) OnTriggerRequest(listener func(context.Context, *proto.TriggerRequest) error)

func (*Client) SendDataStoreConnectionResult

func (c *Client) SendDataStoreConnectionResult(ctx context.Context, response *proto.DataStoreConnectionTestResponse) error

func (*Client) SendOTLPConnectionResult

func (c *Client) SendOTLPConnectionResult(ctx context.Context, response *proto.OTLPConnectionTestResponse) error

func (*Client) SendTrace

func (c *Client) SendTrace(ctx context.Context, pollingResponse *proto.PollingResponse) error

func (*Client) SendTriggerResponse

func (c *Client) SendTriggerResponse(ctx context.Context, response *proto.TriggerResponse) error

func (*Client) SessionConfiguration

func (c *Client) SessionConfiguration() *SessionConfig

func (*Client) Start

func (c *Client) Start(ctx context.Context) error

func (*Client) WaitUntilDisconnected

func (c *Client) WaitUntilDisconnected()

type Config

type Config struct {
	APIKey     string
	AgentName  string
	PingPeriod time.Duration
}

type Option

type Option func(*Client)

func WithAPIKey

func WithAPIKey(apiKey string) Option

func WithAgentName

func WithAgentName(name string) Option

func WithLogger

func WithLogger(logger *zap.Logger) Option

func WithPingPeriod

func WithPingPeriod(period time.Duration) Option

type SessionConfig

type SessionConfig struct {
	BatchTimeout        time.Duration
	AgentIdentification *proto.AgentIdentification
}