fetchers

Documentation

Index

• type CumulativeInstanceData
• type CumulativeUsageFetcher
  • func NewCumulativeUsageFetcher(logCacheClient LogCacheClient) CumulativeUsageFetcher
  • func (f CumulativeUsageFetcher) FetchInstanceData(appGuid string, appInstances map[int]cf.Instance) (map[int]interface{}, error)
• type CurrentInstanceData
• type CurrentUsageFetcher
  • func NewCurrentUsageFetcher(client LogCacheClient) CurrentUsageFetcher
  • func NewCurrentUsageFetcherWithFallbackFetcher(client LogCacheClient, fallbackFetcher Fetcher) CurrentUsageFetcher
  • func (f CurrentUsageFetcher) FetchInstanceData(appGUID string, appInstances map[int]cf.Instance) (map[int]interface{}, error)
• type Fetcher
• type LastSpikeFetcher
  • func NewLastSpikeFetcher(client LogCacheClient, since time.Time) *LastSpikeFetcher
  • func (f LastSpikeFetcher) FetchInstanceData(appGUID string, appInstances map[int]cf.Instance) (map[int]interface{}, error)
• type LastSpikeInstanceData
• type LogCacheClient
• type ProcessInstanceIDFetcher
  • func NewProcessInstanceIDFetcher(client LogCacheClient) ProcessInstanceIDFetcher
  • func NewProcessInstanceIDFetcherWithLimit(client LogCacheClient, limit int) ProcessInstanceIDFetcher
  • func (f ProcessInstanceIDFetcher) Fetch(appGUID string) (map[int]string, error)

Types

type CumulativeInstanceData

type CumulativeInstanceData struct {
	InstanceID int
	Usage      float64
}

type CumulativeUsageFetcher

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

func NewCumulativeUsageFetcher

func NewCumulativeUsageFetcher(logCacheClient LogCacheClient) CumulativeUsageFetcher

func (CumulativeUsageFetcher) FetchInstanceData

func (f CumulativeUsageFetcher) FetchInstanceData(appGuid string, appInstances map[int]cf.Instance) (map[int]interface{}, error)

type CurrentInstanceData

type CurrentInstanceData struct {
	InstanceID int
	Usage      float64
}

type CurrentUsageFetcher

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

func NewCurrentUsageFetcher

func NewCurrentUsageFetcher(client LogCacheClient) CurrentUsageFetcher

func NewCurrentUsageFetcherWithFallbackFetcher

func NewCurrentUsageFetcherWithFallbackFetcher(client LogCacheClient, fallbackFetcher Fetcher) CurrentUsageFetcher

func (CurrentUsageFetcher) FetchInstanceData

func (f CurrentUsageFetcher) FetchInstanceData(appGUID string, appInstances map[int]cf.Instance) (map[int]interface{}, error)

type Fetcher

type Fetcher interface {
	FetchInstanceData(appGUID string, appInstances map[int]cf.Instance) (map[int]interface{}, error)
}

type LastSpikeFetcher

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

func NewLastSpikeFetcher

func NewLastSpikeFetcher(client LogCacheClient, since time.Time) *LastSpikeFetcher

func (LastSpikeFetcher) FetchInstanceData

func (f LastSpikeFetcher) FetchInstanceData(appGUID string, appInstances map[int]cf.Instance) (map[int]interface{}, error)

type LastSpikeInstanceData

type LastSpikeInstanceData struct {
	InstanceID int
	From       time.Time
	To         time.Time
}

type LogCacheClient

type LogCacheClient interface {
	Read(ctx context.Context, sourceID string, start time.Time, opts ...logcache.ReadOption) ([]*loggregator_v2.Envelope, error)
	PromQL(ctx context.Context, query string, opts ...logcache.PromQLOption) (*logcache_v1.PromQL_InstantQueryResult, error)
	PromQLRange(ctx context.Context, query string, opts ...logcache.PromQLOption) (*logcache_v1.PromQL_RangeQueryResult, error)
}

type ProcessInstanceIDFetcher

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

func NewProcessInstanceIDFetcher

func NewProcessInstanceIDFetcher(client LogCacheClient) ProcessInstanceIDFetcher

func NewProcessInstanceIDFetcherWithLimit

func NewProcessInstanceIDFetcherWithLimit(client LogCacheClient, limit int) ProcessInstanceIDFetcher

func (ProcessInstanceIDFetcher) Fetch

func (f ProcessInstanceIDFetcher) Fetch(appGUID string) (map[int]string, error)