ip

Sep 16, 2025

Changes in this version

+ type Backoff interface

+ NextBackOff func() time.Duration

+ Reset func()

Jul 9, 2025

Changes in this version

+ const ACTIVATED

+ const BOOTING

+ const DemotedEvent

+ const ElectedEvent

+ const FAILING

+ const FaultEvent

+ const HealthCheckFailEvent

+ const HealthCheckSuccessEvent

+ const STANDBY

+ var ErrIsNotMaster = errors.New("this node is not master of this endpoint")

+ var ErrNoOtherHosts = errors.New("no other nodes are listening for this endpoint")

+ var ErrReallocationTimedOut = errors.New("reallocation timed out")

+ func NewStateMachine(_ context.Context, opts NewStateMachineOpts) *fsm.FSM

+ type EndpointManager struct

+ func NewManager(ctx context.Context, cfg config.Config, endpoint models.Endpoint, ...) (*EndpointManager, error)

+ func (m *EndpointManager) ElectionKey(ctx context.Context) string

+ func (m *EndpointManager) Endpoint() models.Endpoint

+ func (m *EndpointManager) Failover(ctx context.Context) error

+ func (m *EndpointManager) SetHealthChecks(ctx context.Context, cfg config.Config, healthChecks []models.HealthCheck)

+ func (m *EndpointManager) Start(ctx context.Context)

+ func (m *EndpointManager) Status() string

+ func (m *EndpointManager) Stop(ctx context.Context) error

+ type Manager interface

+ ElectionKey func(ctx context.Context) string

+ Endpoint func() models.Endpoint

+ Failover func(ctx context.Context) error

+ SetHealthChecks func(ctx context.Context, config config.Config, checks []models.HealthCheck)

+ Start func(ctx context.Context)

+ Status func() string

+ Stop func(ctx context.Context) error

+ type NewStateMachineOpts struct

+ ActivatedCallback func(ctx context.Context, e *fsm.Event)

+ FailingCallback func(ctx context.Context, e *fsm.Event)

+ StandbyCallback func(ctx context.Context, e *fsm.Event)