Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

memberlist

package module

Go to main page

Versions in this module

v0

v0.1.6

Feb 21, 2021

Changes in this version

type Config

+ DeadNodeReclaimTime time.Duration

+ GossipVerifyIncoming bool

+ GossipVerifyOutgoing bool

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

+ type NamedBroadcast interface

+ Name func() string

type Node

+ func (n *Node) String() string

+ type UniqueBroadcast interface

+ UniqueBroadcast func()

v0.1.0

Apr 13, 2017

Changes in this version

+ const MetaMaxSize

+ const ProtocolVersion2Compatible

+ const ProtocolVersionMax

+ const ProtocolVersionMin

+ func LogAddress(addr net.Addr) string

+ func LogConn(conn net.Conn) string

+ func ValidateKey(key []byte) error

+ 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

+ Conflict ConflictDelegate

+ DNSConfigPath string

+ Delegate Delegate

+ DelegateProtocolMax uint8

+ DelegateProtocolMin uint8

+ DelegateProtocolVersion uint8

+ DisableTcpPings bool

+ EnableCompression bool

+ Events EventDelegate

+ GossipInterval time.Duration

+ GossipNodes int

+ GossipToTheDeadTime time.Duration

+ HandoffQueueDepth int

+ IndirectChecks int

+ Keyring *Keyring

+ LogOutput io.Writer

+ Logger *log.Logger

+ Merge MergeDelegate

+ Name string

+ Ping PingDelegate

+ ProbeInterval time.Duration

+ ProbeTimeout time.Duration

+ ProtocolVersion uint8

+ PushPullInterval time.Duration

+ RetransmitMult int

+ SecretKey []byte

+ 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

+ 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 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) 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() *MockTransport

+ type MockTransport struct

+ 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) 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)

+ type NetTransport struct

+ func NewNetTransport(config *NetTransportConfig) (*NetTransport, 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) 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)

+ type NetTransportConfig struct

+ BindAddrs []string

+ BindPort int

+ Logger *log.Logger

+ 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

+ func (n *Node) Address() string

+ type NodeEvent struct

+ Event NodeEventType

+ Node *Node

+ type NodeEventType int

+ const NodeJoin

+ const NodeLeave

+ const NodeUpdate

+ 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)

JackTT - Gopher 🇻🇳