kvdbrpc

package

Go to main page

Versions in this module

v0

v0.2.15

Mar 15, 2024

v0.2.14

Mar 15, 2024

v0.2.13

Mar 15, 2024

v0.2.12

Mar 14, 2024

v0.2.11

Mar 11, 2024

v0.2.10

Mar 9, 2024

Changes in this version

+ const Kvdb_AddIndex_FullMethodName

+ const Kvdb_AddKeys_FullMethodName

+ const Kvdb_CountWhere_FullMethodName

+ const Kvdb_CreateDatabase_FullMethodName

+ const Kvdb_CreateTable_FullMethodName

+ const Kvdb_DeleteDatabase_FullMethodName

+ const Kvdb_DeleteIndex_FullMethodName

+ const Kvdb_DeleteKeys_FullMethodName

+ const Kvdb_DeleteTable_FullMethodName

+ const Kvdb_DeleteWhere_FullMethodName

+ const Kvdb_DescribeTable_FullMethodName

+ const Kvdb_Insert_FullMethodName

+ const Kvdb_ListDatabases_FullMethodName

+ const Kvdb_ListIndices_FullMethodName

+ const Kvdb_ListTables_FullMethodName

+ const Kvdb_RenameTable_FullMethodName

+ const Kvdb_SelectOneWhere_FullMethodName

+ const Kvdb_SelectWhereLimit_FullMethodName

+ const Kvdb_UpdateWhere_FullMethodName

+ func ToConditionTemplateAndOrder(cto *ConditionTemplateAndOrder) (condition.Condition, record.Record, sort.OrderBy, error)

+ func ToHasRecord(hr *HasRecord) (record.Record, error)

+ type ConditionTemplateAndOrder struct

+ Condition *Condition

+ Order *OrderBy

+ Template *Record

+ func FromConditionTemplateAndOrder(cond condition.Condition, template record.Record, order sort.OrderBy) (*ConditionTemplateAndOrder, error)

+ func (*ConditionTemplateAndOrder) Descriptor() ([]byte, []int)

+ func (*ConditionTemplateAndOrder) ProtoMessage()

+ func (x *ConditionTemplateAndOrder) GetCondition() *Condition

+ func (x *ConditionTemplateAndOrder) GetOrder() *OrderBy

+ func (x *ConditionTemplateAndOrder) GetTemplate() *Record

+ func (x *ConditionTemplateAndOrder) ProtoReflect() protoreflect.Message

+ func (x *ConditionTemplateAndOrder) Reset()

+ func (x *ConditionTemplateAndOrder) String() string

+ type HasRecord struct

+ HasRecord bool

+ Record *Record

+ func FromHasRecord(r record.Record) (*HasRecord, error)

+ func (*HasRecord) Descriptor() ([]byte, []int)

+ func (*HasRecord) ProtoMessage()

+ func (x *HasRecord) GetHasRecord() bool

+ func (x *HasRecord) GetRecord() *Record

+ func (x *HasRecord) ProtoReflect() protoreflect.Message

+ func (x *HasRecord) Reset()

+ func (x *HasRecord) String() string

type KvdbClient

+ SelectOneWhere func(ctx context.Context, in *ConditionTemplateAndOrder, opts ...grpc.CallOption) (*HasRecord, error)

type KvdbServer

+ SelectOneWhere func(context.Context, *ConditionTemplateAndOrder) (*HasRecord, error)

type UnimplementedKvdbServer

+ func (UnimplementedKvdbServer) SelectOneWhere(context.Context, *ConditionTemplateAndOrder) (*HasRecord, error)

v0.2.9

Apr 8, 2023

v0.2.8

Apr 4, 2023

Changes in this version

type KvdbClient

+ CreateDatabase func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ DeleteDatabase func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)

type KvdbServer

+ CreateDatabase func(context.Context, *emptypb.Empty) (*emptypb.Empty, error)

+ DeleteDatabase func(context.Context, *emptypb.Empty) (*emptypb.Empty, error)

type UnimplementedKvdbServer

+ func (UnimplementedKvdbServer) CreateDatabase(context.Context, *emptypb.Empty) (*emptypb.Empty, error)

+ func (UnimplementedKvdbServer) DeleteDatabase(context.Context, *emptypb.Empty) (*emptypb.Empty, error)

v0.2.7

Dec 20, 2022

v0.2.6

Dec 19, 2022

v0.2.5

Aug 27, 2022

v0.2.4

Aug 27, 2022

v0.2.3

Aug 26, 2022

v0.2.2

May 26, 2022

v0.2.1

May 24, 2022

v0.2.0

May 23, 2022

v0.1.37

Apr 29, 2022

Changes in this version

+ func ToDatabaseNames(dn *DatabaseNames) ([]string, error)

+ type DatabaseNames struct

+ Name []string

+ func (*DatabaseNames) Descriptor() ([]byte, []int)

+ func (*DatabaseNames) ProtoMessage()

+ func (x *DatabaseNames) GetName() []string

+ func (x *DatabaseNames) ProtoReflect() protoreflect.Message

+ func (x *DatabaseNames) Reset()

+ func (x *DatabaseNames) String() string

type KvdbClient

+ ListDatabases func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*DatabaseNames, error)

type KvdbServer

+ ListDatabases func(context.Context, *emptypb.Empty) (*DatabaseNames, error)

type UnimplementedKvdbServer

+ func (UnimplementedKvdbServer) ListDatabases(context.Context, *emptypb.Empty) (*DatabaseNames, error)

v0.1.36

Mar 13, 2022

v0.1.35

Mar 12, 2022

v0.1.34

Mar 3, 2022

v0.1.33

Feb 28, 2022

v0.1.32

Feb 26, 2022

v0.1.31

Feb 22, 2022

Changes in this version

+ var File_condition_proto protoreflect.FileDescriptor

+ var File_kvdb_proto protoreflect.FileDescriptor

+ var File_sort_proto protoreflect.FileDescriptor

+ var File_value_proto protoreflect.FileDescriptor

+ var Kvdb_ServiceDesc = grpc.ServiceDesc

type Condition

+ func (x *Condition) ProtoReflect() protoreflect.Message

type ConditionAndReplacement

+ func (x *ConditionAndReplacement) ProtoReflect() protoreflect.Message

type ConditionTemplateOrderAndLimit

+ func (x *ConditionTemplateOrderAndLimit) ProtoReflect() protoreflect.Message

type Condition_CondType

+ func (Condition_CondType) Descriptor() protoreflect.EnumDescriptor

+ func (Condition_CondType) Type() protoreflect.EnumType

+ func (x Condition_CondType) Enum() *Condition_CondType

+ func (x Condition_CondType) Number() protoreflect.EnumNumber

type Direction

+ func (x *Direction) ProtoReflect() protoreflect.Message

type Index

+ func (x *Index) ProtoReflect() protoreflect.Message

type IndexList

+ func (x *IndexList) ProtoReflect() protoreflect.Message

type Key

+ func (x *Key) ProtoReflect() protoreflect.Message

type KeyList

+ func (x *KeyList) ProtoReflect() protoreflect.Message

type LeafOperator

+ func (x *LeafOperator) ProtoReflect() protoreflect.Message

type LeafOperator_LeafType

+ func (LeafOperator_LeafType) Descriptor() protoreflect.EnumDescriptor

+ func (LeafOperator_LeafType) Type() protoreflect.EnumType

+ func (x LeafOperator_LeafType) Enum() *LeafOperator_LeafType

+ func (x LeafOperator_LeafType) Number() protoreflect.EnumNumber

type LhsBool

+ func (x *LhsBool) ProtoReflect() protoreflect.Message

type LhsLowerUpper

+ func (x *LhsLowerUpper) ProtoReflect() protoreflect.Message

type LhsManyValues

+ func (x *LhsManyValues) ProtoReflect() protoreflect.Message

type ManyConditions

+ func (x *ManyConditions) ProtoReflect() protoreflect.Message

type Name

+ func (x *Name) ProtoReflect() protoreflect.Message

type NameAndTemplate

+ func (x *NameAndTemplate) ProtoReflect() protoreflect.Message

type NumberOfRecords

+ func (x *NumberOfRecords) ProtoReflect() protoreflect.Message

type Order

+ func (x *Order) ProtoReflect() protoreflect.Message

type OrderBy

+ func (x *OrderBy) ProtoReflect() protoreflect.Message

type Record

+ func (x *Record) ProtoReflect() protoreflect.Message

type SrcAndDstNames

+ func (x *SrcAndDstNames) ProtoReflect() protoreflect.Message

type TableNames

+ func (x *TableNames) ProtoReflect() protoreflect.Message

+ type UnsafeKvdbServer interface

type Value

+ func (x *Value) ProtoReflect() protoreflect.Message

type Value_Type

+ func (Value_Type) Descriptor() protoreflect.EnumDescriptor

+ func (Value_Type) Type() protoreflect.EnumType

+ func (x Value_Type) Enum() *Value_Type

+ func (x Value_Type) Number() protoreflect.EnumNumber

v0.1.30

Nov 26, 2021

v0.1.29

Nov 22, 2021

Changes in this version

+ func ToKey(key *Key) string

+ func ToKeys(kl *KeyList) []string

+ func ToSrcAndDst(sd *SrcAndDstNames) (string, string)

+ type Key struct

+ Key string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func FromKey(key string) *Key

+ func (*Key) Descriptor() ([]byte, []int)

+ func (*Key) ProtoMessage()

+ func (m *Key) GetKey() string

+ func (m *Key) Reset()

+ func (m *Key) String() string

+ func (m *Key) XXX_DiscardUnknown()

+ func (m *Key) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Key) XXX_Merge(src proto.Message)

+ func (m *Key) XXX_Size() int

+ func (m *Key) XXX_Unmarshal(b []byte) error

+ type KeyList struct

+ List []*Key

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func FromKeys(keys []string) *KeyList

+ func (*KeyList) Descriptor() ([]byte, []int)

+ func (*KeyList) ProtoMessage()

+ func (m *KeyList) GetList() []*Key

+ func (m *KeyList) Reset()

+ func (m *KeyList) String() string

+ func (m *KeyList) XXX_DiscardUnknown()

+ func (m *KeyList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *KeyList) XXX_Merge(src proto.Message)

+ func (m *KeyList) XXX_Size() int

+ func (m *KeyList) XXX_Unmarshal(b []byte) error

type KvdbClient

+ AddKeys func(ctx context.Context, in *Record, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ DeleteKeys func(ctx context.Context, in *KeyList, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ RenameTable func(ctx context.Context, in *SrcAndDstNames, opts ...grpc.CallOption) (*emptypb.Empty, error)

type KvdbServer

+ AddKeys func(context.Context, *Record) (*emptypb.Empty, error)

+ DeleteKeys func(context.Context, *KeyList) (*emptypb.Empty, error)

+ RenameTable func(context.Context, *SrcAndDstNames) (*emptypb.Empty, error)

+ type SrcAndDstNames struct

+ Dst string

+ Src string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func FromSrcAndDst(src string, dst string) *SrcAndDstNames

+ func (*SrcAndDstNames) Descriptor() ([]byte, []int)

+ func (*SrcAndDstNames) ProtoMessage()

+ func (m *SrcAndDstNames) GetDst() string

+ func (m *SrcAndDstNames) GetSrc() string

+ func (m *SrcAndDstNames) Reset()

+ func (m *SrcAndDstNames) String() string

+ func (m *SrcAndDstNames) XXX_DiscardUnknown()

+ func (m *SrcAndDstNames) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *SrcAndDstNames) XXX_Merge(src proto.Message)

+ func (m *SrcAndDstNames) XXX_Size() int

+ func (m *SrcAndDstNames) XXX_Unmarshal(b []byte) error

type UnimplementedKvdbServer

+ func (*UnimplementedKvdbServer) AddKeys(ctx context.Context, req *Record) (*emptypb.Empty, error)

+ func (*UnimplementedKvdbServer) DeleteKeys(ctx context.Context, req *KeyList) (*emptypb.Empty, error)

+ func (*UnimplementedKvdbServer) RenameTable(ctx context.Context, req *SrcAndDstNames) (*emptypb.Empty, error)

v0.1.28

Nov 10, 2021

v0.1.27

Nov 6, 2021

v0.1.26

Sep 17, 2021

v0.1.25

Sep 16, 2021

v0.1.24

Apr 14, 2021

v0.1.22

Feb 25, 2021

Changes in this version

+ var Condition_CondType_name = map[int32]string

+ var Condition_CondType_value = map[string]int32

+ var LeafOperator_LeafType_name = map[int32]string

+ var LeafOperator_LeafType_value = map[string]int32

+ var Value_Type_name = map[int32]string

+ var Value_Type_value = map[string]int32

+ func RegisterKvdbServer(s *grpc.Server, srv KvdbServer)

+ func ScanRecord(dst record.Record, src *Record) error

+ func ToCondition(c *Condition) (condition.Condition, error)

+ func ToConditionAndReplacement(cr *ConditionAndReplacement) (condition.Condition, record.Record, error)

+ func ToConditionTemplateOrderAndLimit(ctol *ConditionTemplateOrderAndLimit) (condition.Condition, record.Record, sort.OrderBy, int64, error)

+ func ToConditions(mc *ManyConditions) ([]condition.Condition, error)

+ func ToDirection(d *Direction) sort.Direction

+ func ToIndex(idx *Index) string

+ func ToIndices(il *IndexList) []string

+ func ToInt64(nr *NumberOfRecords) int64

+ func ToLHSBool(m *LhsBool) (string, bool, error)

+ func ToLHSLowerUpper(ul *LhsLowerUpper) (lhs string, lower interface{}, upper interface{}, err error)

+ func ToLHSValues(m *LhsManyValues) (string, []interface{}, error)

+ func ToLeafOp(op *LeafOperator) (*condition.LeafOp, error)

+ func ToName(n *Name) string

+ func ToNameAndTemplate(nt *NameAndTemplate) (string, record.Record, error)

+ func ToOrder(s *Order) sort.Order

+ func ToOrderBy(S *OrderBy) sort.OrderBy

+ func ToRecord(r *Record) (record.Record, error)

+ func ToTableNames(tn *TableNames) ([]string, error)

+ type Condition struct

+ Type Condition_CondType

+ Value isCondition_Value

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func FromCondition(c condition.Condition) (*Condition, error)

+ func (*Condition) Descriptor() ([]byte, []int)

+ func (*Condition) ProtoMessage()

+ func (*Condition) XXX_OneofWrappers() []interface{}

+ func (m *Condition) GetBoolValue() bool

+ func (m *Condition) GetLeafValue() *LeafOperator

+ func (m *Condition) GetLhsBoolValue() *LhsBool

+ func (m *Condition) GetLhsLowerUpperValue() *LhsLowerUpper

+ func (m *Condition) GetLhsManyValuesValue() *LhsManyValues

+ func (m *Condition) GetManyConditionsValue() *ManyConditions

+ func (m *Condition) GetType() Condition_CondType

+ func (m *Condition) GetValue() isCondition_Value

+ func (m *Condition) Reset()

+ func (m *Condition) String() string

+ func (m *Condition) XXX_DiscardUnknown()

+ func (m *Condition) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Condition) XXX_Merge(src proto.Message)

+ func (m *Condition) XXX_Size() int

+ func (m *Condition) XXX_Unmarshal(b []byte) error

+ type ConditionAndReplacement struct

+ Condition *Condition

+ Replacement *Record

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func FromConditionAndReplacement(cond condition.Condition, replacement record.Record) (*ConditionAndReplacement, error)

+ func (*ConditionAndReplacement) Descriptor() ([]byte, []int)

+ func (*ConditionAndReplacement) ProtoMessage()

+ func (m *ConditionAndReplacement) GetCondition() *Condition

+ func (m *ConditionAndReplacement) GetReplacement() *Record

+ func (m *ConditionAndReplacement) Reset()

+ func (m *ConditionAndReplacement) String() string

+ func (m *ConditionAndReplacement) XXX_DiscardUnknown()

+ func (m *ConditionAndReplacement) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ConditionAndReplacement) XXX_Merge(src proto.Message)

+ func (m *ConditionAndReplacement) XXX_Size() int

+ func (m *ConditionAndReplacement) XXX_Unmarshal(b []byte) error

+ type ConditionTemplateOrderAndLimit struct

+ Condition *Condition

+ Limit int64

+ Order *OrderBy

+ Template *Record

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func FromConditionTemplateOrderAndLimit(cond condition.Condition, template record.Record, order sort.OrderBy, ...) (*ConditionTemplateOrderAndLimit, error)

+ func (*ConditionTemplateOrderAndLimit) Descriptor() ([]byte, []int)

+ func (*ConditionTemplateOrderAndLimit) ProtoMessage()

+ func (m *ConditionTemplateOrderAndLimit) GetCondition() *Condition

+ func (m *ConditionTemplateOrderAndLimit) GetLimit() int64

+ func (m *ConditionTemplateOrderAndLimit) GetOrder() *OrderBy

+ func (m *ConditionTemplateOrderAndLimit) GetTemplate() *Record

+ func (m *ConditionTemplateOrderAndLimit) Reset()

+ func (m *ConditionTemplateOrderAndLimit) String() string

+ func (m *ConditionTemplateOrderAndLimit) XXX_DiscardUnknown()

+ func (m *ConditionTemplateOrderAndLimit) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ConditionTemplateOrderAndLimit) XXX_Merge(src proto.Message)

+ func (m *ConditionTemplateOrderAndLimit) XXX_Size() int

+ func (m *ConditionTemplateOrderAndLimit) XXX_Unmarshal(b []byte) error

+ type Condition_BoolValue struct

+ BoolValue bool

+ type Condition_CondType int32

+ const Condition_AND

+ const Condition_BETWEEN

+ const Condition_BOOL

+ const Condition_IN

+ const Condition_IS

+ const Condition_LEAF

+ const Condition_NOTBETWEEN

+ const Condition_NOTIN

+ const Condition_OR

+ const Condition_UNDEFINED

+ func (Condition_CondType) EnumDescriptor() ([]byte, []int)

+ func (x Condition_CondType) String() string

+ type Condition_LeafValue struct

+ LeafValue *LeafOperator

+ type Condition_LhsBoolValue struct

+ LhsBoolValue *LhsBool

+ type Condition_LhsLowerUpperValue struct

+ LhsLowerUpperValue *LhsLowerUpper

+ type Condition_LhsManyValuesValue struct

+ LhsManyValuesValue *LhsManyValues

+ type Condition_ManyConditionsValue struct

+ ManyConditionsValue *ManyConditions

+ type Direction struct

+ Direction bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func FromDirection(d sort.Direction) *Direction

+ func (*Direction) Descriptor() ([]byte, []int)

+ func (*Direction) ProtoMessage()

+ func (m *Direction) GetDirection() bool

+ func (m *Direction) Reset()

+ func (m *Direction) String() string

+ func (m *Direction) XXX_DiscardUnknown()

+ func (m *Direction) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Direction) XXX_Merge(src proto.Message)

+ func (m *Direction) XXX_Size() int

+ func (m *Direction) XXX_Unmarshal(b []byte) error

+ type Index struct

+ Index string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func FromIndex(index string) *Index

+ func (*Index) Descriptor() ([]byte, []int)

+ func (*Index) ProtoMessage()

+ func (m *Index) GetIndex() string

+ func (m *Index) Reset()

+ func (m *Index) String() string

+ func (m *Index) XXX_DiscardUnknown()

+ func (m *Index) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Index) XXX_Merge(src proto.Message)

+ func (m *Index) XXX_Size() int

+ func (m *Index) XXX_Unmarshal(b []byte) error

+ type IndexList struct

+ List []*Index

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func FromIndices(indices []string) *IndexList

+ func (*IndexList) Descriptor() ([]byte, []int)

+ func (*IndexList) ProtoMessage()

+ func (m *IndexList) GetList() []*Index

+ func (m *IndexList) Reset()

+ func (m *IndexList) String() string

+ func (m *IndexList) XXX_DiscardUnknown()

+ func (m *IndexList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *IndexList) XXX_Merge(src proto.Message)

+ func (m *IndexList) XXX_Size() int

+ func (m *IndexList) XXX_Unmarshal(b []byte) error

+ type KvdbClient interface

+ AddIndex func(ctx context.Context, in *Index, opts ...grpc.CallOption) (*empty.Empty, error)

+ AddUniqueIndex func(ctx context.Context, in *Index, opts ...grpc.CallOption) (*empty.Empty, error)

+ CountWhere func(ctx context.Context, in *Condition, opts ...grpc.CallOption) (*NumberOfRecords, error)

+ CreateTable func(ctx context.Context, in *NameAndTemplate, opts ...grpc.CallOption) (*empty.Empty, error)

+ DeleteIndex func(ctx context.Context, in *Index, opts ...grpc.CallOption) (*empty.Empty, error)

+ DeleteTable func(ctx context.Context, in *Name, opts ...grpc.CallOption) (*empty.Empty, error)

+ DeleteWhere func(ctx context.Context, in *Condition, opts ...grpc.CallOption) (*NumberOfRecords, error)

+ DescribeTable func(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*Record, error)

+ Insert func(ctx context.Context, opts ...grpc.CallOption) (Kvdb_InsertClient, error)

+ ListIndices func(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*IndexList, error)

+ ListTables func(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*TableNames, error)

+ SelectWhereLimit func(ctx context.Context, in *ConditionTemplateOrderAndLimit, ...) (Kvdb_SelectWhereLimitClient, error)

+ UpdateWhere func(ctx context.Context, in *ConditionAndReplacement, opts ...grpc.CallOption) (*NumberOfRecords, error)

+ func NewKvdbClient(cc *grpc.ClientConn) KvdbClient

+ type KvdbServer interface

+ AddIndex func(context.Context, *Index) (*empty.Empty, error)

+ AddUniqueIndex func(context.Context, *Index) (*empty.Empty, error)

+ CountWhere func(context.Context, *Condition) (*NumberOfRecords, error)

+ CreateTable func(context.Context, *NameAndTemplate) (*empty.Empty, error)

+ DeleteIndex func(context.Context, *Index) (*empty.Empty, error)

+ DeleteTable func(context.Context, *Name) (*empty.Empty, error)

+ DeleteWhere func(context.Context, *Condition) (*NumberOfRecords, error)

+ DescribeTable func(context.Context, *empty.Empty) (*Record, error)

+ Insert func(Kvdb_InsertServer) error

+ ListIndices func(context.Context, *empty.Empty) (*IndexList, error)

+ ListTables func(context.Context, *empty.Empty) (*TableNames, error)

+ SelectWhereLimit func(*ConditionTemplateOrderAndLimit, Kvdb_SelectWhereLimitServer) error

+ UpdateWhere func(context.Context, *ConditionAndReplacement) (*NumberOfRecords, error)

+ type Kvdb_InsertClient interface

+ CloseAndRecv func() (*empty.Empty, error)

+ Send func(*Record) error

+ type Kvdb_InsertServer interface

+ Recv func() (*Record, error)

+ SendAndClose func(*empty.Empty) error

+ type Kvdb_SelectWhereLimitClient interface

+ Recv func() (*Record, error)

+ type Kvdb_SelectWhereLimitServer interface

+ Send func(*Record) error

+ type LeafOperator struct

+ Lhs string

+ Opcode LeafOperator_LeafType

+ Rhs *Value

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func FromLeafOp(c *condition.LeafOp) (*LeafOperator, error)

+ func (*LeafOperator) Descriptor() ([]byte, []int)

+ func (*LeafOperator) ProtoMessage()

+ func (m *LeafOperator) GetLhs() string

+ func (m *LeafOperator) GetOpcode() LeafOperator_LeafType

+ func (m *LeafOperator) GetRhs() *Value

+ func (m *LeafOperator) Reset()

+ func (m *LeafOperator) String() string

+ func (m *LeafOperator) XXX_DiscardUnknown()

+ func (m *LeafOperator) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *LeafOperator) XXX_Merge(src proto.Message)

+ func (m *LeafOperator) XXX_Size() int

+ func (m *LeafOperator) XXX_Unmarshal(b []byte) error

+ type LeafOperator_LeafType int32

+ const LeafOperator_EQ

+ const LeafOperator_GE

+ const LeafOperator_GT

+ const LeafOperator_LE

+ const LeafOperator_LT

+ const LeafOperator_NE

+ const LeafOperator_UNDEFINED

+ func (LeafOperator_LeafType) EnumDescriptor() ([]byte, []int)

+ func (x LeafOperator_LeafType) String() string

+ type LhsBool struct

+ BoolValue bool

+ Lhs string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func FromLHSBool(lhs string, b bool) *LhsBool

+ func (*LhsBool) Descriptor() ([]byte, []int)

+ func (*LhsBool) ProtoMessage()

+ func (m *LhsBool) GetBoolValue() bool

+ func (m *LhsBool) GetLhs() string

+ func (m *LhsBool) Reset()

+ func (m *LhsBool) String() string

+ func (m *LhsBool) XXX_DiscardUnknown()

+ func (m *LhsBool) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *LhsBool) XXX_Merge(src proto.Message)

+ func (m *LhsBool) XXX_Size() int

+ func (m *LhsBool) XXX_Unmarshal(b []byte) error

+ type LhsLowerUpper struct

+ Lhs string

+ Lower *Value

+ Upper *Value

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func FromLHSLowerUpper(lhs string, lower interface{}, upper interface{}) (*LhsLowerUpper, error)

+ func (*LhsLowerUpper) Descriptor() ([]byte, []int)

+ func (*LhsLowerUpper) ProtoMessage()

+ func (m *LhsLowerUpper) GetLhs() string

+ func (m *LhsLowerUpper) GetLower() *Value

+ func (m *LhsLowerUpper) GetUpper() *Value

+ func (m *LhsLowerUpper) Reset()

+ func (m *LhsLowerUpper) String() string

+ func (m *LhsLowerUpper) XXX_DiscardUnknown()

+ func (m *LhsLowerUpper) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *LhsLowerUpper) XXX_Merge(src proto.Message)

+ func (m *LhsLowerUpper) XXX_Size() int

+ func (m *LhsLowerUpper) XXX_Unmarshal(b []byte) error

+ type LhsManyValues struct

+ Lhs string

+ Value []*Value

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func FromLHSValues(lhs string, vs []interface{}) (*LhsManyValues, error)

+ func (*LhsManyValues) Descriptor() ([]byte, []int)

+ func (*LhsManyValues) ProtoMessage()

+ func (m *LhsManyValues) GetLhs() string

+ func (m *LhsManyValues) GetValue() []*Value

+ func (m *LhsManyValues) Reset()

+ func (m *LhsManyValues) String() string

+ func (m *LhsManyValues) XXX_DiscardUnknown()

+ func (m *LhsManyValues) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *LhsManyValues) XXX_Merge(src proto.Message)

+ func (m *LhsManyValues) XXX_Size() int

+ func (m *LhsManyValues) XXX_Unmarshal(b []byte) error

+ type ManyConditions struct

+ Cond []*Condition

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func FromConditions(cs []condition.Condition) (*ManyConditions, error)

+ func (*ManyConditions) Descriptor() ([]byte, []int)

+ func (*ManyConditions) ProtoMessage()

+ func (m *ManyConditions) GetCond() []*Condition

+ func (m *ManyConditions) Reset()

+ func (m *ManyConditions) String() string

+ func (m *ManyConditions) XXX_DiscardUnknown()

+ func (m *ManyConditions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ManyConditions) XXX_Merge(src proto.Message)

+ func (m *ManyConditions) XXX_Size() int

+ func (m *ManyConditions) XXX_Unmarshal(b []byte) error

+ type Name struct

+ Name string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func FromName(name string) *Name

+ func (*Name) Descriptor() ([]byte, []int)

+ func (*Name) ProtoMessage()

+ func (m *Name) GetName() string

+ func (m *Name) Reset()

+ func (m *Name) String() string

+ func (m *Name) XXX_DiscardUnknown()

+ func (m *Name) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Name) XXX_Merge(src proto.Message)

+ func (m *Name) XXX_Size() int

+ func (m *Name) XXX_Unmarshal(b []byte) error

+ type NameAndTemplate struct

+ Name string

+ Template *Record

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func FromNameAndTemplate(name string, template record.Record) (*NameAndTemplate, error)

+ func (*NameAndTemplate) Descriptor() ([]byte, []int)

+ func (*NameAndTemplate) ProtoMessage()

+ func (m *NameAndTemplate) GetName() string

+ func (m *NameAndTemplate) GetTemplate() *Record

+ func (m *NameAndTemplate) Reset()

+ func (m *NameAndTemplate) String() string

+ func (m *NameAndTemplate) XXX_DiscardUnknown()

+ func (m *NameAndTemplate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *NameAndTemplate) XXX_Merge(src proto.Message)

+ func (m *NameAndTemplate) XXX_Size() int

+ func (m *NameAndTemplate) XXX_Unmarshal(b []byte) error

+ type NumberOfRecords struct

+ N int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func FromInt64(n int64) *NumberOfRecords

+ func (*NumberOfRecords) Descriptor() ([]byte, []int)

+ func (*NumberOfRecords) ProtoMessage()

+ func (m *NumberOfRecords) GetN() int64

+ func (m *NumberOfRecords) Reset()

+ func (m *NumberOfRecords) String() string

+ func (m *NumberOfRecords) XXX_DiscardUnknown()

+ func (m *NumberOfRecords) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *NumberOfRecords) XXX_Merge(src proto.Message)

+ func (m *NumberOfRecords) XXX_Size() int

+ func (m *NumberOfRecords) XXX_Unmarshal(b []byte) error

+ type Order struct

+ Direction *Direction

+ Key string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func FromOrder(s sort.Order) *Order

+ func (*Order) Descriptor() ([]byte, []int)

+ func (*Order) ProtoMessage()

+ func (m *Order) GetDirection() *Direction

+ func (m *Order) GetKey() string

+ func (m *Order) Reset()

+ func (m *Order) String() string

+ func (m *Order) XXX_DiscardUnknown()

+ func (m *Order) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Order) XXX_Merge(src proto.Message)

+ func (m *Order) XXX_Size() int

+ func (m *Order) XXX_Unmarshal(b []byte) error

+ type OrderBy struct

+ Order []*Order

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func FromOrderBy(S sort.OrderBy) *OrderBy

+ func (*OrderBy) Descriptor() ([]byte, []int)

+ func (*OrderBy) ProtoMessage()

+ func (m *OrderBy) GetOrder() []*Order

+ func (m *OrderBy) Reset()

+ func (m *OrderBy) String() string

+ func (m *OrderBy) XXX_DiscardUnknown()

+ func (m *OrderBy) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *OrderBy) XXX_Merge(src proto.Message)

+ func (m *OrderBy) XXX_Size() int

+ func (m *OrderBy) XXX_Unmarshal(b []byte) error

+ type Record struct

+ Values map[string]*Value

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func FromRecord(r record.Record) (*Record, error)

+ func (*Record) Descriptor() ([]byte, []int)

+ func (*Record) ProtoMessage()

+ func (m *Record) GetValues() map[string]*Value

+ func (m *Record) Reset()

+ func (m *Record) String() string

+ func (m *Record) XXX_DiscardUnknown()

+ func (m *Record) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Record) XXX_Merge(src proto.Message)

+ func (m *Record) XXX_Size() int

+ func (m *Record) XXX_Unmarshal(b []byte) error

+ type TableNames struct

+ Name []string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TableNames) Descriptor() ([]byte, []int)

+ func (*TableNames) ProtoMessage()

+ func (m *TableNames) GetName() []string

+ func (m *TableNames) Reset()

+ func (m *TableNames) String() string

+ func (m *TableNames) XXX_DiscardUnknown()

+ func (m *TableNames) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TableNames) XXX_Merge(src proto.Message)

+ func (m *TableNames) XXX_Size() int

+ func (m *TableNames) XXX_Unmarshal(b []byte) error

+ type UnimplementedKvdbServer struct

+ func (*UnimplementedKvdbServer) AddIndex(ctx context.Context, req *Index) (*empty.Empty, error)

+ func (*UnimplementedKvdbServer) AddUniqueIndex(ctx context.Context, req *Index) (*empty.Empty, error)

+ func (*UnimplementedKvdbServer) CountWhere(ctx context.Context, req *Condition) (*NumberOfRecords, error)

+ func (*UnimplementedKvdbServer) CreateTable(ctx context.Context, req *NameAndTemplate) (*empty.Empty, error)

+ func (*UnimplementedKvdbServer) DeleteIndex(ctx context.Context, req *Index) (*empty.Empty, error)

+ func (*UnimplementedKvdbServer) DeleteTable(ctx context.Context, req *Name) (*empty.Empty, error)

+ func (*UnimplementedKvdbServer) DeleteWhere(ctx context.Context, req *Condition) (*NumberOfRecords, error)

+ func (*UnimplementedKvdbServer) DescribeTable(ctx context.Context, req *empty.Empty) (*Record, error)

+ func (*UnimplementedKvdbServer) Insert(srv Kvdb_InsertServer) error

+ func (*UnimplementedKvdbServer) ListIndices(ctx context.Context, req *empty.Empty) (*IndexList, error)

+ func (*UnimplementedKvdbServer) ListTables(ctx context.Context, req *empty.Empty) (*TableNames, error)

+ func (*UnimplementedKvdbServer) SelectWhereLimit(req *ConditionTemplateOrderAndLimit, srv Kvdb_SelectWhereLimitServer) error

+ func (*UnimplementedKvdbServer) UpdateWhere(ctx context.Context, req *ConditionAndReplacement) (*NumberOfRecords, error)

+ type Value struct

+ Type Value_Type

+ Value isValue_Value

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Value) Descriptor() ([]byte, []int)

+ func (*Value) ProtoMessage()

+ func (*Value) XXX_OneofWrappers() []interface{}

+ func (m *Value) GetBoolValue() bool

+ func (m *Value) GetBytesValue() []byte

+ func (m *Value) GetDoubleValue() float64

+ func (m *Value) GetInt32Value() int32

+ func (m *Value) GetInt64Value() int64

+ func (m *Value) GetStringValue() string

+ func (m *Value) GetType() Value_Type

+ func (m *Value) GetUint32Value() uint32

+ func (m *Value) GetUint64Value() uint64

+ func (m *Value) GetValue() isValue_Value

+ func (m *Value) Reset()

+ func (m *Value) String() string

+ func (m *Value) XXX_DiscardUnknown()

+ func (m *Value) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Value) XXX_Merge(src proto.Message)

+ func (m *Value) XXX_Size() int

+ func (m *Value) XXX_Unmarshal(b []byte) error

+ type Value_BoolValue struct

+ BoolValue bool

+ type Value_BytesValue struct

+ BytesValue []byte

+ type Value_DoubleValue struct

+ DoubleValue float64

+ type Value_Int32Value struct

+ Int32Value int32

+ type Value_Int64Value struct

+ Int64Value int64

+ type Value_StringValue struct

+ StringValue string

+ type Value_Type int32

+ const Value_BOOL

+ const Value_BYTESLICE

+ const Value_FLOAT64

+ const Value_INT

+ const Value_INT16

+ const Value_INT32

+ const Value_INT64

+ const Value_INT8

+ const Value_STRING

+ const Value_UINT

+ const Value_UINT16

+ const Value_UINT32

+ const Value_UINT64

+ const Value_UINT8

+ const Value_UNDEFINED

+ func (Value_Type) EnumDescriptor() ([]byte, []int)

+ func (x Value_Type) String() string

+ type Value_Uint32Value struct

+ Uint32Value uint32

+ type Value_Uint64Value struct

+ Uint64Value uint64

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL