event

Documentation

Index

• type EGBlkioStats
• type EGNetworkStats
• type EventGenerator
  • func (d *EventGenerator) CleanOldStats(containers []docker.APIContainers)
  • func (d *EventGenerator) GetBlkioEvent(container *docker.APIContainers, stats *docker.Stats) common.MapStr
  • func (d *EventGenerator) GetContainerEvent(container *docker.APIContainers, stats *docker.Stats) common.MapStr
  • func (d *EventGenerator) GetCpuEvent(container *docker.APIContainers, stats *docker.Stats) common.MapStr
  • func (d *EventGenerator) GetLogEvent(level string, message string) common.MapStr
  • func (d *EventGenerator) GetMemoryEvent(container *docker.APIContainers, stats *docker.Stats) common.MapStr
  • func (d *EventGenerator) GetNetworkEvent(container *docker.APIContainers, time time.Time, network string, ...) common.MapStr
  • func (d *EventGenerator) GetNetworksEvent(container *docker.APIContainers, stats *docker.Stats) []common.MapStr
• type Label

Types

type EGBlkioStats

type EGBlkioStats struct {
	sync.RWMutex
	M map[string]calculator.BlkioData
}

type EGNetworkStats

type EGNetworkStats struct {
	sync.RWMutex
	M map[string]map[string]calculator.NetworkData
}

type EventGenerator

type EventGenerator struct {
	Socket            *string
	NetworkStats      EGNetworkStats
	BlkioStats        EGBlkioStats
	CalculatorFactory calculator.CalculatorFactory
	Period            time.Duration
}

func (*EventGenerator) CleanOldStats

func (d *EventGenerator) CleanOldStats(containers []docker.APIContainers)

func (*EventGenerator) GetBlkioEvent

func (d *EventGenerator) GetBlkioEvent(container *docker.APIContainers, stats *docker.Stats) common.MapStr

func (*EventGenerator) GetContainerEvent

func (d *EventGenerator) GetContainerEvent(container *docker.APIContainers, stats *docker.Stats) common.MapStr

func (*EventGenerator) GetCpuEvent

func (d *EventGenerator) GetCpuEvent(container *docker.APIContainers, stats *docker.Stats) common.MapStr

func (*EventGenerator) GetLogEvent

func (d *EventGenerator) GetLogEvent(level string, message string) common.MapStr

func (*EventGenerator) GetMemoryEvent

func (d *EventGenerator) GetMemoryEvent(container *docker.APIContainers, stats *docker.Stats) common.MapStr

func (*EventGenerator) GetNetworkEvent

func (d *EventGenerator) GetNetworkEvent(container *docker.APIContainers, time time.Time, network string, networkStats *docker.NetworkStats) common.MapStr

func (*EventGenerator) GetNetworksEvent

func (d *EventGenerator) GetNetworksEvent(container *docker.APIContainers, stats *docker.Stats) []common.MapStr

type Label

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