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 (*Plugin) StartSupervisor ¶
func (*Plugin) StartSupervisorCE ¶
func (p *Plugin) StartSupervisorCE(ce qtypes_docker_events.ContainerEvent)
func (*Plugin) SubscribeRunning ¶
func (p *Plugin) SubscribeRunning()
Click to show internal directories.
Click to hide internal directories.