request

package
v1.10.5 Latest Latest
Warning

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

 Go to latest Published: Feb 6, 2024 License: GPL-3.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_v1_request_command_proto protoreflect.FileDescriptor
View Source 
var File_v1_request_event_query_proto protoreflect.FileDescriptor
View Source 
var File_v1_request_query_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type AutoMigrateItem 

type AutoMigrateItem struct {
	TablePrefixWithSchema string `protobuf:"bytes,1,opt,name=TablePrefixWithSchema,proto3" json:"TablePrefixWithSchema,omitempty"`
	Version               string `protobuf:"bytes,2,opt,name=Version,proto3" json:"Version,omitempty"`
	TableModelDescribe    []byte `protobuf:"bytes,3,opt,name=TableModelDescribe,proto3" json:"TableModelDescribe,omitempty"`
	NoEvent               bool   `protobuf:"varint,4,opt,name=NoEvent,proto3" json:"NoEvent,omitempty"`
	// contains filtered or unexported fields
}

func (*AutoMigrateItem) Descriptor deprecated 

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

Deprecated: Use AutoMigrateItem.ProtoReflect.Descriptor instead.

func (*AutoMigrateItem) GetNoEvent added in v1.9.0 

func (x *AutoMigrateItem) GetNoEvent() bool

func (*AutoMigrateItem) GetTableModelDescribe 

func (x *AutoMigrateItem) GetTableModelDescribe() []byte

func (*AutoMigrateItem) GetTablePrefixWithSchema 

func (x *AutoMigrateItem) GetTablePrefixWithSchema() string

func (*AutoMigrateItem) GetVersion 

func (x *AutoMigrateItem) GetVersion() string

func (*AutoMigrateItem) ProtoMessage 

func (*AutoMigrateItem) ProtoMessage()

func (*AutoMigrateItem) ProtoReflect 

func (x *AutoMigrateItem) ProtoReflect() protoreflect.Message

func (*AutoMigrateItem) Reset 

func (x *AutoMigrateItem) Reset()

func (*AutoMigrateItem) String 

func (x *AutoMigrateItem) String() string

func (*AutoMigrateItem) Validate 

func (this *AutoMigrateItem) Validate() error

type AutoMigrateRequest 

type AutoMigrateRequest struct {
	DatabaseID string             `protobuf:"bytes,1,opt,name=DatabaseID,proto3" json:"DatabaseID,omitempty"`
	Items      []*AutoMigrateItem `protobuf:"bytes,2,rep,name=Items,proto3" json:"Items,omitempty"`
	// contains filtered or unexported fields
}

func (*AutoMigrateRequest) Descriptor deprecated 

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

Deprecated: Use AutoMigrateRequest.ProtoReflect.Descriptor instead.

func (*AutoMigrateRequest) GetDatabaseID 

func (x *AutoMigrateRequest) GetDatabaseID() string

func (*AutoMigrateRequest) GetItems 

func (x *AutoMigrateRequest) GetItems() []*AutoMigrateItem

func (*AutoMigrateRequest) ProtoMessage 

func (*AutoMigrateRequest) ProtoMessage()

func (*AutoMigrateRequest) ProtoReflect 

func (x *AutoMigrateRequest) ProtoReflect() protoreflect.Message

func (*AutoMigrateRequest) Reset 

func (x *AutoMigrateRequest) Reset()

func (*AutoMigrateRequest) String 

func (x *AutoMigrateRequest) String() string

func (*AutoMigrateRequest) Validate 

func (this *AutoMigrateRequest) Validate() error

type Column 

type Column struct {
	Name  string       `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"`
	Value *ColumnValue `protobuf:"bytes,2,opt,name=Value,proto3" json:"Value,omitempty"`
	// contains filtered or unexported fields
}

func (*Column) Descriptor deprecated 

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

Deprecated: Use Column.ProtoReflect.Descriptor instead.

func (*Column) GetName 

func (x *Column) GetName() string

func (*Column) GetValue 

func (x *Column) GetValue() *ColumnValue

func (*Column) ProtoMessage 

func (*Column) ProtoMessage()

func (*Column) ProtoReflect 

func (x *Column) ProtoReflect() protoreflect.Message

func (*Column) Reset 

func (x *Column) Reset()

func (*Column) String 

func (x *Column) String() string

func (*Column) Validate 

func (this *Column) Validate() error

type ColumnValue 

type ColumnValue struct {
	Type string `protobuf:"bytes,1,opt,name=Type,proto3" json:"Type,omitempty"`
	// Types that are assignable to TypedValue:
	//
	//	*ColumnValue_StringValue
	//	*ColumnValue_Uint64Value
	//	*ColumnValue_Float64Value
	//	*ColumnValue_BoolValue
	TypedValue isColumnValue_TypedValue `protobuf_oneof:"TypedValue"`
	// contains filtered or unexported fields
}

func (*ColumnValue) Descriptor deprecated 

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

Deprecated: Use ColumnValue.ProtoReflect.Descriptor instead.

func (*ColumnValue) GetBoolValue 

func (x *ColumnValue) GetBoolValue() bool

func (*ColumnValue) GetFloat64Value 

func (x *ColumnValue) GetFloat64Value() float64

func (*ColumnValue) GetStringValue 

func (x *ColumnValue) GetStringValue() string

func (*ColumnValue) GetType 

func (x *ColumnValue) GetType() string

func (*ColumnValue) GetTypedValue 

func (m *ColumnValue) GetTypedValue() isColumnValue_TypedValue

func (*ColumnValue) GetUint64Value 

func (x *ColumnValue) GetUint64Value() uint64

func (*ColumnValue) ProtoMessage 

func (*ColumnValue) ProtoMessage()

func (*ColumnValue) ProtoReflect 

func (x *ColumnValue) ProtoReflect() protoreflect.Message

func (*ColumnValue) Reset 

func (x *ColumnValue) Reset()

func (*ColumnValue) String 

func (x *ColumnValue) String() string

func (*ColumnValue) Validate 

func (this *ColumnValue) Validate() error

type ColumnValue_BoolValue 

type ColumnValue_BoolValue struct {
	BoolValue bool `protobuf:"varint,5,opt,name=BoolValue,proto3,oneof"`
}

type ColumnValue_Float64Value 

type ColumnValue_Float64Value struct {
	Float64Value float64 `protobuf:"fixed64,4,opt,name=Float64Value,proto3,oneof"`
}

type ColumnValue_StringValue 

type ColumnValue_StringValue struct {
	StringValue string `protobuf:"bytes,2,opt,name=StringValue,proto3,oneof"`
}

type ColumnValue_Uint64Value 

type ColumnValue_Uint64Value struct {
	Uint64Value uint64 `protobuf:"varint,3,opt,name=Uint64Value,proto3,oneof"`
}

type CommonCountEventRequest 

type CommonCountEventRequest struct {
	DatabaseID            string   `protobuf:"bytes,1,opt,name=DatabaseID,proto3" json:"DatabaseID,omitempty"`
	TablePrefixWithSchema string   `protobuf:"bytes,2,opt,name=TablePrefixWithSchema,proto3" json:"TablePrefixWithSchema,omitempty"`
	KeyValues             []string `protobuf:"bytes,3,rep,name=KeyValues,proto3" json:"KeyValues,omitempty"`
	Version               string   `protobuf:"bytes,4,opt,name=Version,proto3" json:"Version,omitempty"`
	Operation             string   `protobuf:"bytes,5,opt,name=Operation,proto3" json:"Operation,omitempty"`
	CreatorID             string   `protobuf:"bytes,6,opt,name=CreatorID,proto3" json:"CreatorID,omitempty"`
	StartCreatedTime      string   `protobuf:"bytes,7,opt,name=StartCreatedTime,proto3" json:"StartCreatedTime,omitempty"`
	EndCreatedTime        string   `protobuf:"bytes,8,opt,name=EndCreatedTime,proto3" json:"EndCreatedTime,omitempty"`
	// contains filtered or unexported fields
}

func (*CommonCountEventRequest) Descriptor deprecated 

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

Deprecated: Use CommonCountEventRequest.ProtoReflect.Descriptor instead.

func (*CommonCountEventRequest) GetCreatorID 

func (x *CommonCountEventRequest) GetCreatorID() string

func (*CommonCountEventRequest) GetDatabaseID 

func (x *CommonCountEventRequest) GetDatabaseID() string

func (*CommonCountEventRequest) GetEndCreatedTime 

func (x *CommonCountEventRequest) GetEndCreatedTime() string

func (*CommonCountEventRequest) GetKeyValues 

func (x *CommonCountEventRequest) GetKeyValues() []string

func (*CommonCountEventRequest) GetOperation 

func (x *CommonCountEventRequest) GetOperation() string

func (*CommonCountEventRequest) GetStartCreatedTime 

func (x *CommonCountEventRequest) GetStartCreatedTime() string

func (*CommonCountEventRequest) GetTablePrefixWithSchema 

func (x *CommonCountEventRequest) GetTablePrefixWithSchema() string

func (*CommonCountEventRequest) GetVersion 

func (x *CommonCountEventRequest) GetVersion() string

func (*CommonCountEventRequest) ProtoMessage 

func (*CommonCountEventRequest) ProtoMessage()

func (*CommonCountEventRequest) ProtoReflect 

func (x *CommonCountEventRequest) ProtoReflect() protoreflect.Message

func (*CommonCountEventRequest) Reset 

func (x *CommonCountEventRequest) Reset()

func (*CommonCountEventRequest) String 

func (x *CommonCountEventRequest) String() string

func (*CommonCountEventRequest) Validate 

func (this *CommonCountEventRequest) Validate() error

type CommonCountRequest 

type CommonCountRequest struct {
	DatabaseID            string `protobuf:"bytes,1,opt,name=DatabaseID,proto3" json:"DatabaseID,omitempty"`
	TablePrefixWithSchema string `protobuf:"bytes,2,opt,name=TablePrefixWithSchema,proto3" json:"TablePrefixWithSchema,omitempty"`
	Version               string `protobuf:"bytes,3,opt,name=Version,proto3" json:"Version,omitempty"`
	Table                 string `protobuf:"bytes,4,opt,name=Table,proto3" json:"Table,omitempty"`
	Where                 []byte `protobuf:"bytes,5,opt,name=Where,proto3" json:"Where,omitempty"`
	Or                    []byte `protobuf:"bytes,6,opt,name=Or,proto3" json:"Or,omitempty"`
	GroupBy               string `protobuf:"bytes,7,opt,name=GroupBy,proto3" json:"GroupBy,omitempty"`
	Joins                 []byte `protobuf:"bytes,8,opt,name=Joins,proto3" json:"Joins,omitempty"`
	Having                []byte `protobuf:"bytes,9,opt,name=Having,proto3" json:"Having,omitempty"`
	// contains filtered or unexported fields
}

func (*CommonCountRequest) Descriptor deprecated 

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

Deprecated: Use CommonCountRequest.ProtoReflect.Descriptor instead.

func (*CommonCountRequest) GetDatabaseID 

func (x *CommonCountRequest) GetDatabaseID() string

func (*CommonCountRequest) GetGroupBy 

func (x *CommonCountRequest) GetGroupBy() string

func (*CommonCountRequest) GetHaving 

func (x *CommonCountRequest) GetHaving() []byte

func (*CommonCountRequest) GetJoins 

func (x *CommonCountRequest) GetJoins() []byte

func (*CommonCountRequest) GetOr 

func (x *CommonCountRequest) GetOr() []byte

func (*CommonCountRequest) GetTable added in v1.10.0 

func (x *CommonCountRequest) GetTable() string

func (*CommonCountRequest) GetTablePrefixWithSchema 

func (x *CommonCountRequest) GetTablePrefixWithSchema() string

func (*CommonCountRequest) GetVersion 

func (x *CommonCountRequest) GetVersion() string

func (*CommonCountRequest) GetWhere 

func (x *CommonCountRequest) GetWhere() []byte

func (*CommonCountRequest) ProtoMessage 

func (*CommonCountRequest) ProtoMessage()

func (*CommonCountRequest) ProtoReflect 

func (x *CommonCountRequest) ProtoReflect() protoreflect.Message

func (*CommonCountRequest) Reset 

func (x *CommonCountRequest) Reset()

func (*CommonCountRequest) String 

func (x *CommonCountRequest) String() string

func (*CommonCountRequest) Validate 

func (this *CommonCountRequest) Validate() error

type CommonEventQueryRequest 

type CommonEventQueryRequest struct {
	DatabaseID            string   `protobuf:"bytes,1,opt,name=DatabaseID,proto3" json:"DatabaseID,omitempty"`
	TablePrefixWithSchema string   `protobuf:"bytes,2,opt,name=TablePrefixWithSchema,proto3" json:"TablePrefixWithSchema,omitempty"`
	Select                []byte   `protobuf:"bytes,3,opt,name=Select,proto3" json:"Select,omitempty"`
	KeyValues             []string `protobuf:"bytes,4,rep,name=KeyValues,proto3" json:"KeyValues,omitempty"`
	Version               string   `protobuf:"bytes,5,opt,name=Version,proto3" json:"Version,omitempty"`
	Operation             string   `protobuf:"bytes,6,opt,name=Operation,proto3" json:"Operation,omitempty"`
	CreatorID             string   `protobuf:"bytes,7,opt,name=CreatorID,proto3" json:"CreatorID,omitempty"`
	StartCreatedTime      string   `protobuf:"bytes,8,opt,name=StartCreatedTime,proto3" json:"StartCreatedTime,omitempty"`
	EndCreatedTime        string   `protobuf:"bytes,9,opt,name=EndCreatedTime,proto3" json:"EndCreatedTime,omitempty"`
	PageNo                int32    `protobuf:"varint,10,opt,name=PageNo,proto3" json:"PageNo,omitempty"`
	PageSize              int32    `protobuf:"varint,11,opt,name=PageSize,proto3" json:"PageSize,omitempty"`
	// contains filtered or unexported fields
}

func (*CommonEventQueryRequest) Descriptor deprecated 

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

Deprecated: Use CommonEventQueryRequest.ProtoReflect.Descriptor instead.

func (*CommonEventQueryRequest) GetCreatorID 

func (x *CommonEventQueryRequest) GetCreatorID() string

func (*CommonEventQueryRequest) GetDatabaseID 

func (x *CommonEventQueryRequest) GetDatabaseID() string

func (*CommonEventQueryRequest) GetEndCreatedTime 

func (x *CommonEventQueryRequest) GetEndCreatedTime() string

func (*CommonEventQueryRequest) GetKeyValues 

func (x *CommonEventQueryRequest) GetKeyValues() []string

func (*CommonEventQueryRequest) GetOperation 

func (x *CommonEventQueryRequest) GetOperation() string

func (*CommonEventQueryRequest) GetPageNo 

func (x *CommonEventQueryRequest) GetPageNo() int32

func (*CommonEventQueryRequest) GetPageSize 

func (x *CommonEventQueryRequest) GetPageSize() int32

func (*CommonEventQueryRequest) GetSelect 

func (x *CommonEventQueryRequest) GetSelect() []byte

func (*CommonEventQueryRequest) GetStartCreatedTime 

func (x *CommonEventQueryRequest) GetStartCreatedTime() string

func (*CommonEventQueryRequest) GetTablePrefixWithSchema 

func (x *CommonEventQueryRequest) GetTablePrefixWithSchema() string

func (*CommonEventQueryRequest) GetVersion 

func (x *CommonEventQueryRequest) GetVersion() string

func (*CommonEventQueryRequest) ProtoMessage 

func (*CommonEventQueryRequest) ProtoMessage()

func (*CommonEventQueryRequest) ProtoReflect 

func (x *CommonEventQueryRequest) ProtoReflect() protoreflect.Message

func (*CommonEventQueryRequest) Reset 

func (x *CommonEventQueryRequest) Reset()

func (*CommonEventQueryRequest) String 

func (x *CommonEventQueryRequest) String() string

func (*CommonEventQueryRequest) Validate 

func (this *CommonEventQueryRequest) Validate() error

type CommonQueryRequest 

type CommonQueryRequest struct {
	DatabaseID            string `protobuf:"bytes,1,opt,name=DatabaseID,proto3" json:"DatabaseID,omitempty"`
	TablePrefixWithSchema string `protobuf:"bytes,2,opt,name=TablePrefixWithSchema,proto3" json:"TablePrefixWithSchema,omitempty"`
	Version               string `protobuf:"bytes,3,opt,name=Version,proto3" json:"Version,omitempty"`
	Table                 string `protobuf:"bytes,4,opt,name=Table,proto3" json:"Table,omitempty"`
	Select                []byte `protobuf:"bytes,5,opt,name=Select,proto3" json:"Select,omitempty"`
	Where                 []byte `protobuf:"bytes,6,opt,name=Where,proto3" json:"Where,omitempty"`
	OrderBy               string `protobuf:"bytes,7,opt,name=OrderBy,proto3" json:"OrderBy,omitempty"`
	Or                    []byte `protobuf:"bytes,8,opt,name=Or,proto3" json:"Or,omitempty"`
	GroupBy               string `protobuf:"bytes,9,opt,name=GroupBy,proto3" json:"GroupBy,omitempty"`
	Joins                 []byte `protobuf:"bytes,10,opt,name=Joins,proto3" json:"Joins,omitempty"`
	Having                []byte `protobuf:"bytes,11,opt,name=Having,proto3" json:"Having,omitempty"`
	PageNo                int32  `protobuf:"varint,12,opt,name=PageNo,proto3" json:"PageNo,omitempty"`
	PageSize              int32  `protobuf:"varint,13,opt,name=PageSize,proto3" json:"PageSize,omitempty"`
	// contains filtered or unexported fields
}

func (*CommonQueryRequest) Descriptor deprecated 

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

Deprecated: Use CommonQueryRequest.ProtoReflect.Descriptor instead.

func (*CommonQueryRequest) GetDatabaseID 

func (x *CommonQueryRequest) GetDatabaseID() string

func (*CommonQueryRequest) GetGroupBy 

func (x *CommonQueryRequest) GetGroupBy() string

func (*CommonQueryRequest) GetHaving 

func (x *CommonQueryRequest) GetHaving() []byte

func (*CommonQueryRequest) GetJoins 

func (x *CommonQueryRequest) GetJoins() []byte

func (*CommonQueryRequest) GetOr 

func (x *CommonQueryRequest) GetOr() []byte

func (*CommonQueryRequest) GetOrderBy 

func (x *CommonQueryRequest) GetOrderBy() string

func (*CommonQueryRequest) GetPageNo 

func (x *CommonQueryRequest) GetPageNo() int32

func (*CommonQueryRequest) GetPageSize 

func (x *CommonQueryRequest) GetPageSize() int32

func (*CommonQueryRequest) GetSelect 

func (x *CommonQueryRequest) GetSelect() []byte

func (*CommonQueryRequest) GetTable added in v1.10.0 

func (x *CommonQueryRequest) GetTable() string

func (*CommonQueryRequest) GetTablePrefixWithSchema 

func (x *CommonQueryRequest) GetTablePrefixWithSchema() string

func (*CommonQueryRequest) GetVersion 

func (x *CommonQueryRequest) GetVersion() string

func (*CommonQueryRequest) GetWhere 

func (x *CommonQueryRequest) GetWhere() []byte

func (*CommonQueryRequest) ProtoMessage 

func (*CommonQueryRequest) ProtoMessage()

func (*CommonQueryRequest) ProtoReflect 

func (x *CommonQueryRequest) ProtoReflect() protoreflect.Message

func (*CommonQueryRequest) Reset 

func (x *CommonQueryRequest) Reset()

func (*CommonQueryRequest) String 

func (x *CommonQueryRequest) String() string

func (*CommonQueryRequest) Validate 

func (this *CommonQueryRequest) Validate() error

type CountEventByKeysRequest 

type CountEventByKeysRequest struct {
	DatabaseID            string   `protobuf:"bytes,1,opt,name=DatabaseID,proto3" json:"DatabaseID,omitempty"`
	TablePrefixWithSchema string   `protobuf:"bytes,2,opt,name=TablePrefixWithSchema,proto3" json:"TablePrefixWithSchema,omitempty"`
	KeyValues             []string `protobuf:"bytes,3,rep,name=KeyValues,proto3" json:"KeyValues,omitempty"`
	// contains filtered or unexported fields
}

func (*CountEventByKeysRequest) Descriptor deprecated 

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

Deprecated: Use CountEventByKeysRequest.ProtoReflect.Descriptor instead.

func (*CountEventByKeysRequest) GetDatabaseID 

func (x *CountEventByKeysRequest) GetDatabaseID() string

func (*CountEventByKeysRequest) GetKeyValues 

func (x *CountEventByKeysRequest) GetKeyValues() []string

func (*CountEventByKeysRequest) GetTablePrefixWithSchema 

func (x *CountEventByKeysRequest) GetTablePrefixWithSchema() string

func (*CountEventByKeysRequest) ProtoMessage 

func (*CountEventByKeysRequest) ProtoMessage()

func (*CountEventByKeysRequest) ProtoReflect 

func (x *CountEventByKeysRequest) ProtoReflect() protoreflect.Message

func (*CountEventByKeysRequest) Reset 

func (x *CountEventByKeysRequest) Reset()

func (*CountEventByKeysRequest) String 

func (x *CountEventByKeysRequest) String() string

func (*CountEventByKeysRequest) Validate 

func (this *CountEventByKeysRequest) Validate() error

type CountWhereRequest 

type CountWhereRequest struct {
	DatabaseID            string `protobuf:"bytes,1,opt,name=DatabaseID,proto3" json:"DatabaseID,omitempty"`
	TablePrefixWithSchema string `protobuf:"bytes,2,opt,name=TablePrefixWithSchema,proto3" json:"TablePrefixWithSchema,omitempty"`
	Version               string `protobuf:"bytes,3,opt,name=Version,proto3" json:"Version,omitempty"`
	Table                 string `protobuf:"bytes,4,opt,name=Table,proto3" json:"Table,omitempty"`
	Where                 []byte `protobuf:"bytes,5,opt,name=Where,proto3" json:"Where,omitempty"`
	// contains filtered or unexported fields
}

func (*CountWhereRequest) Descriptor deprecated 

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

Deprecated: Use CountWhereRequest.ProtoReflect.Descriptor instead.

func (*CountWhereRequest) GetDatabaseID 

func (x *CountWhereRequest) GetDatabaseID() string

func (*CountWhereRequest) GetTable added in v1.10.0 

func (x *CountWhereRequest) GetTable() string

func (*CountWhereRequest) GetTablePrefixWithSchema 

func (x *CountWhereRequest) GetTablePrefixWithSchema() string

func (*CountWhereRequest) GetVersion 

func (x *CountWhereRequest) GetVersion() string

func (*CountWhereRequest) GetWhere 

func (x *CountWhereRequest) GetWhere() []byte

func (*CountWhereRequest) ProtoMessage 

func (*CountWhereRequest) ProtoMessage()

func (*CountWhereRequest) ProtoReflect 

func (x *CountWhereRequest) ProtoReflect() protoreflect.Message

func (*CountWhereRequest) Reset 

func (x *CountWhereRequest) Reset()

func (*CountWhereRequest) String 

func (x *CountWhereRequest) String() string

func (*CountWhereRequest) Validate 

func (this *CountWhereRequest) Validate() error

type DeleteRequest 

type DeleteRequest struct {
	DatabaseID            string   `protobuf:"bytes,1,opt,name=DatabaseID,proto3" json:"DatabaseID,omitempty"`
	TablePrefixWithSchema string   `protobuf:"bytes,2,opt,name=TablePrefixWithSchema,proto3" json:"TablePrefixWithSchema,omitempty"`
	Version               string   `protobuf:"bytes,3,opt,name=Version,proto3" json:"Version,omitempty"`
	KeyColumns            []string `protobuf:"bytes,4,rep,name=KeyColumns,proto3" json:"KeyColumns,omitempty"`
	KeyValues             []string `protobuf:"bytes,5,rep,name=KeyValues,proto3" json:"KeyValues,omitempty"`
	UserID                string   `protobuf:"bytes,6,opt,name=UserID,proto3" json:"UserID,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteRequest) Descriptor deprecated 

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

Deprecated: Use DeleteRequest.ProtoReflect.Descriptor instead.

func (*DeleteRequest) GetDatabaseID 

func (x *DeleteRequest) GetDatabaseID() string

func (*DeleteRequest) GetKeyColumns added in v1.8.0 

func (x *DeleteRequest) GetKeyColumns() []string

func (*DeleteRequest) GetKeyValues 

func (x *DeleteRequest) GetKeyValues() []string

func (*DeleteRequest) GetTablePrefixWithSchema 

func (x *DeleteRequest) GetTablePrefixWithSchema() string

func (*DeleteRequest) GetUserID 

func (x *DeleteRequest) GetUserID() string

func (*DeleteRequest) GetVersion 

func (x *DeleteRequest) GetVersion() string

func (*DeleteRequest) ProtoMessage 

func (*DeleteRequest) ProtoMessage()

func (*DeleteRequest) ProtoReflect 

func (x *DeleteRequest) ProtoReflect() protoreflect.Message

func (*DeleteRequest) Reset 

func (x *DeleteRequest) Reset()

func (*DeleteRequest) String 

func (x *DeleteRequest) String() string

func (*DeleteRequest) Validate 

func (this *DeleteRequest) Validate() error

type DeleteTxRequest 

type DeleteTxRequest struct {
	TablePrefixWithSchema string   `protobuf:"bytes,1,opt,name=TablePrefixWithSchema,proto3" json:"TablePrefixWithSchema,omitempty"`
	Version               string   `protobuf:"bytes,2,opt,name=Version,proto3" json:"Version,omitempty"`
	KeyColumns            []string `protobuf:"bytes,3,rep,name=KeyColumns,proto3" json:"KeyColumns,omitempty"`
	KeyValues             []string `protobuf:"bytes,4,rep,name=KeyValues,proto3" json:"KeyValues,omitempty"`
	UserID                string   `protobuf:"bytes,5,opt,name=UserID,proto3" json:"UserID,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteTxRequest) Descriptor deprecated 

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

Deprecated: Use DeleteTxRequest.ProtoReflect.Descriptor instead.

func (*DeleteTxRequest) GetKeyColumns added in v1.8.0 

func (x *DeleteTxRequest) GetKeyColumns() []string

func (*DeleteTxRequest) GetKeyValues 

func (x *DeleteTxRequest) GetKeyValues() []string

func (*DeleteTxRequest) GetTablePrefixWithSchema 

func (x *DeleteTxRequest) GetTablePrefixWithSchema() string

func (*DeleteTxRequest) GetUserID 

func (x *DeleteTxRequest) GetUserID() string

func (*DeleteTxRequest) GetVersion 

func (x *DeleteTxRequest) GetVersion() string

func (*DeleteTxRequest) ProtoMessage 

func (*DeleteTxRequest) ProtoMessage()

func (*DeleteTxRequest) ProtoReflect 

func (x *DeleteTxRequest) ProtoReflect() protoreflect.Message

func (*DeleteTxRequest) Reset 

func (x *DeleteTxRequest) Reset()

func (*DeleteTxRequest) String 

func (x *DeleteTxRequest) String() string

func (*DeleteTxRequest) Validate 

func (this *DeleteTxRequest) Validate() error

type DeleteWhereRequest added in v1.6.6 

type DeleteWhereRequest struct {
	DatabaseID            string   `protobuf:"bytes,1,opt,name=DatabaseID,proto3" json:"DatabaseID,omitempty"`
	TablePrefixWithSchema string   `protobuf:"bytes,2,opt,name=TablePrefixWithSchema,proto3" json:"TablePrefixWithSchema,omitempty"`
	Version               string   `protobuf:"bytes,3,opt,name=Version,proto3" json:"Version,omitempty"`
	KeyColumns            []string `protobuf:"bytes,4,rep,name=KeyColumns,proto3" json:"KeyColumns,omitempty"`
	Where                 []byte   `protobuf:"bytes,5,opt,name=Where,proto3" json:"Where,omitempty"`
	UserID                string   `protobuf:"bytes,6,opt,name=UserID,proto3" json:"UserID,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteWhereRequest) Descriptor deprecated added in v1.6.6 

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

Deprecated: Use DeleteWhereRequest.ProtoReflect.Descriptor instead.

func (*DeleteWhereRequest) GetDatabaseID added in v1.6.6 

func (x *DeleteWhereRequest) GetDatabaseID() string

func (*DeleteWhereRequest) GetKeyColumns added in v1.6.6 

func (x *DeleteWhereRequest) GetKeyColumns() []string

func (*DeleteWhereRequest) GetTablePrefixWithSchema added in v1.6.6 

func (x *DeleteWhereRequest) GetTablePrefixWithSchema() string

func (*DeleteWhereRequest) GetUserID added in v1.6.6 

func (x *DeleteWhereRequest) GetUserID() string

func (*DeleteWhereRequest) GetVersion added in v1.6.6 

func (x *DeleteWhereRequest) GetVersion() string

func (*DeleteWhereRequest) GetWhere added in v1.6.6 

func (x *DeleteWhereRequest) GetWhere() []byte

func (*DeleteWhereRequest) ProtoMessage added in v1.6.6 

func (*DeleteWhereRequest) ProtoMessage()

func (*DeleteWhereRequest) ProtoReflect added in v1.6.6 

func (x *DeleteWhereRequest) ProtoReflect() protoreflect.Message

func (*DeleteWhereRequest) Reset added in v1.6.6 

func (x *DeleteWhereRequest) Reset()

func (*DeleteWhereRequest) String added in v1.6.6 

func (x *DeleteWhereRequest) String() string

func (*DeleteWhereRequest) Validate added in v1.6.6 

func (this *DeleteWhereRequest) Validate() error

type DeleteWhereTxRequest added in v1.6.6 

type DeleteWhereTxRequest struct {
	TablePrefixWithSchema string   `protobuf:"bytes,1,opt,name=TablePrefixWithSchema,proto3" json:"TablePrefixWithSchema,omitempty"`
	Version               string   `protobuf:"bytes,2,opt,name=Version,proto3" json:"Version,omitempty"`
	KeyColumns            []string `protobuf:"bytes,3,rep,name=KeyColumns,proto3" json:"KeyColumns,omitempty"`
	Where                 []byte   `protobuf:"bytes,4,opt,name=Where,proto3" json:"Where,omitempty"`
	UserID                string   `protobuf:"bytes,5,opt,name=UserID,proto3" json:"UserID,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteWhereTxRequest) Descriptor deprecated added in v1.6.6 

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

Deprecated: Use DeleteWhereTxRequest.ProtoReflect.Descriptor instead.

func (*DeleteWhereTxRequest) GetKeyColumns added in v1.6.6 

func (x *DeleteWhereTxRequest) GetKeyColumns() []string

func (*DeleteWhereTxRequest) GetTablePrefixWithSchema added in v1.6.6 

func (x *DeleteWhereTxRequest) GetTablePrefixWithSchema() string

func (*DeleteWhereTxRequest) GetUserID added in v1.6.6 

func (x *DeleteWhereTxRequest) GetUserID() string

func (*DeleteWhereTxRequest) GetVersion added in v1.6.6 

func (x *DeleteWhereTxRequest) GetVersion() string

func (*DeleteWhereTxRequest) GetWhere added in v1.6.6 

func (x *DeleteWhereTxRequest) GetWhere() []byte

func (*DeleteWhereTxRequest) ProtoMessage added in v1.6.6 

func (*DeleteWhereTxRequest) ProtoMessage()

func (*DeleteWhereTxRequest) ProtoReflect added in v1.6.6 

func (x *DeleteWhereTxRequest) ProtoReflect() protoreflect.Message

func (*DeleteWhereTxRequest) Reset added in v1.6.6 

func (x *DeleteWhereTxRequest) Reset()

func (*DeleteWhereTxRequest) String added in v1.6.6 

func (x *DeleteWhereTxRequest) String() string

func (*DeleteWhereTxRequest) Validate added in v1.6.6 

func (this *DeleteWhereTxRequest) Validate() error

type EventQueryByKeysRequest 

type EventQueryByKeysRequest struct {
	DatabaseID            string   `protobuf:"bytes,1,opt,name=DatabaseID,proto3" json:"DatabaseID,omitempty"`
	TablePrefixWithSchema string   `protobuf:"bytes,2,opt,name=TablePrefixWithSchema,proto3" json:"TablePrefixWithSchema,omitempty"`
	Select                []byte   `protobuf:"bytes,3,opt,name=Select,proto3" json:"Select,omitempty"`
	KeyValues             []string `protobuf:"bytes,4,rep,name=KeyValues,proto3" json:"KeyValues,omitempty"`
	PageNo                int32    `protobuf:"varint,5,opt,name=PageNo,proto3" json:"PageNo,omitempty"`
	PageSize              int32    `protobuf:"varint,6,opt,name=PageSize,proto3" json:"PageSize,omitempty"`
	// contains filtered or unexported fields
}

func (*EventQueryByKeysRequest) Descriptor deprecated 

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

Deprecated: Use EventQueryByKeysRequest.ProtoReflect.Descriptor instead.

func (*EventQueryByKeysRequest) GetDatabaseID 

func (x *EventQueryByKeysRequest) GetDatabaseID() string

func (*EventQueryByKeysRequest) GetKeyValues 

func (x *EventQueryByKeysRequest) GetKeyValues() []string

func (*EventQueryByKeysRequest) GetPageNo 

func (x *EventQueryByKeysRequest) GetPageNo() int32

func (*EventQueryByKeysRequest) GetPageSize 

func (x *EventQueryByKeysRequest) GetPageSize() int32

func (*EventQueryByKeysRequest) GetSelect 

func (x *EventQueryByKeysRequest) GetSelect() []byte

func (*EventQueryByKeysRequest) GetTablePrefixWithSchema 

func (x *EventQueryByKeysRequest) GetTablePrefixWithSchema() string

func (*EventQueryByKeysRequest) ProtoMessage 

func (*EventQueryByKeysRequest) ProtoMessage()

func (*EventQueryByKeysRequest) ProtoReflect 

func (x *EventQueryByKeysRequest) ProtoReflect() protoreflect.Message

func (*EventQueryByKeysRequest) Reset 

func (x *EventQueryByKeysRequest) Reset()

func (*EventQueryByKeysRequest) String 

func (x *EventQueryByKeysRequest) String() string

func (*EventQueryByKeysRequest) Validate 

func (this *EventQueryByKeysRequest) Validate() error

type InsertBatchRequest 

type InsertBatchRequest struct {
	DatabaseID string                `protobuf:"bytes,1,opt,name=DatabaseID,proto3" json:"DatabaseID,omitempty"`
	Items      []*InsertTableRowItem `protobuf:"bytes,2,rep,name=Items,proto3" json:"Items,omitempty"`
	UserID     string                `protobuf:"bytes,3,opt,name=UserID,proto3" json:"UserID,omitempty"`
	// contains filtered or unexported fields
}

func (*InsertBatchRequest) Descriptor deprecated 

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

Deprecated: Use InsertBatchRequest.ProtoReflect.Descriptor instead.

func (*InsertBatchRequest) GetDatabaseID 

func (x *InsertBatchRequest) GetDatabaseID() string

func (*InsertBatchRequest) GetItems 

func (x *InsertBatchRequest) GetItems() []*InsertTableRowItem

func (*InsertBatchRequest) GetUserID 

func (x *InsertBatchRequest) GetUserID() string

func (*InsertBatchRequest) ProtoMessage 

func (*InsertBatchRequest) ProtoMessage()

func (*InsertBatchRequest) ProtoReflect 

func (x *InsertBatchRequest) ProtoReflect() protoreflect.Message

func (*InsertBatchRequest) Reset 

func (x *InsertBatchRequest) Reset()

func (*InsertBatchRequest) String 

func (x *InsertBatchRequest) String() string

func (*InsertBatchRequest) Validate 

func (this *InsertBatchRequest) Validate() error

type InsertBatchTxRequest 

type InsertBatchTxRequest struct {
	Items  []*InsertTableRowItem `protobuf:"bytes,1,rep,name=Items,proto3" json:"Items,omitempty"`
	UserID string                `protobuf:"bytes,2,opt,name=UserID,proto3" json:"UserID,omitempty"`
	// contains filtered or unexported fields
}

func (*InsertBatchTxRequest) Descriptor deprecated 

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

Deprecated: Use InsertBatchTxRequest.ProtoReflect.Descriptor instead.

func (*InsertBatchTxRequest) GetItems 

func (x *InsertBatchTxRequest) GetItems() []*InsertTableRowItem

func (*InsertBatchTxRequest) GetUserID 

func (x *InsertBatchTxRequest) GetUserID() string

func (*InsertBatchTxRequest) ProtoMessage 

func (*InsertBatchTxRequest) ProtoMessage()

func (*InsertBatchTxRequest) ProtoReflect 

func (x *InsertBatchTxRequest) ProtoReflect() protoreflect.Message

func (*InsertBatchTxRequest) Reset 

func (x *InsertBatchTxRequest) Reset()

func (*InsertBatchTxRequest) String 

func (x *InsertBatchTxRequest) String() string

func (*InsertBatchTxRequest) Validate 

func (this *InsertBatchTxRequest) Validate() error

type InsertRequest 

type InsertRequest struct {
	DatabaseID            string    `protobuf:"bytes,1,opt,name=DatabaseID,proto3" json:"DatabaseID,omitempty"`
	TablePrefixWithSchema string    `protobuf:"bytes,2,opt,name=TablePrefixWithSchema,proto3" json:"TablePrefixWithSchema,omitempty"`
	Version               string    `protobuf:"bytes,3,opt,name=Version,proto3" json:"Version,omitempty"`
	KeyColumns            []string  `protobuf:"bytes,4,rep,name=KeyColumns,proto3" json:"KeyColumns,omitempty"`
	TableRow              *TableRow `protobuf:"bytes,5,opt,name=TableRow,proto3" json:"TableRow,omitempty"`
	UserID                string    `protobuf:"bytes,6,opt,name=UserID,proto3" json:"UserID,omitempty"`
	// contains filtered or unexported fields
}

func (*InsertRequest) Descriptor deprecated 

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

Deprecated: Use InsertRequest.ProtoReflect.Descriptor instead.

func (*InsertRequest) GetDatabaseID 

func (x *InsertRequest) GetDatabaseID() string

func (*InsertRequest) GetKeyColumns 

func (x *InsertRequest) GetKeyColumns() []string

func (*InsertRequest) GetTablePrefixWithSchema 

func (x *InsertRequest) GetTablePrefixWithSchema() string

func (*InsertRequest) GetTableRow 

func (x *InsertRequest) GetTableRow() *TableRow

func (*InsertRequest) GetUserID 

func (x *InsertRequest) GetUserID() string

func (*InsertRequest) GetVersion 

func (x *InsertRequest) GetVersion() string

func (*InsertRequest) ProtoMessage 

func (*InsertRequest) ProtoMessage()

func (*InsertRequest) ProtoReflect 

func (x *InsertRequest) ProtoReflect() protoreflect.Message

func (*InsertRequest) Reset 

func (x *InsertRequest) Reset()

func (*InsertRequest) String 

func (x *InsertRequest) String() string

func (*InsertRequest) Validate 

func (this *InsertRequest) Validate() error

type InsertTableRowItem 

type InsertTableRowItem struct {
	TablePrefixWithSchema string      `protobuf:"bytes,1,opt,name=TablePrefixWithSchema,proto3" json:"TablePrefixWithSchema,omitempty"`
	Version               string      `protobuf:"bytes,2,opt,name=Version,proto3" json:"Version,omitempty"`
	KeyColumns            []string    `protobuf:"bytes,3,rep,name=KeyColumns,proto3" json:"KeyColumns,omitempty"`
	TableRows             []*TableRow `protobuf:"bytes,4,rep,name=TableRows,proto3" json:"TableRows,omitempty"`
	// contains filtered or unexported fields
}

func (*InsertTableRowItem) Descriptor deprecated 

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

Deprecated: Use InsertTableRowItem.ProtoReflect.Descriptor instead.

func (*InsertTableRowItem) GetKeyColumns 

func (x *InsertTableRowItem) GetKeyColumns() []string

func (*InsertTableRowItem) GetTablePrefixWithSchema 

func (x *InsertTableRowItem) GetTablePrefixWithSchema() string

func (*InsertTableRowItem) GetTableRows 

func (x *InsertTableRowItem) GetTableRows() []*TableRow

func (*InsertTableRowItem) GetVersion 

func (x *InsertTableRowItem) GetVersion() string

func (*InsertTableRowItem) ProtoMessage 

func (*InsertTableRowItem) ProtoMessage()

func (*InsertTableRowItem) ProtoReflect 

func (x *InsertTableRowItem) ProtoReflect() protoreflect.Message

func (*InsertTableRowItem) Reset 

func (x *InsertTableRowItem) Reset()

func (*InsertTableRowItem) String 

func (x *InsertTableRowItem) String() string

func (*InsertTableRowItem) Validate 

func (this *InsertTableRowItem) Validate() error

type InsertTxRequest 

type InsertTxRequest struct {
	TablePrefixWithSchema string    `protobuf:"bytes,1,opt,name=TablePrefixWithSchema,proto3" json:"TablePrefixWithSchema,omitempty"`
	Version               string    `protobuf:"bytes,2,opt,name=Version,proto3" json:"Version,omitempty"`
	KeyColumns            []string  `protobuf:"bytes,3,rep,name=KeyColumns,proto3" json:"KeyColumns,omitempty"`
	TableRow              *TableRow `protobuf:"bytes,4,opt,name=TableRow,proto3" json:"TableRow,omitempty"`
	UserID                string    `protobuf:"bytes,5,opt,name=UserID,proto3" json:"UserID,omitempty"`
	// contains filtered or unexported fields
}

func (*InsertTxRequest) Descriptor deprecated 

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

Deprecated: Use InsertTxRequest.ProtoReflect.Descriptor instead.

func (*InsertTxRequest) GetKeyColumns 

func (x *InsertTxRequest) GetKeyColumns() []string

func (*InsertTxRequest) GetTablePrefixWithSchema 

func (x *InsertTxRequest) GetTablePrefixWithSchema() string

func (*InsertTxRequest) GetTableRow 

func (x *InsertTxRequest) GetTableRow() *TableRow

func (*InsertTxRequest) GetUserID 

func (x *InsertTxRequest) GetUserID() string

func (*InsertTxRequest) GetVersion 

func (x *InsertTxRequest) GetVersion() string

func (*InsertTxRequest) ProtoMessage 

func (*InsertTxRequest) ProtoMessage()

func (*InsertTxRequest) ProtoReflect 

func (x *InsertTxRequest) ProtoReflect() protoreflect.Message

func (*InsertTxRequest) Reset 

func (x *InsertTxRequest) Reset()

func (*InsertTxRequest) String 

func (x *InsertTxRequest) String() string

func (*InsertTxRequest) Validate 

func (this *InsertTxRequest) Validate() error

type QueryByKeysRequest 

type QueryByKeysRequest struct {
	DatabaseID            string   `protobuf:"bytes,1,opt,name=DatabaseID,proto3" json:"DatabaseID,omitempty"`
	TablePrefixWithSchema string   `protobuf:"bytes,2,opt,name=TablePrefixWithSchema,proto3" json:"TablePrefixWithSchema,omitempty"`
	Version               string   `protobuf:"bytes,3,opt,name=Version,proto3" json:"Version,omitempty"`
	Select                []byte   `protobuf:"bytes,4,opt,name=Select,proto3" json:"Select,omitempty"`
	KeyColumns            []string `protobuf:"bytes,5,rep,name=KeyColumns,proto3" json:"KeyColumns,omitempty"`
	KeyValues             []string `protobuf:"bytes,6,rep,name=KeyValues,proto3" json:"KeyValues,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryByKeysRequest) Descriptor deprecated 

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

Deprecated: Use QueryByKeysRequest.ProtoReflect.Descriptor instead.

func (*QueryByKeysRequest) GetDatabaseID 

func (x *QueryByKeysRequest) GetDatabaseID() string

func (*QueryByKeysRequest) GetKeyColumns added in v1.8.0 

func (x *QueryByKeysRequest) GetKeyColumns() []string

func (*QueryByKeysRequest) GetKeyValues 

func (x *QueryByKeysRequest) GetKeyValues() []string

func (*QueryByKeysRequest) GetSelect 

func (x *QueryByKeysRequest) GetSelect() []byte

func (*QueryByKeysRequest) GetTablePrefixWithSchema 

func (x *QueryByKeysRequest) GetTablePrefixWithSchema() string

func (*QueryByKeysRequest) GetVersion 

func (x *QueryByKeysRequest) GetVersion() string

func (*QueryByKeysRequest) ProtoMessage 

func (*QueryByKeysRequest) ProtoMessage()

func (*QueryByKeysRequest) ProtoReflect 

func (x *QueryByKeysRequest) ProtoReflect() protoreflect.Message

func (*QueryByKeysRequest) Reset 

func (x *QueryByKeysRequest) Reset()

func (*QueryByKeysRequest) String 

func (x *QueryByKeysRequest) String() string

func (*QueryByKeysRequest) Validate 

func (this *QueryByKeysRequest) Validate() error

type QueryByWhereAndOrderByRequest 

type QueryByWhereAndOrderByRequest struct {
	DatabaseID            string `protobuf:"bytes,1,opt,name=DatabaseID,proto3" json:"DatabaseID,omitempty"`
	TablePrefixWithSchema string `protobuf:"bytes,2,opt,name=TablePrefixWithSchema,proto3" json:"TablePrefixWithSchema,omitempty"`
	Version               string `protobuf:"bytes,3,opt,name=Version,proto3" json:"Version,omitempty"`
	Table                 string `protobuf:"bytes,4,opt,name=Table,proto3" json:"Table,omitempty"`
	Select                []byte `protobuf:"bytes,5,opt,name=Select,proto3" json:"Select,omitempty"`
	Where                 []byte `protobuf:"bytes,6,opt,name=Where,proto3" json:"Where,omitempty"`
	OrderBy               string `protobuf:"bytes,7,opt,name=OrderBy,proto3" json:"OrderBy,omitempty"`
	PageNo                int32  `protobuf:"varint,8,opt,name=PageNo,proto3" json:"PageNo,omitempty"`
	PageSize              int32  `protobuf:"varint,9,opt,name=PageSize,proto3" json:"PageSize,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryByWhereAndOrderByRequest) Descriptor deprecated 

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

Deprecated: Use QueryByWhereAndOrderByRequest.ProtoReflect.Descriptor instead.

func (*QueryByWhereAndOrderByRequest) GetDatabaseID 

func (x *QueryByWhereAndOrderByRequest) GetDatabaseID() string

func (*QueryByWhereAndOrderByRequest) GetOrderBy 

func (x *QueryByWhereAndOrderByRequest) GetOrderBy() string

func (*QueryByWhereAndOrderByRequest) GetPageNo 

func (x *QueryByWhereAndOrderByRequest) GetPageNo() int32

func (*QueryByWhereAndOrderByRequest) GetPageSize 

func (x *QueryByWhereAndOrderByRequest) GetPageSize() int32

func (*QueryByWhereAndOrderByRequest) GetSelect 

func (x *QueryByWhereAndOrderByRequest) GetSelect() []byte

func (*QueryByWhereAndOrderByRequest) GetTable added in v1.10.0 

func (x *QueryByWhereAndOrderByRequest) GetTable() string

func (*QueryByWhereAndOrderByRequest) GetTablePrefixWithSchema 

func (x *QueryByWhereAndOrderByRequest) GetTablePrefixWithSchema() string

func (*QueryByWhereAndOrderByRequest) GetVersion 

func (x *QueryByWhereAndOrderByRequest) GetVersion() string

func (*QueryByWhereAndOrderByRequest) GetWhere 

func (x *QueryByWhereAndOrderByRequest) GetWhere() []byte

func (*QueryByWhereAndOrderByRequest) ProtoMessage 

func (*QueryByWhereAndOrderByRequest) ProtoMessage()

func (*QueryByWhereAndOrderByRequest) ProtoReflect 

func (x *QueryByWhereAndOrderByRequest) ProtoReflect() protoreflect.Message

func (*QueryByWhereAndOrderByRequest) Reset 

func (x *QueryByWhereAndOrderByRequest) Reset()

func (*QueryByWhereAndOrderByRequest) String 

func (x *QueryByWhereAndOrderByRequest) String() string

func (*QueryByWhereAndOrderByRequest) Validate 

func (this *QueryByWhereAndOrderByRequest) Validate() error

type ReplayRequest 

type ReplayRequest struct {
	DatabaseID            string   `protobuf:"bytes,1,opt,name=DatabaseID,proto3" json:"DatabaseID,omitempty"`
	TablePrefixWithSchema string   `protobuf:"bytes,2,opt,name=TablePrefixWithSchema,proto3" json:"TablePrefixWithSchema,omitempty"`
	Version               string   `protobuf:"bytes,3,opt,name=Version,proto3" json:"Version,omitempty"`
	KeyColumns            []string `protobuf:"bytes,4,rep,name=KeyColumns,proto3" json:"KeyColumns,omitempty"`
	KeyValues             []string `protobuf:"bytes,5,rep,name=KeyValues,proto3" json:"KeyValues,omitempty"`
	UserID                string   `protobuf:"bytes,6,opt,name=UserID,proto3" json:"UserID,omitempty"`
	// contains filtered or unexported fields
}

func (*ReplayRequest) Descriptor deprecated 

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

Deprecated: Use ReplayRequest.ProtoReflect.Descriptor instead.

func (*ReplayRequest) GetDatabaseID 

func (x *ReplayRequest) GetDatabaseID() string

func (*ReplayRequest) GetKeyColumns added in v1.8.0 

func (x *ReplayRequest) GetKeyColumns() []string

func (*ReplayRequest) GetKeyValues 

func (x *ReplayRequest) GetKeyValues() []string

func (*ReplayRequest) GetTablePrefixWithSchema 

func (x *ReplayRequest) GetTablePrefixWithSchema() string

func (*ReplayRequest) GetUserID 

func (x *ReplayRequest) GetUserID() string

func (*ReplayRequest) GetVersion 

func (x *ReplayRequest) GetVersion() string

func (*ReplayRequest) ProtoMessage 

func (*ReplayRequest) ProtoMessage()

func (*ReplayRequest) ProtoReflect 

func (x *ReplayRequest) ProtoReflect() protoreflect.Message

func (*ReplayRequest) Reset 

func (x *ReplayRequest) Reset()

func (*ReplayRequest) String 

func (x *ReplayRequest) String() string

func (*ReplayRequest) Validate 

func (this *ReplayRequest) Validate() error

type TableRow 

type TableRow struct {
	Columns []*Column `protobuf:"bytes,1,rep,name=Columns,proto3" json:"Columns,omitempty"`
	// contains filtered or unexported fields
}

func (*TableRow) Descriptor deprecated 

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

Deprecated: Use TableRow.ProtoReflect.Descriptor instead.

func (*TableRow) GetColumns 

func (x *TableRow) GetColumns() []*Column

func (*TableRow) ProtoMessage 

func (*TableRow) ProtoMessage()

func (*TableRow) ProtoReflect 

func (x *TableRow) ProtoReflect() protoreflect.Message

func (*TableRow) Reset 

func (x *TableRow) Reset()

func (*TableRow) String 

func (x *TableRow) String() string

func (*TableRow) Validate 

func (this *TableRow) Validate() error

type TransactionBeginRequest 

type TransactionBeginRequest struct {
	DatabaseID string `protobuf:"bytes,1,opt,name=DatabaseID,proto3" json:"DatabaseID,omitempty"`
	// contains filtered or unexported fields
}

func (*TransactionBeginRequest) Descriptor deprecated 

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

Deprecated: Use TransactionBeginRequest.ProtoReflect.Descriptor instead.

func (*TransactionBeginRequest) GetDatabaseID 

func (x *TransactionBeginRequest) GetDatabaseID() string

func (*TransactionBeginRequest) ProtoMessage 

func (*TransactionBeginRequest) ProtoMessage()

func (*TransactionBeginRequest) ProtoReflect 

func (x *TransactionBeginRequest) ProtoReflect() protoreflect.Message

func (*TransactionBeginRequest) Reset 

func (x *TransactionBeginRequest) Reset()

func (*TransactionBeginRequest) String 

func (x *TransactionBeginRequest) String() string

func (*TransactionBeginRequest) Validate 

func (this *TransactionBeginRequest) Validate() error

type TransactionEndRequest 

type TransactionEndRequest struct {
	// contains filtered or unexported fields
}

func (*TransactionEndRequest) Descriptor deprecated 

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

Deprecated: Use TransactionEndRequest.ProtoReflect.Descriptor instead.

func (*TransactionEndRequest) ProtoMessage 

func (*TransactionEndRequest) ProtoMessage()

func (*TransactionEndRequest) ProtoReflect 

func (x *TransactionEndRequest) ProtoReflect() protoreflect.Message

func (*TransactionEndRequest) Reset 

func (x *TransactionEndRequest) Reset()

func (*TransactionEndRequest) String 

func (x *TransactionEndRequest) String() string

func (*TransactionEndRequest) Validate 

func (this *TransactionEndRequest) Validate() error

type TransactionOperation 

type TransactionOperation struct {

	// Types that are assignable to Request:
	//
	//	*TransactionOperation_TransactionBeginRequest
	//	*TransactionOperation_InsertTxRequest
	//	*TransactionOperation_InsertBatchTxRequest
	//	*TransactionOperation_DeleteTxRequest
	//	*TransactionOperation_DeleteWhereTxRequest
	//	*TransactionOperation_UpdateTxRequest
	//	*TransactionOperation_UpdateWhereTxRequest
	//	*TransactionOperation_TransactionEndRequest
	Request isTransactionOperation_Request `protobuf_oneof:"Request"`
	// contains filtered or unexported fields
}

func (*TransactionOperation) Descriptor deprecated 

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

Deprecated: Use TransactionOperation.ProtoReflect.Descriptor instead.

func (*TransactionOperation) GetDeleteTxRequest 

func (x *TransactionOperation) GetDeleteTxRequest() *DeleteTxRequest

func (*TransactionOperation) GetDeleteWhereTxRequest added in v1.6.6 

func (x *TransactionOperation) GetDeleteWhereTxRequest() *DeleteWhereTxRequest

func (*TransactionOperation) GetInsertBatchTxRequest 

func (x *TransactionOperation) GetInsertBatchTxRequest() *InsertBatchTxRequest

func (*TransactionOperation) GetInsertTxRequest 

func (x *TransactionOperation) GetInsertTxRequest() *InsertTxRequest

func (*TransactionOperation) GetRequest 

func (m *TransactionOperation) GetRequest() isTransactionOperation_Request

func (*TransactionOperation) GetTransactionBeginRequest 

func (x *TransactionOperation) GetTransactionBeginRequest() *TransactionBeginRequest

func (*TransactionOperation) GetTransactionEndRequest 

func (x *TransactionOperation) GetTransactionEndRequest() *TransactionEndRequest

func (*TransactionOperation) GetUpdateTxRequest 

func (x *TransactionOperation) GetUpdateTxRequest() *UpdateTxRequest

func (*TransactionOperation) GetUpdateWhereTxRequest added in v1.7.0 

func (x *TransactionOperation) GetUpdateWhereTxRequest() *UpdateWhereTxRequest

func (*TransactionOperation) ProtoMessage 

func (*TransactionOperation) ProtoMessage()

func (*TransactionOperation) ProtoReflect 

func (x *TransactionOperation) ProtoReflect() protoreflect.Message

func (*TransactionOperation) Reset 

func (x *TransactionOperation) Reset()

func (*TransactionOperation) String 

func (x *TransactionOperation) String() string

func (*TransactionOperation) Validate 

func (this *TransactionOperation) Validate() error

type TransactionOperation_DeleteTxRequest 

type TransactionOperation_DeleteTxRequest struct {
	DeleteTxRequest *DeleteTxRequest `protobuf:"bytes,4,opt,name=DeleteTxRequest,proto3,oneof"`
}

type TransactionOperation_DeleteWhereTxRequest added in v1.6.6 

type TransactionOperation_DeleteWhereTxRequest struct {
	DeleteWhereTxRequest *DeleteWhereTxRequest `protobuf:"bytes,5,opt,name=DeleteWhereTxRequest,proto3,oneof"`
}

type TransactionOperation_InsertBatchTxRequest 

type TransactionOperation_InsertBatchTxRequest struct {
	InsertBatchTxRequest *InsertBatchTxRequest `protobuf:"bytes,3,opt,name=InsertBatchTxRequest,proto3,oneof"`
}

type TransactionOperation_InsertTxRequest 

type TransactionOperation_InsertTxRequest struct {
	InsertTxRequest *InsertTxRequest `protobuf:"bytes,2,opt,name=InsertTxRequest,proto3,oneof"`
}

type TransactionOperation_TransactionBeginRequest 

type TransactionOperation_TransactionBeginRequest struct {
	TransactionBeginRequest *TransactionBeginRequest `protobuf:"bytes,1,opt,name=TransactionBeginRequest,proto3,oneof"`
}

type TransactionOperation_TransactionEndRequest 

type TransactionOperation_TransactionEndRequest struct {
	TransactionEndRequest *TransactionEndRequest `protobuf:"bytes,8,opt,name=TransactionEndRequest,proto3,oneof"`
}

type TransactionOperation_UpdateTxRequest 

type TransactionOperation_UpdateTxRequest struct {
	UpdateTxRequest *UpdateTxRequest `protobuf:"bytes,6,opt,name=UpdateTxRequest,proto3,oneof"`
}

type TransactionOperation_UpdateWhereTxRequest added in v1.7.0 

type TransactionOperation_UpdateWhereTxRequest struct {
	UpdateWhereTxRequest *UpdateWhereTxRequest `protobuf:"bytes,7,opt,name=UpdateWhereTxRequest,proto3,oneof"`
}

type UpdateRequest 

type UpdateRequest struct {
	DatabaseID            string    `protobuf:"bytes,1,opt,name=DatabaseID,proto3" json:"DatabaseID,omitempty"`
	TablePrefixWithSchema string    `protobuf:"bytes,2,opt,name=TablePrefixWithSchema,proto3" json:"TablePrefixWithSchema,omitempty"`
	Version               string    `protobuf:"bytes,3,opt,name=Version,proto3" json:"Version,omitempty"`
	KeyColumns            []string  `protobuf:"bytes,4,rep,name=KeyColumns,proto3" json:"KeyColumns,omitempty"`
	KeyValues             []string  `protobuf:"bytes,5,rep,name=KeyValues,proto3" json:"KeyValues,omitempty"`
	NewTableRow           *TableRow `protobuf:"bytes,6,opt,name=NewTableRow,proto3" json:"NewTableRow,omitempty"`
	UserID                string    `protobuf:"bytes,7,opt,name=UserID,proto3" json:"UserID,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateRequest) Descriptor deprecated 

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

Deprecated: Use UpdateRequest.ProtoReflect.Descriptor instead.

func (*UpdateRequest) GetDatabaseID 

func (x *UpdateRequest) GetDatabaseID() string

func (*UpdateRequest) GetKeyColumns added in v1.8.0 

func (x *UpdateRequest) GetKeyColumns() []string

func (*UpdateRequest) GetKeyValues 

func (x *UpdateRequest) GetKeyValues() []string

func (*UpdateRequest) GetNewTableRow 

func (x *UpdateRequest) GetNewTableRow() *TableRow

func (*UpdateRequest) GetTablePrefixWithSchema 

func (x *UpdateRequest) GetTablePrefixWithSchema() string

func (*UpdateRequest) GetUserID 

func (x *UpdateRequest) GetUserID() string

func (*UpdateRequest) GetVersion 

func (x *UpdateRequest) GetVersion() string

func (*UpdateRequest) ProtoMessage 

func (*UpdateRequest) ProtoMessage()

func (*UpdateRequest) ProtoReflect 

func (x *UpdateRequest) ProtoReflect() protoreflect.Message

func (*UpdateRequest) Reset 

func (x *UpdateRequest) Reset()

func (*UpdateRequest) String 

func (x *UpdateRequest) String() string

func (*UpdateRequest) Validate 

func (this *UpdateRequest) Validate() error

type UpdateTxRequest 

type UpdateTxRequest struct {
	TablePrefixWithSchema string    `protobuf:"bytes,1,opt,name=TablePrefixWithSchema,proto3" json:"TablePrefixWithSchema,omitempty"`
	Version               string    `protobuf:"bytes,2,opt,name=Version,proto3" json:"Version,omitempty"`
	KeyColumns            []string  `protobuf:"bytes,3,rep,name=KeyColumns,proto3" json:"KeyColumns,omitempty"`
	KeyValues             []string  `protobuf:"bytes,4,rep,name=KeyValues,proto3" json:"KeyValues,omitempty"`
	NewTableRow           *TableRow `protobuf:"bytes,5,opt,name=NewTableRow,proto3" json:"NewTableRow,omitempty"`
	UserID                string    `protobuf:"bytes,6,opt,name=UserID,proto3" json:"UserID,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateTxRequest) Descriptor deprecated 

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

Deprecated: Use UpdateTxRequest.ProtoReflect.Descriptor instead.

func (*UpdateTxRequest) GetKeyColumns added in v1.8.0 

func (x *UpdateTxRequest) GetKeyColumns() []string

func (*UpdateTxRequest) GetKeyValues 

func (x *UpdateTxRequest) GetKeyValues() []string

func (*UpdateTxRequest) GetNewTableRow 

func (x *UpdateTxRequest) GetNewTableRow() *TableRow

func (*UpdateTxRequest) GetTablePrefixWithSchema 

func (x *UpdateTxRequest) GetTablePrefixWithSchema() string

func (*UpdateTxRequest) GetUserID 

func (x *UpdateTxRequest) GetUserID() string

func (*UpdateTxRequest) GetVersion 

func (x *UpdateTxRequest) GetVersion() string

func (*UpdateTxRequest) ProtoMessage 

func (*UpdateTxRequest) ProtoMessage()

func (*UpdateTxRequest) ProtoReflect 

func (x *UpdateTxRequest) ProtoReflect() protoreflect.Message

func (*UpdateTxRequest) Reset 

func (x *UpdateTxRequest) Reset()

func (*UpdateTxRequest) String 

func (x *UpdateTxRequest) String() string

func (*UpdateTxRequest) Validate 

func (this *UpdateTxRequest) Validate() error

type UpdateWhereRequest added in v1.7.0 

type UpdateWhereRequest struct {
	DatabaseID            string    `protobuf:"bytes,1,opt,name=DatabaseID,proto3" json:"DatabaseID,omitempty"`
	TablePrefixWithSchema string    `protobuf:"bytes,2,opt,name=TablePrefixWithSchema,proto3" json:"TablePrefixWithSchema,omitempty"`
	Version               string    `protobuf:"bytes,3,opt,name=Version,proto3" json:"Version,omitempty"`
	KeyColumns            []string  `protobuf:"bytes,4,rep,name=KeyColumns,proto3" json:"KeyColumns,omitempty"`
	Where                 []byte    `protobuf:"bytes,5,opt,name=Where,proto3" json:"Where,omitempty"`
	NewTableRow           *TableRow `protobuf:"bytes,6,opt,name=NewTableRow,proto3" json:"NewTableRow,omitempty"`
	UserID                string    `protobuf:"bytes,7,opt,name=UserID,proto3" json:"UserID,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateWhereRequest) Descriptor deprecated added in v1.7.0 

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

Deprecated: Use UpdateWhereRequest.ProtoReflect.Descriptor instead.

func (*UpdateWhereRequest) GetDatabaseID added in v1.7.0 

func (x *UpdateWhereRequest) GetDatabaseID() string

func (*UpdateWhereRequest) GetKeyColumns added in v1.7.0 

func (x *UpdateWhereRequest) GetKeyColumns() []string

func (*UpdateWhereRequest) GetNewTableRow added in v1.7.0 

func (x *UpdateWhereRequest) GetNewTableRow() *TableRow

func (*UpdateWhereRequest) GetTablePrefixWithSchema added in v1.7.0 

func (x *UpdateWhereRequest) GetTablePrefixWithSchema() string

func (*UpdateWhereRequest) GetUserID added in v1.7.0 

func (x *UpdateWhereRequest) GetUserID() string

func (*UpdateWhereRequest) GetVersion added in v1.7.0 

func (x *UpdateWhereRequest) GetVersion() string

func (*UpdateWhereRequest) GetWhere added in v1.7.0 

func (x *UpdateWhereRequest) GetWhere() []byte

func (*UpdateWhereRequest) ProtoMessage added in v1.7.0 

func (*UpdateWhereRequest) ProtoMessage()

func (*UpdateWhereRequest) ProtoReflect added in v1.7.0 

func (x *UpdateWhereRequest) ProtoReflect() protoreflect.Message

func (*UpdateWhereRequest) Reset added in v1.7.0 

func (x *UpdateWhereRequest) Reset()

func (*UpdateWhereRequest) String added in v1.7.0 

func (x *UpdateWhereRequest) String() string

func (*UpdateWhereRequest) Validate added in v1.7.0 

func (this *UpdateWhereRequest) Validate() error

type UpdateWhereTxRequest added in v1.7.0 

type UpdateWhereTxRequest struct {
	TablePrefixWithSchema string    `protobuf:"bytes,1,opt,name=TablePrefixWithSchema,proto3" json:"TablePrefixWithSchema,omitempty"`
	Version               string    `protobuf:"bytes,2,opt,name=Version,proto3" json:"Version,omitempty"`
	KeyColumns            []string  `protobuf:"bytes,3,rep,name=KeyColumns,proto3" json:"KeyColumns,omitempty"`
	Where                 []byte    `protobuf:"bytes,4,opt,name=Where,proto3" json:"Where,omitempty"`
	NewTableRow           *TableRow `protobuf:"bytes,5,opt,name=NewTableRow,proto3" json:"NewTableRow,omitempty"`
	UserID                string    `protobuf:"bytes,6,opt,name=UserID,proto3" json:"UserID,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateWhereTxRequest) Descriptor deprecated added in v1.7.0 

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

Deprecated: Use UpdateWhereTxRequest.ProtoReflect.Descriptor instead.

func (*UpdateWhereTxRequest) GetKeyColumns added in v1.7.0 

func (x *UpdateWhereTxRequest) GetKeyColumns() []string

func (*UpdateWhereTxRequest) GetNewTableRow added in v1.7.0 

func (x *UpdateWhereTxRequest) GetNewTableRow() *TableRow

func (*UpdateWhereTxRequest) GetTablePrefixWithSchema added in v1.7.0 

func (x *UpdateWhereTxRequest) GetTablePrefixWithSchema() string

func (*UpdateWhereTxRequest) GetUserID added in v1.7.0 

func (x *UpdateWhereTxRequest) GetUserID() string

func (*UpdateWhereTxRequest) GetVersion added in v1.7.0 

func (x *UpdateWhereTxRequest) GetVersion() string

func (*UpdateWhereTxRequest) GetWhere added in v1.7.0 

func (x *UpdateWhereTxRequest) GetWhere() []byte

func (*UpdateWhereTxRequest) ProtoMessage added in v1.7.0 

func (*UpdateWhereTxRequest) ProtoMessage()

func (*UpdateWhereTxRequest) ProtoReflect added in v1.7.0 

func (x *UpdateWhereTxRequest) ProtoReflect() protoreflect.Message

func (*UpdateWhereTxRequest) Reset added in v1.7.0 

func (x *UpdateWhereTxRequest) Reset()

func (*UpdateWhereTxRequest) String added in v1.7.0 

func (x *UpdateWhereTxRequest) String() string

func (*UpdateWhereTxRequest) Validate added in v1.7.0 

func (this *UpdateWhereTxRequest) Validate() 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.