IPMustBeChecked return true if IPAllowed must be called

The unique identity of this broadcast message.

RemoveKey drops a key from the keyring. This will return an error if the key requested for removal is currently at position 0 (primary key).

UseKey changes the key used to encrypt messages. This is the only key used to encrypt messages, so peers should know this key before this method is ca

compressPayload takes an opaque input buffer, compresses it and wraps it in a compress{} message that is encoded.

decompressBuffer is used to decompress the buffer of a single compress message, handling multiple algorithms

encodeBroadcastNotify encodes a message and enqueues it for broadcast and notifies the given channel when transmission is finished. Fails silently if

failedRemote checks the error and decides if it indicates a failure on the other end.

gossip is invoked every GossipInterval period to broadcast our gossip messages to a few random nodes.

hasPort is given a string of the form "host", "host:port", "ipv6::address", or "[ipv6::address]:port", and returns true if the string includes a port.

installKeys will take out a lock on the keyring, and replace the keys with a new set of keys. The key indicated by primaryKey will be installed as the

Invokes nack handler if any is associated.

newMemberlist creates the network listeners. Does not schedule execution of background maintenance.

nextIncarnation returns the next incarnation number in a thread safe way

refute gossips an alive message in response to incoming information that we are suspect or dead. It will make sure the incarnation number beats the gi

resetNodes is used when the tick wraps around. It will reap the dead nodes and shuffle the node list.

resolveAddr is used to resolve the address into an address, port, and error. If no port is given, use the default

Consul bug, rapid restart (before failure detection), with an updated meta data. Should be at incarnation 1 for both. This test is uncommented becaus

setAckHandler is used to attach a handler to be invoked when an ack with a given sequence number is received. If a timeout is reached, the handler is

DialTimeout is used to create a connection that allows us to perform two-way communication with a peer. This is generally more expensive than packet c

FailNow is called when the retrying is abandoned.

GetAutoBindPort returns the bind port that was automatically given by the kernel, if a bind port of 0 was given.

GetBroadcasts is called when user data messages can be broadcast. It can return a list of buffers to send. Each buffer should assume an overhead as pr

Leave will broadcast a leave message but will not shutdown the background listeners, meaning the node will continue participating in gossip and state

LocalNode is used to return the local Node

NextOr returns true if the operation should be repeated. Otherwise, it calls fail and returns false.

NodeMeta is used to retrieve meta-data about the current node when broadcasting an alive message. It's length is limited to the given byte size. This

NotifyJoin is invoked when a node is detected to have joined. The Node argument must not be modified.

NotifyLeave is invoked when a node is detected to have left. The Node argument must not be modified.

NotifyMsg is called when a user-data message is received. Care should be taken that this method does not block, since doing so would block the entire

NotifyUpdate is invoked when a node is detected to have updated, usually involving the meta data. The Node argument must not be modified.

Ping initiates a ping to the node with the specified name.

RemoveLabelHeaderFromPacket removes any label header from the provided packet and returns it along with the remaining packet contents.

RemoveLabelHeaderFromStream removes any label header from the beginning of the stream if present and returns it along with an updated conn with that h

ScaleTimeout takes the given duration and scales it based on the current score. Less healthyness will lead to longer timeouts.

SendBestEffort uses the unreliable packet-oriented interface of the transport to target a user message at the given node (this does not use the gossip

SendReliable uses the reliable stream-oriented interface of the transport to target a user message at the given node (this does not use the gossip mec

UpdateNode is used to trigger re-advertising the local node. This is primarily used with a Delegate to support dynamic updates to the local meta data.

addItem adds the given item into the overall datastructure. You must already hold the mutex.

Check for any other alive node.

decompressPayload is used to unpack an encoded compress{} message and return its payload uncompressed

decryptRemoteState is used to help decrypt the remote state

encryptLocalState is used to help encrypt local state before sending

encryptOverhead returns the maximum possible overhead of encryption by version

ensurePort makes sure the given string has a port number on it, otherwise it appends the given port as a default.

getBroadcasts is used to return a slice of broadcasts to send up to a maximum byte size, while imposing a per-broadcast overhead. This is used to fill

mergeRemoteState is used to merge the remote state with our local state

mergeState is invoked by the network layer when we get a Push/Pull state transfer

moveDeadNodes moves dead and left nodes that that have not changed during the gossipToTheDeadTime interval to the end of the slice and returns the ind

newAwareness returns a new awareness object.

newPeekedConnFromBufferedReader will splice the buffer contents after the offset into the provided net.Conn and return the result so that the rest of

pkcs7decode is used to decode a buffer that has been padded

pkcs7encode is used to pad a byte buffer to a specific block size using the PKCS7 algorithm. "Ignores" some bytes to compensate for IV

pushPull is invoked periodically to randomly perform a complete state exchange. Used to ensure a high level of convergence, but is also reasonably exp

pushPullNode does a complete state exchange with a specific node.

queueBroadcast is like QueueBroadcast but you can use a nonzero value for the initial transmit tier assigned to the message. This is meant to be used

readRemoteState is used to read the remote state from a connection

remainingSuspicionTime takes the state variables of the suspicion timer and calculates the remaining time to wait before considering a node dead. The

sendLocalState is invoked to send our local state over a stream connection.

shuffleNodes randomly shuffles the input nodes using the Fisher-Yates shuffle

suspicionTimeout computes the timeout that should be used when a node is suspected

tcpListen is a long running goroutine that accepts incoming TCP connections and hands them off to the stream channel.

triggerFunc is used to trigger a function call each time a message is received until a stop tick arrives.

verifyProtocol verifies that all the remote nodes can speak with our nodes and vice versa on both the core protocol as well as the delegate protocol l

walkReadOnlyLocked calls f for each item in the queue traversing it in natural order (by Less) when reverse=false and the opposite when true. You must

AckPayload is invoked when an ack is being sent; the returned bytes will be appended to the ack

CheckInteg will skip a test if integration testing is not enabled.

DefaultFailer provides default retry.Run() behavior for unit tests.

DefaultWANConfig works like DefaultConfig, however it returns a configuration that is optimized for most WAN environments. The default configuration i

See NodeAwareTransport.

See NodeAwareTransport.

FinalAdvertiseAddr is given the user's configured values (which might be empty) and returns the desired IP and port to advertise to the rest of the cl