elect

Documentation

Index

• func CmdAssert(ctx context.Context, client *clientv3.Client, office string, minRev int64, ...) (int, error)
• func CmdWatch(ctx context.Context, client *clientv3.Client, office string, useJSON bool) (int, error)
• func CmdWho(ctx context.Context, client *clientv3.Client, office string, useJSON bool) (int, error)
• func RunElect(ctx context.Context, logger *slog.Logger, endpoints []string, ...) (int, error)
• type AssertOutput
• type ElectHolder
  • func NewElectHolder(sess *core.CoreSession, office string, val string, waitLimit time.Duration) *ElectHolder
  • func (eh *ElectHolder) Acquire(ctx context.Context) (int64, error)
  • func (eh *ElectHolder) Key() string
  • func (eh *ElectHolder) Name() string
  • func (eh *ElectHolder) Release(ctx context.Context) error

Functions

func CmdAssert

func CmdAssert(ctx context.Context, client *clientv3.Client, office string, minRev int64, useJSON bool) (int, error)

func CmdWatch

func CmdWatch(ctx context.Context, client *clientv3.Client, office string, useJSON bool) (int, error)

func CmdWho

func CmdWho(ctx context.Context, client *clientv3.Client, office string, useJSON bool) (int, error)

func RunElect

func RunElect(ctx context.Context, logger *slog.Logger, endpoints []string, dialTimeout time.Duration, ttl time.Duration, killAfter time.Duration, restart bool, office string, waitLimit time.Duration, stableThreshold time.Duration, onAcquire string, onLose string, hookTimeout time.Duration, cmdArgs []string) (int, error)

Types

type AssertOutput

type AssertOutput struct {
	Held bool   `json:"held"`
	Rev  int64  `json:"rev"`
	Host string `json:"host"`
}

type ElectHolder

type ElectHolder struct {
	// contains filtered or unexported fields
}

func NewElectHolder

func NewElectHolder(sess *core.CoreSession, office string, val string, waitLimit time.Duration) *ElectHolder

func (*ElectHolder) Acquire

func (eh *ElectHolder) Acquire(ctx context.Context) (int64, error)

func (*ElectHolder) Key

func (eh *ElectHolder) Key() string

func (*ElectHolder) Name

func (eh *ElectHolder) Name() string

func (*ElectHolder) Release

func (eh *ElectHolder) Release(ctx context.Context) error