firehosenozzle

Documentation

Index

• type DebugPrinter
  • func (dp DebugPrinter) Print(title, dump string)
• type FirehoseNozzle
  • func New(url string, skipSSLValidation bool, subscriptionID string, ...) *FirehoseNozzle
  • func (n *FirehoseNozzle) Start()

Types

type DebugPrinter

type DebugPrinter struct{}

func (DebugPrinter) Print

func (dp DebugPrinter) Print(title, dump string)

type FirehoseNozzle

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

func New

func New(
	url string,
	skipSSLValidation bool,
	subscriptionID string,
	idleTimeout time.Duration,
	minRetryDelay time.Duration,
	maxRetryDelay time.Duration,
	maxRetryCount int,
	authTokenRefresher consumer.TokenRefresher,
	metricsStore *metrics.Store,
) *FirehoseNozzle

func (*FirehoseNozzle) Start

func (n *FirehoseNozzle) Start()

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