firehoseclient

Documentation

Index

• type FirehoseConfig
• type FirehoseNozzle
  • func NewFirehoseNozzle(uaaR *uaatokenrefresher.UAATokenRefresher, ...) *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()

Types

type FirehoseConfig

type FirehoseConfig struct {
	MinRetryDelay          time.Duration
	MaxRetryDelay          time.Duration
	MaxRetryCount          int
	TrafficControllerURL   string
	InsecureSSLSkipVerify  bool
	IdleTimeoutSeconds     time.Duration
	FirehoseSubscriptionID string
	BufferSize             int
}

type FirehoseNozzle

type FirehoseNozzle struct {
	Readerrs chan error

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

func NewFirehoseNozzle

func NewFirehoseNozzle(uaaR *uaatokenrefresher.UAATokenRefresher,
	eventRouting eventRouting.EventRouting,
	firehoseconfig *FirehoseConfig,
	stats *stats.Stats) *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