collector

type AppGUID ¶

type AppGUID string

AppGUID represets an application GUID.

type AppInfo ¶

type AppInfo struct {
	Name  string
	Space string
	Org   string
}

AppInfo holds the names of an application, space, and organization.

func (a AppInfo) String() string

type AppInfoStore ¶

type AppInfoStore interface {
	Lookup(guids []string) (map[AppGUID]AppInfo, error)
}

AppInfoStore provides a way to find AppInfo for an app GUID.

type Authenticator ¶

type Authenticator interface {
	RefreshAuthToken() (string, error)
}

Authenticator is used to refresh the authentication token.

type CachedAppInfoStore ¶

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

CachedAppInfoStore caches app info lookups against the APIStore.

func NewCachedAppInfoStore(s AppInfoStore, opts ...CachedAppInfoStoreOption) *CachedAppInfoStore

func (c *CachedAppInfoStore) Lookup(guids []string) (map[AppGUID]AppInfo, error)

type CachedAppInfoStoreOption ¶

type CachedAppInfoStoreOption func(*CachedAppInfoStore)

func WithCacheTTL(cacheTTL time.Duration) CachedAppInfoStoreOption

type Collector ¶

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

Collector handles fetch rates form multiple nozzles and summing their rates.

func New(
	nozzles []string,
	auth Authenticator,
	nozzleAppGUID string,
	store AppInfoStore,
	opts ...CollectorOption,
) *Collector

func (c *Collector) BuildPoints(timestamp int64) ([]datadog.Point, error)

func (c *Collector) Rate(timestamp int64) (store.Rate, error)

type CollectorOption ¶

type CollectorOption func(c *Collector)

CollectorOption is a type of func that can be used for optional configuration settings for the Collector.

func WithHTTPClient(client *http.Client) CollectorOption

func WithReportLimit(n int) CollectorOption

type GUIDIndex ¶

type GUIDIndex string

GUIDIndex is a concatentation of GUID and instance index in the format some-guid/some-index, e.g., 7b8228a0-cf40-42d8-a7bb-b287a88198a3/0

func (g GUIDIndex) GUID() string

func (g GUIDIndex) Index() string

type HTTPAppInfoStore ¶

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

HTTPAppInfoStore provides a focused source of Cloud Controller API data.

func NewHTTPAppInfoStore(
	apiAddr string,
	client HTTPClient,
	auth Authenticator,
) *HTTPAppInfoStore

func (s *HTTPAppInfoStore) Lookup(guids []string) (map[AppGUID]AppInfo, error)

type HTTPClient ¶

type HTTPClient interface {
	Do(*http.Request) (*http.Response, error)
}

HTTPClient supports HTTP requests.

type V2Resource ¶

type V2Resource struct {
	Metadata struct {
		GUID string `json:"guid"`
	} `json:"metadata"`

	Entity struct {
		Name string `json:"name"`
	} `json:"entity"`
}

V2Resource represents a single V2 API resource

type V2Response ¶

type V2Response struct {
	Resources []V2Resource `json:"resources"`
}

V2Response represents a list of V2 API resources.

type V3Relationship ¶

type V3Relationship struct {
	Data struct {
		GUID string `json:"guid"`
	} `json:"data"`
}

V3Relationship represents a V3 API resource relationship.

type V3Resource ¶

type V3Resource struct {
	GUID          string                    `json:"guid"`
	Name          string                    `json:"name"`
	Relationships map[string]V3Relationship `json:"relationships"`
}

V3Resource represents application data returned from the Cloud Controller API.

type V3Response ¶

type V3Response struct {
	Resources []V3Resource `json:"resources"`
}

V3Response represents a list of V3 API resources and associated data.