NewBatchedIngressClient returns a new BatchedIngressClient.

NewEgressReverseProxy returns a new EgressReverseProxy.

NewIngressReverseProxy returns a new IngressReverseProxy.

NewLocalStoreReader creates and returns a new LocalStoreReader.

NewOrchestratorAgent returns a new OrchestratorAgent.

NewRoutingTable returns a new RoutingTable.

NewStaticLookup creates and returns a StaticLookup.

WithMetaCacheDuration is a EgressReverseProxyOption to configure how long to cache results from the Meta endpoint.

BatchedIngressClient batches envelopes before sending it.

EgressReverseProxy is a reverse proxy for Egress requests.

IngressReverseProxy is a reverse proxy for Ingress requests.

LocalStoreReader accesses a store via gRPC calls.

OrchestratorAgent manages the Log Cache node's routes.

RoutingTable makes decisions for where a item should be routed.

StaticLookup is used to do lookup for static routes.

StoreReader proxies to the log cache for getting envelopes or Log Cache Metadata.

IngressClientFunc transforms a function into an IngressClient.

Lookup is used to find which Clients a source ID should be routed to.