qframe_collector_docker_log

Documentation

Index

• type ContainerSupervisor
  • func (cs ContainerSupervisor) Run()
• type Plugin
  • func New(qChan qtypes.QChan, cfg *config.Config, name string) (Plugin, error)
  • func (p *Plugin) Run()
  • func (p *Plugin) StartSupervisor(ce events.Message, cnt types.ContainerJSON)
  • func (p *Plugin) StartSupervisorCE(ce qtypes.ContainerEvent)
  • func (p *Plugin) SubscribeRunning()

Types

type ContainerSupervisor

type ContainerSupervisor struct {
	Plugin
	Action    string
	CntID     string // ContainerID
	CntName   string // sanatized name of container
	Container types.ContainerJSON
	Com       chan interface{} // Channel to communicate with goroutine
	// 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
	// contains filtered or unexported fields
}

func New

func New(qChan qtypes.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)

func (*Plugin) StartSupervisorCE

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

func (*Plugin) SubscribeRunning

func (p *Plugin) SubscribeRunning()