proto

Documentation

Index

• Constants
• type BinlogTransaction
  • func (binlogTransaction *BinlogTransaction) MarshalBson(buf *bytes2.ChunkedWriter, key string)
  • func (binlogTransaction *BinlogTransaction) UnmarshalBson(buf *bytes.Buffer, kind byte)
• type KeyRangeRequest
• type Statement
  • func (statement *Statement) MarshalBson(buf *bytes2.ChunkedWriter, key string)
  • func (statement *Statement) UnmarshalBson(buf *bytes.Buffer, kind byte)
• type StreamEvent
  • func (streamEvent *StreamEvent) MarshalBson(buf *bytes2.ChunkedWriter, key string)
  • func (streamEvent *StreamEvent) UnmarshalBson(buf *bytes.Buffer, kind byte)
• type TablesRequest
• type UpdateStreamRequest

Constants

const (
	BL_UNRECOGNIZED = iota
	BL_BEGIN
	BL_COMMIT
	BL_ROLLBACK
	BL_DML
	BL_DDL
	BL_SET
)

Valid statement types in the binlogs.

Types

type BinlogTransaction

type BinlogTransaction struct {
	Statements []Statement
	GroupId    int64
}

BinlogTransaction represents one transaction as read from the binlog.

func (*BinlogTransaction) MarshalBson

func (binlogTransaction *BinlogTransaction) MarshalBson(buf *bytes2.ChunkedWriter, key string)

MarshalBson bson-encodes BinlogTransaction.

func (*BinlogTransaction) UnmarshalBson

func (binlogTransaction *BinlogTransaction) UnmarshalBson(buf *bytes.Buffer, kind byte)

UnmarshalBson bson-decodes into BinlogTransaction.

type KeyRangeRequest

type KeyRangeRequest struct {
	GroupId        int64
	KeyspaceIdType key.KeyspaceIdType
	KeyRange       key.KeyRange
}

KeyRangeRequest is used to make a request for StreamKeyRange.

type Statement

type Statement struct {
	Category int
	Sql      []byte
}

Statement represents one statement as read from the binlog.

func (*Statement) MarshalBson

func (statement *Statement) MarshalBson(buf *bytes2.ChunkedWriter, key string)

MarshalBson bson-encodes Statement.

func (*Statement) UnmarshalBson

func (statement *Statement) UnmarshalBson(buf *bytes.Buffer, kind byte)

UnmarshalBson bson-decodes into Statement.

type StreamEvent

type StreamEvent struct {
	// Category can be "DML", "DDL", "ERR" or "POS"
	Category string

	// DML
	TableName  string
	PKColNames []string
	PKValues   [][]interface{}

	// DDL or ERR
	Sql string

	// Timestamp is set for DML, DDL or ERR
	Timestamp int64

	// POS
	GroupId int64
}

StreamEvent represents one event for the update stream.

func (*StreamEvent) MarshalBson

func (streamEvent *StreamEvent) MarshalBson(buf *bytes2.ChunkedWriter, key string)

MarshalBson bson-encodes StreamEvent.

func (*StreamEvent) UnmarshalBson

func (streamEvent *StreamEvent) UnmarshalBson(buf *bytes.Buffer, kind byte)

UnmarshalBson bson-decodes into StreamEvent.

type TablesRequest

type TablesRequest struct {
	GroupId int64
	Tables  []string
}

TablesRequest is used to make a request for StreamTables.

type UpdateStreamRequest

type UpdateStreamRequest struct {
	GroupId int64
}

UpdateStreamRequest is used to make a request for ServeUpdateStream.