docker

package
v0.1.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 25, 2026 License: MIT Imports: 30 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ReadOp  = "Read"
	WriteOp = "Write"
)

Variables

This section is empty.

Functions

This section is empty.

Types

type BlkIOEntry 

type BlkIOEntry struct {
	Dev   string
	Value uint64
}

type BlkIOMetrics 

type BlkIOMetrics struct {
	IOServiceBytesReadRecursive  []*BlkIOEntry
	IOServiceBytesWriteRecursive []*BlkIOEntry
	IOServicedReadRecursive      []*BlkIOEntry
	IOServicedWriteRecursive     []*BlkIOEntry
}

type Container 

type Container struct {
	coretypes.StatusMeta
	Pid         int
	Name        string
	EntryPoint  string
	Ident       string
	CPUNum      float64
	CPUQuota    int64
	CPUPeriod   int64
	Memory      int64
	Labels      map[string]string
	Env         map[string]string
	HealthCheck *coretypes.HealthCheck
	LocalIP     string `json:"-"`
}

func (*Container) CheckHealth 

func (c *Container) CheckHealth(ctx context.Context, timeout time.Duration) bool

type Docker 

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

func GetClient 

func GetClient(ctx context.Context, config *types.Config, nodeIP string) (*Docker, error)

GetClient returns the process-wide docker runtime, creating it on first call.

func New 

func New(ctx context.Context, config *types.Config, nodeIP string) (*Docker, error)

func (*Docker) AttachWorkload 

func (d *Docker) AttachWorkload(ctx context.Context, ID string) (io.Reader, io.Reader, error)

func (*Docker) CollectWorkloadMetrics 

func (d *Docker) CollectWorkloadMetrics(ctx context.Context, ID string)

func (*Docker) Events 

func (d *Docker) Events(ctx context.Context, filters map[string]string) (<-chan *types.WorkloadEventMessage, <-chan error)

func (*Docker) GetStatus 

func (d *Docker) GetStatus(ctx context.Context, ID string, checkHealth bool) (*types.WorkloadStatus, error)

func (*Docker) GetWorkloadName 

func (d *Docker) GetWorkloadName(ctx context.Context, ID string) (string, error)

func (*Docker) IsDaemonRunning 

func (d *Docker) IsDaemonRunning(ctx context.Context) bool

func (*Docker) ListWorkloadIDs 

func (d *Docker) ListWorkloadIDs(ctx context.Context, filters map[string]string) ([]string, error)

func (*Docker) LogFieldsExtra 

func (d *Docker) LogFieldsExtra(ctx context.Context, ID string) (map[string]string, error)

type MetricsClient 

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

func NewMetricsClient 

func NewMetricsClient(statsd, hostname string, container *Container) *MetricsClient

func (*MetricsClient) BytesRecv 

func (m *MetricsClient) BytesRecv(nic string, i float64)

func (*MetricsClient) BytesSent 

func (m *MetricsClient) BytesSent(nic string, i float64)

func (*MetricsClient) CPUContainerSysUsage 

func (m *MetricsClient) CPUContainerSysUsage(i float64)

func (*MetricsClient) CPUContainerUsage 

func (m *MetricsClient) CPUContainerUsage(i float64)

func (*MetricsClient) CPUContainerUserUsage 

func (m *MetricsClient) CPUContainerUserUsage(i float64)

func (*MetricsClient) CPUHostSysUsage 

func (m *MetricsClient) CPUHostSysUsage(i float64)

func (*MetricsClient) CPUHostUsage 

func (m *MetricsClient) CPUHostUsage(i float64)

func (*MetricsClient) CPUHostUserUsage 

func (m *MetricsClient) CPUHostUserUsage(i float64)

func (*MetricsClient) DropIn 

func (m *MetricsClient) DropIn(nic string, i float64)

func (*MetricsClient) DropOut 

func (m *MetricsClient) DropOut(nic string, i float64)

func (*MetricsClient) ErrIn 

func (m *MetricsClient) ErrIn(nic string, i float64)

func (*MetricsClient) ErrOut 

func (m *MetricsClient) ErrOut(nic string, i float64)

func (*MetricsClient) IOServiceBytesRead 

func (m *MetricsClient) IOServiceBytesRead(dev string, i float64)

func (*MetricsClient) IOServiceBytesReadPerSecond 

func (m *MetricsClient) IOServiceBytesReadPerSecond(dev string, i float64)

func (*MetricsClient) IOServiceBytesWrite 

func (m *MetricsClient) IOServiceBytesWrite(dev string, i float64)

func (*MetricsClient) IOServiceBytesWritePerSecond 

func (m *MetricsClient) IOServiceBytesWritePerSecond(dev string, i float64)

func (*MetricsClient) IOServicedRead 

func (m *MetricsClient) IOServicedRead(dev string, i float64)

func (*MetricsClient) IOServicedReadPerSecond 

func (m *MetricsClient) IOServicedReadPerSecond(dev string, i float64)

func (*MetricsClient) IOServicedWrite 

func (m *MetricsClient) IOServicedWrite(dev string, i float64)

func (*MetricsClient) IOServicedWritePerSecond 

func (m *MetricsClient) IOServicedWritePerSecond(dev string, i float64)

func (*MetricsClient) MemMaxUsage 

func (m *MetricsClient) MemMaxUsage(i float64)

func (*MetricsClient) MemPercent 

func (m *MetricsClient) MemPercent(i float64)

func (*MetricsClient) MemRSSPercent 

func (m *MetricsClient) MemRSSPercent(i float64)

func (*MetricsClient) MemRss 

func (m *MetricsClient) MemRss(i float64)

func (*MetricsClient) MemUsage 

func (m *MetricsClient) MemUsage(i float64)

func (*MetricsClient) PacketsRecv 

func (m *MetricsClient) PacketsRecv(nic string, i float64)

func (*MetricsClient) PacketsSent 

func (m *MetricsClient) PacketsSent(nic string, i float64)

func (*MetricsClient) Send 

func (m *MetricsClient) Send(ctx context.Context) error

func (*MetricsClient) Unregister 

func (m *MetricsClient) Unregister()

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.