timer

Documentation

Index

• func Default(c *Config)
• type Config
  • func InitConfig(filename string) (*Config, error)
  • func (c *Config) GetLeaderElectionConfig() *leaderelection.Config
  • func (c *Config) GetTimingWheelConfig() *timingwheel.Config
• type LeaderElectionConfig
• type MetadataConfig
• type TimingWheelConfig

Functions

func Default

func Default(c *Config)

Types

type Config

type Config struct {
	Name                 string               `yaml:"name"`
	IP                   string               `yaml:"ip"`
	Port                 int                  `yaml:"port"`
	Replicas             uint                 `yaml:"replicas"`
	EtcdEndpoints        []string             `yaml:"etcd"`
	CtrlEndpoints        []string             `yaml:"controllers"`
	MetadataConfig       MetadataConfig       `yaml:"metadata"`
	LeaderElectionConfig LeaderElectionConfig `yaml:"leader_election"`
	TimingWheelConfig    TimingWheelConfig    `yaml:"timingwheel"`
	Observability        observability.Config `yaml:"observability"`
}

func InitConfig

func InitConfig(filename string) (*Config, error)

func (*Config) GetLeaderElectionConfig

func (c *Config) GetLeaderElectionConfig() *leaderelection.Config

func (*Config) GetTimingWheelConfig

func (c *Config) GetTimingWheelConfig() *timingwheel.Config

type LeaderElectionConfig

type LeaderElectionConfig struct {
	LeaseDuration int64 `yaml:"lease_duration"`
}

type MetadataConfig

type MetadataConfig struct {
	KeyPrefix string `yaml:"key_prefix"`
}

type TimingWheelConfig

type TimingWheelConfig struct {
	Tick      int64 `yaml:"tick"`
	WheelSize int64 `yaml:"wheel_size"`
	Layers    int64 `yaml:"layers"`
}