metrics

Documentation

Index

• Variables
• type ProcessRule
• type RuleFilter
• type TraefikMetricProcessor
  • func NewTraefikMetricProcessor(config []common.RulesConfig) (*TraefikMetricProcessor, error)
  • func (mp TraefikMetricProcessor) Process(entry model.TraefikLog, timestamp int64, measurement string) (client.BatchPoints, error)

Variables

var ApacheCombinedLogRegex = regexp.MustCompile(`^(?P<client_host>\S+)\s-\s+(?P<username>\S+\s+)+\[(?P<timestamp>[^]]+)\]\s"(?P<method>\S*)\s?(?P<path>(?:[^"]*(?:\\")?)*)\s(?P<protocol>[^"]*)"\s(?P<status>\d+)\s(?P<content_size>\d+)\s"(?P<referer>(?:[^"]*(?:\\")?)*)"\s"(?P<useragent>.*)"\s(?P<request_count>\d+)\s"(?P<frontend_name>[^"]+)"\s"(?P<backend_url>[^"]+)"\s(?P<request_time>\d+)ms$`)

Types

type ProcessRule

type ProcessRule struct {
	Id           string
	PathRegexp   *regexp.Regexp
	MethodRegexp *regexp.Regexp
	Filter       RuleFilter
}

type RuleFilter

type RuleFilter func(model.TraefikLog) bool

type TraefikMetricProcessor

type TraefikMetricProcessor struct {
	Rules map[*regexp.Regexp]ProcessRule
	// contains filtered or unexported fields
}

func NewTraefikMetricProcessor

func NewTraefikMetricProcessor(config []common.RulesConfig) (*TraefikMetricProcessor, error)

func (TraefikMetricProcessor) Process

func (mp TraefikMetricProcessor) Process(entry model.TraefikLog, timestamp int64, measurement string) (client.BatchPoints, error)