parser

Documentation

Index

• type App
• type AppParser
  • func NewAppParser(cfClient *cloudfoundry.CFClient, cacheWorkers int, grabInterval int, ...) (*AppParser, error)
  • func (am *AppParser) Parse(envelope *loggregator_v2.Envelope) ([]metric.MetricPackage, error)
  • func (am *AppParser) Stop()
• type InfraParser
  • func NewInfraParser(environment string, deploymentUUIDRegex *regexp.Regexp, ...) (*InfraParser, error)
  • func (p InfraParser) Parse(envelope *loggregator_v2.Envelope) ([]metric.MetricPackage, error)
• type Parser

Types

type App

type App struct {
	Name                   string
	GUID                   string
	SpaceID                string
	SpaceName              string
	SpaceURL               string
	OrgName                string
	OrgID                  string
	Host                   string
	Buildpacks             []string
	NumberOfInstances      int
	TotalDiskConfigured    int
	TotalMemoryConfigured  int
	TotalDiskProvisioned   int
	TotalMemoryProvisioned int
	Tags                   []string
	// contains filtered or unexported fields
}

App holds all the needed attribute from an app

type AppParser

type AppParser struct {
	AppCache appCache
	// contains filtered or unexported fields
}

AppParser is used to parse app metrics

func NewAppParser

func NewAppParser(
	cfClient *cloudfoundry.CFClient,
	cacheWorkers int,
	grabInterval int,
	log *gosteno.Logger,
	customTags []string,
	environment string,
) (*AppParser, error)

NewAppParser create a new AppParser

func (*AppParser) Parse

func (am *AppParser) Parse(envelope *loggregator_v2.Envelope) ([]metric.MetricPackage, error)

Parse takes an envelope, and extract app metrics from it

func (*AppParser) Stop

func (am *AppParser) Stop()

Stop sends a message on the stopper channel to quit the goroutine refreshing the cache

type InfraParser

type InfraParser struct {
	Environment           string
	DeploymentUUIDRegex   *regexp.Regexp
	JobPartitionUUIDRegex *regexp.Regexp
	CustomTags            []string
}

func NewInfraParser

func NewInfraParser(
	environment string,
	deploymentUUIDRegex *regexp.Regexp,
	jobPartitionUUIDRegex *regexp.Regexp,
	customTags []string) (*InfraParser, error)

func (InfraParser) Parse

func (p InfraParser) Parse(envelope *loggregator_v2.Envelope) ([]metric.MetricPackage, error)

type Parser

type Parser interface {
	Parse(envelope *loggregator_v2.Envelope) ([]metric.MetricPackage, error)
}