package
0.0.0-20250312052118-2008840fee0c
Repository: https://github.com/couchbase/indexing.git
Documentation: pkg.go.dev

# Functions

Application starts a new dataport application to receive mutations from the other end.
NewClient returns a pool of connection.
NewConnectionError makes a new connection-error map.
NewRouterEndpoint instantiate a new RouterEndpoint routine and return its reference.
NewServer creates a new dataport daemon.
ProtobufVersion return version of protobuf schema used in packet transport.

# Variables

ErrorClientEmptyKeys.
ErrorDaemonExit.
ErrorDuplicateClient.
ErrorDuplicateStreamBegin.
ErrorMissingPayload.
ErrorMissingStreamBegin.
ErrorPayload.
ErrorTransportVersion.
ErrorWorkerKilled.

# Structs

Client is an active client for each remote host, and there can be multiple connections opened with remote host for the same endpoint.
No description provided by the author
RouterEndpoint structure, per topic, to gather key-versions / mutations from one or more vbuckets and push them downstream to a specific node.
Server handles an active dataport server of mutation for all vbuckets.

# Type aliases

ConnectionError to application.