firehoseclient

package
v0.0.0-...-232336a Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 8, 2018 License: MIT Imports: 14 Imported by: 9

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL