encoding

Documentation

Index

• Constants
• func DataMapToPB(data map[string]interface{}) (map[string]*types.Any, error)
• func DecodeMsgFromPB(pbmsg *msgpb.Msg) (*core.Msg, error)
• func DecodeMsgHeaderFromPB(pbmsg *msgpb.Msg) (*core.Msg, error)
• func EncodeMsgHeaderToPB(msg *core.Msg) (*msgpb.Msg, error)
• func EncodeMsgToPB(msg *core.Msg) (*msgpb.Msg, error)
• func InterfaceValueToPB(v interface{}) (*types.Any, error)
• func PBToDataMap(data map[string]*types.Any) (map[string]interface{}, error)
• func PbToInterface(v *types.Any) (interface{}, error)
• type DDLJson_2_0
• type DDLMsg_0_1
• type DmlJson_2_0
• type DmlStringMsg_0_1
• type Encoder
  • func NewEncoder(input string, format string) Encoder
• type JsonMsg01
• type JsonMsgVersion20
• type MysqlJson_0_1_header
• type MysqlJson_2_0_header

Constants

const (
	Version01      = "0.1"
	Version20Alpha = "2.0.alpha"
)

Functions

func DataMapToPB

func DataMapToPB(data map[string]interface{}) (map[string]*types.Any, error)

func DecodeMsgFromPB

func DecodeMsgFromPB(pbmsg *msgpb.Msg) (*core.Msg, error)

func DecodeMsgHeaderFromPB

func DecodeMsgHeaderFromPB(pbmsg *msgpb.Msg) (*core.Msg, error)

func EncodeMsgHeaderToPB

func EncodeMsgHeaderToPB(msg *core.Msg) (*msgpb.Msg, error)

func EncodeMsgToPB

func EncodeMsgToPB(msg *core.Msg) (*msgpb.Msg, error)

func InterfaceValueToPB

func InterfaceValueToPB(v interface{}) (*types.Any, error)

func PBToDataMap

func PBToDataMap(data map[string]*types.Any) (map[string]interface{}, error)

func PbToInterface

func PbToInterface(v *types.Any) (interface{}, error)

Types

type DDLJson_2_0

type DDLJson_2_0 struct {
	MysqlJson_2_0_header
	SQL string `json:"sql"`
}

type DDLMsg_0_1

type DDLMsg_0_1 struct {
	MysqlJson_0_1_header
	SQL string `json:"sql"`
}

type DmlJson_2_0

type DmlJson_2_0 struct {
	MysqlJson_2_0_header
	Data map[string]interface{}
	Old  map[string]interface{}
	Pks  map[string]interface{}
}

type DmlStringMsg_0_1

type DmlStringMsg_0_1 struct {
	MysqlJson_0_1_header
	Data map[string]*string `json:"data"`
	Old  map[string]*string `json:"old"`
	Pks  map[string]*string `json:"pks,omitempty"`
}

type Encoder

type Encoder interface {
	Serialize(msg *core.Msg, version string) ([]byte, error)
	Deserialize(b []byte) (core.Msg, error)
}

func NewEncoder

func NewEncoder(input string, format string) Encoder

type JsonMsg01

type JsonMsg01 struct {
	Version          string  `json:"version"`
	Database         string  `json:"database"`
	Collection       string  `json:"collection"`
	UniqueSourceName string  `json:"unique_source_name"`
	Oplog            *gtm.Op `json:"oplog"`
}

type JsonMsgVersion20

type JsonMsgVersion20 struct {
	Version    string                 `json:"version"`
	Database   string                 `json:"database"`
	Collection string                 `json:"collection"`
	Data       map[string]interface{} `json:"data"`
	Row        map[string]interface{} `json:"row"`
}

type MysqlJson_0_1_header

type MysqlJson_0_1_header struct {
	Version   string `json:"version"`
	Database  string `json:"database"`
	Table     string `json:"table"`
	Type      string `json:"type"`
	Timestamp int64  `json:"ts"`
	TimeZone  string `json:"time_zone"`
	Host      string `json:"host"`
}

version 0.1

type MysqlJson_2_0_header

type MysqlJson_2_0_header struct {
	Version  string `json:"version"`
	Database string `json:"database"`
	Table    string `json:"table"`
	Type     string `json:"type"`
}

version 2.0