pipelog

Documentation

Index

• type Log
  • func New(opts *opts.Opts) *Log
  • func (p *Log) AddNext(pe pipeline.Pipeline)
  • func (p *Log) Next() pipeline.Pipeline
  • func (p *Log) Publish(m *model.Message) error

Types

type Log

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

Log is a pipeline processor that logs incoming messages

func New

func New(opts *opts.Opts) *Log

New creates new instance of Log pipeline element

func (*Log) AddNext

func (p *Log) AddNext(pe pipeline.Pipeline)

AddNext ...

func (*Log) Next

func (p *Log) Next() pipeline.Pipeline

Next ...

func (*Log) Publish

func (p *Log) Publish(m *model.Message) error

Publish ...