Invalidates checks if enqueuing the current broadcast invalidates a previous broadcast

IsInteg returns a boolean telling you if we're in integ testing mode.

Less tests whether the current item is less than the given argument. This must provide a strict weak ordering. If !a.Less(b) && !b.Less(a), we treat

LocalState is used for a TCP Push/Pull. This is sent to the remote side in addition to the membership information. Any data can be sent here. See Merg

MergeRemoteState is invoked after a TCP Push/Pull. This is the state received from the remote side and is the result of the remote side's LocalState c

NewNetTransport returns a net transport with the given configuration. On success all the network listeners will be created and listening.

NotifyAlive is invoked when a message about a live node is received from the network. Returning a non-nil error prevents the node from being consider

NotifyConflict is invoked when a name conflict is detected

NotifyMerge is invoked when a merge could take place. Provides a list of the nodes known by the peer. If the return value is non-nil, the merge is can

NotifyPing is invoked when an ack for a ping is received

PacketCh returns a channel that can be read to receive incoming packets from other peers. How this is set up for listening is left as an exercise for

Prune will retain the maxRetain latest messages, and the rest will be discarded. This can be used to prevent unbounded queue sizes

Deprecated: SendTo is deprecated in favor of SendBestEffort, which requires a node to target. If you don't have a node then use SendToAddress.

Deprecated: SendToTCP is deprecated in favor of SendReliable.

Deprecated: SendToUDP is deprecated in favor of SendBestEffort.

See Transport.

StreamCh returns a channel that can be read to handle incoming stream connections from other peers. How this is set up for listening is left as an exe

See net.Addr.

ValidateKey will check to see if the key is valid and returns an error if not. key should be either 16, 24, or 32 bytes to select AES-128, AES-192, o

See NodeAwareTransport.

See NodeAwareTransport.

checkBroadcastQueueDepth periodically checks the size of the broadcast queue to see if it is too large

decryptMessage performs the actual decryption of ciphertext. This is in its own function to allow it to be called on all keys easily.

Deschedule is used to stop the background maintenance. This is safe to call multiple times.

ensureCanConnect return the IP from a RemoteAddress return error if this client must not connect

getNextMessage returns the next message to process in priority order, using LIFO

getTransmitRange returns a pair of min/max values for transmit values represented by the current queue contents. Both values represent actual transmit

handleCompressed is used to unpack a compressed message

handleConn handles a single incoming stream connection from the transport.

handleUser is used to notify channels of incoming user data

Init allocates substructures

lazyInit initializes internal data structures the first time they are needed. You must already hold the mutex.

makeCompoundMessages takes a list of messages and packs them into one or multiple messages based on the limitations of compound messages (255 messages

packetHandler is a long running goroutine that processes messages received over the packet interface, but is decoupled from the listener to avoid bloc

packetListen is a long running goroutine that pulls packets out of the transport and hands them off for processing.

Tick is used to perform a single round of failure detection and gossip

probeNodeByAddr just safely calls probeNode given only the address of the node (for tests)

pushPullTrigger is used to periodically trigger a push/pull until a stop tick arrives. We don't use triggerFunc since the push/pull timer is dynamical

queueBroadcast is used to start dissemination of a message. It will be sent up to a configured number of times. The message could potentially be inval

readUserMsg is used to decode a userMsg from a stream.

sendAndReceiveState is used to initiate a push/pull over a stream with a remote host.

sendMsg is used to send a message via packet to another host. It will opportunistically create a compoundMsg and piggy back other broadcasts.

sendUserMsg is used to stream a user message to another host.

setUDPRecvBuf is used to resize the UDP receive window. The function attempts to set the read buffer to `udpRecvBuf` but backs off until the read buff

skipIncarnation adds the positive offset to the incarnation number.

streamListen is a long running goroutine that pulls incoming streams from the transport and hands them off for processing.

tcpLookupIP is a helper to initiate a TCP-based DNS lookup for the given host. The built-in Go resolver will do a UDP lookup first, and will only use

udpListen is a long running goroutine that accepts incoming UDP packets and hands them off to the packet channel.

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

DefaultLocalConfig works like DefaultConfig, however it returns a configuration that is optimized for a local loopback environments. The default confi

See Transport.

See Transport.

See Transport.

See Transport.

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

GetHealthScore gives this instance's idea of how well it is meeting the soft real-time requirements of the protocol. Lower numbers are better, and zer

See NodeAwareTransport.

See IngestionAwareTransport.

See NodeAwareTransport.

See IngestionAwareTransport.

memberlist.NamedBroadcast optional interface

See net.Addr.

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