Versions in this module Expand all Collapse all v0 v0.3.1 May 29, 2022 v0.3.0 May 29, 2022 Changes in this version + var Driver_ServiceDesc = grpc.ServiceDesc + var File_plugin_proto protoreflect.FileDescriptor + func RegisterDriverServer(s grpc.ServiceRegistrar, srv DriverServer) + type Column struct + Name string + Value *Value + func (*Column) Descriptor() ([]byte, []int) + func (*Column) ProtoMessage() + func (x *Column) GetName() string + func (x *Column) GetValue() *Value + func (x *Column) ProtoReflect() protoreflect.Message + func (x *Column) Reset() + func (x *Column) String() string + type DriverClient interface + CommitOrRollback func(ctx context.Context, in *TxnContext, opts ...grpc.CallOption) (*TxnContext, error) + Query func(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error) + func NewDriverClient(cc grpc.ClientConnInterface) DriverClient + type DriverServer interface + CommitOrRollback func(context.Context, *TxnContext) (*TxnContext, error) + Query func(context.Context, *Request) (*Response, error) + type NamedValue struct + Name string + Ordinal int64 + Value *Value + func (*NamedValue) Descriptor() ([]byte, []int) + func (*NamedValue) ProtoMessage() + func (x *NamedValue) GetName() string + func (x *NamedValue) GetOrdinal() int64 + func (x *NamedValue) GetValue() *Value + func (x *NamedValue) ProtoReflect() protoreflect.Message + func (x *NamedValue) Reset() + func (x *NamedValue) String() string + type Request struct + Args []*NamedValue + Query string + ReturnsRows bool + StartTs uint64 + Txn *TxnContext + func (*Request) Descriptor() ([]byte, []int) + func (*Request) ProtoMessage() + func (x *Request) GetArgs() []*NamedValue + func (x *Request) GetQuery() string + func (x *Request) GetReturnsRows() bool + func (x *Request) GetStartTs() uint64 + func (x *Request) GetTxn() *TxnContext + func (x *Request) ProtoReflect() protoreflect.Message + func (x *Request) Reset() + func (x *Request) String() string + type Response struct + Columns []string + LastInsertId int64 + Rows []*Row + RowsAffected int64 + Txn *TxnContext + func (*Response) Descriptor() ([]byte, []int) + func (*Response) ProtoMessage() + func (x *Response) GetColumns() []string + func (x *Response) GetLastInsertId() int64 + func (x *Response) GetRows() []*Row + func (x *Response) GetRowsAffected() int64 + func (x *Response) GetTxn() *TxnContext + func (x *Response) ProtoReflect() protoreflect.Message + func (x *Response) Reset() + func (x *Response) String() string + type Row struct + Columns []*Column + func (*Row) Descriptor() ([]byte, []int) + func (*Row) ProtoMessage() + func (x *Row) GetColumns() []*Column + func (x *Row) ProtoReflect() protoreflect.Message + func (x *Row) Reset() + func (x *Row) String() string + type TxnContext struct + Aborted bool + CommitTs int64 + Committed bool + Isolation int64 + ReadOnly bool + StartTs int64 + func (*TxnContext) Descriptor() ([]byte, []int) + func (*TxnContext) ProtoMessage() + func (x *TxnContext) GetAborted() bool + func (x *TxnContext) GetCommitTs() int64 + func (x *TxnContext) GetCommitted() bool + func (x *TxnContext) GetIsolation() int64 + func (x *TxnContext) GetReadOnly() bool + func (x *TxnContext) GetStartTs() int64 + func (x *TxnContext) ProtoReflect() protoreflect.Message + func (x *TxnContext) Reset() + func (x *TxnContext) String() string + type UnimplementedDriverServer struct + func (UnimplementedDriverServer) CommitOrRollback(context.Context, *TxnContext) (*TxnContext, error) + func (UnimplementedDriverServer) Query(context.Context, *Request) (*Response, error) + type UnsafeDriverServer interface + type Value struct + Value isValue_Value + func (*Value) Descriptor() ([]byte, []int) + func (*Value) ProtoMessage() + func (m *Value) GetValue() isValue_Value + func (x *Value) GetBool() bool + func (x *Value) GetBytes() []byte + func (x *Value) GetFloat64() float64 + func (x *Value) GetInt64() int64 + func (x *Value) GetNull() bool + func (x *Value) GetString_() string + func (x *Value) GetTime() *timestamppb.Timestamp + func (x *Value) ProtoReflect() protoreflect.Message + func (x *Value) Reset() + func (x *Value) String() string + type Value_Bool struct + Bool bool + type Value_Bytes struct + Bytes []byte + type Value_Float64 struct + Float64 float64 + type Value_Int64 struct + Int64 int64 + type Value_Null struct + Null bool + type Value_String_ struct + String_ string + type Value_Time struct + Time *timestamppb.Timestamp
Go to main page