qcollector_docker_logs

package module
v0.4.3 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 7, 2017 License: Apache-2.0 Imports: 16 Imported by: 2

README

collector-docker-logs

Collector to scrape json-file stdout/stderr of engine-local containers

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func SkipContainer added in v0.4.3

func SkipContainer(cjson *types.ContainerJSON, logEnv string) (skip bool, err error)

Types

type ContainerSupervisor

type ContainerSupervisor struct {
	Plugin
	TailRunning string
	Action      string
	CntID       string // ContainerID
	CntName     string // sanatized name of container
	Info        *types.Info
	Container   *types.ContainerJSON
	Com         chan interface{} // Channel to communicate with goroutine

	TimeRexex *regexp.Regexp
	// contains filtered or unexported fields
}

struct to keep info and channels to goroutine -> get heartbeats so that we know it's still alive -> allow for gracefully shutdown of the supervisor

func (ContainerSupervisor) Run

func (cs ContainerSupervisor) Run()

type Plugin

type Plugin struct {
	*qtypes_plugin.Plugin

	TimeRegex *regexp.Regexp
	// contains filtered or unexported fields
}

func New

func New(qChan qtypes_qchannel.QChan, cfg *config.Config, name string) (Plugin, error)

func (*Plugin) Run

func (p *Plugin) Run()

func (*Plugin) StartSupervisor

func (p *Plugin) StartSupervisor(ce events.Message, cnt types.ContainerJSON, info types.Info)

func (*Plugin) StartSupervisorCE

func (p *Plugin) StartSupervisorCE(ce qtypes_docker_events.ContainerEvent)

func (*Plugin) SubscribeRunning

func (p *Plugin) SubscribeRunning()

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL