firehoseclient

Documentation

Index

• type FirehoseConfig
• type FirehoseNozzle
  • func NewFirehoseNozzle(uaaR *uaatokenrefresher.UAATokenRefresher, ...) *FirehoseNozzle
  • func (f *FirehoseNozzle) Start() error

Types

type FirehoseConfig

type FirehoseConfig struct {
	TrafficControllerURL   string
	InsecureSSLSkipVerify  bool
	IdleTimeoutSeconds     time.Duration
	FirehoseSubscriptionID string
}

type FirehoseNozzle

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

func NewFirehoseNozzle

func NewFirehoseNozzle(uaaR *uaatokenrefresher.UAATokenRefresher, eventRouting eventRouting.EventRouting, firehoseconfig *FirehoseConfig) *FirehoseNozzle

func (*FirehoseNozzle) Start

func (f *FirehoseNozzle) Start() error