resources

Documentation

Index

• type Monitor
  • func NewMonitor() (*Monitor, error)
  • func (m *Monitor) Close() error
  • func (m *Monitor) RecordNamespace(ns string, opt RecordOpt) (resourcestypes.Recorder, error)
• type NetworkSampler
• type RecordOpt
• type Sampler
  • func NewSampler[T WithTimestamp](minInterval time.Duration, maxSamples int, cb func(time.Time) (T, error)) *Sampler[T]
  • func NewSysSampler() (*Sampler[*resourcestypes.SysSample], error)
  • func (s *Sampler[T]) Close() error
  • func (s *Sampler[T]) Record() *Sub[T]
• type Sub
  • func (s *Sub[T]) Close(captureLast bool) ([]T, error)
• type SysSampler
• type WithTimestamp

Types

type Monitor

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

func NewMonitor

func NewMonitor() (*Monitor, error)

func (*Monitor) Close

func (m *Monitor) Close() error

func (*Monitor) RecordNamespace

func (m *Monitor) RecordNamespace(ns string, opt RecordOpt) (resourcestypes.Recorder, error)

type NetworkSampler

type NetworkSampler interface {
	Sample() (*resourcestypes.NetworkSample, error)
}

type RecordOpt

type RecordOpt struct {
	NetworkSampler NetworkSampler
}

type Sampler

type Sampler[T WithTimestamp] struct {
	// contains filtered or unexported fields
}

func NewSampler

func NewSampler[T WithTimestamp](minInterval time.Duration, maxSamples int, cb func(time.Time) (T, error)) *Sampler[T]

func NewSysSampler

func NewSysSampler() (*Sampler[*resourcestypes.SysSample], error)

func (*Sampler[T]) Close

func (s *Sampler[T]) Close() error

func (*Sampler[T]) Record

func (s *Sampler[T]) Record() *Sub[T]

type Sub

type Sub[T WithTimestamp] struct {
	// contains filtered or unexported fields
}

func (*Sub[T]) Close

func (s *Sub[T]) Close(captureLast bool) ([]T, error)

type SysSampler

type SysSampler = Sub[*resourcestypes.SysSample]

type WithTimestamp

type WithTimestamp interface {
	Timestamp() time.Time
}