firehoseclient

type FirehoseConfig struct {
	RLPAddr                string
	InsecureSSLSkipVerify  bool
	FirehoseSubscriptionID string
	BufferSize             int
}

type FirehoseNozzle struct {
	Readerrs chan error

	Stats *stats.Stats
	// contains filtered or unexported fields
}

type Streamer interface {
	Stream(ctx context.Context, req *loggregator_v2.EgressBatchRequest) loggregator.EnvelopeStream
}

type V2Adapter struct {
	// contains filtered or unexported fields
}