sources

Documentation

Index

• type DockerProcessor
  • func NewDockerProcessor(handler EventHandler, label string, logger logger) *DockerProcessor
  • func (d *DockerProcessor) Process()
• type EventHandler
• type StdinProcessor
  • func NewIOProcessor(input io.Reader, handler EventHandler) *StdinProcessor
  • func NewStdinProcessor(handler EventHandler) *StdinProcessor
  • func (p *StdinProcessor) Process()

Types

type DockerProcessor

type DockerProcessor struct {
	// contains filtered or unexported fields
}

func NewDockerProcessor

func NewDockerProcessor(handler EventHandler, label string, logger logger) *DockerProcessor

func (*DockerProcessor) Process

func (d *DockerProcessor) Process()

type EventHandler

type EventHandler interface {
	ProcessLine(string, *time.Time)
}

type StdinProcessor

type StdinProcessor struct {
	// contains filtered or unexported fields
}

func NewIOProcessor

func NewIOProcessor(input io.Reader, handler EventHandler) *StdinProcessor

func NewStdinProcessor

func NewStdinProcessor(handler EventHandler) *StdinProcessor

func (*StdinProcessor) Process

func (p *StdinProcessor) Process()