timingwheel

Documentation

Index

• type Config
• type Manager
  • func NewTimingWheel(c *Config) Manager

Types

type Config

type Config struct {
	Tick          time.Duration `yaml:"tick"`
	WheelSize     int64         `yaml:"wheel_size"`
	Layers        int64         `yaml:"layers"`
	KeyPrefix     string        `yaml:"key_prefix"`
	EtcdEndpoints []string      `yaml:"etcd"`
	CtrlEndpoints []string      `yaml:"controllers"`
}

type Manager

type Manager interface {
	Init(ctx context.Context) error
	Start(ctx context.Context) error
	Push(ctx context.Context, e *ce.Event) bool
	SetLeader(isleader bool)
	IsLeader() bool
	IsDeployed(ctx context.Context) bool
	Recover(ctx context.Context) error
	StopNotify() <-chan struct{}
	Stop(ctx context.Context)
}

func NewTimingWheel

func NewTimingWheel(c *Config) Manager