io

package

v0.1.0 Latest Latest Go to latest Published: Apr 24, 2018 License: MIT Imports: 6 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Consumer struct {
	sync.Mutex
	// contains filtered or unexported fields
}

Consumer must be initialized with NewConsumer or calling Msg() will panic.

func NewConsumer(pth string) (*Consumer, error)

func (c *Consumer) Msg() (msg []byte, done bool, err error)

func (c *Consumer) Stop() error

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

func NewNullProducer() *Producer

func NewProducer() *Producer

func NewStdErrProducer() *Producer

func NewStdoutProducer() *Producer

func (p *Producer) Send(topic string, msg []byte) error

Send takes a topic and the message to send. The topic is a file name and is required unless initialized with NewStdoutProducer.

If initialized with NewStdoutProducer then the msg will always be written to "/dev/stdout".

func (p *Producer) Stop() error