firehosenozzle

Documentation

Index

• type FirehoseNozzle
  • func New(url string, skipSSLValidation bool, subscriptionID string, ...) *FirehoseNozzle
  • func (n *FirehoseNozzle) Start() error

Types

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,
	authTokenRefresher consumer.TokenRefresher,
	metricsStore *metrics.Store,
) *FirehoseNozzle

func (*FirehoseNozzle) Start

func (n *FirehoseNozzle) Start() error