producer

Documentation

Index

• func PipeFromReader(r io.Reader, p Producer) error
• func PipeFromReaderWith(r io.Reader, fn PrepareForProducerFn, p Generic) error
• type Generic
• type Marshal
  • func NewMarshal(pr Producer, f formats.Format) *Marshal
  • func (p *Marshal) Close() error
  • func (p *Marshal) Produce(v interface{}) error
• type PrepareForProducerFn
• type Producer

Functions

func PipeFromReader

func PipeFromReader(r io.Reader, p Producer) error

func PipeFromReaderWith

func PipeFromReaderWith(r io.Reader, fn PrepareForProducerFn, p Generic) error

Types

type Generic

type Generic interface {
	Produce(m interface{}) error
	Close() error
}

type Marshal

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

func NewMarshal

func NewMarshal(pr Producer, f formats.Format) *Marshal

func (*Marshal) Close

func (p *Marshal) Close() error

func (*Marshal) Produce

func (p *Marshal) Produce(v interface{}) error

type PrepareForProducerFn

type PrepareForProducerFn = func(buf []byte) (interface{}, error)

type Producer

type Producer interface {
	Produce(m message.Message) error
	Close() error
}