msgpb

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

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

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

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 */
}

type DataSourceType int32

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)
}

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

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

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"`
}

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"`
}