autopilot

package module

Go to main page

Versions in this module

v0

v0.3.0

Dec 11, 2024

v0.2.0

Nov 5, 2022

Changes in this version

type Autopilot

+ func (a *Autopilot) ComputeState(ctx context.Context) (*State, error)

+ type MockApplicationIntegration struct

+ func NewMockApplicationIntegration(t mockConstructorTestingTNewMockApplicationIntegration) *MockApplicationIntegration

+ func (_m *MockApplicationIntegration) AutopilotConfig() *Config

+ func (_m *MockApplicationIntegration) FetchServerStats(_a0 context.Context, _a1 map[raft.ServerID]*Server) map[raft.ServerID]*ServerStats

+ func (_m *MockApplicationIntegration) KnownServers() map[raft.ServerID]*Server

+ func (_m *MockApplicationIntegration) NotifyState(_a0 *State)

+ func (_m *MockApplicationIntegration) RemoveFailedServer(_a0 *Server)

+ type MockOption struct

+ func NewMockOption(t mockConstructorTestingTNewMockOption) *MockOption

+ func (_m *MockOption) Execute(_a0 *Autopilot)

+ type MockPromoter struct

+ func NewMockPromoter(t mockConstructorTestingTNewMockPromoter) *MockPromoter

+ func (_m *MockPromoter) CalculatePromotionsAndDemotions(_a0 *Config, _a1 *State) RaftChanges

+ func (_m *MockPromoter) FilterFailedServerRemovals(_a0 *Config, _a1 *State, _a2 *FailedServers) *FailedServers

+ func (_m *MockPromoter) GetNodeTypes(_a0 *Config, _a1 *State) map[raft.ServerID]NodeType

+ func (_m *MockPromoter) GetServerExt(_a0 *Config, _a1 *ServerState) interface{}

+ func (_m *MockPromoter) GetStateExt(_a0 *Config, _a1 *State) interface{}

+ func (_m *MockPromoter) IsPotentialVoter(_a0 NodeType) bool

+ type MockRaft struct

+ func NewMockRaft(t mockConstructorTestingTNewMockRaft) *MockRaft

+ func (_m *MockRaft) AddNonvoter(id raft.ServerID, address raft.ServerAddress, prevIndex uint64, ...) raft.IndexFuture

+ func (_m *MockRaft) AddVoter(id raft.ServerID, address raft.ServerAddress, prevIndex uint64, ...) raft.IndexFuture

+ func (_m *MockRaft) DemoteVoter(id raft.ServerID, prevIndex uint64, timeout time.Duration) raft.IndexFuture

+ func (_m *MockRaft) GetConfiguration() raft.ConfigurationFuture

+ func (_m *MockRaft) LastIndex() uint64

+ func (_m *MockRaft) Leader() raft.ServerAddress

+ func (_m *MockRaft) LeadershipTransferToServer(id raft.ServerID, address raft.ServerAddress) raft.Future

+ func (_m *MockRaft) RemoveServer(id raft.ServerID, prevIndex uint64, timeout time.Duration) raft.IndexFuture

+ func (_m *MockRaft) State() raft.RaftState

+ func (_m *MockRaft) Stats() map[string]string

+ type MockTimeProvider struct

+ func NewMockTimeProvider(t mockConstructorTestingTNewMockTimeProvider) *MockTimeProvider

+ func (_m *MockTimeProvider) Now() time.Time

type Option

+ func WithTimeProvider(provider TimeProvider) Option

type Promoter

+ IsPotentialVoter func(NodeType) bool

type StablePromoter

+ func (_ *StablePromoter) IsPotentialVoter(nodeType NodeType) bool

+ type TimeProvider interface

+ Now func() time.Time

v0.1.6

Apr 4, 2022

Changes in this version

type Autopilot

+ func (a *Autopilot) DisableReconciliation()

+ func (a *Autopilot) EnableReconciliation()

+ func (a *Autopilot) ReconciliationEnabled() bool

type Option

+ func WithReconciliationDisabled() Option

type Raft

+ State func() raft.RaftState

v0.1.5

May 27, 2021

v0.1.4

May 26, 2021

v0.1.3

Apr 23, 2021

Changes in this version

type Server

+ IsLeader bool

v0.1.2

Jan 26, 2021

Changes in this version

type Autopilot

+ func (a *Autopilot) IsRunning() (ExecutionStatus, <-chan struct{})

+ type ExecutionStatus string

+ const NotRunning

+ const Running

+ const ShuttingDown

v0.1.1

Nov 6, 2020

v0.1.0

Nov 5, 2020

Changes in this version

+ const DefaultReconcileInterval

+ const DefaultUpdateInterval

+ func ServerLessThan(id1 raft.ServerID, id2 raft.ServerID, s *State) bool

+ func SortServers(ids []raft.ServerID, s *State)

+ type ApplicationIntegration interface

+ AutopilotConfig func() *Config

+ FetchServerStats func(context.Context, map[raft.ServerID]*Server) map[raft.ServerID]*ServerStats

+ KnownServers func() map[raft.ServerID]*Server

+ NotifyState func(*State)

+ RemoveFailedServer func(*Server)

+ type Autopilot struct

+ func New(raft Raft, delegate ApplicationIntegration, options ...Option) *Autopilot

+ func (a *Autopilot) AddServer(s *Server) error

+ func (a *Autopilot) GetServerHealth(id raft.ServerID) *ServerHealth

+ func (a *Autopilot) GetState() *State

+ func (a *Autopilot) NumVoters() (int, error)

+ func (a *Autopilot) RemoveDeadServers()

+ func (a *Autopilot) RemoveServer(id raft.ServerID) error

+ func (a *Autopilot) Start(ctx context.Context)

+ func (a *Autopilot) Stop() <-chan struct{}

+ type Config struct

+ CleanupDeadServers bool

+ Ext interface{}

+ LastContactThreshold time.Duration

+ MaxTrailingLogs uint64

+ MinQuorum uint

+ ServerStabilizationTime time.Duration

+ type FailedServers struct

+ FailedNonVoters []*Server

+ FailedVoters []*Server

+ StaleNonVoters []raft.ServerID

+ StaleVoters []raft.ServerID

+ type NodeStatus string

+ const NodeAlive

+ const NodeFailed

+ const NodeLeft

+ const NodeUnknown

+ type NodeType string

+ const NodeVoter

+ type Option func(*Autopilot)

+ func WithLogger(logger hclog.Logger) Option

+ func WithPromoter(promoter Promoter) Option

+ func WithReconcileInterval(t time.Duration) Option

+ func WithUpdateInterval(t time.Duration) Option

+ type Promoter interface

+ CalculatePromotionsAndDemotions func(*Config, *State) RaftChanges

+ FilterFailedServerRemovals func(*Config, *State, *FailedServers) *FailedServers

+ GetNodeTypes func(*Config, *State) map[raft.ServerID]NodeType

+ GetServerExt func(*Config, *ServerState) interface{}

+ GetStateExt func(*Config, *State) interface{}

+ func DefaultPromoter() Promoter

+ type Raft interface

+ AddNonvoter func(id raft.ServerID, address raft.ServerAddress, prevIndex uint64, ...) raft.IndexFuture

+ AddVoter func(id raft.ServerID, address raft.ServerAddress, prevIndex uint64, ...) raft.IndexFuture

+ DemoteVoter func(id raft.ServerID, prevIndex uint64, timeout time.Duration) raft.IndexFuture

+ GetConfiguration func() raft.ConfigurationFuture

+ LastIndex func() uint64

+ Leader func() raft.ServerAddress

+ LeadershipTransferToServer func(id raft.ServerID, address raft.ServerAddress) raft.Future

+ RemoveServer func(id raft.ServerID, prevIndex uint64, timeout time.Duration) raft.IndexFuture

+ Stats func() map[string]string

+ type RaftChanges struct

+ Demotions []raft.ServerID

+ Leader raft.ServerID

+ Promotions []raft.ServerID

+ type RaftState string

+ const RaftLeader

+ const RaftNonVoter

+ const RaftNone

+ const RaftStaging

+ const RaftVoter

+ func (s RaftState) IsPotentialVoter() bool

+ type Server struct

+ Address raft.ServerAddress

+ Ext interface{}

+ ID raft.ServerID

+ Meta map[string]string

+ Name string

+ NodeStatus NodeStatus

+ NodeType NodeType

+ RaftVersion int

+ Version string

+ type ServerHealth struct

+ Healthy bool

+ StableSince time.Time

+ func (h *ServerHealth) IsStable(now time.Time, minStableDuration time.Duration) bool

+ type ServerState struct

+ Health ServerHealth

+ Server Server

+ State RaftState

+ Stats ServerStats

+ func (s *ServerState) HasVotingRights() bool

+ type ServerStats struct

+ LastContact time.Duration

+ LastIndex uint64

+ LastTerm uint64

+ type StablePromoter struct

+ func (_ *StablePromoter) CalculatePromotionsAndDemotions(c *Config, s *State) RaftChanges

+ func (_ *StablePromoter) FilterFailedServerRemovals(_ *Config, _ *State, failed *FailedServers) *FailedServers

+ func (_ *StablePromoter) GetNodeTypes(_ *Config, s *State) map[raft.ServerID]NodeType

+ func (_ *StablePromoter) GetServerExt(_ *Config, srv *ServerState) interface{}

+ func (_ *StablePromoter) GetStateExt(_ *Config, _ *State) interface{}

+ type State struct

+ Ext interface{}

+ FailureTolerance int

+ Healthy bool

+ Leader raft.ServerID

+ Servers map[raft.ServerID]*ServerState

+ Voters []raft.ServerID

+ func (s *State) ServerStabilizationTime(c *Config) time.Duration

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL