containermetric

Documentation

Index

• type ContainerMetricSink
  • func NewContainerMetricSink(appID string, ttl time.Duration, inactivityDuration time.Duration) *ContainerMetricSink
  • func (sink *ContainerMetricSink) AppID() string
  • func (sink *ContainerMetricSink) GetLatest() []*events.Envelope
  • func (sink *ContainerMetricSink) Identifier() string
  • func (sink *ContainerMetricSink) Run(eventChan <-chan *events.Envelope)
  • func (sink *ContainerMetricSink) ShouldReceiveErrors() bool

Types

type ContainerMetricSink

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

func NewContainerMetricSink

func NewContainerMetricSink(appID string, ttl time.Duration, inactivityDuration time.Duration) *ContainerMetricSink

func (*ContainerMetricSink) AppID

func (sink *ContainerMetricSink) AppID() string

func (*ContainerMetricSink) GetLatest

func (sink *ContainerMetricSink) GetLatest() []*events.Envelope

func (*ContainerMetricSink) Identifier

func (sink *ContainerMetricSink) Identifier() string

func (*ContainerMetricSink) Run

func (sink *ContainerMetricSink) Run(eventChan <-chan *events.Envelope)

func (*ContainerMetricSink) ShouldReceiveErrors

func (sink *ContainerMetricSink) ShouldReceiveErrors() bool