message

Documentation

Index

• Constants
• Variables
• func Put(msg *Message)
• type AlterTable
• type Content
• type CreateTable
• type Delete
• type Head
• type Insert
• type Message
  • func Get() *Message
  • func New() *Message
  • func (msg *Message) Json() (string, error)
  • func (msg *Message) JsonContent() (string, error)
  • func (msg *Message) Table() string
  • func (msg *Message) ToString() string
• type MessageType
  • func (mt MessageType) String() string
• type STATUS
• type Update

Constants

const (
	// STATUS_NEW a new message
	STATUS_NEW = iota
	// STATUS_SEND message has be sended
	STATUS_SEND
	// STATUS_RECORD message has be recorded
	STATUS_RECORD
)

Variables

var Pool = sync.Pool{
	New: func() interface{} {
		return &Message{}
	},
}

Pool reuse message object

Functions

func Put

func Put(msg *Message)

Types

type AlterTable

type AlterTable struct {
}

AlterTable for mysql ddl

type Content

type Content struct {
	Head Head        `json:"head"`
	Data interface{} `json:"data"`
}

Content of Message

type CreateTable

type CreateTable struct {
}

CreateTable for mysql ddl

type Delete

type Delete struct {
	Old map[string]interface{} `json:"old"`
}

Delete for mysql delete

type Head

type Head struct {
	Type     string            `json:"type"`
	Time     uint32            `json:"time"`
	Database string            `json:"database"`
	Table    string            `json:"table"`
	Position pipeline.Position `json:"position"`
}

Head of Message

type Insert

type Insert struct {
	New map[string]interface{} `json:"new"`
}

Insert for mysql insert

type Message

type Message struct {
	Status  int16
	Filter  bool
	Content Content
}

Message basic message for pipeline handle

func Get

func Get() *Message

func New

func New() *Message

New return a new message

func (*Message) Json

func (msg *Message) Json() (string, error)

Json marshal message to json data

func (*Message) JsonContent

func (msg *Message) JsonContent() (string, error)

JsonContent only marshal message's content to josn data

func (*Message) Table

func (msg *Message) Table() string

Table returns table with database

func (*Message) ToString

func (msg *Message) ToString() string

ToString returns message's string data

type MessageType

type MessageType byte

MessageType for pipeline handle

var (
	TYPE_EMPTY        MessageType = 0
	TYPE_INSERT       MessageType = 1
	TYPE_UPDATE       MessageType = 2
	TYPE_DELETE       MessageType = 3
	TYPE_CREATE_TABLE MessageType = 4
	TYPE_ALTER_TABLE  MessageType = 5
)

func (MessageType) String

func (mt MessageType) String() string

String returns MessageType's string

type STATUS

type STATUS int16

STATUS for message control

type Update

type Update struct {
	Old map[string]interface{} `json:"old"`
	New map[string]interface{} `json:"new"`
}

Update for mysql update