Documentation
¶
Index ¶
Constants ¶
View Source
const ( // DefaultContainerMetricsPublishInterval is the default interval that we publish // metrics to the ECS telemetry backend (TACS) DefaultContainerMetricsPublishInterval = 20 * time.Second )
Variables ¶
This section is empty.
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.
Source Files
Click to show internal directories.
Click to hide internal directories.