outputs

Documentation

Index

• type DumpOutput
  • func (plugin *DumpOutput) Close()
  • func (plugin *DumpOutput) Configure(pipelineName string, data map[string]interface{}) error
  • func (plugin *DumpOutput) Execute(msgs []*core.Msg) error
  • func (plugin *DumpOutput) GetRouter() core.Router
  • func (plugin *DumpOutput) Start() error

Types

type DumpOutput

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

func (*DumpOutput) Close

func (plugin *DumpOutput) Close()

func (*DumpOutput) Configure

func (plugin *DumpOutput) Configure(pipelineName string, data map[string]interface{}) error

func (*DumpOutput) Execute

func (plugin *DumpOutput) Execute(msgs []*core.Msg) error

func (*DumpOutput) GetRouter

func (plugin *DumpOutput) GetRouter() core.Router

func (*DumpOutput) Start

func (plugin *DumpOutput) Start() error