Liking cljdoc? Tell your friends :D

lb.cluster.conntrack

Connection tracking synchronization for seamless failover.

This namespace implements connection state replication across cluster nodes:

  • Owner node tracks connections where first packet arrived
  • Shadow entries stored on non-owner nodes for failover
  • On node failure, shadow entries promoted to active BPF entries

Sync Strategy:

  • Batch updates for efficiency (every 100ms or 100 connections)
  • Delta sync: only changed entries since last gossip
  • Full sync on node join via push-pull
  • Conservative: shadow entries don't affect routing until failover
Connection tracking synchronization for seamless failover.

This namespace implements connection state replication across cluster nodes:
- Owner node tracks connections where first packet arrived
- Shadow entries stored on non-owner nodes for failover
- On node failure, shadow entries promoted to active BPF entries

Sync Strategy:
- Batch updates for efficiency (every 100ms or 100 connections)
- Delta sync: only changed entries since last gossip
- Full sync on node join via push-pull
- Conservative: shadow entries don't affect routing until failover
raw docstring

create-conntrack-providerclj

(create-conntrack-provider)

Create a conntrack state provider for cluster sync.

Create a conntrack state provider for cluster sync.
sourceraw docstring

default-configclj

Default conntrack sync configuration.

Default conntrack sync configuration.
sourceraw docstring

force-full-sync!clj

(force-full-sync!)

Force a full sync of all local connections to the cluster.

Force a full sync of all local connections to the cluster.
sourceraw docstring

on-connection-created!clj

(on-connection-created! conn)

Called when a new connection is created locally. Queues the connection for sync to cluster.

Called when a new connection is created locally.
Queues the connection for sync to cluster.
sourceraw docstring

on-connection-deleted!clj

(on-connection-deleted! conn)

Called when a connection is deleted locally. Queues the deletion for sync to cluster.

Called when a connection is deleted locally.
Queues the deletion for sync to cluster.
sourceraw docstring

promote-all-shadows!clj

(promote-all-shadows!)

Manually promote all shadow connections to active BPF entries. Use with caution - may cause duplicate connections.

Manually promote all shadow connections to active BPF entries.
Use with caution - may cause duplicate connections.
sourceraw docstring

running?clj

(running?)

Check if conntrack sync is running.

Check if conntrack sync is running.
sourceraw docstring

start!clj

(start! conntrack-map & {:as opts})

Start conntrack synchronization.

Args:

  • conntrack-map: BPF conntrack map reference
  • opts: Configuration options (see default-config)
Start conntrack synchronization.

Args:
- conntrack-map: BPF conntrack map reference
- opts: Configuration options (see default-config)
sourceraw docstring

stop!clj

(stop!)

Stop conntrack synchronization.

Stop conntrack synchronization.
sourceraw docstring

sync-statsclj

(sync-stats)

Get conntrack sync statistics.

Get conntrack sync statistics.
sourceraw docstring

cljdoc builds & hosts documentation for Clojure/Script libraries

Keyboard shortcuts
Ctrl+kJump to recent docs
Move to previous article
Move to next article
Ctrl+/Jump to the search field
× close