reporter

Documentation

Index

• type Config
  • func NewDefaultConfig() *Config
  • func (c *Config) InitFlags(fs *flag.FlagSet)
• type Reporter
  • func NewReporter(cfg *Config, kubeClient *clientset.Clientset, ...) Reporter

Types

type Config

type Config struct {
	ReportInterval time.Duration
}

func NewDefaultConfig

func NewDefaultConfig() *Config

func (*Config) InitFlags

func (c *Config) InitFlags(fs *flag.FlagSet)

type Reporter

type Reporter interface {
	Run(stopCh <-chan struct{}) error
}

func NewReporter

func NewReporter(cfg *Config, kubeClient *clientset.Clientset, crdClient *clientsetbeta1.Clientset,
	nodeName string, metricCache metriccache.MetricCache, statesInformer statesinformer.StatesInformer) Reporter