leader

Documentation

Index

• type Leader
  • func NewLeader(opts Opts) (leader Leader, onPromote <-chan time.Time, onDemote <-chan time.Time, ...)
• type Opts
• type RedisCompatible

Types

type Leader

type Leader interface {
	Start()
	Stop() error
	IsLeading() bool
}

func NewLeader

func NewLeader(opts Opts) (leader Leader, onPromote <-chan time.Time, onDemote <-chan time.Time, onError <-chan error)

type Opts

type Opts struct {
	Redis    RedisCompatible
	TTL      time.Duration
	Wait     time.Duration
	JitterMS int
	Key      string
}

type RedisCompatible

type RedisCompatible interface {
	Get(ctx context.Context, key string) *redis.StringCmd
	EvalSha(ctx context.Context, sha string, keys []string, args ...any) *redis.Cmd
	ScriptLoad(ctx context.Context, script string) *redis.StringCmd
}