Documentation ¶
Index ¶
- Constants
- func MarshalPKRowBson(buf *bytes2.ChunkedWriter, key string, pkRow []interface{})
- func MarshalPKValuesBson(buf *bytes2.ChunkedWriter, key string, pkValues [][]interface{})
- func MarshalStatementsBson(buf *bytes2.ChunkedWriter, key string, statements []Statement)
- func UnmarshalPKRowBson(buf *bytes.Buffer, kind byte) []interface{}
- func UnmarshalPKValuesBson(buf *bytes.Buffer, kind byte) [][]interface{}
- type BinlogTransaction
- type KeyRangeRequest
- type Statement
- type StreamEvent
- type TablesRequest
- type UpdateStreamRequest
Constants ¶
View Source
const ( BL_UNRECOGNIZED = iota BL_BEGIN BL_COMMIT BL_ROLLBACK BL_DML BL_DDL BL_SET )
Valid statement types in the binlogs.
Variables ¶
This section is empty.
Functions ¶
func MarshalPKRowBson ¶
func MarshalPKRowBson(buf *bytes2.ChunkedWriter, key string, pkRow []interface{})
func MarshalPKValuesBson ¶
func MarshalPKValuesBson(buf *bytes2.ChunkedWriter, key string, pkValues [][]interface{})
func MarshalStatementsBson ¶
func MarshalStatementsBson(buf *bytes2.ChunkedWriter, key string, statements []Statement)
func UnmarshalPKRowBson ¶
func UnmarshalPKValuesBson ¶
Types ¶
type BinlogTransaction ¶
BinlogTransaction represents one transaction as read from the binlog.
func (*BinlogTransaction) MarshalBson ¶
func (blt *BinlogTransaction) MarshalBson(buf *bytes2.ChunkedWriter, key string)
func (*BinlogTransaction) UnmarshalBson ¶
func (blt *BinlogTransaction) UnmarshalBson(buf *bytes.Buffer, kind byte)
type KeyRangeRequest ¶
type KeyRangeRequest struct { GroupId int64 KeyspaceIdType key.KeyspaceIdType KeyRange key.KeyRange }
KeyRangeRequest is used to make a request for StreamKeyRange.
type Statement ¶
Statement represents one statement as read from the binlog.
func UnmarshalStatementsBson ¶
func (*Statement) MarshalBson ¶
func (stmt *Statement) MarshalBson(buf *bytes2.ChunkedWriter, key string)
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 (ste *StreamEvent) MarshalBson(buf *bytes2.ChunkedWriter, key string)
func (*StreamEvent) UnmarshalBson ¶
func (ste *StreamEvent) UnmarshalBson(buf *bytes.Buffer, kind byte)
type TablesRequest ¶
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.
Click to show internal directories.
Click to hide internal directories.