mori

package module

Go to main page

Versions in this module

v0

v0.7.0

Jul 11, 2026

Changes in this version

+ var ErrLeft = errors.New("memberlist: node has left the cluster")

+ var ErrMetaTooLarge = errors.New("memberlist: node meta data exceeds size limit")

+ var ErrNoLocalNode = errors.New("memberlist: local node not found in node map")

+ var ErrShutdown = errors.New("memberlist: already shut down")

type Config

+ MetaMaxSize int

+ PushPullConcurrency int

+ type MaxPacketSizeTransport interface

+ MaxPacketSize func() int

type Memberlist

+ func (m *Memberlist) LeaveContext(ctx context.Context) error

+ func (m *Memberlist) UpdateNodeContext(ctx context.Context) error

type NetTransport

+ func (t *NetTransport) MaxPacketSize() int

v0.6.0

Jul 10, 2026

Changes in this version

+ const LabelMaxSize

+ const MetaMaxSize

+ const ProtocolVersion2Compatible

+ const ProtocolVersionMax

+ const ProtocolVersionMin

+ func AddLabelHeaderToPacket(buf []byte, label string) ([]byte, error)

+ func AddLabelHeaderToStream(conn net.Conn, label string) error

+ func LogAddress(addr net.Addr) string

+ func LogConn(conn net.Conn) string

+ func LogStringAddress(addr string) string

+ func ParseCIDRs(v []string) ([]net.IPNet, error)

+ func RemoveLabelHeaderFromPacket(buf []byte) (newBuf []byte, label string, err error)

+ func RemoveLabelHeaderFromStream(conn net.Conn) (net.Conn, string, error)

+ func ValidateKey(key []byte) error

+ type Address struct

+ Addr string

+ Name string

+ func (a *Address) String() string

+ type AliveDelegate interface

+ NotifyAlive func(peer *Node) error

+ type Broadcast interface

+ Finished func()

+ Invalidates func(b Broadcast) bool

+ Message func() []byte

+ type ChannelEventDelegate struct

+ Ch chan<- NodeEvent

+ func (c *ChannelEventDelegate) NotifyJoin(n *Node)

+ func (c *ChannelEventDelegate) NotifyLeave(n *Node)

+ func (c *ChannelEventDelegate) NotifyUpdate(n *Node)

+ type Config struct

+ AdvertiseAddr string

+ AdvertisePort int

+ Alive AliveDelegate

+ AwarenessMaxMultiplier int

+ BindAddr string

+ BindPort int

+ CIDRsAllowed []net.IPNet

+ Conflict ConflictDelegate

+ DNSConfigPath string

+ DeadNodeReclaimTime time.Duration

+ Delegate Delegate

+ DelegateProtocolMax uint8

+ DelegateProtocolMin uint8

+ DelegateProtocolVersion uint8

+ DisableTcpPings bool

+ DisableTcpPingsForNode func(nodeName string) bool

+ EnableCompression bool

+ Events EventDelegate

+ GossipInterval time.Duration

+ GossipNodes int

+ GossipToTheDeadTime time.Duration

+ GossipVerifyIncoming bool

+ GossipVerifyOutgoing bool

+ HandoffQueueDepth int

+ IndirectChecks int

+ Keyring *Keyring

+ Label string

+ LogOutput io.Writer

+ Logger *log.Logger

+ Merge MergeDelegate

+ MetricLabels []metrics.Label

+ MsgpackUseNewTimeFormat bool

+ Name string

+ Ping PingDelegate

+ ProbeInterval time.Duration

+ ProbeTimeout time.Duration

+ ProtocolVersion uint8

+ PushPullInterval time.Duration

+ QueueCheckInterval time.Duration

+ RequireNodeNames bool

+ RetransmitMult int

+ SecretKey []byte

+ SkipInboundLabelCheck bool

+ SuspicionMaxTimeoutMult int

+ SuspicionMult int

+ TCPTimeout time.Duration

+ Transport Transport

+ UDPBufferSize int

+ func DefaultLANConfig() *Config

+ func DefaultLocalConfig() *Config

+ func DefaultWANConfig() *Config

+ func (c *Config) EncryptionEnabled() bool

+ func (c *Config) IPAllowed(ip net.IP) error

+ func (c *Config) IPMustBeChecked() bool

+ func (conf *Config) BuildVsnArray() []uint8

+ type ConflictDelegate interface

+ NotifyConflict func(existing, other *Node)

+ type Delegate interface

+ GetBroadcasts func(overhead, limit int) [][]byte

+ LocalState func(join bool) []byte

+ MergeRemoteState func(buf []byte, join bool)

+ NodeMeta func(limit int) []byte

+ NotifyMsg func([]byte)

+ type EventDelegate interface

+ NotifyJoin func(*Node)

+ NotifyLeave func(*Node)

+ NotifyUpdate func(*Node)

+ type IngestionAwareTransport interface

+ IngestPacket func(conn net.Conn, addr net.Addr, now time.Time, shouldClose bool) error

+ IngestStream func(conn net.Conn) error

+ type Keyring struct

+ func NewKeyring(keys [][]byte, primaryKey []byte) (*Keyring, error)

+ func (k *Keyring) AddKey(key []byte) error

+ func (k *Keyring) GetKeys() [][]byte

+ func (k *Keyring) GetPrimaryKey() (key []byte)

+ func (k *Keyring) RemoveKey(key []byte) error

+ func (k *Keyring) UseKey(key []byte) error

+ type Memberlist struct

+ func Create(conf *Config) (*Memberlist, error)

+ func (m *Memberlist) GetHealthScore() int

+ func (m *Memberlist) Join(existing []string) (int, error)

+ func (m *Memberlist) Leave(timeout time.Duration) error

+ func (m *Memberlist) LocalNode() *Node

+ func (m *Memberlist) Members() []*Node

+ func (m *Memberlist) NumMembers() (alive int)

+ func (m *Memberlist) Ping(node string, addr net.Addr) (time.Duration, error)

+ func (m *Memberlist) ProtocolVersion() uint8

+ func (m *Memberlist) SendBestEffort(to *Node, msg []byte) error

+ func (m *Memberlist) SendReliable(to *Node, msg []byte) error

+ func (m *Memberlist) SendTo(to net.Addr, msg []byte) error

+ func (m *Memberlist) SendToAddress(a Address, msg []byte) error

+ func (m *Memberlist) SendToTCP(to *Node, msg []byte) error

+ func (m *Memberlist) SendToUDP(to *Node, msg []byte) error

+ func (m *Memberlist) Shutdown() error

+ func (m *Memberlist) UpdateNode(timeout time.Duration) error

+ type MergeDelegate interface

+ NotifyMerge func(peers []*Node) error

+ type MockAddress struct

+ func (a *MockAddress) Network() string

+ func (a *MockAddress) String() string

+ type MockNetwork struct

+ func (n *MockNetwork) NewTransport(name string) *MockTransport

+ type MockTransport struct

+ func (t *MockTransport) DialAddressTimeout(a Address, timeout time.Duration) (net.Conn, error)

+ func (t *MockTransport) DialTimeout(addr string, timeout time.Duration) (net.Conn, error)

+ func (t *MockTransport) FinalAdvertiseAddr(string, int) (net.IP, int, error)

+ func (t *MockTransport) IngestPacket(conn net.Conn, addr net.Addr, now time.Time, shouldClose bool) error

+ func (t *MockTransport) IngestStream(conn net.Conn) error

+ func (t *MockTransport) PacketCh() <-chan *Packet

+ func (t *MockTransport) Shutdown() error

+ func (t *MockTransport) StreamCh() <-chan net.Conn

+ func (t *MockTransport) WriteTo(b []byte, addr string) (time.Time, error)

+ func (t *MockTransport) WriteToAddress(b []byte, a Address) (time.Time, error)

+ type NamedBroadcast interface

+ Name func() string

+ type NetTransport struct

+ func NewNetTransport(config *NetTransportConfig) (*NetTransport, error)

+ func (t *NetTransport) DialAddressTimeout(a Address, timeout time.Duration) (net.Conn, error)

+ func (t *NetTransport) DialTimeout(addr string, timeout time.Duration) (net.Conn, error)

+ func (t *NetTransport) FinalAdvertiseAddr(ip string, port int) (net.IP, int, error)

+ func (t *NetTransport) GetAutoBindPort() int

+ func (t *NetTransport) IngestPacket(conn net.Conn, addr net.Addr, now time.Time, shouldClose bool) error

+ func (t *NetTransport) IngestStream(conn net.Conn) error

+ func (t *NetTransport) PacketCh() <-chan *Packet

+ func (t *NetTransport) Shutdown() error

+ func (t *NetTransport) StreamCh() <-chan net.Conn

+ func (t *NetTransport) WriteTo(b []byte, addr string) (time.Time, error)

+ func (t *NetTransport) WriteToAddress(b []byte, a Address) (time.Time, error)

+ type NetTransportConfig struct

+ BindAddrs []string

+ BindPort int

+ Logger *log.Logger

+ MetricLabels []metrics.Label

+ type NoPingResponseError struct

+ func (f NoPingResponseError) Error() string

+ type Node struct

+ Addr net.IP

+ DCur uint8

+ DMax uint8

+ DMin uint8

+ Meta []byte

+ Name string

+ PCur uint8

+ PMax uint8

+ PMin uint8

+ Port uint16

+ State NodeStateType

+ func (n *Node) Address() string

+ func (n *Node) FullAddress() Address

+ func (n *Node) String() string

+ type NodeAwareTransport interface

+ DialAddressTimeout func(addr Address, timeout time.Duration) (net.Conn, error)

+ WriteToAddress func(b []byte, addr Address) (time.Time, error)

+ type NodeEvent struct

+ Event NodeEventType

+ Node *Node

+ type NodeEventType int

+ const NodeJoin

+ const NodeLeave

+ const NodeUpdate

+ type NodeStateType int

+ const StateAlive

+ const StateDead

+ const StateLeft

+ const StateSuspect

+ type Packet struct

+ Buf []byte

+ From net.Addr

+ Timestamp time.Time

+ type PingDelegate interface

+ AckPayload func() []byte

+ NotifyPingComplete func(other *Node, rtt time.Duration, payload []byte)

+ type TransmitLimitedQueue struct

+ NumNodes func() int

+ RetransmitMult int

+ func (q *TransmitLimitedQueue) GetBroadcasts(overhead, limit int) [][]byte

+ func (q *TransmitLimitedQueue) NumQueued() int

+ func (q *TransmitLimitedQueue) Prune(maxRetain int)

+ func (q *TransmitLimitedQueue) QueueBroadcast(b Broadcast)

+ func (q *TransmitLimitedQueue) Reset()

+ type Transport interface

+ DialTimeout func(addr string, timeout time.Duration) (net.Conn, error)

+ FinalAdvertiseAddr func(ip string, port int) (net.IP, int, error)

+ PacketCh func() <-chan *Packet

+ Shutdown func() error

+ StreamCh func() <-chan net.Conn

+ WriteTo func(b []byte, addr string) (time.Time, error)

+ type UniqueBroadcast interface

+ UniqueBroadcast func()

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