events

Documentation

Index

• type AppEvent
• type Fetcher
  • func NewFetcher(config *FetcherConfig, appEventChan chan *AppEvent, ...) *Fetcher
  • func (m *Fetcher) RefreshAuthToken() (token string, authError error)
  • func (m *Fetcher) Run() error
• type FetcherConfig
• type FetcherProcess

Types

type AppEvent

type AppEvent struct {
	Envelope *events.Envelope
	App      cfclient.App
}

type Fetcher

type Fetcher struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewFetcher

func NewFetcher(
	config *FetcherConfig,
	appEventChan chan *AppEvent,
	newAppInstanceChan chan string,
	deletedAppInstanceChan chan string,
	errorChan chan error,
) *Fetcher

func (*Fetcher) RefreshAuthToken

func (m *Fetcher) RefreshAuthToken() (token string, authError error)

RefreshAuthToken satisfies the `consumer.TokenRefresher` interface.

func (*Fetcher) Run

func (m *Fetcher) Run() error

type FetcherConfig

type FetcherConfig struct {
	CFClientConfig  *cfclient.Config
	EventTypes      []sonde_events.Envelope_EventType
	UpdateFrequency time.Duration
}

type FetcherProcess

type FetcherProcess interface {
	Run() error
}