msgpb

package
v0.9.38 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 23, 2019 License: Apache-2.0 Imports: 7 Imported by: 2

Documentation

Overview

Package msgpb is a generated protocol buffer package.

It is generated from these files: 

message.proto

It has these top-level messages: 

Msg
DDLMsg
DMLMsg
ConfigureRequest
ConfigureResponse
FilterRequest
FilterResponse

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthMessage = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMessage   = fmt.Errorf("proto: integer overflow")
)
View Source 
var DataSourceType_name = map[int32]string{
	0: "UNKNOWN_DATA_SOURCE",
	1: "MYSQL",
	2: "MONGODB",
	3: "TIDB",
	4: "REDIS",
	5: "CODIS",
}
View Source 
var DataSourceType_value = map[string]int32{
	"UNKNOWN_DATA_SOURCE": 0,
	"MYSQL":               1,
	"MONGODB":             2,
	"TIDB":                3,
	"REDIS":               4,
	"CODIS":               5,
}

Functions

func RegisterFilterPluginServer added in v0.9.22 

func RegisterFilterPluginServer(s *grpc.Server, srv FilterPluginServer)

Types

type ConfigureRequest added in v0.9.22 

type ConfigureRequest struct {
	Data map[string]*google_protobuf2.Any `` /* 135-byte string literal not displayed */
}

func (*ConfigureRequest) Descriptor added in v0.9.22 

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

func (*ConfigureRequest) GetData added in v0.9.22 

func (m *ConfigureRequest) GetData() map[string]*google_protobuf2.Any

func (*ConfigureRequest) Marshal added in v0.9.22 

func (m *ConfigureRequest) Marshal() (dAtA []byte, err error)

func (*ConfigureRequest) MarshalTo added in v0.9.22 

func (m *ConfigureRequest) MarshalTo(dAtA []byte) (int, error)

func (*ConfigureRequest) ProtoMessage added in v0.9.22 

func (*ConfigureRequest) ProtoMessage()

func (*ConfigureRequest) Reset added in v0.9.22 

func (m *ConfigureRequest) Reset()

func (*ConfigureRequest) Size added in v0.9.22 

func (m *ConfigureRequest) Size() (n int)

func (*ConfigureRequest) String added in v0.9.22 

func (m *ConfigureRequest) String() string

func (*ConfigureRequest) Unmarshal added in v0.9.22 

func (m *ConfigureRequest) Unmarshal(dAtA []byte) error

type ConfigureResponse added in v0.9.22 

type ConfigureResponse struct {
	Error *google_protobuf1.StringValue `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
}

func (*ConfigureResponse) Descriptor added in v0.9.22 

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

func (*ConfigureResponse) GetError added in v0.9.22 

func (m *ConfigureResponse) GetError() *google_protobuf1.StringValue

func (*ConfigureResponse) Marshal added in v0.9.22 

func (m *ConfigureResponse) Marshal() (dAtA []byte, err error)

func (*ConfigureResponse) MarshalTo added in v0.9.22 

func (m *ConfigureResponse) MarshalTo(dAtA []byte) (int, error)

func (*ConfigureResponse) ProtoMessage added in v0.9.22 

func (*ConfigureResponse) ProtoMessage()

func (*ConfigureResponse) Reset added in v0.9.22 

func (m *ConfigureResponse) Reset()

func (*ConfigureResponse) Size added in v0.9.22 

func (m *ConfigureResponse) Size() (n int)

func (*ConfigureResponse) String added in v0.9.22 

func (m *ConfigureResponse) String() string

func (*ConfigureResponse) Unmarshal added in v0.9.22 

func (m *ConfigureResponse) Unmarshal(dAtA []byte) error

type DDLMsg 

type DDLMsg struct {
	// The DDL SQL
	SQL string `protobuf:"bytes,2,opt,name=SQL,proto3" json:"SQL,omitempty"`
}

DDLMsg is not available for Mongo?

func (*DDLMsg) Descriptor 

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

func (*DDLMsg) GetSQL 

func (m *DDLMsg) GetSQL() string

func (*DDLMsg) Marshal 

func (m *DDLMsg) Marshal() (dAtA []byte, err error)

func (*DDLMsg) MarshalTo 

func (m *DDLMsg) MarshalTo(dAtA []byte) (int, error)

func (*DDLMsg) ProtoMessage 

func (*DDLMsg) ProtoMessage()

func (*DDLMsg) Reset 

func (m *DDLMsg) Reset()

func (*DDLMsg) Size 

func (m *DDLMsg) Size() (n int)

func (*DDLMsg) String 

func (m *DDLMsg) String() string

func (*DDLMsg) Unmarshal 

func (m *DDLMsg) Unmarshal(dAtA []byte) error

type DMLMsg 

type DMLMsg struct {
	Op string `protobuf:"bytes,1,opt,name=Op,proto3" json:"Op,omitempty"`
	// Data is the changed data
	Data map[string]*google_protobuf2.Any `` /* 135-byte string literal not displayed */
	// Old is the original data (if it is not empty)
	Old map[string]*google_protobuf2.Any `` /* 133-byte string literal not displayed */
	// Pks is the pkColumnName -> pkColumnValue mapping,
	Pks map[string]*google_protobuf2.Any `` /* 133-byte string literal not displayed */
}

func (*DMLMsg) Descriptor 

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

func (*DMLMsg) GetData 

func (m *DMLMsg) GetData() map[string]*google_protobuf2.Any

func (*DMLMsg) GetOld 

func (m *DMLMsg) GetOld() map[string]*google_protobuf2.Any

func (*DMLMsg) GetOp added in v0.9.22 

func (m *DMLMsg) GetOp() string

func (*DMLMsg) GetPks 

func (m *DMLMsg) GetPks() map[string]*google_protobuf2.Any

func (*DMLMsg) Marshal 

func (m *DMLMsg) Marshal() (dAtA []byte, err error)

func (*DMLMsg) MarshalTo 

func (m *DMLMsg) MarshalTo(dAtA []byte) (int, error)

func (*DMLMsg) ProtoMessage 

func (*DMLMsg) ProtoMessage()

func (*DMLMsg) Reset 

func (m *DMLMsg) Reset()

func (*DMLMsg) Size 

func (m *DMLMsg) Size() (n int)

func (*DMLMsg) String 

func (m *DMLMsg) String() string

func (*DMLMsg) Unmarshal 

func (m *DMLMsg) Unmarshal(dAtA []byte) error

type DataSourceType 

type DataSourceType int32
const (
	DataSourceType_UNKNOWN_DATA_SOURCE DataSourceType = 0
	DataSourceType_MYSQL               DataSourceType = 1
	DataSourceType_MONGODB             DataSourceType = 2
	DataSourceType_TIDB                DataSourceType = 3
	DataSourceType_REDIS               DataSourceType = 4
	DataSourceType_CODIS               DataSourceType = 5
)

func (DataSourceType) EnumDescriptor 

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

func (DataSourceType) String 

func (x DataSourceType) String() string

type FilterPluginClient added in v0.9.22 

type FilterPluginClient interface {
	Configure(ctx context.Context, in *ConfigureRequest, opts ...grpc.CallOption) (*ConfigureResponse, error)
	Filter(ctx context.Context, in *FilterRequest, opts ...grpc.CallOption) (*FilterResponse, error)
}

func NewFilterPluginClient added in v0.9.22 

func NewFilterPluginClient(cc *grpc.ClientConn) FilterPluginClient

type FilterPluginServer added in v0.9.22 

type FilterPluginServer interface {
	Configure(context.Context, *ConfigureRequest) (*ConfigureResponse, error)
	Filter(context.Context, *FilterRequest) (*FilterResponse, error)
}

type FilterRequest added in v0.9.22 

type FilterRequest struct {
	Msg *Msg `protobuf:"bytes,1,opt,name=msg" json:"msg,omitempty"`
}

func (*FilterRequest) Descriptor added in v0.9.22 

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

func (*FilterRequest) GetMsg added in v0.9.22 

func (m *FilterRequest) GetMsg() *Msg

func (*FilterRequest) Marshal added in v0.9.22 

func (m *FilterRequest) Marshal() (dAtA []byte, err error)

func (*FilterRequest) MarshalTo added in v0.9.22 

func (m *FilterRequest) MarshalTo(dAtA []byte) (int, error)

func (*FilterRequest) ProtoMessage added in v0.9.22 

func (*FilterRequest) ProtoMessage()

func (*FilterRequest) Reset added in v0.9.22 

func (m *FilterRequest) Reset()

func (*FilterRequest) Size added in v0.9.22 

func (m *FilterRequest) Size() (n int)

func (*FilterRequest) String added in v0.9.22 

func (m *FilterRequest) String() string

func (*FilterRequest) Unmarshal added in v0.9.22 

func (m *FilterRequest) Unmarshal(dAtA []byte) error

type FilterResponse added in v0.9.22 

type FilterResponse struct {
	Msg          *Msg                          `protobuf:"bytes,1,opt,name=msg" json:"msg,omitempty"`
	ContinueNext bool                          `protobuf:"varint,2,opt,name=continueNext,proto3" json:"continueNext,omitempty"`
	Error        *google_protobuf1.StringValue `protobuf:"bytes,3,opt,name=error" json:"error,omitempty"`
}

func (*FilterResponse) Descriptor added in v0.9.22 

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

func (*FilterResponse) GetContinueNext added in v0.9.22 

func (m *FilterResponse) GetContinueNext() bool

func (*FilterResponse) GetError added in v0.9.22 

func (m *FilterResponse) GetError() *google_protobuf1.StringValue

func (*FilterResponse) GetMsg added in v0.9.22 

func (m *FilterResponse) GetMsg() *Msg

func (*FilterResponse) Marshal added in v0.9.22 

func (m *FilterResponse) Marshal() (dAtA []byte, err error)

func (*FilterResponse) MarshalTo added in v0.9.22 

func (m *FilterResponse) MarshalTo(dAtA []byte) (int, error)

func (*FilterResponse) ProtoMessage added in v0.9.22 

func (*FilterResponse) ProtoMessage()

func (*FilterResponse) Reset added in v0.9.22 

func (m *FilterResponse) Reset()

func (*FilterResponse) Size added in v0.9.22 

func (m *FilterResponse) Size() (n int)

func (*FilterResponse) String added in v0.9.22 

func (m *FilterResponse) String() string

func (*FilterResponse) Unmarshal added in v0.9.22 

func (m *FilterResponse) Unmarshal(dAtA []byte) error

type Msg 

type Msg struct {
	// Version is the Msg definition version
	Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	// Database is the database/schema name for MySQL
	// is the database for Mongo
	Database string `protobuf:"bytes,2,opt,name=database,proto3" json:"database,omitempty"`
	// Table is the table name for MySQL
	// is the collection name for Mongo
	Table string `protobuf:"bytes,3,opt,name=table,proto3" json:"table,omitempty"`
	// MsgType is the message type
	MsgType string `protobuf:"bytes,4,opt,name=msgType,proto3" json:"msgType,omitempty"`
	// Timestamp is the binlog event header timestamp for MySQL
	Timestamp *google_protobuf.Timestamp `protobuf:"bytes,5,opt,name=timestamp" json:"timestamp,omitempty"`
	DmlMsg    *DMLMsg                    `protobuf:"bytes,6,opt,name=dmlMsg" json:"dmlMsg,omitempty"`
	DdlMsg    *DDLMsg                    `protobuf:"bytes,7,opt,name=ddlMsg" json:"ddlMsg,omitempty"`
}

func (*Msg) Descriptor 

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

func (*Msg) GetDatabase 

func (m *Msg) GetDatabase() string

func (*Msg) GetDdlMsg 

func (m *Msg) GetDdlMsg() *DDLMsg

func (*Msg) GetDmlMsg 

func (m *Msg) GetDmlMsg() *DMLMsg

func (*Msg) GetMsgType 

func (m *Msg) GetMsgType() string

func (*Msg) GetTable 

func (m *Msg) GetTable() string

func (*Msg) GetTimestamp 

func (m *Msg) GetTimestamp() *google_protobuf.Timestamp

func (*Msg) GetVersion 

func (m *Msg) GetVersion() string

func (*Msg) Marshal 

func (m *Msg) Marshal() (dAtA []byte, err error)

func (*Msg) MarshalTo 

func (m *Msg) MarshalTo(dAtA []byte) (int, error)

func (*Msg) ProtoMessage 

func (*Msg) ProtoMessage()

func (*Msg) Reset 

func (m *Msg) Reset()

func (*Msg) Size 

func (m *Msg) Size() (n int)

func (*Msg) String 

func (m *Msg) String() string

func (*Msg) Unmarshal 

func (m *Msg) Unmarshal(dAtA []byte) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.