Documentation
¶
Index ¶
Constants ¶
View Source
const ( TenantActivityStatusFREEZING = "FREEZING" TenantActivityStatusUNFREEZING = "UNFREEZING" )
Variables ¶
View Source
var ( // ErrNotLeader is returned when an operation can't be completed on a // follower or candidate node. ErrNotLeader = errors.New("node is not the leader") ErrLeaderNotFound = errors.New("leader not found") ErrNotOpen = errors.New("store not open") ErrUnknownCommand = errors.New("unknown command") // ErrDeadlineExceeded represents an error returned when the deadline for waiting for a specific update is exceeded. ErrDeadlineExceeded = errors.New("deadline exceeded for waiting for update") )
Functions ¶
This section is empty.
Types ¶
type ClassState ¶
ClassState represent a class and it's associated sharding state
type RaftResolver ¶
type RaftResolver interface { ServerAddr(id raft.ServerID) (raft.ServerAddress, error) NewTCPTransport(bindAddr string, advertise net.Addr, maxPool int, timeout time.Duration, logger *logrus.Logger) (*raft.NetworkTransport, error) NotResolvedNodes() map[raft.ServerID]struct{} }
RaftResolver is passed to raft to resolver node ids to their real ip:port so that tranport can be established.
Click to show internal directories.
Click to hide internal directories.