redlease

Jul 11, 2026

Changes in this version

+ var ErrTooManyEvalBodies = errors.New(...)

type Observer

+ OnError func(err error)

Jul 11, 2026

Changes in this version

type Elector

+ func (e *Elector) Resign()

Jun 24, 2026

Changes in this version

type Elector

+ func (e *Elector) Fencer() (f Fencer, ok bool)

+ type Fencer struct

+ func NewFencer(e *Elector, token int64) Fencer

+ func (f Fencer) Eval(ctx context.Context, body string, writeKeys []string, args ...any) (applied bool, err error)

+ func (f Fencer) HSet(ctx context.Context, hashKey, field, value string) (applied bool, err error)

+ func (f Fencer) Set(ctx context.Context, key, value string) (applied bool, err error)

+ func (f Fencer) Token() int64

Jun 24, 2026

Changes in this version

type Observer

+ OnFollower func()

Jun 24, 2026

Changes in this version

+ const DefaultAcquireInterval

+ const DefaultRenewInterval

+ const DefaultTTL

+ type Config struct

+ AcquireInterval time.Duration

+ InstanceID string

+ Name string

+ Observer Observer

+ RenewInterval time.Duration

+ TTL time.Duration

+ type Elector struct

+ func New(client Redis, cfg Config) (*Elector, error)

+ func (e *Elector) FenceEval(ctx context.Context, token int64, body string, writeKeys []string, args ...any) (applied bool, err error)

+ func (e *Elector) FenceHSet(ctx context.Context, token int64, hashKey, field, value string) (applied bool, err error)

+ func (e *Elector) FenceSet(ctx context.Context, token int64, key, value string) (applied bool, err error)

+ func (e *Elector) InstanceID() string

+ func (e *Elector) IsLeader() bool

+ func (e *Elector) Run(ctx context.Context, fn LeaderFunc)

+ func (e *Elector) Token() (token int64, ok bool)

+ type LeaderFunc func(ctx context.Context, token int64)

+ type Observer struct

+ OnElected func(token int64)

+ OnSteppedDown func()

+ type Redis interface