tcsclient

Documentation

Index

• Constants
• func New(url string, cfg *wsclient.WSClientMinAgentConfig, doctor *doctor.Doctor, ...) wsclient.ClientServer
• func NewTCSDecoder() wsclient.TypeDecoder
• type UnretriableErrors
  • func (err *UnretriableErrors) Get() []interface{}

Constants

const (

	// DefaultContainerMetricsPublishInterval is the default interval that we publish
	// metrics to the ECS telemetry backend (TACS)
	DefaultContainerMetricsPublishInterval = 20 * time.Second
)

Functions

func New

func New(url string,
	cfg *wsclient.WSClientMinAgentConfig,
	doctor *doctor.Doctor,
	disableResourceMetrics bool,
	publishMetricsInterval time.Duration,
	credentialProvider *credentials.Credentials,
	rwTimeout time.Duration,
	metricsMessages <-chan ecstcs.TelemetryMessage,
	healthMessages <-chan ecstcs.HealthMessage,
	metricsFactory metrics.EntryFactory,
) wsclient.ClientServer

New returns a client/server to bidirectionally communicate with the backend. The returned struct should have both 'Connect' and 'Serve' called upon it before being used.

func NewTCSDecoder

func NewTCSDecoder() wsclient.TypeDecoder

Types

type UnretriableErrors

type UnretriableErrors struct{}

UnretriableErrors wraps all the typed errors that TCS may return

func (*UnretriableErrors) Get

func (err *UnretriableErrors) Get() []interface{}

Get gets the list of unretriable error types.