stores

Documentation

Index

• Constants
• type K8sStore
• type Owner
• type PodStore
  • func NewPodStore(hostIP string, prefFullPodName bool) *PodStore
  • func (p *PodStore) Decorate(metric telegraf.Metric, kubernetesBlob map[string]interface{}) bool
  • func (p *PodStore) RefreshTick()
• type ServiceStore
  • func NewServiceStore() *ServiceStore
  • func (s *ServiceStore) Decorate(metric telegraf.Metric, kubernetesBlob map[string]interface{}) bool
  • func (s *ServiceStore) RefreshTick()

Constants

const (
	MeasurementsExpiry = 10 * time.Minute
	PodsExpiry         = 2 * time.Minute
)

Types

type K8sStore

type K8sStore interface {
	Decorate(metric telegraf.Metric, kubernetesBlob map[string]interface{}) bool
	RefreshTick()
}

type Owner

type Owner struct {
	OwnerKind string `json:"owner_kind"`
	OwnerName string `json:"owner_name"`
}

type PodStore

type PodStore struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewPodStore

func NewPodStore(hostIP string, prefFullPodName bool) *PodStore

func (*PodStore) Decorate

func (p *PodStore) Decorate(metric telegraf.Metric, kubernetesBlob map[string]interface{}) bool

func (*PodStore) RefreshTick

func (p *PodStore) RefreshTick()

type ServiceStore

type ServiceStore struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewServiceStore

func NewServiceStore() *ServiceStore

func (*ServiceStore) Decorate

func (s *ServiceStore) Decorate(metric telegraf.Metric, kubernetesBlob map[string]interface{}) bool

service info is not mandatory

func (*ServiceStore) RefreshTick

func (s *ServiceStore) RefreshTick()