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.