raft

Aug 23, 2023

Changes in this version

type Config

+ CommitTimeout *time.Duration

Feb 20, 2023

Changes in this version

+ type Env interface

+ GetEventDispatcher func() event.Dispatcher

+ GetId func() *identity.TokenId

+ GetMetricsRegistry func() metrics.Registry

+ GetRaftConfig func() *Config

+ GetVersionProvider func() versions.VersionProvider

Feb 20, 2023

Changes in this version

type Controller

+ func (self *Controller) HandleTransferLeadership(req *cmd_pb.TransferLeadershipRequest) error

+ func (self *Controller) HandleTransferLeadershipAsLeader(req *cmd_pb.TransferLeadershipRequest) error

Feb 20, 2023

Changes in this version

type Config

+ ElectionTimeout *time.Duration

+ HeartbeatTimeout *time.Duration

+ LeaderLeaseTimeout *time.Duration

+ LogLevel *string

+ Logger hclog.Logger

+ MaxAppendEntries *uint32

+ SnapshotInterval *time.Duration

+ SnapshotThreshold *uint32

+ TrailingLogs *uint32

+ func (self *Config) Configure(conf *raft.Config)

+ func (self *Config) ConfigureReloadable(conf *raft.ReloadableConfig)

type Controller

+ func (self *Controller) ConfigureMeshHandlers(bindHandler channel.BindHandler)

+ func (self *Controller) GetCloseNotify() <-chan struct{}

+ func (self *Controller) GetMetricsRegistry() metrics.Registry

+ func (self *Controller) GetPeers() map[string]channel.Channel

+ func (self *Controller) HandleAddPeer(req *cmd_pb.AddPeerRequest) error

+ func (self *Controller) HandleAddPeerAsLeader(req *cmd_pb.AddPeerRequest) error

+ func (self *Controller) HandleRemovePeer(req *cmd_pb.RemovePeerRequest) error

+ func (self *Controller) HandleRemovePeerAsLeader(req *cmd_pb.RemovePeerRequest) error

+ func (self *Controller) RenderJsonConfig() (string, error)

Feb 10, 2023

Changes in this version

+ type ClusterEvent uint32

+ const ClusterEventLeadershipGained

+ const ClusterEventLeadershipLost

+ const ClusterEventReadOnly

+ const ClusterEventReadWrite

+ func (self ClusterEvent) String() string

+ type ClusterState uint8

+ func (c ClusterState) IsLeader() bool

+ func (c ClusterState) IsReadWrite() bool

+ func (c ClusterState) String() string

type Controller

+ func (self *Controller) IsDistributed() bool

+ func (self *Controller) IsReadOnlyMode() bool

+ func (self *Controller) ObserveLeaderChanges()

+ func (self *Controller) RegisterClusterEventHandler(f func(event ClusterEvent, state ClusterState))

Jan 18, 2023

Changes in this version

type BoltDbFsm

+ func (self *BoltDbFsm) GetCurrentState(raft *raft.Raft) (uint64, *raft.Configuration)

+ func (self *BoltDbFsm) StoreConfiguration(index uint64, configuration raft.Configuration)

type Controller

+ func (self *Controller) CtrlAddresses() (uint64, []string)

+ type RouterDispatchCallback func(*raft.Configuration) error

Jan 12, 2023

Changes in this version

type Member

+ Connected bool

+ Version string

Jan 4, 2023

Changes in this version

type Controller

+ func (self *Controller) IsLeaderOrLeaderless() bool

Jan 4, 2023

Changes in this version

type Controller

+ func (self *Controller) Bootstrap() error

+ type MigrationManager interface

+ InitializeRaftFromBoltDb func(srcDb string) error

+ TryInitializeRaftFromBoltDb func() error

Aug 26, 2022

Changes in this version

+ const IndexHeader

+ type IndexTracker interface

+ Index func() uint64

+ NotifyOfIndex func(index uint64)

+ WaitForIndex func(index uint64, deadline time.Time) error

+ func NewIndexTracker() IndexTracker

Jun 3, 2022

Changes in this version

+ const ErrorCodeApiError

+ const ErrorCodeBadMessage

+ const ErrorCodeGeneric

+ const ErrorCodeNotLeader

+ const ErrorResponseType

+ const HeaderErrorCode

+ const JoinRequestType

+ const NewLogEntryType

+ const RemoveRequestType

+ const SuccessResponseType

+ func NewCommandHandler(controller *Controller) channel.TypedReceiveHandler

+ func NewHcLogrusLogger() hclog.Logger

+ func NewJoinHandler(controller *Controller) channel.TypedReceiveHandler

+ func NewRemoveHandler(controller *Controller) channel.TypedReceiveHandler

+ type BoltDbFsm struct

+ func NewFsm(dataDir string, decoders command.Decoders) *BoltDbFsm

+ func (self *BoltDbFsm) Apply(log *raft.Log) interface{}

+ func (self *BoltDbFsm) GetDb() *db.Db

+ func (self *BoltDbFsm) Init() error

+ func (self *BoltDbFsm) RaftInitialized()

+ func (self *BoltDbFsm) Restore(snapshot io.ReadCloser) error

+ func (self *BoltDbFsm) Snapshot() (raft.FSMSnapshot, error)

+ type Config struct

+ AdvertiseAddress string

+ BindAddress string

+ BootstrapMembers []string

+ CommandHandlerOptions struct{ ... }

+ DataDir string

+ MinClusterSize uint32

+ Recover bool

+ type Controller struct

+ Config *Config

+ Fsm *BoltDbFsm

+ Id *identity.TokenId

+ Mesh mesh.Mesh

+ Raft *raft.Raft

+ func NewController(id *identity.TokenId, config *Config, metricsRegistry metrics.Registry) (*Controller, error)

+ func (self *Controller) ApplyEncodedCommand(encoded []byte) error

+ func (self *Controller) ApplyWithTimeout(log []byte, timeout time.Duration) (interface{}, error)

+ func (self *Controller) Dispatch(cmd command.Command) error

+ func (self *Controller) GetDb() *db.Db

+ func (self *Controller) GetLeaderAddr() string

+ func (self *Controller) GetMesh() mesh.Mesh

+ func (self *Controller) GetRaft() *raft.Raft

+ func (self *Controller) HandleJoin(req *JoinRequest) error

+ func (self *Controller) HandleJoinAsLeader(req *JoinRequest) error

+ func (self *Controller) HandleRemove(req *RemoveRequest) error

+ func (self *Controller) HandleRemoveAsLeader(req *RemoveRequest) error

+ func (self *Controller) Init() error

+ func (self *Controller) IsLeader() bool

+ func (self *Controller) Join(req *JoinRequest) error

+ func (self *Controller) ListMembers() ([]*Member, error)

+ func (self *Controller) RemoveServer(id string) error

+ type JoinRequest struct

+ Addr string

+ Id string

+ IsVoter bool

+ func (self *JoinRequest) Decode(msg *channel.Message) error

+ func (self *JoinRequest) Encode() (*channel.Message, error)

+ type Member struct

+ Addr string

+ Id string

+ Leader bool

+ Voter bool

+ type MemberModel interface

+ HandleJoin func(req *JoinRequest) error

+ HandleRemove func(req *RemoveRequest) error

+ ListMembers func() ([]*Member, error)

+ type RemoveRequest struct

+ Id string

+ func (self *RemoveRequest) Decode(msg *channel.Message) error

+ func (self *RemoveRequest) Encode() (*channel.Message, error)