options

Documentation

Index

• Constants
• type CollectorOptions
  • func NewCollectorOptions() *CollectorOptions
  • func (o *CollectorOptions) AddFlags(fss *cliflag.NamedFlagSets)
  • func (o *CollectorOptions) ApplyTo(c *metric.CollectorConfiguration) error
  • func (o *CollectorOptions) Config() (*metric.CollectorConfiguration, error)
• type MockOptions
  • func NewMockOptions() *MockOptions
  • func (o *MockOptions) AddFlags(fss *cliflag.NamedFlagSets)
  • func (o *MockOptions) ApplyTo(c *metric.MockConfiguration) error
• type Options
  • func NewOptions() *Options
  • func (o *Options) AddFlags(fss *cliflag.NamedFlagSets)
  • func (o *Options) ApplyTo(c *config.Configuration) error
  • func (o *Options) Config() (*config.Configuration, error)
• type ProviderOptions
  • func NewProviderOptions() *ProviderOptions
  • func (o *ProviderOptions) AddFlags(fss *cliflag.NamedFlagSets)
  • func (o *ProviderOptions) ApplyTo(c *metric.ProviderConfiguration) error
  • func (o *ProviderOptions) Config() (*metric.ProviderConfiguration, error)
• type StoreOptions
  • func NewStoreOptions() *StoreOptions
  • func (o *StoreOptions) AddFlags(fss *cliflag.NamedFlagSets)
  • func (o *StoreOptions) ApplyTo(c *metric.StoreConfiguration) error
  • func (o *StoreOptions) Config() (*metric.StoreConfiguration, error)

Constants

const (
	WorkModeProvider     = "provider"
	WorkModeCollector    = "collect"
	WorkModeStoreServing = "storeServer"
)

const (
	CustomMetricsCollectorNamePrometheus = "prometheus-collector"
)

Types

type CollectorOptions

type CollectorOptions struct {
	PodLabelSelector  string
	NodeLabelSelector string

	ShardNum        int
	CollectorName   string
	CollectInterval time.Duration
	CredentialPath  string
}

CollectorOptions holds the configurations for katalyst metrics collectors.

func NewCollectorOptions

func NewCollectorOptions() *CollectorOptions

NewCollectorOptions creates a new CollectorOptions with a default config.

func (*CollectorOptions) AddFlags

func (o *CollectorOptions) AddFlags(fss *cliflag.NamedFlagSets)

AddFlags adds flags to the specified FlagSet.

func (*CollectorOptions) ApplyTo

func (o *CollectorOptions) ApplyTo(c *metric.CollectorConfiguration) error

ApplyTo fills up config with options

func (*CollectorOptions) Config

func (o *CollectorOptions) Config() (*metric.CollectorConfiguration, error)

type MockOptions

type MockOptions struct {
	NamespaceCount int
	WorkloadCount  int
	PodCount       int
}

MockOptions holds the configurations for katalyst metrics mock data.It's only for pressure test.

func NewMockOptions

func NewMockOptions() *MockOptions

NewMockOptions creates a new MockOptions with a default config.

func (*MockOptions) AddFlags

func (o *MockOptions) AddFlags(fss *cliflag.NamedFlagSets)

AddFlags adds flags to the specified FlagSet.

func (*MockOptions) ApplyTo

func (o *MockOptions) ApplyTo(c *metric.MockConfiguration) error

ApplyTo fills up config with options

type Options

type Options struct {
	*options.GenericOptions

	election.LeaderElectionConfiguration

	WorkMode        []string
	OutOfDataPeriod time.Duration

	*MockOptions
	*StoreOptions
	*ProviderOptions
	*CollectorOptions
}

Options holds the configurations for katalyst metrics module.

func NewOptions

func NewOptions() *Options

NewOptions creates a new Options with a default config.

func (*Options) AddFlags

func (o *Options) AddFlags(fss *cliflag.NamedFlagSets)

AddFlags adds flags to the specified FlagSet.

func (*Options) ApplyTo

func (o *Options) ApplyTo(c *config.Configuration) error

ApplyTo fills up config with options

func (*Options) Config

func (o *Options) Config() (*config.Configuration, error)

type ProviderOptions

type ProviderOptions struct {
	// since we use the wrapped tools in custom-metrics-api-server,
	// use all the flags in it (to connect with APIServer)
	AdapterBase *basecmd.AdapterBase
}

ProviderOptions holds the configurations for katalyst metrics module.

func NewProviderOptions

func NewProviderOptions() *ProviderOptions

NewProviderOptions creates a new ProviderOptions with a default config.

func (*ProviderOptions) AddFlags

func (o *ProviderOptions) AddFlags(fss *cliflag.NamedFlagSets)

AddFlags adds flags to the specified FlagSet.

func (*ProviderOptions) ApplyTo

func (o *ProviderOptions) ApplyTo(c *metric.ProviderConfiguration) error

ApplyTo fills up config with options

func (*ProviderOptions) Config

func (o *ProviderOptions) Config() (*metric.ProviderConfiguration, error)

type StoreOptions

type StoreOptions struct {
	StoreName      string
	GCInterval     time.Duration
	PurgeInterval  time.Duration
	IndexLabelKeys []string

	StoreServerShardCount   int
	StoreServerReplicaTotal int

	ServiceDiscoveryName string
	SDPodSelector        string
	SDServiceNamespace   string
	SDServiceName        string
}

StoreOptions holds the configurations for katalyst metrics stores.

func NewStoreOptions

func NewStoreOptions() *StoreOptions

NewStoreOptions creates a new StoreOptions with a default config.

func (*StoreOptions) AddFlags

func (o *StoreOptions) AddFlags(fss *cliflag.NamedFlagSets)

AddFlags adds flags to the specified FlagSet.

func (*StoreOptions) ApplyTo

func (o *StoreOptions) ApplyTo(c *metric.StoreConfiguration) error

ApplyTo fills up config with options

func (*StoreOptions) Config

func (o *StoreOptions) Config() (*metric.StoreConfiguration, error)