Package combined implements a dispatcher that combines caching, redispatching and optional cluster dispatching.

Code generated by github.com/ecordell/optgen.

AddResponseMetadata adds the metadata found in the incoming metadata to the existing metadata, *modifying it in place*.

CheckDepth returns ErrMaxDepth if there is insufficient depth remaining to dispatch.

NewCollectingDispatchStream creates a new CollectingDispatchStream.

NewHandlingDispatchStream returns a new handling dispatch stream.

NewMaxDepthExceededError creates a new MaxDepthExceededError.

StreamWithContext returns the given dispatch stream, wrapped to return the given context.

WrapGRPCStream wraps a gRPC result stream with a concurrent-safe dispatch stream.

CollectingDispatchStream is a dispatch stream that collects results in memory.

CountingDispatchStream is a dispatch stream that counts the number of items published.

HandlingDispatchStream is a dispatch stream that executes a handler for each item published.

MaxDepthExceededError is an error returned when the maximum depth for dispatching has been exceeded.

ReadyState represents the ready state of the dispatcher.

WrappedDispatchStream is a dispatch stream that wraps another dispatch stream, and performs an operation on each result before puppeting back up to the parent stream.

Check interface describes just the methods required to dispatch check requests.

DispatchableRequest is an interface for requests.

Dispatcher interface describes a method for passing subchecks off to additional machines.

Expand interface describes just the methods required to dispatch expand requests.

LookupSubjects interface describes just the methods required to dispatch lookup subjects requests.

Stream defines the interface generically matching a streaming dispatch response.