memberlist

package module

Go to main page

Versions in this module

v0

v0.3.3

Aug 20, 2020

v0.3.1

Aug 20, 2020

v0.3.0

Aug 20, 2020

v0.2.5

Aug 20, 2020

v0.2.4

Aug 20, 2020

v0.2.3

Aug 18, 2020

Changes in this version

+ func LogStringAddress(addr string) string

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

+ type Address struct

+ Addr string

+ Name string

+ func (a *Address) String() string

type Config

+ CIDRsAllowed []net.IPNet

+ DeadNodeReclaimTime time.Duration

+ DisableTcpPingsForNode func(nodeName string) bool

+ GossipVerifyIncoming bool

+ GossipVerifyOutgoing bool

+ RequireNodeNames bool

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

+ func (c *Config) IPMustBeChecked() bool

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

+ type IngestionAwareTransport interface

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

+ IngestStream func(conn net.Conn) error

type Memberlist

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

type MockTransport

+ func (t *MockTransport) DialAddressTimeout(a Address, timeout time.Duration) (net.Conn, 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) WriteToAddress(b []byte, a Address) (time.Time, error)

+ type NamedBroadcast interface

+ Name func() string

type NetTransport

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

+ 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) WriteToAddress(b []byte, a Address) (time.Time, error)

type Node

+ State NodeStateType

+ 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 NodeStateType int

+ const StateAlive

+ const StateDead

+ const StateLeft

+ const StateSuspect

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

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