qinput

Documentation

Index

• type DockerEvents
  • func NewDockerEvents(cfg *config.Config, qC qtypes.Channels) DockerEvents
  • func (de DockerEvents) Run()
• type DockerGelf
  • func NewDockerGelf(cfg *config.Config, qC qtypes.Channels) DockerGelf
  • func (dg DockerGelf) Run()

Types

type DockerEvents

type DockerEvents struct {
	qtypes.QWorker
}

DockerEvents is a simple qworker

func NewDockerEvents

func NewDockerEvents(cfg *config.Config, qC qtypes.Channels) DockerEvents

NewDockerEvents returns instance of DockerEventInput

func (DockerEvents) Run

func (de DockerEvents) Run()

Run subscribes to messages and events from the docker-engine

type DockerGelf

type DockerGelf struct {
	qtypes.QWorker
}

DockerGelf is a simple qworker

func NewDockerGelf

func NewDockerGelf(cfg *config.Config, qC qtypes.Channels) DockerGelf

NewDockerGelf returns instance of DockerEventInput

func (DockerGelf) Run

func (dg DockerGelf) Run()

Run start a UDP server to listen for GELF messages (uncompressed)