datax

Documentation

Index

• type DataX
  • func New() (*DataX, error)
  • func (dx *DataX) Close()
  • func (dx *DataX) Configuration(cfg interface{}) error
  • func (dx *DataX) Emit(msg interface{}, reference ...string) error
  • func (dx *DataX) EmitRaw(rawMsg []byte, reference ...string) error
  • func (dx *DataX) EmitWithReference(msg interface{}, reference string) error
  • func (dx *DataX) Next(msg interface{}) (stream, reference string, err error)
  • func (dx *DataX) NextRaw() (stream, reference string, data []byte, err error)

Types

type DataX

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

func New

func New() (*DataX, error)

func (*DataX) Close

func (dx *DataX) Close()

func (*DataX) Configuration

func (dx *DataX) Configuration(cfg interface{}) error

func (*DataX) Emit

func (dx *DataX) Emit(msg interface{}, reference ...string) error

func (*DataX) EmitRaw

func (dx *DataX) EmitRaw(rawMsg []byte, reference ...string) error

func (*DataX) EmitWithReference

func (dx *DataX) EmitWithReference(msg interface{}, reference string) error

EmitWithReference Deprecated, use Emit()

func (*DataX) Next

func (dx *DataX) Next(msg interface{}) (stream, reference string, err error)

func (*DataX) NextRaw

func (dx *DataX) NextRaw() (stream, reference string, data []byte, err error)