Documentation ¶
Index ¶
- Constants
- func OversizedMessage(b []byte) bool
- type Channel
- type Peer
- func (p *Peer) AddState(key string, s State, reg prometheus.Registerer) *Channel
- func (p *Peer) ClusterSize() int
- func (p *Peer) Info() map[string]interface{}
- func (p *Peer) Leave(timeout time.Duration) error
- func (p *Peer) Name() string
- func (p *Peer) Peers() []*memberlist.Node
- func (p *Peer) Position() int
- func (p *Peer) Ready() bool
- func (p *Peer) Self() *memberlist.Node
- func (p *Peer) Settle(ctx context.Context, interval time.Duration)
- func (p *Peer) Status() string
- func (p *Peer) WaitReady()
- type PeerStatus
- type State
Constants ¶
const ( DefaultPushPullInterval = 60 * time.Second DefaultGossipInterval = 200 * time.Millisecond DefaultTcpTimeout = 10 * time.Second DefaultProbeTimeout = 500 * time.Millisecond DefaultProbeInterval = 1 * time.Second DefaultReconnectInterval = 10 * time.Second DefaultReconnectTimeout = 6 * time.Hour )
Variables ¶
This section is empty.
Functions ¶
func OversizedMessage ¶
OversizedMessage indicates whether or not the byte payload should be sent via TCP.
Types ¶
type Channel ¶
type Channel struct {
// contains filtered or unexported fields
}
Channel allows clients to send messages for a specific state type that will be broadcasted in a best-effort manner.
func NewChannel ¶
func NewChannel( key string, send func([]byte), peers func() []*memberlist.Node, sendOversize func(*memberlist.Node, []byte) error, logger log.Logger, stopc chan struct{}, reg prometheus.Registerer, ) *Channel
NewChannel creates a new Channel struct, which handles sending normal and oversize messages to peers.
type Peer ¶
type Peer struct {
// contains filtered or unexported fields
}
Peer is a single peer in a gossip cluster.
func Join ¶
func Join( l log.Logger, reg prometheus.Registerer, bindAddr string, advertiseAddr string, knownPeers []string, waitIfEmpty bool, pushPullInterval time.Duration, gossipInterval time.Duration, tcpTimeout time.Duration, probeTimeout time.Duration, probeInterval time.Duration, reconnectInterval time.Duration, reconnectTimeout time.Duration, ) (*Peer, error)
func (*Peer) AddState ¶
func (p *Peer) AddState(key string, s State, reg prometheus.Registerer) *Channel
AddState adds a new state that will be gossiped. It returns a channel to which broadcast messages for the state can be sent.
func (*Peer) ClusterSize ¶
ClusterSize returns the current number of alive members in the cluster.
func (*Peer) Peers ¶
func (p *Peer) Peers() []*memberlist.Node
Peers returns the peers in the cluster.
func (*Peer) Self ¶
func (p *Peer) Self() *memberlist.Node
Self returns the node information about the peer itself.
func (*Peer) Settle ¶
Settle waits until the mesh is ready (and sets the appropriate internal state when it is). The idea is that we don't want to start "working" before we get a chance to know most of the alerts and/or silences. Inspired from https://github.com/apache/cassandra/blob/7a40abb6a5108688fb1b10c375bb751cbb782ea4/src/java/org/apache/cassandra/gms/Gossiper.java This is clearly not perfect or strictly correct but should prevent the alertmanager to send notification before it is obviously not ready. This is especially important for those that do not have persistent storage.
type PeerStatus ¶
type PeerStatus int
PeerStatus is the state that a peer is in.
const ( StatusNone PeerStatus = iota StatusAlive StatusFailed )
func (PeerStatus) String ¶
func (s PeerStatus) String() string