Shutdown is called when memberlist is shutting down; this gives the transport a chance to clean up any listeners.

String returns the node name

aliveNode is invoked by the network layer when we get a message about a live node.

Members returns a list of all known live nodes. The node structures returned must not be modified. If you wish to modify a Node, make a copy first.

Create will create a new Memberlist using the given configuration. This will not connect to any other node (see Join) yet, but will start all the list

BuildVsnArray creates the array of Vsn

Join is used to take an existing Memberlist and attempt to join a cluster by contacting all the given hosts and performing a state sync. Initially, th

DefaultLANConfig returns a sane set of configurations for Memberlist. It uses the hostname as the node name, and otherwise sets very conservative valu

Encode writes an encoded object to a new bytes buffer

NumQueued returns the number of queued messages

QueueBroadcast is used to enqueue a broadcast

estNumNodes is used to get the current estimate of the number of nodes

GetHealthScore returns the raw health score.

deadNode is invoked by the network layer when we get a message about a dead node

Decode reverses the encode operation on a byte slice input

for testing; emits in transmit order if reverse=false

Returns whether or not encryption is enabled

GetKeys returns the current set of keys on the ring.

Returns a byte form of the message

rawSendMsgPacket is used to send message via packet to another host without modification, other than compression or encryption if enabled.

suspectNode is invoked by the network layer when we get a message about a suspect node

Reset clears all the queued messages. Should only be used for tests.

FullAddress returns the node name and host:port form of a node's address, suitable for use with a transport.

probeNode handles a single round of failure checking on a node.

IPAllowed return an error if access to memberlist is denied

NewKeyring constructs a new container for a set of encryption keys. The keyring contains all key data used internally by memberlist. While creating a

WriteTo is a packet-oriented interface that fires off the given payload to the given address in a connectionless fashion. This should return a time st

makeCompoundMessage takes a list of messages and generates a single compound message containing all of them

rawSendMsgStream is used to stream a message to another host without modification, other than applying compression and encryption if enabled.

ParseCIDRs return a possible empty list of all Network that have been parsed In case of error, it returns succesfully parsed CIDRs and the last error

encodeAndSendMsg is used to combine the encoding and sending steps

Schedule is used to ensure the Tick is performed periodically. This function is safe to call multiple times. If the memberlist is already scheduled, t

ApplyDelta takes the given delta and applies it to the score in a thread-safe manner. It also enforces a floor of zero and a max of max, so deltas may

GetBroadcasts is used to get a number of broadcasts, up to a byte limit and applying a per-message overhead as provided.

NumMembers returns the number of alive nodes currently known. Between the time of calling this and calling Members, the number of alive nodes may have

decryptPayload is used to decrypt a message with a given key, and verify it's contents. Any padding will be removed, and a slice to the plaintext is r

Invokes an ack handler if any is associated, and reaps the handler immediately

joinHostPort returns the host:port form of an address, for use with a transport.

kRandomNodes is used to select up to k random Nodes, excluding any nodes where the exclude function returns true. It is possible that less than k node

readStream is used to read messages from a stream connection, decrypting and decompressing the stream if necessary. The provided streamLabel if prese

setAlive is used to mark this node as being alive. This is the same as if we received an alive notification our own network channel for ourself.

Confirm registers that a possibly new peer has also determined the given node is suspect. This returns true if this was new information, and false if

Finished is invoked when the message will no longer be broadcast, either due to invalidation or to the transmit limit being reached

GetPrimaryKey returns the key on the ring at position 0. This is the key used for encrypting messages, and is the first key tried for decrypting messa

NewTransport returns a new MockTransport with a unique address, wired up to talk to the other transports in the MockNetwork.

ProtocolVersion returns the protocol version currently in use by this memberlist.

decodeCompoundMessage splits a compound message and returns the slices of individual messages. Also returns the number of truncated messages and any p

encodeAndBroadcast encodes a message and enqueues it for broadcast. Fails silently if there is an encoding error.

encryptPayload is used to encrypt a message with a given key. We make use of AES-128 in GCM mode. New byte buffer is the version, nonce, ciphertext an

lenLocked returns the length of the overall queue datastructure. You must hold the mutex.

nextSeqNo returns a usable sequence number in a thread safe way

retransmitLimit computes the limit of retransmissions

sendPingAndWaitForAck makes a stream connection to the given address, sends a ping, and waits for an ack. All of this is done as a series of blocking

setProbeChannels is used to attach the ackCh to receive a message when an ack with a given sequence number is received. The `complete` field of the me

AddKey will install a new key on the ring. Adding a key to the ring will make it available for use in decryption. If the key already exists on the rin

Address returns the host:port form of a node's address, suitable for use with a transport.

Log is called for the final test output

deleteItem removes the given item from the overall datastructure. You must already hold the mutex.

encryptedLength is used to compute the buffer size needed for a message of given length

encryptionVersion returns the encryption version to use

newSuspicion returns a timer started with the max time, and that will drive to the min time after seeing k or more confirmations. The from node will b

pushPushScale is used to scale the time interval at which push/pull syncs take place. It is used to prevent network saturation as the cluster size gro

Returns a random offset between 0 and n

AddLabelHeaderToPacket prefixes outgoing packets with the correct header if the label is not empty.

AddLabelHeaderToStream prefixes outgoing streams with the correct header if the label is not empty.