json

Documentation

Index

• type DBChangeUnmarshaller
  • func NewDBChangeUnmarshaller() *DBChangeUnmarshaller
  • func (um *DBChangeUnmarshaller) Process(msg *core.Message) (skip bool, err error)
• type JsonMarshaller
  • func NewJsonMarshaller() *JsonMarshaller
  • func (m *JsonMarshaller) Process(msg *core.Message) (skip bool, err error)

Types

type DBChangeUnmarshaller

type DBChangeUnmarshaller struct {
	*core.BaseComponent
}

func NewDBChangeUnmarshaller

func NewDBChangeUnmarshaller() *DBChangeUnmarshaller

func (*DBChangeUnmarshaller) Process

func (um *DBChangeUnmarshaller) Process(msg *core.Message) (skip bool, err error)

type JsonMarshaller

type JsonMarshaller struct {
	*core.BaseComponent
}

func NewJsonMarshaller

func NewJsonMarshaller() *JsonMarshaller

func (*JsonMarshaller) Process

func (m *JsonMarshaller) Process(msg *core.Message) (skip bool, err error)