NewEgressServer is the constructor for EgressServer.

NewPubSub is the constructor for PubSub.

NewRepeater is the constructor for Repeater.

WithRand allows for configuration of the random number generator.

EgressServer implements the loggregator_v2.EgressServer interface.

PubSub provides a means for callers to subscribe to envelope streams.

Repeater connects a reader to a writer.

DataSetter accepts writes of v2.Envelopes TODO: This could be a named function.

HealthRegistrar describes the health interface for keeping track of various values.

MetricClient creates new CounterMetrics to be emitted periodically.

Subscriber registers stream DataSetters to accept reads.

PubSubOption allows for configuration of the PubSub.

Reader reads envelopes.

Writer writes envelopes.