firehoseclient

Documentation

Index

• type CfClientTokenRefresh
  • func (ct *CfClientTokenRefresh) RefreshAuthToken() (string, error)
• type FirehoseConfig
• type FirehoseNozzle
  • func NewFirehoseNozzle(cfClient *cfclient.Client, eventRouting *eventRouting.EventRouting, ...) *FirehoseNozzle
  • func (f *FirehoseNozzle) ResetCfClient()
  • func (f *FirehoseNozzle) Start() error

Types

type CfClientTokenRefresh

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

func (*CfClientTokenRefresh) RefreshAuthToken

func (ct *CfClientTokenRefresh) RefreshAuthToken() (string, error)

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(cfClient *cfclient.Client, eventRouting *eventRouting.EventRouting, firehoseconfig *FirehoseConfig) *FirehoseNozzle

func (*FirehoseNozzle) ResetCfClient

func (f *FirehoseNozzle) ResetCfClient()

func (*FirehoseNozzle) Start

func (f *FirehoseNozzle) Start() error