influx

Documentation

Index

• Constants
• type CAdvisorClient
  • func New(params CAdvisorClientParams) (*CAdvisorClient, error)
  • func (s *CAdvisorClient) AddStats(cInfo *info.ContainerInfo, stats *info.ContainerStats) error
  • func (s *CAdvisorClient) Close() error
  • func (s *CAdvisorClient) ContainerFilesystemStatsToPoints(cInfo *info.ContainerInfo, stats *info.ContainerStats) (points []*write.Point)
  • func (s *CAdvisorClient) ContainerStatsToPoints(cInfo *info.ContainerInfo, stats *info.ContainerStats) (points []*write.Point)
  • func (s *CAdvisorClient) DefaultTags(cInfo *info.ContainerInfo, stats *info.ContainerStats) map[string]string
  • func (s *CAdvisorClient) GetStats() ([]map[string]interface{}, error)
  • func (s *CAdvisorClient) HugetlbStatsToPoints(cInfo *info.ContainerInfo, stats *info.ContainerStats) (points []*write.Point)
  • func (s *CAdvisorClient) MemoryStatsToPoints(cInfo *info.ContainerInfo, stats *info.ContainerStats) (points []*write.Point)
  • func (s *CAdvisorClient) OverrideReadyToFlush(readyToFlush func() bool)
  • func (s *CAdvisorClient) PerfStatsToPoints(cInfo *info.ContainerInfo, stats *info.ContainerStats) (points []*write.Point)
  • func (s *CAdvisorClient) ResctrlStatsToPoints(cInfo *info.ContainerInfo, stats *info.ContainerStats) (points []*write.Point)
  • func (s *CAdvisorClient) TagPoints(cInfo *info.ContainerInfo, stats *info.ContainerStats, points []*write.Point)
• type CAdvisorClientParams

Constants

const (
	DefaultBucketName = "metrics"
	DefaultOrgName    = "stalker"
	DefaultUsername   = "stalker_admin"
)

Types

type CAdvisorClient

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

func New

func New(params CAdvisorClientParams) (*CAdvisorClient, error)

func (*CAdvisorClient) AddStats

func (s *CAdvisorClient) AddStats(cInfo *info.ContainerInfo, stats *info.ContainerStats) error

func (*CAdvisorClient) Close

func (s *CAdvisorClient) Close() error

func (*CAdvisorClient) ContainerFilesystemStatsToPoints

func (s *CAdvisorClient) ContainerFilesystemStatsToPoints(
	cInfo *info.ContainerInfo,
	stats *info.ContainerStats) (points []*write.Point)

func (*CAdvisorClient) ContainerStatsToPoints

func (s *CAdvisorClient) ContainerStatsToPoints(
	cInfo *info.ContainerInfo,
	stats *info.ContainerStats,
) (points []*write.Point)

func (*CAdvisorClient) DefaultTags

func (s *CAdvisorClient) DefaultTags(cInfo *info.ContainerInfo, stats *info.ContainerStats) map[string]string

Set tags and timestamp for all points of the batch. Points should inherit the tags that are set for BatchPoints, but that does not seem to work.

func (*CAdvisorClient) GetStats

func (s *CAdvisorClient) GetStats() ([]map[string]interface{}, error)

func (*CAdvisorClient) HugetlbStatsToPoints

func (s *CAdvisorClient) HugetlbStatsToPoints(
	cInfo *info.ContainerInfo,
	stats *info.ContainerStats,
) (points []*write.Point)

func (*CAdvisorClient) MemoryStatsToPoints

func (s *CAdvisorClient) MemoryStatsToPoints(
	cInfo *info.ContainerInfo,
	stats *info.ContainerStats,
) (points []*write.Point)

func (*CAdvisorClient) OverrideReadyToFlush

func (s *CAdvisorClient) OverrideReadyToFlush(readyToFlush func() bool)

func (*CAdvisorClient) PerfStatsToPoints

func (s *CAdvisorClient) PerfStatsToPoints(
	cInfo *info.ContainerInfo,
	stats *info.ContainerStats,
) (points []*write.Point)

func (*CAdvisorClient) ResctrlStatsToPoints

func (s *CAdvisorClient) ResctrlStatsToPoints(
	cInfo *info.ContainerInfo,
	stats *info.ContainerStats,
) (points []*write.Point)

func (*CAdvisorClient) TagPoints

func (s *CAdvisorClient) TagPoints(cInfo *info.ContainerInfo, stats *info.ContainerStats, points []*write.Point)

Set tags and timestamp for all points of the batch. Points should inherit the tags that are set for BatchPoints, but that does not seem to work.

type CAdvisorClientParams

type CAdvisorClientParams struct {
	Token string
	Uri   string
}