ForkAdapter creates a copy of the adapter with auto-naming (_copy_N suffix).

ForkedAdapterNeedsReview returns true when the built-in adapter that a fork was created from has been updated since the fork was made.

NewCircuitBreakerManager creates a new circuit breaker manager.

NewTestStoreWith returns a Store pre-loaded with the given key-value pairs.

PruneOrphanPrefixes deletes dictionary prefixes no longer referenced by any catalog entry. Run after a feed resync (outside its transaction): resync r

PurgeUserSnapshots deletes user snapshots older than N days, keeping the newest record just outside the window for graph continuity.

Serialize encodes the NOTIFICATION message to wire format including header.

Serialize encodes the Large Communities path attribute value (RFC 8092).

SetUserCatalogModeTx sets a user's catalog_mode_id within an existing transaction, so callers that also need to persist selection changes in the same

WithContext creates a new context with the logger embedded

WithLogger adds a logger to the context

WithRequestID returns a new logger with request ID added to all logs

WithRequestIDContext creates a new context with request ID

addFeedTx inserts a feeds row within an existing transaction, shared by AddFeed and AddFeedWithMode.

allowRequest checks if a request should be allowed.

apiModeCommunitiesGenerate handles POST /api/admin/modes/{id}/communities/generate.

--- Mode-Feed assignment handlers --- apiModeFeedsGet handles GET /api/admin/modes/{id}/feeds.

--- Mode CRUD handlers --- apiModesList handles GET /api/admin/modes.

apiModesUpdate handles PUT /api/admin/modes/{id}.

apiUserCredentialsList handles GET /api/admin/users/{id}/credentials.

apiUserPeerState handles GET /api/admin/users/{id}/peer-state.

apiUsersDelete handles DELETE /api/admin/users/{id}.

apiUsersNormalizeNetworks handles POST /api/admin/users/normalize-networks. Given a raw list of CIDRs, returns the minimal equivalent set — masked, de

applyListenerMD5 sets TCP MD5 keys on the listener socket for all configured peers that have passwords. This must be called before accepting connectio

applyRouteFiltersToPrefixes applies route filters to prefixes without database queries

backupTimestamp extracts the sortable timestamp suffix from a backup filename ({prefix}_r{rev}_{timestamp}.js), so files can be ordered chronologicall

buildSockaddrStorage builds a SockaddrStorage for the given address, using the specified socket address family (AF_INET or AF_INET6). Dual-stack IPv6

buildVersion31DB creates a database migrated through version 31 (the last text-based catalog schema) with representative catalog, selection, and commu

clearCSRFCookie removes the CSRF cookie, mirroring session logout.

countFilteredPrefixes applies the user's effective route filters to the prefixes and counts the IPv4/IPv6 survivors.

dbEnvKeys exposes the storage/env keys for internal introspection only (see TestNoSettingIsBothDBAndEnvInaccessible) — a setting with both empty would

decodeStoredAddr renders a stored address BLOB as text; nil (SQL NULL) becomes "".

encodeAddrArg converts a textual IP to its stored BLOB form for use as a query argument.

encodeUserAddrs converts a user's textual peer_ip/next_hop to their stored BLOB forms; an empty next_hop becomes nil (SQL NULL).

findFirstFree returns the first integer >= start that is not in used.

findFirstFree returns the first integer >= start that is not in used.

fireCallbacks invokes all registered callbacks with the given value.

fireCallbacks invokes all registered callbacks with the given value.

genCommunitiesRuntime generates communities using catalog_mode_feeds (post-migration-20). Used by GenerateCommunities during normal runtime operation.

getsocketFamily returns the address family (AF_INET or AF_INET6) of the socket.

hasEstablishedConn reports whether the peer has any BGP session in progress (CONNECT/OPENSENT/OPENCONFIRM/ESTABLISHED). Used to prevent duplicate sess

keepaliveLoop sends periodic keepalive messages on conn at the configured interval (holdTime/3). Exits when the stop channel is closed or a write fail

lower returns lowercase string.

mergedAllowedHosts merges the adapter's declared additional hosts with user-provided ones. Must be called before opening a transaction: it queries s.D

normalizeWithTrie uses a binary trie for O(m) containment checks

peerPort returns the destination port for a peer connection. Dynamic peers (0.0.0.0/::) are passive-only: Port=-1 prevents active dialing. When active

portFilePath returns where the HTTP listen port is recorded so that a separate `wdbgp healthcheck` invocation can find it. It lives next to the databa

queryPrefixes runs a query returning (ip BLOB, bits) rows and decodes them, skipping default routes (a feed-provided default route is never a useful s

recordResult records the result of an operation.

resolveCommunityKey maps a (category, service) name pair to dictionary ids, creating dictionary rows as needed. service="" resolves to the group-level

skipRemainingItemsForConstraint consumes all items in a default rule until srsItemFinal. Used when we encounter an unparseable item (like domain match