Versions in this module Expand all Collapse all v0 v0.1.0 Mar 16, 2023 Changes in this version + type DBChangeUnmarshaller struct + func NewDBChangeUnmarshaller() *DBChangeUnmarshaller + func (um *DBChangeUnmarshaller) Process(msg *core.Message) (skip bool, err error) + type JsonMarshaller struct + func NewJsonMarshaller() *JsonMarshaller + func (m *JsonMarshaller) Process(msg *core.Message) (skip bool, err error)
Go to main page