kubernetes

Documentation

Index

• Variables
• func ParseContainerIDFromPodStatus(containerID string) string
• type ObjListWatcher
  • func NewObjListWatcher(bpfSupportedMetrics bpf.SupportedMetrics) (*ObjListWatcher, error)
  • func (w *ObjListWatcher) Run() error
  • func (w *ObjListWatcher) ShutDownWithDrain()
  • func (w *ObjListWatcher) Stop()

Variables

var (
	IsWatcherEnabled = false
)

Functions

func ParseContainerIDFromPodStatus

func ParseContainerIDFromPodStatus(containerID string) string

Types

type ObjListWatcher

type ObjListWatcher struct {
	// Lock to synchronize the collector update with the watcher
	// NOTE: This lock is shared with the Collector
	Mx *sync.Mutex

	ResourceKind string

	// NOTE: This map is shared with the Collector
	// ContainerStats holds all container energy and resource usage metrics
	ContainerStats map[string]*stats.ContainerStats
	// contains filtered or unexported fields
}

func NewObjListWatcher

func NewObjListWatcher(bpfSupportedMetrics bpf.SupportedMetrics) (*ObjListWatcher, error)

func (*ObjListWatcher) Run

func (w *ObjListWatcher) Run() error

func (*ObjListWatcher) ShutDownWithDrain

func (w *ObjListWatcher) ShutDownWithDrain()

func (*ObjListWatcher) Stop

func (w *ObjListWatcher) Stop()