firehoseclient

Documentation

Index

• type FirehoseConfig
• type FirehoseNozzle
  • func NewFirehoseNozzle(eventRouting eventRouting.EventRouting, firehoseconfig *FirehoseConfig, ...) *FirehoseNozzle
  • func (f *FirehoseNozzle) Draining(ctx context.Context)
  • func (f *FirehoseNozzle) ReadLogsBuffer(ctx context.Context)
  • func (f *FirehoseNozzle) Start(ctx context.Context)
  • func (f *FirehoseNozzle) StopReading()
• type Streamer
• type V2Adapter
  • func NewV2Adapter(s Streamer) V2Adapter
  • func (a V2Adapter) Firehose(subscriptionID string) chan *events.Envelope

Types

type FirehoseConfig

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

type FirehoseNozzle

type FirehoseNozzle struct {
	Readerrs chan error

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

func NewFirehoseNozzle

func NewFirehoseNozzle(
	eventRouting eventRouting.EventRouting,
	firehoseconfig *FirehoseConfig,
	stats *stats.Stats,
	httpClient doer,
) *FirehoseNozzle

func (*FirehoseNozzle) Draining

func (f *FirehoseNozzle) Draining(ctx context.Context)

func (*FirehoseNozzle) ReadLogsBuffer

func (f *FirehoseNozzle) ReadLogsBuffer(ctx context.Context)

func (*FirehoseNozzle) Start

func (f *FirehoseNozzle) Start(ctx context.Context)

Start consumer and reading ingest loop

func (*FirehoseNozzle) StopReading

func (f *FirehoseNozzle) StopReading()

Stop reading loop

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) Firehose

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