input

Documentation

Index

• type InputType
• type ZeroMQ
  • func NewZeroMQ() *ZeroMQ
  • func (z *ZeroMQ) Receive(output chan []byte) error
  • func (z *ZeroMQ) Register(args map[string]interface{}) error

Types

type InputType

type InputType interface {
	Receive(chan []byte) error
}

type ZeroMQ

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

func NewZeroMQ

func NewZeroMQ() *ZeroMQ

func (*ZeroMQ) Receive

func (z *ZeroMQ) Receive(output chan []byte) error

func (*ZeroMQ) Register

func (z *ZeroMQ) Register(args map[string]interface{}) error

Called once for every time a "grok" config is used