influxdbfirehosenozzle

Documentation

Index

• type AuthTokenFetcher
• type InfluxDbFirehoseNozzle
  • func NewInfluxDbFirehoseNozzle(config *nozzleconfig.NozzleConfig, tokenFetcher AuthTokenFetcher, ...) *InfluxDbFirehoseNozzle
  • func (d *InfluxDbFirehoseNozzle) Start() error

Types

type AuthTokenFetcher

type AuthTokenFetcher interface {
	FetchAuthToken() string
}

type InfluxDbFirehoseNozzle

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

func NewInfluxDbFirehoseNozzle

func NewInfluxDbFirehoseNozzle(config *nozzleconfig.NozzleConfig, tokenFetcher AuthTokenFetcher, log *gosteno.Logger, appinfo map[string]cfinstanceinfoapi.AppInfo) *InfluxDbFirehoseNozzle

func (*InfluxDbFirehoseNozzle) Start

func (d *InfluxDbFirehoseNozzle) Start() error