proto

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
  • func (blt *BinlogTransaction) MarshalBson(buf *bytes2.ChunkedWriter, key string)
  • func (blt *BinlogTransaction) UnmarshalBson(buf *bytes.Buffer, kind byte)
• type KeyRangeRequest
• type Statement
  • func UnmarshalStatementsBson(buf *bytes.Buffer, kind byte) []Statement
  • func (stmt *Statement) MarshalBson(buf *bytes2.ChunkedWriter, key string)
  • func (stmt *Statement) UnmarshalBson(buf *bytes.Buffer, kind byte)
• type StreamEvent
  • func (ste *StreamEvent) MarshalBson(buf *bytes2.ChunkedWriter, key string)
  • func (ste *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.

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 UnmarshalPKRowBson(buf *bytes.Buffer, kind byte) []interface{}

func UnmarshalPKValuesBson

func UnmarshalPKValuesBson(buf *bytes.Buffer, kind byte) [][]interface{}

Types

type BinlogTransaction

type BinlogTransaction struct {
	Statements []Statement
	GroupId    int64
}

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

type Statement struct {
	Category int
	Sql      []byte
}

Statement represents one statement as read from the binlog.

func UnmarshalStatementsBson

func UnmarshalStatementsBson(buf *bytes.Buffer, kind byte) []Statement

func (*Statement) MarshalBson

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

func (*Statement) UnmarshalBson

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

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

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.