sink

Documentation

Index

• Variables
• func NewModule(wrap *module.Wrap) (module.Module, error)
• type Config
• type Configurer
• type Module
  • func NewSink(wrap *module.Wrap) (*Module, error)
  • func (p *Module) Receive(val interface{})

Variables

var Manifest *module.Manifest

Functions

func NewModule

func NewModule(wrap *module.Wrap) (module.Module, error)

Types

type Config

type Config struct {
	base.Config
}

type Configurer

type Configurer interface {
	base.Configurer
}

type Module

type Module struct {
	base.Module
}

func NewSink

func NewSink(wrap *module.Wrap) (*Module, error)

func (*Module) Receive

func (p *Module) Receive(val interface{})