protocol

Documentation

Overview

Package protocol is a generated protocol buffer package.

It is generated from these files:

binlog.proto

It has these top-level messages:

Binlog
Row
Pos

Index

• Constants
• Variables
• type Binlog
  • func (*Binlog) Descriptor() ([]byte, []int)
  • func (m *Binlog) GetColumnCount() int32
  • func (m *Binlog) GetDbName() string
  • func (m *Binlog) GetPostion() *Pos
  • func (m *Binlog) GetPrimaryKey() []*Row
  • func (m *Binlog) GetRows() []*Row
  • func (m *Binlog) GetTableName() string
  • func (m *Binlog) GetType() BinlogType
  • func (*Binlog) ProtoMessage()
  • func (m *Binlog) Reset()
  • func (m *Binlog) String() string
• type BinlogType
  • func (x BinlogType) Enum() *BinlogType
  • func (BinlogType) EnumDescriptor() ([]byte, []int)
  • func (x BinlogType) String() string
  • func (x *BinlogType) UnmarshalJSON(data []byte) error
• type Pos
  • func (*Pos) Descriptor() ([]byte, []int)
  • func (m *Pos) GetBinlogFile() string
  • func (m *Pos) GetPos() uint64
  • func (*Pos) ProtoMessage()
  • func (m *Pos) Reset()
  • func (m *Pos) String() string
• type Row
  • func (*Row) Descriptor() ([]byte, []int)
  • func (m *Row) GetColumnName() string
  • func (m *Row) GetColumnType() string
  • func (m *Row) GetColumnValue() string
  • func (m *Row) GetSql() string
  • func (*Row) ProtoMessage()
  • func (m *Row) Reset()
  • func (m *Row) String() string

Constants

const Default_Binlog_ColumnCount int32 = 0

Variables

var BinlogType_name = map[int32]string{
	0: "INSERT",
	1: "UPDATE",
	2: "DELETE",
	3: "DDL",
}

var BinlogType_value = map[string]int32{
	"INSERT": 0,
	"UPDATE": 1,
	"DELETE": 2,
	"DDL":    3,
}

Types

type Binlog

type Binlog struct {
	Postion          *Pos        `protobuf:"bytes,1,opt,name=postion" json:"postion,omitempty"`
	DbName           *string     `protobuf:"bytes,2,opt,name=dbName" json:"dbName,omitempty"`
	TableName        *string     `protobuf:"bytes,3,opt,name=tableName" json:"tableName,omitempty"`
	Type             *BinlogType `protobuf:"varint,4,opt,name=type,enum=protocol.BinlogType" json:"type,omitempty"`
	ColumnCount      *int32      `protobuf:"varint,5,opt,name=columnCount,def=0" json:"columnCount,omitempty"`
	PrimaryKey       []*Row      `protobuf:"bytes,6,rep,name=primaryKey" json:"primaryKey,omitempty"`
	Rows             []*Row      `protobuf:"bytes,7,rep,name=rows" json:"rows,omitempty"`
	XXX_unrecognized []byte      `json:"-"`
}

func (*Binlog) Descriptor

func (*Binlog) Descriptor() ([]byte, []int)

func (*Binlog) GetColumnCount

func (m *Binlog) GetColumnCount() int32

func (*Binlog) GetDbName

func (m *Binlog) GetDbName() string

func (*Binlog) GetPostion

func (m *Binlog) GetPostion() *Pos

func (*Binlog) GetPrimaryKey

func (m *Binlog) GetPrimaryKey() []*Row

func (*Binlog) GetRows

func (m *Binlog) GetRows() []*Row

func (*Binlog) GetTableName

func (m *Binlog) GetTableName() string

func (*Binlog) GetType

func (m *Binlog) GetType() BinlogType

func (*Binlog) ProtoMessage

func (*Binlog) ProtoMessage()

func (*Binlog) Reset

func (m *Binlog) Reset()

func (*Binlog) String

func (m *Binlog) String() string

type BinlogType

type BinlogType int32

const (
	BinlogType_INSERT BinlogType = 0
	BinlogType_UPDATE BinlogType = 1
	BinlogType_DELETE BinlogType = 2
	BinlogType_DDL    BinlogType = 3
)

func (BinlogType) Enum

func (x BinlogType) Enum() *BinlogType

func (BinlogType) EnumDescriptor

func (BinlogType) EnumDescriptor() ([]byte, []int)

func (BinlogType) String

func (x BinlogType) String() string

func (*BinlogType) UnmarshalJSON

func (x *BinlogType) UnmarshalJSON(data []byte) error

type Pos

type Pos struct {
	BinlogFile       *string `protobuf:"bytes,1,opt,name=binlogFile" json:"binlogFile,omitempty"`
	Pos              *uint64 `protobuf:"varint,2,opt,name=pos" json:"pos,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*Pos) Descriptor

func (*Pos) Descriptor() ([]byte, []int)

func (*Pos) GetBinlogFile

func (m *Pos) GetBinlogFile() string

func (*Pos) GetPos

func (m *Pos) GetPos() uint64

func (*Pos) ProtoMessage

func (*Pos) ProtoMessage()

func (*Pos) Reset

func (m *Pos) Reset()

func (*Pos) String

func (m *Pos) String() string

type Row

type Row struct {
	ColumnName       *string `protobuf:"bytes,1,opt,name=column_name,json=columnName" json:"column_name,omitempty"`
	ColumnType       *string `protobuf:"bytes,2,opt,name=column_type,json=columnType" json:"column_type,omitempty"`
	ColumnValue      *string `protobuf:"bytes,3,opt,name=column_value,json=columnValue" json:"column_value,omitempty"`
	Sql              *string `protobuf:"bytes,4,opt,name=sql" json:"sql,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*Row) Descriptor

func (*Row) Descriptor() ([]byte, []int)

func (*Row) GetColumnName

func (m *Row) GetColumnName() string

func (*Row) GetColumnType

func (m *Row) GetColumnType() string

func (*Row) GetColumnValue

func (m *Row) GetColumnValue() string

func (*Row) GetSql

func (m *Row) GetSql() string

func (*Row) ProtoMessage

func (*Row) ProtoMessage()

func (*Row) Reset

func (m *Row) Reset()

func (*Row) String

func (m *Row) String() string