cgrouprate

Documentation

Index

• func Check(kube *processapi.MsgK8s, ktime uint64)
• func Config()
• func NewCgroupRate(ctx context.Context, listener observer.Listener, opts *option.CgroupRate) error
• func NewTestCgroupRate(listener observer.Listener, hash *program.Map, opts *option.CgroupRate)
• func RegisterCgroupRate(sensor *sensors.Sensor) (*sensors.Sensor, error)
• type CgroupRate

Functions

func Check

func Check(kube *processapi.MsgK8s, ktime uint64)

Called from event handlers to kick off the cgroup rate periodical check for event's cgroup.

func Config

func Config()

func NewCgroupRate

func NewCgroupRate(ctx context.Context,
	listener observer.Listener,
	opts *option.CgroupRate) error

func NewTestCgroupRate

func NewTestCgroupRate(listener observer.Listener,
	hash *program.Map,
	opts *option.CgroupRate)

func RegisterCgroupRate

func RegisterCgroupRate(sensor *sensors.Sensor) (*sensors.Sensor, error)

Types

type CgroupRate

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