nozzle

Documentation

Index

• type AuthTokenFetcher
• type Nozzle
  • func NewNozzle(config *config.Config, tokenFetcher AuthTokenFetcher, log *gosteno.Logger) *Nozzle
  • func (n *Nozzle) AlertSlowConsumerError()
  • func (n *Nozzle) ResetSlowConsumerError()
  • func (n *Nozzle) Start() error
  • func (n *Nozzle) Stop()

Types

type AuthTokenFetcher

type AuthTokenFetcher interface {
	FetchAuthToken() string
}

AuthTokenFetcher is an interface for fetching an auth token from uaa

type Nozzle

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

Nozzle is the struct that holds the state of the nozzle

func NewNozzle

func NewNozzle(config *config.Config, tokenFetcher AuthTokenFetcher, log *gosteno.Logger) *Nozzle

NewNozzle creates a new nozzle

func (*Nozzle) AlertSlowConsumerError

func (n *Nozzle) AlertSlowConsumerError()

AlertSlowConsumerError sets the slow consumer alert

func (*Nozzle) ResetSlowConsumerError

func (n *Nozzle) ResetSlowConsumerError()

ResetSlowConsumerError resets the alert

func (*Nozzle) Start

func (n *Nozzle) Start() error

Start starts the nozzle

func (*Nozzle) Stop

func (n *Nozzle) Stop()

Stop stops the Nozzle