Versions in this module Expand all Collapse all v0 v0.1.0 Aug 25, 2026 Changes in this version + const ReadOp + const WriteOp + type BlkIOEntry struct + Dev string + Value uint64 + type BlkIOMetrics struct + IOServiceBytesReadRecursive []*BlkIOEntry + IOServiceBytesWriteRecursive []*BlkIOEntry + IOServicedReadRecursive []*BlkIOEntry + IOServicedWriteRecursive []*BlkIOEntry + type Container struct + CPUNum float64 + CPUPeriod int64 + CPUQuota int64 + EntryPoint string + Env map[string]string + HealthCheck *coretypes.HealthCheck + Ident string + Labels map[string]string + LocalIP string + Memory int64 + Name string + Pid int + func (c *Container) CheckHealth(ctx context.Context, timeout time.Duration) bool + type Docker struct + func GetClient(ctx context.Context, config *types.Config, nodeIP string) (*Docker, error) + func New(ctx context.Context, config *types.Config, nodeIP string) (*Docker, error) + func (d *Docker) AttachWorkload(ctx context.Context, ID string) (io.Reader, io.Reader, error) + func (d *Docker) CollectWorkloadMetrics(ctx context.Context, ID string) + func (d *Docker) Events(ctx context.Context, filters map[string]string) (<-chan *types.WorkloadEventMessage, <-chan error) + func (d *Docker) GetStatus(ctx context.Context, ID string, checkHealth bool) (*types.WorkloadStatus, error) + func (d *Docker) GetWorkloadName(ctx context.Context, ID string) (string, error) + func (d *Docker) IsDaemonRunning(ctx context.Context) bool + func (d *Docker) ListWorkloadIDs(ctx context.Context, filters map[string]string) ([]string, error) + func (d *Docker) LogFieldsExtra(ctx context.Context, ID string) (map[string]string, error) + type MetricsClient struct + func NewMetricsClient(statsd, hostname string, container *Container) *MetricsClient + func (m *MetricsClient) BytesRecv(nic string, i float64) + func (m *MetricsClient) BytesSent(nic string, i float64) + func (m *MetricsClient) CPUContainerSysUsage(i float64) + func (m *MetricsClient) CPUContainerUsage(i float64) + func (m *MetricsClient) CPUContainerUserUsage(i float64) + func (m *MetricsClient) CPUHostSysUsage(i float64) + func (m *MetricsClient) CPUHostUsage(i float64) + func (m *MetricsClient) CPUHostUserUsage(i float64) + func (m *MetricsClient) DropIn(nic string, i float64) + func (m *MetricsClient) DropOut(nic string, i float64) + func (m *MetricsClient) ErrIn(nic string, i float64) + func (m *MetricsClient) ErrOut(nic string, i float64) + func (m *MetricsClient) IOServiceBytesRead(dev string, i float64) + func (m *MetricsClient) IOServiceBytesReadPerSecond(dev string, i float64) + func (m *MetricsClient) IOServiceBytesWrite(dev string, i float64) + func (m *MetricsClient) IOServiceBytesWritePerSecond(dev string, i float64) + func (m *MetricsClient) IOServicedRead(dev string, i float64) + func (m *MetricsClient) IOServicedReadPerSecond(dev string, i float64) + func (m *MetricsClient) IOServicedWrite(dev string, i float64) + func (m *MetricsClient) IOServicedWritePerSecond(dev string, i float64) + func (m *MetricsClient) MemMaxUsage(i float64) + func (m *MetricsClient) MemPercent(i float64) + func (m *MetricsClient) MemRSSPercent(i float64) + func (m *MetricsClient) MemRss(i float64) + func (m *MetricsClient) MemUsage(i float64) + func (m *MetricsClient) PacketsRecv(nic string, i float64) + func (m *MetricsClient) PacketsSent(nic string, i float64) + func (m *MetricsClient) Send(ctx context.Context) error + func (m *MetricsClient) Unregister()
Go to main page