cluster

Documentation

Index

• Variables
• type Config
  • func (c Config) IsZero() bool
  • func (c *Config) RegisterFlags(f *flag.FlagSet)
  • func (c *Config) RegisterFlagsWithPrefix(prefix string, f *flag.FlagSet)
  • func (c *Config) UnmarshalYAML(unmarshal func(interface{}) error) error
• type KVConfig
  • func (k KVConfig) IsZero() bool
• type LifecyclerConfig
  • func (l LifecyclerConfig) IsZero() bool

Variables

var DefaultConfig = *flagutil.DefaultConfigFromFlags(&Config{}).(*Config)

DefaultConfig provides default values for the config

Types

type Config

type Config struct {
	Enabled                    bool             `yaml:"enabled,omitempty"`
	ReshardInterval            time.Duration    `yaml:"reshard_interval,omitempty"`
	ReshardTimeout             time.Duration    `yaml:"reshard_timeout,omitempty"`
	ClusterReshardEventTimeout time.Duration    `yaml:"cluster_reshard_event_timeout,omitempty"`
	KVStore                    KVConfig         `yaml:"kvstore,omitempty"`
	Lifecycler                 LifecyclerConfig `yaml:"lifecycler,omitempty"`

	DangerousAllowReadingFiles bool `yaml:"dangerous_allow_reading_files,omitempty"`

	Client                    client.Config `yaml:"-"`
	APIEnableGetConfiguration bool          `yaml:"-"`
}

Config describes how to instantiate a scraping service Server instance.

func (Config) IsZero

func (c Config) IsZero() bool

func (*Config) RegisterFlags

func (c *Config) RegisterFlags(f *flag.FlagSet)

RegisterFlags adds the flags required to config the Server to the given FlagSet.

func (*Config) RegisterFlagsWithPrefix

func (c *Config) RegisterFlagsWithPrefix(prefix string, f *flag.FlagSet)

RegisterFlagsWithPrefix adds the flags required to config this to the given FlagSet with a specified prefix.

func (*Config) UnmarshalYAML

func (c *Config) UnmarshalYAML(unmarshal func(interface{}) error) error

UnmarshalYAML implements yaml.Unmarshaler.

type KVConfig

type KVConfig struct {
	kv.Config `yaml:",inline"`
}

KVConfig wraps the kv.Config type to allow defining IsZero, which is required to make omitempty work when marshalling YAML.

func (KVConfig) IsZero

func (k KVConfig) IsZero() bool

type LifecyclerConfig

type LifecyclerConfig struct {
	ring.LifecyclerConfig `yaml:",inline"`
}

LifecyclerConfig wraps the ring.LifecyclerConfig type to allow defining IsZero, which is required to make omitempty work when marshalling YAML.

func (LifecyclerConfig) IsZero

func (l LifecyclerConfig) IsZero() bool