metric

Documentation

Index

• type CollectorConfiguration
  • func NewCollectorConfiguration() *CollectorConfiguration
• type CustomMetricConfiguration
  • func NewCustomMetricConfiguration() *CustomMetricConfiguration
• type GenericMetricConfiguration
  • func NewGenericMetricConfiguration() *GenericMetricConfiguration
• type ProviderConfiguration
  • func NewProviderConfiguration() *ProviderConfiguration
• type StoreConfiguration
  • func NewStoreConfiguration() *StoreConfiguration

Types

type CollectorConfiguration

type CollectorConfiguration struct {
	// PodSelector and NodeSelector are used to only match with those resources that real-time pipeline needed
	PodSelector  labels.Selector
	NodeSelector labels.Selector
	SyncInterval time.Duration

	// ShardNum is used to indicate which shard splits current collector will be responsible for
	// todo: currently, we don't support to ShardNum to be set > 1
	ShardNum int

	// CollectorName is used to switch from different collector implementations.
	CollectorName string
}

func NewCollectorConfiguration

func NewCollectorConfiguration() *CollectorConfiguration

type CustomMetricConfiguration

type CustomMetricConfiguration struct {
	WorkMode []string

	*CollectorConfiguration
	*StoreConfiguration
	*ProviderConfiguration
}

func NewCustomMetricConfiguration

func NewCustomMetricConfiguration() *CustomMetricConfiguration

type GenericMetricConfiguration

type GenericMetricConfiguration struct {
	// leaderElection defines the configuration of leader election client.
	LeaderElection componentbaseconfig.LeaderElectionConfiguration

	OutOfDataPeriod time.Duration
}

func NewGenericMetricConfiguration

func NewGenericMetricConfiguration() *GenericMetricConfiguration

type ProviderConfiguration

type ProviderConfiguration struct {
	Adapter *basecmd.AdapterBase
}

func NewProviderConfiguration

func NewProviderConfiguration() *ProviderConfiguration

type StoreConfiguration

type StoreConfiguration struct {
	StoreServerShardCount   int
	StoreServerReplicaTotal int
	StoreServerSelector     labels.Selector

	StoreName string

	GCPeriod time.Duration
}

func NewStoreConfiguration

func NewStoreConfiguration() *StoreConfiguration