metric

Documentation

Index

• func NewRunner(dockerEndpoint string, interval time.Duration, metricsBackend string) *runner
• func Register(name string, b backendFactory)
• type Backend
  • func Get(name string) (Backend, error)
• type ContainerInfo
  • func NewContainerInfo(container *container.Container) ContainerInfo
• type HostClient
  • func NewHostClient() (*HostClient, error)
  • func (h *HostClient) GetHostMetrics() ([]map[string]float, error)
  • func (h *HostClient) GetHostname() (string, error)
• type HostInfo
• type Reporter
  • func (r *Reporter) Do()

Functions

func NewRunner

func NewRunner(dockerEndpoint string, interval time.Duration, metricsBackend string) *runner

func Register

func Register(name string, b backendFactory)

Register registers a new Backend

Types

type Backend

type Backend interface {
	Send(container ContainerInfo, key string, value interface{}) error
	SendConn(container ContainerInfo, host string) error
	SendHost(host HostInfo, key string, value interface{}) error
}

func Get

func Get(name string) (Backend, error)

Get gets the named backend

type ContainerInfo

type ContainerInfo struct {
	Name     string
	Image    string
	Hostname string
	App      string
	Process  string
	Labels   map[string]string
}

func NewContainerInfo

func NewContainerInfo(container *container.Container) ContainerInfo

type HostClient

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

func NewHostClient

func NewHostClient() (*HostClient, error)

func (*HostClient) GetHostMetrics

func (h *HostClient) GetHostMetrics() ([]map[string]float, error)

func (*HostClient) GetHostname

func (h *HostClient) GetHostname() (string, error)

type HostInfo

type HostInfo struct {
	Name  string
	Addrs []string
}

type Reporter

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

func (*Reporter) Do

func (r *Reporter) Do()