Documentation
¶
Index ¶
Constants ¶
View Source
const ( AnnotationRuleKey = "categraf/logs.stdout.processing_rules" AnnotationTopicKey = "categraf/logs.stdout.topic" AnnotationTagPrefixKey = "categraf/tags.prefix" AnnotationCollectKey = "categraf/logs.stdout.collect" )
Variables ¶
View Source
var JSONParser logparser.Parser = &jsonParser{}
JSONParser is a shared json parser.
View Source
var Parser *parser
Parser parses Kubernetes log lines
Functions ¶
func IsAvailable ¶
IsAvailable retrues true if the launcher is available and a retrier otherwise
func ServiceNameFromTags ¶
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.
type Scanner ¶
type Scanner struct {
// contains filtered or unexported fields
}
func NewScanner ¶
func NewScanner(services *logService.Services) *Scanner
func (*Scanner) SetActives ¶
Source Files
Click to show internal directories.
Click to hide internal directories.