kubernetes

Documentation

Index

• Constants
• Variables
• func IsAvailable() (bool, *retry.Retrier)
• func ServiceNameFromTags(ctrName, taggerEntity string) string
• type Launcher
  • func NewLauncher(sources *logsconfig.LogSources, services *service.Services, collectAll bool) *Launcher
  • func (l *Launcher) Start()
  • func (l *Launcher) Stop()
• type Scanner
  • func NewScanner(services *logService.Services) *Scanner
  • func (s *Scanner) Contains(id string) bool
  • func (s *Scanner) Scan()
  • func (s *Scanner) SetActives(ids map[string]struct{})

Constants

const (
	AnnotationRuleKey      = "categraf/logs.stdout.processing_rules"
	AnnotationTopicKey     = "categraf/logs.stdout.topic"
	AnnotationTagPrefixKey = "categraf/tags.prefix"
	AnnotationCollectKey   = "categraf/logs.stdout.collect"
)

Variables

var JSONParser logparser.Parser = &jsonParser{}

JSONParser is a shared json parser.

var Parser *parser

Parser parses Kubernetes log lines

Functions

func IsAvailable

func IsAvailable() (bool, *retry.Retrier)

IsAvailable retrues true if the launcher is available and a retrier otherwise

func ServiceNameFromTags

func ServiceNameFromTags(ctrName, taggerEntity string) string

Types

type Launcher

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

Launcher looks for new and deleted pods to create or delete one logs-source per container.

func NewLauncher

func NewLauncher(sources *logsconfig.LogSources, services *service.Services, collectAll bool) *Launcher

NewLauncher returns a new launcher.

func (*Launcher) Start

func (l *Launcher) Start()

Start starts the launcher

func (*Launcher) Stop

func (l *Launcher) Stop()

Stop stops the launcher

type Scanner

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

func NewScanner

func NewScanner(services *logService.Services) *Scanner

func (*Scanner) Contains

func (s *Scanner) Contains(id string) bool

func (*Scanner) Scan

func (s *Scanner) Scan()

func (*Scanner) SetActives

func (s *Scanner) SetActives(ids map[string]struct{})