Documentation ¶
Index ¶
- Variables
- func Execute()
- type ConvergenceState
- type DBConvergenceInfo
- type KeeperInfoHistories
- type KeeperInfoHistory
- type ProxyInfoHistories
- type ProxyInfoHistory
- type Sentinel
- func (s *Sentinel) CleanDBError(uid string)
- func (s *Sentinel) CleanDBNotIncreasingXLogPos(uid string)
- func (s *Sentinel) CleanKeeperError(uid string)
- func (s *Sentinel) SetDBError(uid string)
- func (s *Sentinel) SetDBNotIncreasingXLogPos(uid string)
- func (s *Sentinel) SetKeeperError(uid string)
- func (s *Sentinel) Start(ctx context.Context)
Constants ¶
This section is empty.
Variables ¶
View Source
var CmdSentinel = &cobra.Command{ Use: "stolon-sentinel", Run: sentinel, Version: cmd.Version, }
Functions ¶
Types ¶
type ConvergenceState ¶
type ConvergenceState uint
const ( Converging ConvergenceState = iota Converged ConvergenceFailed )
type DBConvergenceInfo ¶
type KeeperInfoHistories ¶
type KeeperInfoHistories map[string]*KeeperInfoHistory
func (KeeperInfoHistories) DeepCopy ¶
func (k KeeperInfoHistories) DeepCopy() KeeperInfoHistories
type KeeperInfoHistory ¶
type KeeperInfoHistory struct { KeeperInfo *cluster.KeeperInfo Seen bool Timer int64 }
type ProxyInfoHistories ¶
type ProxyInfoHistories map[string]*ProxyInfoHistory
func (ProxyInfoHistories) DeepCopy ¶
func (p ProxyInfoHistories) DeepCopy() ProxyInfoHistories
type ProxyInfoHistory ¶
type Sentinel ¶
type Sentinel struct { // Make UIDFn settable to ease testing with reproducible UIDs UIDFn func() string // Make RandFn settable to ease testing with reproducible "random" numbers RandFn func(int) int // contains filtered or unexported fields }
func (*Sentinel) CleanDBError ¶
func (*Sentinel) CleanDBNotIncreasingXLogPos ¶
func (*Sentinel) CleanKeeperError ¶
func (*Sentinel) SetDBError ¶
func (*Sentinel) SetDBNotIncreasingXLogPos ¶
func (*Sentinel) SetKeeperError ¶
Click to show internal directories.
Click to hide internal directories.