Documentation ¶
Index ¶
- Variables
- type BackupRequest
- func (*BackupRequest) Descriptor() ([]byte, []int)deprecated
- func (x *BackupRequest) GetCompress() bool
- func (x *BackupRequest) GetFormat() BackupRequest_Format
- func (x *BackupRequest) GetLeader() bool
- func (x *BackupRequest) GetVacuum() bool
- func (*BackupRequest) ProtoMessage()
- func (x *BackupRequest) ProtoReflect() protoreflect.Message
- func (x *BackupRequest) Reset()
- func (x *BackupRequest) String() string
- type BackupRequest_Format
- func (BackupRequest_Format) Descriptor() protoreflect.EnumDescriptor
- func (x BackupRequest_Format) Enum() *BackupRequest_Format
- func (BackupRequest_Format) EnumDescriptor() ([]byte, []int)deprecated
- func (x BackupRequest_Format) Number() protoreflect.EnumNumber
- func (x BackupRequest_Format) String() string
- func (BackupRequest_Format) Type() protoreflect.EnumType
- type Command
- func (*Command) Descriptor() ([]byte, []int)deprecated
- func (x *Command) GetCompressed() bool
- func (x *Command) GetSubCommand() []byte
- func (x *Command) GetType() Command_Type
- func (*Command) ProtoMessage()
- func (x *Command) ProtoReflect() protoreflect.Message
- func (x *Command) Reset()
- func (x *Command) String() string
- type Command_Type
- func (Command_Type) Descriptor() protoreflect.EnumDescriptor
- func (x Command_Type) Enum() *Command_Type
- func (Command_Type) EnumDescriptor() ([]byte, []int)deprecated
- func (x Command_Type) Number() protoreflect.EnumNumber
- func (x Command_Type) String() string
- func (Command_Type) Type() protoreflect.EnumType
- type ExecuteQueryRequest
- func (*ExecuteQueryRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ExecuteQueryRequest) GetFreshness() int64
- func (x *ExecuteQueryRequest) GetFreshnessStrict() bool
- func (x *ExecuteQueryRequest) GetLevel() QueryRequest_Level
- func (x *ExecuteQueryRequest) GetRequest() *Request
- func (x *ExecuteQueryRequest) GetTimings() bool
- func (*ExecuteQueryRequest) ProtoMessage()
- func (x *ExecuteQueryRequest) ProtoReflect() protoreflect.Message
- func (x *ExecuteQueryRequest) Reset()
- func (x *ExecuteQueryRequest) String() string
- type ExecuteQueryResponse
- func (*ExecuteQueryResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ExecuteQueryResponse) GetE() *ExecuteResult
- func (x *ExecuteQueryResponse) GetError() string
- func (x *ExecuteQueryResponse) GetQ() *QueryRows
- func (m *ExecuteQueryResponse) GetResult() isExecuteQueryResponse_Result
- func (*ExecuteQueryResponse) ProtoMessage()
- func (x *ExecuteQueryResponse) ProtoReflect() protoreflect.Message
- func (x *ExecuteQueryResponse) Reset()
- func (x *ExecuteQueryResponse) String() string
- type ExecuteQueryResponse_E
- type ExecuteQueryResponse_Error
- type ExecuteQueryResponse_Q
- type ExecuteRequest
- func (*ExecuteRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ExecuteRequest) GetRequest() *Request
- func (x *ExecuteRequest) GetTimings() bool
- func (*ExecuteRequest) ProtoMessage()
- func (x *ExecuteRequest) ProtoReflect() protoreflect.Message
- func (x *ExecuteRequest) Reset()
- func (x *ExecuteRequest) String() string
- type ExecuteResult
- func (*ExecuteResult) Descriptor() ([]byte, []int)deprecated
- func (x *ExecuteResult) GetError() string
- func (x *ExecuteResult) GetLastInsertId() int64
- func (x *ExecuteResult) GetRowsAffected() int64
- func (x *ExecuteResult) GetTime() float64
- func (*ExecuteResult) ProtoMessage()
- func (x *ExecuteResult) ProtoReflect() protoreflect.Message
- func (x *ExecuteResult) Reset()
- func (x *ExecuteResult) String() string
- type JoinRequest
- func (*JoinRequest) Descriptor() ([]byte, []int)deprecated
- func (x *JoinRequest) GetAddress() string
- func (x *JoinRequest) GetId() string
- func (x *JoinRequest) GetVoter() bool
- func (*JoinRequest) ProtoMessage()
- func (x *JoinRequest) ProtoReflect() protoreflect.Message
- func (x *JoinRequest) Reset()
- func (x *JoinRequest) String() string
- type LoadChunkRequest
- func (*LoadChunkRequest) Descriptor() ([]byte, []int)deprecated
- func (x *LoadChunkRequest) GetAbort() bool
- func (x *LoadChunkRequest) GetData() []byte
- func (x *LoadChunkRequest) GetIsLast() bool
- func (x *LoadChunkRequest) GetSequenceNum() int64
- func (x *LoadChunkRequest) GetStreamId() string
- func (*LoadChunkRequest) ProtoMessage()
- func (x *LoadChunkRequest) ProtoReflect() protoreflect.Message
- func (x *LoadChunkRequest) Reset()
- func (x *LoadChunkRequest) String() string
- type LoadRequest
- type Noop
- type NotifyRequest
- func (*NotifyRequest) Descriptor() ([]byte, []int)deprecated
- func (x *NotifyRequest) GetAddress() string
- func (x *NotifyRequest) GetId() string
- func (*NotifyRequest) ProtoMessage()
- func (x *NotifyRequest) ProtoReflect() protoreflect.Message
- func (x *NotifyRequest) Reset()
- func (x *NotifyRequest) String() string
- type Parameter
- func (*Parameter) Descriptor() ([]byte, []int)deprecated
- func (x *Parameter) GetB() bool
- func (x *Parameter) GetD() float64
- func (x *Parameter) GetI() int64
- func (x *Parameter) GetName() string
- func (x *Parameter) GetS() string
- func (m *Parameter) GetValue() isParameter_Value
- func (x *Parameter) GetY() []byte
- func (*Parameter) ProtoMessage()
- func (x *Parameter) ProtoReflect() protoreflect.Message
- func (x *Parameter) Reset()
- func (x *Parameter) String() string
- type Parameter_B
- type Parameter_D
- type Parameter_I
- type Parameter_S
- type Parameter_Y
- type QueryRequest
- func (*QueryRequest) Descriptor() ([]byte, []int)deprecated
- func (x *QueryRequest) GetFreshness() int64
- func (x *QueryRequest) GetFreshnessStrict() bool
- func (x *QueryRequest) GetLevel() QueryRequest_Level
- func (x *QueryRequest) GetRequest() *Request
- func (x *QueryRequest) GetTimings() bool
- func (*QueryRequest) ProtoMessage()
- func (x *QueryRequest) ProtoReflect() protoreflect.Message
- func (x *QueryRequest) Reset()
- func (x *QueryRequest) String() string
- type QueryRequest_Level
- func (QueryRequest_Level) Descriptor() protoreflect.EnumDescriptor
- func (x QueryRequest_Level) Enum() *QueryRequest_Level
- func (QueryRequest_Level) EnumDescriptor() ([]byte, []int)deprecated
- func (x QueryRequest_Level) Number() protoreflect.EnumNumber
- func (x QueryRequest_Level) String() string
- func (QueryRequest_Level) Type() protoreflect.EnumType
- type QueryRows
- func (*QueryRows) Descriptor() ([]byte, []int)deprecated
- func (x *QueryRows) GetColumns() []string
- func (x *QueryRows) GetError() string
- func (x *QueryRows) GetTime() float64
- func (x *QueryRows) GetTypes() []string
- func (x *QueryRows) GetValues() []*Values
- func (*QueryRows) ProtoMessage()
- func (x *QueryRows) ProtoReflect() protoreflect.Message
- func (x *QueryRows) Reset()
- func (x *QueryRows) String() string
- type RemoveNodeRequest
- type Request
- func (*Request) Descriptor() ([]byte, []int)deprecated
- func (x *Request) GetDbTimeout() int64
- func (x *Request) GetStatements() []*Statement
- func (x *Request) GetTransaction() bool
- func (*Request) ProtoMessage()
- func (x *Request) ProtoReflect() protoreflect.Message
- func (x *Request) Reset()
- func (x *Request) String() string
- type Statement
- func (*Statement) Descriptor() ([]byte, []int)deprecated
- func (x *Statement) GetForceQuery() bool
- func (x *Statement) GetParameters() []*Parameter
- func (x *Statement) GetSql() string
- func (*Statement) ProtoMessage()
- func (x *Statement) ProtoReflect() protoreflect.Message
- func (x *Statement) Reset()
- func (x *Statement) String() string
- type Values
Constants ¶
This section is empty.
Variables ¶
var ( QueryRequest_Level_name = map[int32]string{ 0: "QUERY_REQUEST_LEVEL_NONE", 1: "QUERY_REQUEST_LEVEL_WEAK", 2: "QUERY_REQUEST_LEVEL_STRONG", } QueryRequest_Level_value = map[string]int32{ "QUERY_REQUEST_LEVEL_NONE": 0, "QUERY_REQUEST_LEVEL_WEAK": 1, "QUERY_REQUEST_LEVEL_STRONG": 2, } )
Enum value maps for QueryRequest_Level.
var ( BackupRequest_Format_name = map[int32]string{ 0: "BACKUP_REQUEST_FORMAT_NONE", 1: "BACKUP_REQUEST_FORMAT_SQL", 2: "BACKUP_REQUEST_FORMAT_BINARY", } BackupRequest_Format_value = map[string]int32{ "BACKUP_REQUEST_FORMAT_NONE": 0, "BACKUP_REQUEST_FORMAT_SQL": 1, "BACKUP_REQUEST_FORMAT_BINARY": 2, } )
Enum value maps for BackupRequest_Format.
var ( Command_Type_name = map[int32]string{ 0: "COMMAND_TYPE_UNKNOWN", 1: "COMMAND_TYPE_QUERY", 2: "COMMAND_TYPE_EXECUTE", 3: "COMMAND_TYPE_NOOP", 4: "COMMAND_TYPE_LOAD", 5: "COMMAND_TYPE_JOIN", 6: "COMMAND_TYPE_EXECUTE_QUERY", 7: "COMMAND_TYPE_LOAD_CHUNK", } Command_Type_value = map[string]int32{ "COMMAND_TYPE_UNKNOWN": 0, "COMMAND_TYPE_QUERY": 1, "COMMAND_TYPE_EXECUTE": 2, "COMMAND_TYPE_NOOP": 3, "COMMAND_TYPE_LOAD": 4, "COMMAND_TYPE_JOIN": 5, "COMMAND_TYPE_EXECUTE_QUERY": 6, "COMMAND_TYPE_LOAD_CHUNK": 7, } )
Enum value maps for Command_Type.
var File_command_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type BackupRequest ¶
type BackupRequest struct { Format BackupRequest_Format `protobuf:"varint,1,opt,name=format,proto3,enum=command.BackupRequest_Format" json:"format,omitempty"` Leader bool `protobuf:"varint,2,opt,name=Leader,proto3" json:"Leader,omitempty"` Vacuum bool `protobuf:"varint,3,opt,name=Vacuum,proto3" json:"Vacuum,omitempty"` Compress bool `protobuf:"varint,4,opt,name=Compress,proto3" json:"Compress,omitempty"` // contains filtered or unexported fields }
func (*BackupRequest) Descriptor
deprecated
func (*BackupRequest) Descriptor() ([]byte, []int)
Deprecated: Use BackupRequest.ProtoReflect.Descriptor instead.
func (*BackupRequest) GetCompress ¶ added in v8.16.0
func (x *BackupRequest) GetCompress() bool
func (*BackupRequest) GetFormat ¶
func (x *BackupRequest) GetFormat() BackupRequest_Format
func (*BackupRequest) GetLeader ¶
func (x *BackupRequest) GetLeader() bool
func (*BackupRequest) GetVacuum ¶
func (x *BackupRequest) GetVacuum() bool
func (*BackupRequest) ProtoMessage ¶
func (*BackupRequest) ProtoMessage()
func (*BackupRequest) ProtoReflect ¶
func (x *BackupRequest) ProtoReflect() protoreflect.Message
func (*BackupRequest) Reset ¶
func (x *BackupRequest) Reset()
func (*BackupRequest) String ¶
func (x *BackupRequest) String() string
type BackupRequest_Format ¶
type BackupRequest_Format int32
const ( BackupRequest_BACKUP_REQUEST_FORMAT_NONE BackupRequest_Format = 0 BackupRequest_BACKUP_REQUEST_FORMAT_SQL BackupRequest_Format = 1 BackupRequest_BACKUP_REQUEST_FORMAT_BINARY BackupRequest_Format = 2 )
func (BackupRequest_Format) Descriptor ¶
func (BackupRequest_Format) Descriptor() protoreflect.EnumDescriptor
func (BackupRequest_Format) Enum ¶
func (x BackupRequest_Format) Enum() *BackupRequest_Format
func (BackupRequest_Format) EnumDescriptor
deprecated
func (BackupRequest_Format) EnumDescriptor() ([]byte, []int)
Deprecated: Use BackupRequest_Format.Descriptor instead.
func (BackupRequest_Format) Number ¶
func (x BackupRequest_Format) Number() protoreflect.EnumNumber
func (BackupRequest_Format) String ¶
func (x BackupRequest_Format) String() string
func (BackupRequest_Format) Type ¶
func (BackupRequest_Format) Type() protoreflect.EnumType
type Command ¶
type Command struct { Type Command_Type `protobuf:"varint,1,opt,name=type,proto3,enum=command.Command_Type" json:"type,omitempty"` SubCommand []byte `protobuf:"bytes,2,opt,name=sub_command,json=subCommand,proto3" json:"sub_command,omitempty"` Compressed bool `protobuf:"varint,3,opt,name=compressed,proto3" json:"compressed,omitempty"` // contains filtered or unexported fields }
func (*Command) Descriptor
deprecated
func (*Command) GetCompressed ¶
func (*Command) GetSubCommand ¶
func (*Command) GetType ¶
func (x *Command) GetType() Command_Type
func (*Command) ProtoMessage ¶
func (*Command) ProtoMessage()
func (*Command) ProtoReflect ¶
func (x *Command) ProtoReflect() protoreflect.Message
type Command_Type ¶
type Command_Type int32
const ( Command_COMMAND_TYPE_UNKNOWN Command_Type = 0 Command_COMMAND_TYPE_QUERY Command_Type = 1 Command_COMMAND_TYPE_EXECUTE Command_Type = 2 Command_COMMAND_TYPE_NOOP Command_Type = 3 Command_COMMAND_TYPE_LOAD Command_Type = 4 Command_COMMAND_TYPE_JOIN Command_Type = 5 Command_COMMAND_TYPE_EXECUTE_QUERY Command_Type = 6 Command_COMMAND_TYPE_LOAD_CHUNK Command_Type = 7 )
func (Command_Type) Descriptor ¶
func (Command_Type) Descriptor() protoreflect.EnumDescriptor
func (Command_Type) Enum ¶
func (x Command_Type) Enum() *Command_Type
func (Command_Type) EnumDescriptor
deprecated
func (Command_Type) EnumDescriptor() ([]byte, []int)
Deprecated: Use Command_Type.Descriptor instead.
func (Command_Type) Number ¶
func (x Command_Type) Number() protoreflect.EnumNumber
func (Command_Type) String ¶
func (x Command_Type) String() string
func (Command_Type) Type ¶
func (Command_Type) Type() protoreflect.EnumType
type ExecuteQueryRequest ¶
type ExecuteQueryRequest struct { Request *Request `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"` Timings bool `protobuf:"varint,2,opt,name=timings,proto3" json:"timings,omitempty"` Level QueryRequest_Level `protobuf:"varint,3,opt,name=level,proto3,enum=command.QueryRequest_Level" json:"level,omitempty"` Freshness int64 `protobuf:"varint,4,opt,name=freshness,proto3" json:"freshness,omitempty"` FreshnessStrict bool `protobuf:"varint,5,opt,name=freshness_strict,json=freshnessStrict,proto3" json:"freshness_strict,omitempty"` // contains filtered or unexported fields }
func (*ExecuteQueryRequest) Descriptor
deprecated
func (*ExecuteQueryRequest) Descriptor() ([]byte, []int)
Deprecated: Use ExecuteQueryRequest.ProtoReflect.Descriptor instead.
func (*ExecuteQueryRequest) GetFreshness ¶
func (x *ExecuteQueryRequest) GetFreshness() int64
func (*ExecuteQueryRequest) GetFreshnessStrict ¶ added in v8.20.0
func (x *ExecuteQueryRequest) GetFreshnessStrict() bool
func (*ExecuteQueryRequest) GetLevel ¶
func (x *ExecuteQueryRequest) GetLevel() QueryRequest_Level
func (*ExecuteQueryRequest) GetRequest ¶
func (x *ExecuteQueryRequest) GetRequest() *Request
func (*ExecuteQueryRequest) GetTimings ¶
func (x *ExecuteQueryRequest) GetTimings() bool
func (*ExecuteQueryRequest) ProtoMessage ¶
func (*ExecuteQueryRequest) ProtoMessage()
func (*ExecuteQueryRequest) ProtoReflect ¶
func (x *ExecuteQueryRequest) ProtoReflect() protoreflect.Message
func (*ExecuteQueryRequest) Reset ¶
func (x *ExecuteQueryRequest) Reset()
func (*ExecuteQueryRequest) String ¶
func (x *ExecuteQueryRequest) String() string
type ExecuteQueryResponse ¶
type ExecuteQueryResponse struct { // Types that are assignable to Result: // // *ExecuteQueryResponse_Q // *ExecuteQueryResponse_E // *ExecuteQueryResponse_Error Result isExecuteQueryResponse_Result `protobuf_oneof:"result"` // contains filtered or unexported fields }
func (*ExecuteQueryResponse) Descriptor
deprecated
func (*ExecuteQueryResponse) Descriptor() ([]byte, []int)
Deprecated: Use ExecuteQueryResponse.ProtoReflect.Descriptor instead.
func (*ExecuteQueryResponse) GetE ¶
func (x *ExecuteQueryResponse) GetE() *ExecuteResult
func (*ExecuteQueryResponse) GetError ¶
func (x *ExecuteQueryResponse) GetError() string
func (*ExecuteQueryResponse) GetQ ¶
func (x *ExecuteQueryResponse) GetQ() *QueryRows
func (*ExecuteQueryResponse) GetResult ¶
func (m *ExecuteQueryResponse) GetResult() isExecuteQueryResponse_Result
func (*ExecuteQueryResponse) ProtoMessage ¶
func (*ExecuteQueryResponse) ProtoMessage()
func (*ExecuteQueryResponse) ProtoReflect ¶
func (x *ExecuteQueryResponse) ProtoReflect() protoreflect.Message
func (*ExecuteQueryResponse) Reset ¶
func (x *ExecuteQueryResponse) Reset()
func (*ExecuteQueryResponse) String ¶
func (x *ExecuteQueryResponse) String() string
type ExecuteQueryResponse_E ¶
type ExecuteQueryResponse_E struct {
E *ExecuteResult `protobuf:"bytes,2,opt,name=e,proto3,oneof"`
}
type ExecuteQueryResponse_Error ¶
type ExecuteQueryResponse_Error struct {
Error string `protobuf:"bytes,3,opt,name=error,proto3,oneof"`
}
type ExecuteQueryResponse_Q ¶
type ExecuteQueryResponse_Q struct {
Q *QueryRows `protobuf:"bytes,1,opt,name=q,proto3,oneof"`
}
type ExecuteRequest ¶
type ExecuteRequest struct { Request *Request `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"` Timings bool `protobuf:"varint,2,opt,name=timings,proto3" json:"timings,omitempty"` // contains filtered or unexported fields }
func (*ExecuteRequest) Descriptor
deprecated
func (*ExecuteRequest) Descriptor() ([]byte, []int)
Deprecated: Use ExecuteRequest.ProtoReflect.Descriptor instead.
func (*ExecuteRequest) GetRequest ¶
func (x *ExecuteRequest) GetRequest() *Request
func (*ExecuteRequest) GetTimings ¶
func (x *ExecuteRequest) GetTimings() bool
func (*ExecuteRequest) ProtoMessage ¶
func (*ExecuteRequest) ProtoMessage()
func (*ExecuteRequest) ProtoReflect ¶
func (x *ExecuteRequest) ProtoReflect() protoreflect.Message
func (*ExecuteRequest) Reset ¶
func (x *ExecuteRequest) Reset()
func (*ExecuteRequest) String ¶
func (x *ExecuteRequest) String() string
type ExecuteResult ¶
type ExecuteResult struct { LastInsertId int64 `protobuf:"varint,1,opt,name=last_insert_id,json=lastInsertId,proto3" json:"last_insert_id,omitempty"` RowsAffected int64 `protobuf:"varint,2,opt,name=rows_affected,json=rowsAffected,proto3" json:"rows_affected,omitempty"` Error string `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"` Time float64 `protobuf:"fixed64,4,opt,name=time,proto3" json:"time,omitempty"` // contains filtered or unexported fields }
func (*ExecuteResult) Descriptor
deprecated
func (*ExecuteResult) Descriptor() ([]byte, []int)
Deprecated: Use ExecuteResult.ProtoReflect.Descriptor instead.
func (*ExecuteResult) GetError ¶
func (x *ExecuteResult) GetError() string
func (*ExecuteResult) GetLastInsertId ¶
func (x *ExecuteResult) GetLastInsertId() int64
func (*ExecuteResult) GetRowsAffected ¶
func (x *ExecuteResult) GetRowsAffected() int64
func (*ExecuteResult) GetTime ¶
func (x *ExecuteResult) GetTime() float64
func (*ExecuteResult) ProtoMessage ¶
func (*ExecuteResult) ProtoMessage()
func (*ExecuteResult) ProtoReflect ¶
func (x *ExecuteResult) ProtoReflect() protoreflect.Message
func (*ExecuteResult) Reset ¶
func (x *ExecuteResult) Reset()
func (*ExecuteResult) String ¶
func (x *ExecuteResult) String() string
type JoinRequest ¶
type JoinRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"` Voter bool `protobuf:"varint,3,opt,name=voter,proto3" json:"voter,omitempty"` // contains filtered or unexported fields }
func (*JoinRequest) Descriptor
deprecated
func (*JoinRequest) Descriptor() ([]byte, []int)
Deprecated: Use JoinRequest.ProtoReflect.Descriptor instead.
func (*JoinRequest) GetAddress ¶
func (x *JoinRequest) GetAddress() string
func (*JoinRequest) GetId ¶
func (x *JoinRequest) GetId() string
func (*JoinRequest) GetVoter ¶
func (x *JoinRequest) GetVoter() bool
func (*JoinRequest) ProtoMessage ¶
func (*JoinRequest) ProtoMessage()
func (*JoinRequest) ProtoReflect ¶
func (x *JoinRequest) ProtoReflect() protoreflect.Message
func (*JoinRequest) Reset ¶
func (x *JoinRequest) Reset()
func (*JoinRequest) String ¶
func (x *JoinRequest) String() string
type LoadChunkRequest ¶
type LoadChunkRequest struct { StreamId string `protobuf:"bytes,1,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"` SequenceNum int64 `protobuf:"varint,2,opt,name=sequence_num,json=sequenceNum,proto3" json:"sequence_num,omitempty"` IsLast bool `protobuf:"varint,3,opt,name=is_last,json=isLast,proto3" json:"is_last,omitempty"` Data []byte `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"` Abort bool `protobuf:"varint,5,opt,name=abort,proto3" json:"abort,omitempty"` // contains filtered or unexported fields }
func (*LoadChunkRequest) Descriptor
deprecated
func (*LoadChunkRequest) Descriptor() ([]byte, []int)
Deprecated: Use LoadChunkRequest.ProtoReflect.Descriptor instead.
func (*LoadChunkRequest) GetAbort ¶
func (x *LoadChunkRequest) GetAbort() bool
func (*LoadChunkRequest) GetData ¶
func (x *LoadChunkRequest) GetData() []byte
func (*LoadChunkRequest) GetIsLast ¶
func (x *LoadChunkRequest) GetIsLast() bool
func (*LoadChunkRequest) GetSequenceNum ¶
func (x *LoadChunkRequest) GetSequenceNum() int64
func (*LoadChunkRequest) GetStreamId ¶
func (x *LoadChunkRequest) GetStreamId() string
func (*LoadChunkRequest) ProtoMessage ¶
func (*LoadChunkRequest) ProtoMessage()
func (*LoadChunkRequest) ProtoReflect ¶
func (x *LoadChunkRequest) ProtoReflect() protoreflect.Message
func (*LoadChunkRequest) Reset ¶
func (x *LoadChunkRequest) Reset()
func (*LoadChunkRequest) String ¶
func (x *LoadChunkRequest) String() string
type LoadRequest ¶
type LoadRequest struct { Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"` // contains filtered or unexported fields }
func (*LoadRequest) Descriptor
deprecated
func (*LoadRequest) Descriptor() ([]byte, []int)
Deprecated: Use LoadRequest.ProtoReflect.Descriptor instead.
func (*LoadRequest) GetData ¶
func (x *LoadRequest) GetData() []byte
func (*LoadRequest) ProtoMessage ¶
func (*LoadRequest) ProtoMessage()
func (*LoadRequest) ProtoReflect ¶
func (x *LoadRequest) ProtoReflect() protoreflect.Message
func (*LoadRequest) Reset ¶
func (x *LoadRequest) Reset()
func (*LoadRequest) String ¶
func (x *LoadRequest) String() string
type Noop ¶
type Noop struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
func (*Noop) Descriptor
deprecated
func (*Noop) ProtoMessage ¶
func (*Noop) ProtoMessage()
func (*Noop) ProtoReflect ¶
func (x *Noop) ProtoReflect() protoreflect.Message
type NotifyRequest ¶
type NotifyRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"` // contains filtered or unexported fields }
func (*NotifyRequest) Descriptor
deprecated
func (*NotifyRequest) Descriptor() ([]byte, []int)
Deprecated: Use NotifyRequest.ProtoReflect.Descriptor instead.
func (*NotifyRequest) GetAddress ¶
func (x *NotifyRequest) GetAddress() string
func (*NotifyRequest) GetId ¶
func (x *NotifyRequest) GetId() string
func (*NotifyRequest) ProtoMessage ¶
func (*NotifyRequest) ProtoMessage()
func (*NotifyRequest) ProtoReflect ¶
func (x *NotifyRequest) ProtoReflect() protoreflect.Message
func (*NotifyRequest) Reset ¶
func (x *NotifyRequest) Reset()
func (*NotifyRequest) String ¶
func (x *NotifyRequest) String() string
type Parameter ¶
type Parameter struct { // Types that are assignable to Value: // // *Parameter_I // *Parameter_D // *Parameter_B // *Parameter_Y // *Parameter_S Value isParameter_Value `protobuf_oneof:"value"` Name string `protobuf:"bytes,6,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
func (*Parameter) Descriptor
deprecated
func (*Parameter) ProtoMessage ¶
func (*Parameter) ProtoMessage()
func (*Parameter) ProtoReflect ¶
func (x *Parameter) ProtoReflect() protoreflect.Message
type Parameter_B ¶
type Parameter_B struct {
B bool `protobuf:"varint,3,opt,name=b,proto3,oneof"`
}
type Parameter_D ¶
type Parameter_D struct {
D float64 `protobuf:"fixed64,2,opt,name=d,proto3,oneof"`
}
type Parameter_I ¶
type Parameter_I struct {
I int64 `protobuf:"zigzag64,1,opt,name=i,proto3,oneof"`
}
type Parameter_S ¶
type Parameter_S struct {
S string `protobuf:"bytes,5,opt,name=s,proto3,oneof"`
}
type Parameter_Y ¶
type Parameter_Y struct {
Y []byte `protobuf:"bytes,4,opt,name=y,proto3,oneof"`
}
type QueryRequest ¶
type QueryRequest struct { Request *Request `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"` Timings bool `protobuf:"varint,2,opt,name=timings,proto3" json:"timings,omitempty"` Level QueryRequest_Level `protobuf:"varint,3,opt,name=level,proto3,enum=command.QueryRequest_Level" json:"level,omitempty"` Freshness int64 `protobuf:"varint,4,opt,name=freshness,proto3" json:"freshness,omitempty"` FreshnessStrict bool `protobuf:"varint,5,opt,name=freshness_strict,json=freshnessStrict,proto3" json:"freshness_strict,omitempty"` // contains filtered or unexported fields }
func (*QueryRequest) Descriptor
deprecated
func (*QueryRequest) Descriptor() ([]byte, []int)
Deprecated: Use QueryRequest.ProtoReflect.Descriptor instead.
func (*QueryRequest) GetFreshness ¶
func (x *QueryRequest) GetFreshness() int64
func (*QueryRequest) GetFreshnessStrict ¶ added in v8.20.0
func (x *QueryRequest) GetFreshnessStrict() bool
func (*QueryRequest) GetLevel ¶
func (x *QueryRequest) GetLevel() QueryRequest_Level
func (*QueryRequest) GetRequest ¶
func (x *QueryRequest) GetRequest() *Request
func (*QueryRequest) GetTimings ¶
func (x *QueryRequest) GetTimings() bool
func (*QueryRequest) ProtoMessage ¶
func (*QueryRequest) ProtoMessage()
func (*QueryRequest) ProtoReflect ¶
func (x *QueryRequest) ProtoReflect() protoreflect.Message
func (*QueryRequest) Reset ¶
func (x *QueryRequest) Reset()
func (*QueryRequest) String ¶
func (x *QueryRequest) String() string
type QueryRequest_Level ¶
type QueryRequest_Level int32
const ( QueryRequest_QUERY_REQUEST_LEVEL_NONE QueryRequest_Level = 0 QueryRequest_QUERY_REQUEST_LEVEL_WEAK QueryRequest_Level = 1 QueryRequest_QUERY_REQUEST_LEVEL_STRONG QueryRequest_Level = 2 )
func (QueryRequest_Level) Descriptor ¶
func (QueryRequest_Level) Descriptor() protoreflect.EnumDescriptor
func (QueryRequest_Level) Enum ¶
func (x QueryRequest_Level) Enum() *QueryRequest_Level
func (QueryRequest_Level) EnumDescriptor
deprecated
func (QueryRequest_Level) EnumDescriptor() ([]byte, []int)
Deprecated: Use QueryRequest_Level.Descriptor instead.
func (QueryRequest_Level) Number ¶
func (x QueryRequest_Level) Number() protoreflect.EnumNumber
func (QueryRequest_Level) String ¶
func (x QueryRequest_Level) String() string
func (QueryRequest_Level) Type ¶
func (QueryRequest_Level) Type() protoreflect.EnumType
type QueryRows ¶
type QueryRows struct { Columns []string `protobuf:"bytes,1,rep,name=columns,proto3" json:"columns,omitempty"` Types []string `protobuf:"bytes,2,rep,name=types,proto3" json:"types,omitempty"` Values []*Values `protobuf:"bytes,3,rep,name=values,proto3" json:"values,omitempty"` Error string `protobuf:"bytes,4,opt,name=error,proto3" json:"error,omitempty"` Time float64 `protobuf:"fixed64,5,opt,name=time,proto3" json:"time,omitempty"` // contains filtered or unexported fields }
func (*QueryRows) Descriptor
deprecated
func (*QueryRows) GetColumns ¶
func (*QueryRows) ProtoMessage ¶
func (*QueryRows) ProtoMessage()
func (*QueryRows) ProtoReflect ¶
func (x *QueryRows) ProtoReflect() protoreflect.Message
type RemoveNodeRequest ¶
type RemoveNodeRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
func (*RemoveNodeRequest) Descriptor
deprecated
func (*RemoveNodeRequest) Descriptor() ([]byte, []int)
Deprecated: Use RemoveNodeRequest.ProtoReflect.Descriptor instead.
func (*RemoveNodeRequest) GetId ¶
func (x *RemoveNodeRequest) GetId() string
func (*RemoveNodeRequest) ProtoMessage ¶
func (*RemoveNodeRequest) ProtoMessage()
func (*RemoveNodeRequest) ProtoReflect ¶
func (x *RemoveNodeRequest) ProtoReflect() protoreflect.Message
func (*RemoveNodeRequest) Reset ¶
func (x *RemoveNodeRequest) Reset()
func (*RemoveNodeRequest) String ¶
func (x *RemoveNodeRequest) String() string
type Request ¶
type Request struct { Transaction bool `protobuf:"varint,1,opt,name=transaction,proto3" json:"transaction,omitempty"` Statements []*Statement `protobuf:"bytes,2,rep,name=statements,proto3" json:"statements,omitempty"` DbTimeout int64 `protobuf:"varint,3,opt,name=dbTimeout,proto3" json:"dbTimeout,omitempty"` // contains filtered or unexported fields }
func (*Request) Descriptor
deprecated
func (*Request) GetDbTimeout ¶ added in v8.19.0
func (*Request) GetStatements ¶
func (*Request) GetTransaction ¶
func (*Request) ProtoMessage ¶
func (*Request) ProtoMessage()
func (*Request) ProtoReflect ¶
func (x *Request) ProtoReflect() protoreflect.Message
type Statement ¶
type Statement struct { Sql string `protobuf:"bytes,1,opt,name=sql,proto3" json:"sql,omitempty"` Parameters []*Parameter `protobuf:"bytes,2,rep,name=parameters,proto3" json:"parameters,omitempty"` ForceQuery bool `protobuf:"varint,3,opt,name=forceQuery,proto3" json:"forceQuery,omitempty"` // contains filtered or unexported fields }
func (*Statement) Descriptor
deprecated
func (*Statement) GetForceQuery ¶ added in v8.23.0
func (*Statement) GetParameters ¶
func (*Statement) ProtoMessage ¶
func (*Statement) ProtoMessage()
func (*Statement) ProtoReflect ¶
func (x *Statement) ProtoReflect() protoreflect.Message
type Values ¶
type Values struct { Parameters []*Parameter `protobuf:"bytes,1,rep,name=parameters,proto3" json:"parameters,omitempty"` // contains filtered or unexported fields }
func (*Values) Descriptor
deprecated
func (*Values) GetParameters ¶
func (*Values) ProtoMessage ¶
func (*Values) ProtoMessage()
func (*Values) ProtoReflect ¶
func (x *Values) ProtoReflect() protoreflect.Message