lb.cluster.gossip — org.clojars.pgdad/clj-ebpf-lb 0.10.2

Gossip protocol implementation for state synchronization.

Uses UDP for small messages (<1KB) and TCP for larger payloads. Implements push-pull anti-entropy for eventual consistency.

apply-remote-states! clj

(apply-remote-states! states)

Apply received remote states to appropriate providers.

broadcast-message! clj

(broadcast-message! msg)

Broadcast a message to all alive peers.

broadcast-state-change! clj

(broadcast-state-change! state)

Immediately broadcast a state change to peers.

broadcast-states! clj

(broadcast-states! states)

Broadcast multiple state changes to peers.

configure! clj

(configure! new-config)

Update gossip configuration.

default-config clj

Default gossip configuration.

get-all-sync-states clj

(get-all-sync-states)

Get all syncable states from all providers.

get-state-digest clj

(get-state-digest)

Get combined state digest from all providers.

get-state-providers clj

(get-state-providers)

Get all registered state providers.

gossip-stats clj

(gossip-stats)

Get gossip statistics.

gossip-to-random! clj

(gossip-to-random! msg)

Gossip a message to random subset of peers.

register-state-provider! clj

(register-state-provider! provider)

Register a state provider for synchronization.

running? clj

(running?)

Check if gossip transport is running.

send-message! clj

(send-message! address msg)

Send a gossip message to a peer. Uses UDP for small messages, TCP for large.

start! clj

(start!)

Start the gossip transport.

stop! clj

(stop!)

Stop the gossip transport.

unregister-state-provider! clj

(unregister-state-provider! type)

Unregister a state provider.