logstream

Documentation

Index

• type LogStream
  • func New(url string, skipSSLValidation bool, subscriptionID string, ...) *LogStream
  • func (n *LogStream) Start()
• type Streamer
• type V2Adapter
  • func NewV2Adapter(s Streamer) *V2Adapter
  • func (a *V2Adapter) Close()
  • func (a *V2Adapter) Firehose(subscriptionID string) chan *events.Envelope

Types

type LogStream

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

func New

func New(
	url string,
	skipSSLValidation bool,
	subscriptionID string,
	metricsStore *metrics.Store,
	httpClient doer,
) *LogStream

func (*LogStream) Start

func (n *LogStream) Start()

Start processes both errors and messages until both channels are closed It then closes the underlying consumer.

type Streamer

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

type V2Adapter

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

func NewV2Adapter

func NewV2Adapter(s Streamer) *V2Adapter

func (*V2Adapter) Close

func (a *V2Adapter) Close()

func (*V2Adapter) Firehose

func (a *V2Adapter) Firehose(subscriptionID string) chan *events.Envelope