Documentation

Index

Constants

This section is empty.

Variables

View Source
var Condition_CondType_name = map[int32]string{
	0: "UNDEFINED",
	1: "AND",
	2: "BETWEEN",
	3: "BOOL",
	4: "IN",
	5: "LEAF",
	6: "NOTBETWEEN",
	7: "NOTIN",
	8: "OR",
	9: "IS",
}
View Source
var Condition_CondType_value = map[string]int32{
	"UNDEFINED":  0,
	"AND":        1,
	"BETWEEN":    2,
	"BOOL":       3,
	"IN":         4,
	"LEAF":       5,
	"NOTBETWEEN": 6,
	"NOTIN":      7,
	"OR":         8,
	"IS":         9,
}
View Source
var LeafOperator_LeafType_name = map[int32]string{
	0: "UNDEFINED",
	1: "EQ",
	2: "NE",
	3: "GT",
	4: "LT",
	5: "GE",
	6: "LE",
}
View Source
var LeafOperator_LeafType_value = map[string]int32{
	"UNDEFINED": 0,
	"EQ":        1,
	"NE":        2,
	"GT":        3,
	"LT":        4,
	"GE":        5,
	"LE":        6,
}
View Source
var Value_Type_name = map[int32]string{
	0:  "UNDEFINED",
	1:  "INT",
	2:  "INT8",
	3:  "INT16",
	4:  "INT32",
	5:  "INT64",
	6:  "UINT",
	7:  "UINT8",
	8:  "UINT16",
	9:  "UINT32",
	10: "UINT64",
	11: "BOOL",
	12: "FLOAT64",
	13: "STRING",
	14: "BYTESLICE",
}
View Source
var Value_Type_value = map[string]int32{
	"UNDEFINED": 0,
	"INT":       1,
	"INT8":      2,
	"INT16":     3,
	"INT32":     4,
	"INT64":     5,
	"UINT":      6,
	"UINT8":     7,
	"UINT16":    8,
	"UINT32":    9,
	"UINT64":    10,
	"BOOL":      11,
	"FLOAT64":   12,
	"STRING":    13,
	"BYTESLICE": 14,
}

Functions

func RegisterKvdbServer

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

func ScanRecord

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

    ScanRecord scans the contents of "src" into "dst". Any previously set keys or values in "dst" will be deleted or overwritten.

    func ToCondition

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

      ToCondition converts a *Condition to a condition.Condition

      func ToConditionAndReplacement

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

        ToConditionAndReplacement converts a *ConditionAndReplacement to a condition.Condition and a record.Record.

        func ToConditionTemplateOrderAndLimit

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

          ToConditionTemplateOrderAndLimit converts a *ConditionTemplateOrderAndLimit to a condition.Condition, a record.Record, a sort.Order, and an int64.

          func ToConditions

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

            ToConditions converts a *ManyConditions to a slice of condition.Conditions

            func ToDirection

            func ToDirection(d *Direction) sort.Direction

              ToDirection converts a *Direction to a sort.Direction

              func ToIndex

              func ToIndex(idx *Index) string

                ToIndex converts a *Index to a string.

                func ToIndices

                func ToIndices(il *IndexList) []string

                  ToIndices converts a *IndexList to a slice of strings.

                  func ToInt64

                  func ToInt64(nr *NumberOfRecords) int64

                    ToInt64 converts a *NumberOfRecords to an int64.

                    func ToLHSBool

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

                      ToLHSBool converts a *LhsBool to a string and a bool.

                      func ToLHSLowerUpper

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

                        ToLHSLowerUpper converts a *LhsLowerUpper to a string and a pair of interface{}s.

                        func ToLHSValues

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

                          ToLHSValues converts a *LhsManyValues to a string and a slice of interface{}s.

                          func ToLeafOp

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

                            ToLeafOp converts a *LeafOperator to a *condition.LeafOp

                            func ToName

                            func ToName(n *Name) string

                              ToName converts a *Name to a string.

                              func ToNameAndTemplate

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

                                ToNameAndTemplate converts a *NameAndTemplate to a string and a record.Record.

                                func ToOrder

                                func ToOrder(s *Order) sort.Order

                                  ToOrder converts a *Order to a sort.Order.

                                  func ToOrderBy

                                  func ToOrderBy(S *OrderBy) sort.OrderBy

                                    ToOrderBy converts a *OrderBy to a sort.OrderBy.

                                    func ToRecord

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

                                      ToRecord converts a *Record to a record.Record

                                      func ToTableNames

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

                                        ToTableNames converts a *TableNames to a slice of strings.

                                        Types

                                        type Condition

                                        type Condition struct {
                                        	Type Condition_CondType `protobuf:"varint,1,opt,name=type,proto3,enum=kvdb.Condition_CondType" json:"type,omitempty"`
                                        	// Types that are valid to be assigned to Value:
                                        	//	*Condition_ManyConditionsValue
                                        	//	*Condition_LhsLowerUpperValue
                                        	//	*Condition_BoolValue
                                        	//	*Condition_LhsManyValuesValue
                                        	//	*Condition_LeafValue
                                        	//	*Condition_LhsBoolValue
                                        	Value                isCondition_Value `protobuf_oneof:"value"`
                                        	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
                                        	XXX_unrecognized     []byte            `json:"-"`
                                        	XXX_sizecache        int32             `json:"-"`
                                        }

                                          Condition describes a condition

                                          func FromCondition

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

                                            FromCondition converts a condition.Condition to a *Condition

                                            func (*Condition) Descriptor

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

                                            func (*Condition) GetBoolValue

                                            func (m *Condition) GetBoolValue() bool

                                            func (*Condition) GetLeafValue

                                            func (m *Condition) GetLeafValue() *LeafOperator

                                            func (*Condition) GetLhsBoolValue

                                            func (m *Condition) GetLhsBoolValue() *LhsBool

                                            func (*Condition) GetLhsLowerUpperValue

                                            func (m *Condition) GetLhsLowerUpperValue() *LhsLowerUpper

                                            func (*Condition) GetLhsManyValuesValue

                                            func (m *Condition) GetLhsManyValuesValue() *LhsManyValues

                                            func (*Condition) GetManyConditionsValue

                                            func (m *Condition) GetManyConditionsValue() *ManyConditions

                                            func (*Condition) GetType

                                            func (m *Condition) GetType() Condition_CondType

                                            func (*Condition) GetValue

                                            func (m *Condition) GetValue() isCondition_Value

                                            func (*Condition) ProtoMessage

                                            func (*Condition) ProtoMessage()

                                            func (*Condition) Reset

                                            func (m *Condition) Reset()

                                            func (*Condition) String

                                            func (m *Condition) String() string

                                            func (*Condition) XXX_DiscardUnknown

                                            func (m *Condition) XXX_DiscardUnknown()

                                            func (*Condition) XXX_Marshal

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

                                            func (*Condition) XXX_Merge

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

                                            func (*Condition) XXX_OneofWrappers

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

                                              XXX_OneofWrappers is for the internal use of the proto package.

                                              func (*Condition) XXX_Size

                                              func (m *Condition) XXX_Size() int

                                              func (*Condition) XXX_Unmarshal

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

                                              type ConditionAndReplacement

                                              type ConditionAndReplacement struct {
                                              	Condition            *Condition `protobuf:"bytes,1,opt,name=condition,proto3" json:"condition,omitempty"`
                                              	Replacement          *Record    `protobuf:"bytes,2,opt,name=replacement,proto3" json:"replacement,omitempty"`
                                              	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
                                              	XXX_unrecognized     []byte     `json:"-"`
                                              	XXX_sizecache        int32      `json:"-"`
                                              }

                                                ConditionAndReplacement describes the condition to match against and the replacement values.

                                                func FromConditionAndReplacement

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

                                                  FromConditionAndReplacement converts a condition.Condition and a record.Record to a *ConditionAndReplacement

                                                  func (*ConditionAndReplacement) Descriptor

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

                                                  func (*ConditionAndReplacement) GetCondition

                                                  func (m *ConditionAndReplacement) GetCondition() *Condition

                                                  func (*ConditionAndReplacement) GetReplacement

                                                  func (m *ConditionAndReplacement) GetReplacement() *Record

                                                  func (*ConditionAndReplacement) ProtoMessage

                                                  func (*ConditionAndReplacement) ProtoMessage()

                                                  func (*ConditionAndReplacement) Reset

                                                  func (m *ConditionAndReplacement) Reset()

                                                  func (*ConditionAndReplacement) String

                                                  func (m *ConditionAndReplacement) String() string

                                                  func (*ConditionAndReplacement) XXX_DiscardUnknown

                                                  func (m *ConditionAndReplacement) XXX_DiscardUnknown()

                                                  func (*ConditionAndReplacement) XXX_Marshal

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

                                                  func (*ConditionAndReplacement) XXX_Merge

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

                                                  func (*ConditionAndReplacement) XXX_Size

                                                  func (m *ConditionAndReplacement) XXX_Size() int

                                                  func (*ConditionAndReplacement) XXX_Unmarshal

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

                                                  type ConditionTemplateOrderAndLimit

                                                  type ConditionTemplateOrderAndLimit struct {
                                                  	Condition            *Condition `protobuf:"bytes,1,opt,name=condition,proto3" json:"condition,omitempty"`
                                                  	Template             *Record    `protobuf:"bytes,2,opt,name=template,proto3" json:"template,omitempty"`
                                                  	Order                *OrderBy   `protobuf:"bytes,3,opt,name=order,proto3" json:"order,omitempty"`
                                                  	Limit                int64      `protobuf:"varint,4,opt,name=limit,proto3" json:"limit,omitempty"`
                                                  	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
                                                  	XXX_unrecognized     []byte     `json:"-"`
                                                  	XXX_sizecache        int32      `json:"-"`
                                                  }

                                                    ConditionTemplateOrderAndLimit is the argument for a SelectWhereLimit task.

                                                    func FromConditionTemplateOrderAndLimit

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

                                                      FromConditionTemplateOrderAndLimit converts a condition.Condition, a record.Record, a sort.Order, and an int64 to a *ConditionTemplateOrderAndLimit.

                                                      func (*ConditionTemplateOrderAndLimit) Descriptor

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

                                                      func (*ConditionTemplateOrderAndLimit) GetCondition

                                                      func (m *ConditionTemplateOrderAndLimit) GetCondition() *Condition

                                                      func (*ConditionTemplateOrderAndLimit) GetLimit

                                                      func (m *ConditionTemplateOrderAndLimit) GetLimit() int64

                                                      func (*ConditionTemplateOrderAndLimit) GetOrder

                                                      func (m *ConditionTemplateOrderAndLimit) GetOrder() *OrderBy

                                                      func (*ConditionTemplateOrderAndLimit) GetTemplate

                                                      func (m *ConditionTemplateOrderAndLimit) GetTemplate() *Record

                                                      func (*ConditionTemplateOrderAndLimit) ProtoMessage

                                                      func (*ConditionTemplateOrderAndLimit) ProtoMessage()

                                                      func (*ConditionTemplateOrderAndLimit) Reset

                                                      func (m *ConditionTemplateOrderAndLimit) Reset()

                                                      func (*ConditionTemplateOrderAndLimit) String

                                                      func (*ConditionTemplateOrderAndLimit) XXX_DiscardUnknown

                                                      func (m *ConditionTemplateOrderAndLimit) XXX_DiscardUnknown()

                                                      func (*ConditionTemplateOrderAndLimit) XXX_Marshal

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

                                                      func (*ConditionTemplateOrderAndLimit) XXX_Merge

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

                                                      func (*ConditionTemplateOrderAndLimit) XXX_Size

                                                      func (m *ConditionTemplateOrderAndLimit) XXX_Size() int

                                                      func (*ConditionTemplateOrderAndLimit) XXX_Unmarshal

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

                                                      type Condition_BoolValue

                                                      type Condition_BoolValue struct {
                                                      	BoolValue bool `protobuf:"varint,4,opt,name=bool_value,json=boolValue,proto3,oneof"`
                                                      }

                                                      type Condition_CondType

                                                      type Condition_CondType int32

                                                        CondType enumerates the possible condition types

                                                        const (
                                                        	Condition_UNDEFINED  Condition_CondType = 0
                                                        	Condition_AND        Condition_CondType = 1
                                                        	Condition_BETWEEN    Condition_CondType = 2
                                                        	Condition_BOOL       Condition_CondType = 3
                                                        	Condition_IN         Condition_CondType = 4
                                                        	Condition_LEAF       Condition_CondType = 5
                                                        	Condition_NOTBETWEEN Condition_CondType = 6
                                                        	Condition_NOTIN      Condition_CondType = 7
                                                        	Condition_OR         Condition_CondType = 8
                                                        	Condition_IS         Condition_CondType = 9
                                                        )

                                                        func (Condition_CondType) EnumDescriptor

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

                                                        func (Condition_CondType) String

                                                        func (x Condition_CondType) String() string

                                                        type Condition_LeafValue

                                                        type Condition_LeafValue struct {
                                                        	LeafValue *LeafOperator `protobuf:"bytes,6,opt,name=leaf_value,json=leafValue,proto3,oneof"`
                                                        }

                                                        type Condition_LhsBoolValue

                                                        type Condition_LhsBoolValue struct {
                                                        	LhsBoolValue *LhsBool `protobuf:"bytes,7,opt,name=lhs_bool_value,json=lhsBoolValue,proto3,oneof"`
                                                        }

                                                        type Condition_LhsLowerUpperValue

                                                        type Condition_LhsLowerUpperValue struct {
                                                        	LhsLowerUpperValue *LhsLowerUpper `protobuf:"bytes,3,opt,name=lhs_lower_upper_value,json=lhsLowerUpperValue,proto3,oneof"`
                                                        }

                                                        type Condition_LhsManyValuesValue

                                                        type Condition_LhsManyValuesValue struct {
                                                        	LhsManyValuesValue *LhsManyValues `protobuf:"bytes,5,opt,name=lhs_many_values_value,json=lhsManyValuesValue,proto3,oneof"`
                                                        }

                                                        type Condition_ManyConditionsValue

                                                        type Condition_ManyConditionsValue struct {
                                                        	ManyConditionsValue *ManyConditions `protobuf:"bytes,2,opt,name=many_conditions_value,json=manyConditionsValue,proto3,oneof"`
                                                        }

                                                        type Direction

                                                        type Direction struct {
                                                        	Direction            bool     `protobuf:"varint,1,opt,name=direction,proto3" json:"direction,omitempty"`
                                                        	XXX_NoUnkeyedLiteral struct{} `json:"-"`
                                                        	XXX_unrecognized     []byte   `json:"-"`
                                                        	XXX_sizecache        int32    `json:"-"`
                                                        }

                                                          Direction represents a direction for a sort order

                                                          func FromDirection

                                                          func FromDirection(d sort.Direction) *Direction

                                                            FromDirection converts a sort.Direction to a *Direction

                                                            func (*Direction) Descriptor

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

                                                            func (*Direction) GetDirection

                                                            func (m *Direction) GetDirection() bool

                                                            func (*Direction) ProtoMessage

                                                            func (*Direction) ProtoMessage()

                                                            func (*Direction) Reset

                                                            func (m *Direction) Reset()

                                                            func (*Direction) String

                                                            func (m *Direction) String() string

                                                            func (*Direction) XXX_DiscardUnknown

                                                            func (m *Direction) XXX_DiscardUnknown()

                                                            func (*Direction) XXX_Marshal

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

                                                            func (*Direction) XXX_Merge

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

                                                            func (*Direction) XXX_Size

                                                            func (m *Direction) XXX_Size() int

                                                            func (*Direction) XXX_Unmarshal

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

                                                            type Index

                                                            type Index struct {
                                                            	Index                string   `protobuf:"bytes,1,opt,name=index,proto3" json:"index,omitempty"`
                                                            	XXX_NoUnkeyedLiteral struct{} `json:"-"`
                                                            	XXX_unrecognized     []byte   `json:"-"`
                                                            	XXX_sizecache        int32    `json:"-"`
                                                            }

                                                              Index describes the name of an index.

                                                              func FromIndex

                                                              func FromIndex(index string) *Index

                                                                FromIndex converts a string to a *Index.

                                                                func (*Index) Descriptor

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

                                                                func (*Index) GetIndex

                                                                func (m *Index) GetIndex() string

                                                                func (*Index) ProtoMessage

                                                                func (*Index) ProtoMessage()

                                                                func (*Index) Reset

                                                                func (m *Index) Reset()

                                                                func (*Index) String

                                                                func (m *Index) String() string

                                                                func (*Index) XXX_DiscardUnknown

                                                                func (m *Index) XXX_DiscardUnknown()

                                                                func (*Index) XXX_Marshal

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

                                                                func (*Index) XXX_Merge

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

                                                                func (*Index) XXX_Size

                                                                func (m *Index) XXX_Size() int

                                                                func (*Index) XXX_Unmarshal

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

                                                                type IndexList

                                                                type IndexList struct {
                                                                	List                 []*Index `protobuf:"bytes,1,rep,name=list,proto3" json:"list,omitempty"`
                                                                	XXX_NoUnkeyedLiteral struct{} `json:"-"`
                                                                	XXX_unrecognized     []byte   `json:"-"`
                                                                	XXX_sizecache        int32    `json:"-"`
                                                                }

                                                                  IndexList is a list of indices.

                                                                  func FromIndices

                                                                  func FromIndices(indices []string) *IndexList

                                                                    FromIndices converts a slice of strings to a *IndexList.

                                                                    func (*IndexList) Descriptor

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

                                                                    func (*IndexList) GetList

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

                                                                    func (*IndexList) ProtoMessage

                                                                    func (*IndexList) ProtoMessage()

                                                                    func (*IndexList) Reset

                                                                    func (m *IndexList) Reset()

                                                                    func (*IndexList) String

                                                                    func (m *IndexList) String() string

                                                                    func (*IndexList) XXX_DiscardUnknown

                                                                    func (m *IndexList) XXX_DiscardUnknown()

                                                                    func (*IndexList) XXX_Marshal

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

                                                                    func (*IndexList) XXX_Merge

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

                                                                    func (*IndexList) XXX_Size

                                                                    func (m *IndexList) XXX_Size() int

                                                                    func (*IndexList) XXX_Unmarshal

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

                                                                    type KvdbClient

                                                                    type KvdbClient interface {
                                                                    	// ListTables returns the tables in the database.
                                                                    	ListTables(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*TableNames, error)
                                                                    	// CreateTable creates a table with the given name and template.
                                                                    	CreateTable(ctx context.Context, in *NameAndTemplate, opts ...grpc.CallOption) (*empty.Empty, error)
                                                                    	// DescribeTable returns a best-guess template for the data in the table.
                                                                    	DescribeTable(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*Record, error)
                                                                    	// DeleteTable deletes the table with the given name.
                                                                    	DeleteTable(ctx context.Context, in *Name, opts ...grpc.CallOption) (*empty.Empty, error)
                                                                    	// CountWhere returns the number of records in the table that match the
                                                                    	// given condition.
                                                                    	CountWhere(ctx context.Context, in *Condition, opts ...grpc.CallOption) (*NumberOfRecords, error)
                                                                    	// Insert inserts the records from stream into the table.
                                                                    	Insert(ctx context.Context, opts ...grpc.CallOption) (Kvdb_InsertClient, error)
                                                                    	// UpdateWhere updates all records in the table that match the given
                                                                    	// condition by setting all keys present in the given record to the
                                                                    	// corresponding values. Returns the number of records updated.
                                                                    	UpdateWhere(ctx context.Context, in *ConditionAndReplacement, opts ...grpc.CallOption) (*NumberOfRecords, error)
                                                                    	// SelectWhereLimit returns a stream of records matching the given
                                                                    	// condition. The returned records will be in the form specified by the
                                                                    	// given template. If the given limit is non-negative then at most that
                                                                    	// many records will be returned.
                                                                    	SelectWhereLimit(ctx context.Context, in *ConditionTemplateOrderAndLimit, opts ...grpc.CallOption) (Kvdb_SelectWhereLimitClient, error)
                                                                    	// DeleteWhere deletes those records in the table that match the given
                                                                    	// condition. Returns the number of records deleted.
                                                                    	DeleteWhere(ctx context.Context, in *Condition, opts ...grpc.CallOption) (*NumberOfRecords, error)
                                                                    	// AddIndex adds an index on the given key.
                                                                    	AddIndex(ctx context.Context, in *Index, opts ...grpc.CallOption) (*empty.Empty, error)
                                                                    	// AddUniqueIndex adds an index on the given key and the constraint that, for each value of this key, there is at most one record with that value.
                                                                    	AddUniqueIndex(ctx context.Context, in *Index, opts ...grpc.CallOption) (*empty.Empty, error)
                                                                    	// DeleteIndex deletes the index on the given key.
                                                                    	DeleteIndex(ctx context.Context, in *Index, opts ...grpc.CallOption) (*empty.Empty, error)
                                                                    	// ListIndices lists the keys for which indices are present.
                                                                    	ListIndices(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*IndexList, error)
                                                                    }

                                                                      KvdbClient is the client API for Kvdb service.

                                                                      For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

                                                                      func NewKvdbClient

                                                                      func NewKvdbClient(cc *grpc.ClientConn) KvdbClient

                                                                      type KvdbServer

                                                                      type KvdbServer interface {
                                                                      	// ListTables returns the tables in the database.
                                                                      	ListTables(context.Context, *empty.Empty) (*TableNames, error)
                                                                      	// CreateTable creates a table with the given name and template.
                                                                      	CreateTable(context.Context, *NameAndTemplate) (*empty.Empty, error)
                                                                      	// DescribeTable returns a best-guess template for the data in the table.
                                                                      	DescribeTable(context.Context, *empty.Empty) (*Record, error)
                                                                      	// DeleteTable deletes the table with the given name.
                                                                      	DeleteTable(context.Context, *Name) (*empty.Empty, error)
                                                                      	// CountWhere returns the number of records in the table that match the
                                                                      	// given condition.
                                                                      	CountWhere(context.Context, *Condition) (*NumberOfRecords, error)
                                                                      	// Insert inserts the records from stream into the table.
                                                                      	Insert(Kvdb_InsertServer) error
                                                                      	// UpdateWhere updates all records in the table that match the given
                                                                      	// condition by setting all keys present in the given record to the
                                                                      	// corresponding values. Returns the number of records updated.
                                                                      	UpdateWhere(context.Context, *ConditionAndReplacement) (*NumberOfRecords, error)
                                                                      	// SelectWhereLimit returns a stream of records matching the given
                                                                      	// condition. The returned records will be in the form specified by the
                                                                      	// given template. If the given limit is non-negative then at most that
                                                                      	// many records will be returned.
                                                                      	SelectWhereLimit(*ConditionTemplateOrderAndLimit, Kvdb_SelectWhereLimitServer) error
                                                                      	// DeleteWhere deletes those records in the table that match the given
                                                                      	// condition. Returns the number of records deleted.
                                                                      	DeleteWhere(context.Context, *Condition) (*NumberOfRecords, error)
                                                                      	// AddIndex adds an index on the given key.
                                                                      	AddIndex(context.Context, *Index) (*empty.Empty, error)
                                                                      	// AddUniqueIndex adds an index on the given key and the constraint that, for each value of this key, there is at most one record with that value.
                                                                      	AddUniqueIndex(context.Context, *Index) (*empty.Empty, error)
                                                                      	// DeleteIndex deletes the index on the given key.
                                                                      	DeleteIndex(context.Context, *Index) (*empty.Empty, error)
                                                                      	// ListIndices lists the keys for which indices are present.
                                                                      	ListIndices(context.Context, *empty.Empty) (*IndexList, error)
                                                                      }

                                                                        KvdbServer is the server API for Kvdb service.

                                                                        type Kvdb_InsertClient

                                                                        type Kvdb_InsertClient interface {
                                                                        	Send(*Record) error
                                                                        	CloseAndRecv() (*empty.Empty, error)
                                                                        	grpc.ClientStream
                                                                        }

                                                                        type Kvdb_InsertServer

                                                                        type Kvdb_InsertServer interface {
                                                                        	SendAndClose(*empty.Empty) error
                                                                        	Recv() (*Record, error)
                                                                        	grpc.ServerStream
                                                                        }

                                                                        type Kvdb_SelectWhereLimitClient

                                                                        type Kvdb_SelectWhereLimitClient interface {
                                                                        	Recv() (*Record, error)
                                                                        	grpc.ClientStream
                                                                        }

                                                                        type Kvdb_SelectWhereLimitServer

                                                                        type Kvdb_SelectWhereLimitServer interface {
                                                                        	Send(*Record) error
                                                                        	grpc.ServerStream
                                                                        }

                                                                        type LeafOperator

                                                                        type LeafOperator struct {
                                                                        	Lhs                  string                `protobuf:"bytes,1,opt,name=lhs,proto3" json:"lhs,omitempty"`
                                                                        	Opcode               LeafOperator_LeafType `protobuf:"varint,2,opt,name=opcode,proto3,enum=kvdb.LeafOperator_LeafType" json:"opcode,omitempty"`
                                                                        	Rhs                  *Value                `protobuf:"bytes,3,opt,name=rhs,proto3" json:"rhs,omitempty"`
                                                                        	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
                                                                        	XXX_unrecognized     []byte                `json:"-"`
                                                                        	XXX_sizecache        int32                 `json:"-"`
                                                                        }

                                                                          LeafOperator represents an operator of the form "lhs op rhs" where lhs is a key and rhs is a value.

                                                                          func FromLeafOp

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

                                                                            FromLeafOp converts a *condition.LeafOp to a *LeafOperator

                                                                            func (*LeafOperator) Descriptor

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

                                                                            func (*LeafOperator) GetLhs

                                                                            func (m *LeafOperator) GetLhs() string

                                                                            func (*LeafOperator) GetOpcode

                                                                            func (m *LeafOperator) GetOpcode() LeafOperator_LeafType

                                                                            func (*LeafOperator) GetRhs

                                                                            func (m *LeafOperator) GetRhs() *Value

                                                                            func (*LeafOperator) ProtoMessage

                                                                            func (*LeafOperator) ProtoMessage()

                                                                            func (*LeafOperator) Reset

                                                                            func (m *LeafOperator) Reset()

                                                                            func (*LeafOperator) String

                                                                            func (m *LeafOperator) String() string

                                                                            func (*LeafOperator) XXX_DiscardUnknown

                                                                            func (m *LeafOperator) XXX_DiscardUnknown()

                                                                            func (*LeafOperator) XXX_Marshal

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

                                                                            func (*LeafOperator) XXX_Merge

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

                                                                            func (*LeafOperator) XXX_Size

                                                                            func (m *LeafOperator) XXX_Size() int

                                                                            func (*LeafOperator) XXX_Unmarshal

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

                                                                            type LeafOperator_LeafType

                                                                            type LeafOperator_LeafType int32

                                                                              LeafType enumerates the possible leaf operators

                                                                              const (
                                                                              	LeafOperator_UNDEFINED LeafOperator_LeafType = 0
                                                                              	LeafOperator_EQ        LeafOperator_LeafType = 1
                                                                              	LeafOperator_NE        LeafOperator_LeafType = 2
                                                                              	LeafOperator_GT        LeafOperator_LeafType = 3
                                                                              	LeafOperator_LT        LeafOperator_LeafType = 4
                                                                              	LeafOperator_GE        LeafOperator_LeafType = 5
                                                                              	LeafOperator_LE        LeafOperator_LeafType = 6
                                                                              )

                                                                              func (LeafOperator_LeafType) EnumDescriptor

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

                                                                              func (LeafOperator_LeafType) String

                                                                              func (x LeafOperator_LeafType) String() string

                                                                              type LhsBool

                                                                              type LhsBool struct {
                                                                              	Lhs                  string   `protobuf:"bytes,1,opt,name=lhs,proto3" json:"lhs,omitempty"`
                                                                              	BoolValue            bool     `protobuf:"varint,2,opt,name=bool_value,json=boolValue,proto3" json:"bool_value,omitempty"`
                                                                              	XXX_NoUnkeyedLiteral struct{} `json:"-"`
                                                                              	XXX_unrecognized     []byte   `json:"-"`
                                                                              	XXX_sizecache        int32    `json:"-"`
                                                                              }

                                                                                LhsBool represents an IS condition

                                                                                func FromLHSBool

                                                                                func FromLHSBool(lhs string, b bool) *LhsBool

                                                                                  FromLHSBool converts a string and a slice of interface{} to a *LhsBool

                                                                                  func (*LhsBool) Descriptor

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

                                                                                  func (*LhsBool) GetBoolValue

                                                                                  func (m *LhsBool) GetBoolValue() bool

                                                                                  func (*LhsBool) GetLhs

                                                                                  func (m *LhsBool) GetLhs() string

                                                                                  func (*LhsBool) ProtoMessage

                                                                                  func (*LhsBool) ProtoMessage()

                                                                                  func (*LhsBool) Reset

                                                                                  func (m *LhsBool) Reset()

                                                                                  func (*LhsBool) String

                                                                                  func (m *LhsBool) String() string

                                                                                  func (*LhsBool) XXX_DiscardUnknown

                                                                                  func (m *LhsBool) XXX_DiscardUnknown()

                                                                                  func (*LhsBool) XXX_Marshal

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

                                                                                  func (*LhsBool) XXX_Merge

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

                                                                                  func (*LhsBool) XXX_Size

                                                                                  func (m *LhsBool) XXX_Size() int

                                                                                  func (*LhsBool) XXX_Unmarshal

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

                                                                                  type LhsLowerUpper

                                                                                  type LhsLowerUpper struct {
                                                                                  	Lhs                  string   `protobuf:"bytes,1,opt,name=lhs,proto3" json:"lhs,omitempty"`
                                                                                  	Lower                *Value   `protobuf:"bytes,2,opt,name=lower,proto3" json:"lower,omitempty"`
                                                                                  	Upper                *Value   `protobuf:"bytes,3,opt,name=upper,proto3" json:"upper,omitempty"`
                                                                                  	XXX_NoUnkeyedLiteral struct{} `json:"-"`
                                                                                  	XXX_unrecognized     []byte   `json:"-"`
                                                                                  	XXX_sizecache        int32    `json:"-"`
                                                                                  }

                                                                                    LhsLowerUpper represents a BETWEEN or NOT BETWEEN condition

                                                                                    func FromLHSLowerUpper

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

                                                                                      FromLHSLowerUpper converts a string and a pair of interface{}s to a *LhsLowerUpper

                                                                                      func (*LhsLowerUpper) Descriptor

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

                                                                                      func (*LhsLowerUpper) GetLhs

                                                                                      func (m *LhsLowerUpper) GetLhs() string

                                                                                      func (*LhsLowerUpper) GetLower

                                                                                      func (m *LhsLowerUpper) GetLower() *Value

                                                                                      func (*LhsLowerUpper) GetUpper

                                                                                      func (m *LhsLowerUpper) GetUpper() *Value

                                                                                      func (*LhsLowerUpper) ProtoMessage

                                                                                      func (*LhsLowerUpper) ProtoMessage()

                                                                                      func (*LhsLowerUpper) Reset

                                                                                      func (m *LhsLowerUpper) Reset()

                                                                                      func (*LhsLowerUpper) String

                                                                                      func (m *LhsLowerUpper) String() string

                                                                                      func (*LhsLowerUpper) XXX_DiscardUnknown

                                                                                      func (m *LhsLowerUpper) XXX_DiscardUnknown()

                                                                                      func (*LhsLowerUpper) XXX_Marshal

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

                                                                                      func (*LhsLowerUpper) XXX_Merge

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

                                                                                      func (*LhsLowerUpper) XXX_Size

                                                                                      func (m *LhsLowerUpper) XXX_Size() int

                                                                                      func (*LhsLowerUpper) XXX_Unmarshal

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

                                                                                      type LhsManyValues

                                                                                      type LhsManyValues struct {
                                                                                      	Lhs                  string   `protobuf:"bytes,1,opt,name=lhs,proto3" json:"lhs,omitempty"`
                                                                                      	Value                []*Value `protobuf:"bytes,2,rep,name=value,proto3" json:"value,omitempty"`
                                                                                      	XXX_NoUnkeyedLiteral struct{} `json:"-"`
                                                                                      	XXX_unrecognized     []byte   `json:"-"`
                                                                                      	XXX_sizecache        int32    `json:"-"`
                                                                                      }

                                                                                        LhsManyValues represents an IN or NOT IN condition

                                                                                        func FromLHSValues

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

                                                                                          FromLHSValues converts a string and a slice of interface{} to a *LhsManyValues

                                                                                          func (*LhsManyValues) Descriptor

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

                                                                                          func (*LhsManyValues) GetLhs

                                                                                          func (m *LhsManyValues) GetLhs() string

                                                                                          func (*LhsManyValues) GetValue

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

                                                                                          func (*LhsManyValues) ProtoMessage

                                                                                          func (*LhsManyValues) ProtoMessage()

                                                                                          func (*LhsManyValues) Reset

                                                                                          func (m *LhsManyValues) Reset()

                                                                                          func (*LhsManyValues) String

                                                                                          func (m *LhsManyValues) String() string

                                                                                          func (*LhsManyValues) XXX_DiscardUnknown

                                                                                          func (m *LhsManyValues) XXX_DiscardUnknown()

                                                                                          func (*LhsManyValues) XXX_Marshal

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

                                                                                          func (*LhsManyValues) XXX_Merge

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

                                                                                          func (*LhsManyValues) XXX_Size

                                                                                          func (m *LhsManyValues) XXX_Size() int

                                                                                          func (*LhsManyValues) XXX_Unmarshal

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

                                                                                          type ManyConditions

                                                                                          type ManyConditions struct {
                                                                                          	Cond                 []*Condition `protobuf:"bytes,1,rep,name=cond,proto3" json:"cond,omitempty"`
                                                                                          	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
                                                                                          	XXX_unrecognized     []byte       `json:"-"`
                                                                                          	XXX_sizecache        int32        `json:"-"`
                                                                                          }

                                                                                            ManyConditions represents a sequence of conditions

                                                                                            func FromConditions

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

                                                                                              FromConditions converts a slice of condition.Conditions to a *ManyConditions

                                                                                              func (*ManyConditions) Descriptor

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

                                                                                              func (*ManyConditions) GetCond

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

                                                                                              func (*ManyConditions) ProtoMessage

                                                                                              func (*ManyConditions) ProtoMessage()

                                                                                              func (*ManyConditions) Reset

                                                                                              func (m *ManyConditions) Reset()

                                                                                              func (*ManyConditions) String

                                                                                              func (m *ManyConditions) String() string

                                                                                              func (*ManyConditions) XXX_DiscardUnknown

                                                                                              func (m *ManyConditions) XXX_DiscardUnknown()

                                                                                              func (*ManyConditions) XXX_Marshal

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

                                                                                              func (*ManyConditions) XXX_Merge

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

                                                                                              func (*ManyConditions) XXX_Size

                                                                                              func (m *ManyConditions) XXX_Size() int

                                                                                              func (*ManyConditions) XXX_Unmarshal

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

                                                                                              type Name

                                                                                              type Name struct {
                                                                                              	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
                                                                                              	XXX_NoUnkeyedLiteral struct{} `json:"-"`
                                                                                              	XXX_unrecognized     []byte   `json:"-"`
                                                                                              	XXX_sizecache        int32    `json:"-"`
                                                                                              }

                                                                                                Name describes the name of a table.

                                                                                                func FromName

                                                                                                func FromName(name string) *Name

                                                                                                  FromName converts a string to a *Name.

                                                                                                  func (*Name) Descriptor

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

                                                                                                  func (*Name) GetName

                                                                                                  func (m *Name) GetName() string

                                                                                                  func (*Name) ProtoMessage

                                                                                                  func (*Name) ProtoMessage()

                                                                                                  func (*Name) Reset

                                                                                                  func (m *Name) Reset()

                                                                                                  func (*Name) String

                                                                                                  func (m *Name) String() string

                                                                                                  func (*Name) XXX_DiscardUnknown

                                                                                                  func (m *Name) XXX_DiscardUnknown()

                                                                                                  func (*Name) XXX_Marshal

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

                                                                                                  func (*Name) XXX_Merge

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

                                                                                                  func (*Name) XXX_Size

                                                                                                  func (m *Name) XXX_Size() int

                                                                                                  func (*Name) XXX_Unmarshal

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

                                                                                                  type NameAndTemplate

                                                                                                  type NameAndTemplate struct {
                                                                                                  	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
                                                                                                  	Template             *Record  `protobuf:"bytes,2,opt,name=template,proto3" json:"template,omitempty"`
                                                                                                  	XXX_NoUnkeyedLiteral struct{} `json:"-"`
                                                                                                  	XXX_unrecognized     []byte   `json:"-"`
                                                                                                  	XXX_sizecache        int32    `json:"-"`
                                                                                                  }

                                                                                                    NameAndTemplate describes the name and template for a table.

                                                                                                    func FromNameAndTemplate

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

                                                                                                      FromNameAndTemplate converts a string and a record.Record to a *NameAndTemplate.

                                                                                                      func (*NameAndTemplate) Descriptor

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

                                                                                                      func (*NameAndTemplate) GetName

                                                                                                      func (m *NameAndTemplate) GetName() string

                                                                                                      func (*NameAndTemplate) GetTemplate

                                                                                                      func (m *NameAndTemplate) GetTemplate() *Record

                                                                                                      func (*NameAndTemplate) ProtoMessage

                                                                                                      func (*NameAndTemplate) ProtoMessage()

                                                                                                      func (*NameAndTemplate) Reset

                                                                                                      func (m *NameAndTemplate) Reset()

                                                                                                      func (*NameAndTemplate) String

                                                                                                      func (m *NameAndTemplate) String() string

                                                                                                      func (*NameAndTemplate) XXX_DiscardUnknown

                                                                                                      func (m *NameAndTemplate) XXX_DiscardUnknown()

                                                                                                      func (*NameAndTemplate) XXX_Marshal

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

                                                                                                      func (*NameAndTemplate) XXX_Merge

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

                                                                                                      func (*NameAndTemplate) XXX_Size

                                                                                                      func (m *NameAndTemplate) XXX_Size() int

                                                                                                      func (*NameAndTemplate) XXX_Unmarshal

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

                                                                                                      type NumberOfRecords

                                                                                                      type NumberOfRecords struct {
                                                                                                      	N                    int64    `protobuf:"varint,1,opt,name=n,proto3" json:"n,omitempty"`
                                                                                                      	XXX_NoUnkeyedLiteral struct{} `json:"-"`
                                                                                                      	XXX_unrecognized     []byte   `json:"-"`
                                                                                                      	XXX_sizecache        int32    `json:"-"`
                                                                                                      }

                                                                                                        NumberOfRecords is the result of performing a task whose result is the number of records.

                                                                                                        func FromInt64

                                                                                                        func FromInt64(n int64) *NumberOfRecords

                                                                                                          FromInt64 converts an int64 to a *NumberOfRecords.

                                                                                                          func (*NumberOfRecords) Descriptor

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

                                                                                                          func (*NumberOfRecords) GetN

                                                                                                          func (m *NumberOfRecords) GetN() int64

                                                                                                          func (*NumberOfRecords) ProtoMessage

                                                                                                          func (*NumberOfRecords) ProtoMessage()

                                                                                                          func (*NumberOfRecords) Reset

                                                                                                          func (m *NumberOfRecords) Reset()

                                                                                                          func (*NumberOfRecords) String

                                                                                                          func (m *NumberOfRecords) String() string

                                                                                                          func (*NumberOfRecords) XXX_DiscardUnknown

                                                                                                          func (m *NumberOfRecords) XXX_DiscardUnknown()

                                                                                                          func (*NumberOfRecords) XXX_Marshal

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

                                                                                                          func (*NumberOfRecords) XXX_Merge

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

                                                                                                          func (*NumberOfRecords) XXX_Size

                                                                                                          func (m *NumberOfRecords) XXX_Size() int

                                                                                                          func (*NumberOfRecords) XXX_Unmarshal

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

                                                                                                          type Order

                                                                                                          type Order struct {
                                                                                                          	Key                  string     `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
                                                                                                          	Direction            *Direction `protobuf:"bytes,2,opt,name=direction,proto3" json:"direction,omitempty"`
                                                                                                          	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
                                                                                                          	XXX_unrecognized     []byte     `json:"-"`
                                                                                                          	XXX_sizecache        int32      `json:"-"`
                                                                                                          }

                                                                                                            Order represents a sort order

                                                                                                            func FromOrder

                                                                                                            func FromOrder(s sort.Order) *Order

                                                                                                              FromOrder converts a sort.Order to a *Order.

                                                                                                              func (*Order) Descriptor

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

                                                                                                              func (*Order) GetDirection

                                                                                                              func (m *Order) GetDirection() *Direction

                                                                                                              func (*Order) GetKey

                                                                                                              func (m *Order) GetKey() string

                                                                                                              func (*Order) ProtoMessage

                                                                                                              func (*Order) ProtoMessage()

                                                                                                              func (*Order) Reset

                                                                                                              func (m *Order) Reset()

                                                                                                              func (*Order) String

                                                                                                              func (m *Order) String() string

                                                                                                              func (*Order) XXX_DiscardUnknown

                                                                                                              func (m *Order) XXX_DiscardUnknown()

                                                                                                              func (*Order) XXX_Marshal

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

                                                                                                              func (*Order) XXX_Merge

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

                                                                                                              func (*Order) XXX_Size

                                                                                                              func (m *Order) XXX_Size() int

                                                                                                              func (*Order) XXX_Unmarshal

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

                                                                                                              type OrderBy

                                                                                                              type OrderBy struct {
                                                                                                              	Order                []*Order `protobuf:"bytes,1,rep,name=order,proto3" json:"order,omitempty"`
                                                                                                              	XXX_NoUnkeyedLiteral struct{} `json:"-"`
                                                                                                              	XXX_unrecognized     []byte   `json:"-"`
                                                                                                              	XXX_sizecache        int32    `json:"-"`
                                                                                                              }

                                                                                                                OrderBy represents a sequence of sort orders

                                                                                                                func FromOrderBy

                                                                                                                func FromOrderBy(S sort.OrderBy) *OrderBy

                                                                                                                  FromOrderBy converts a sort.OrderBy to a *OrderBy.

                                                                                                                  func (*OrderBy) Descriptor

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

                                                                                                                  func (*OrderBy) GetOrder

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

                                                                                                                  func (*OrderBy) ProtoMessage

                                                                                                                  func (*OrderBy) ProtoMessage()

                                                                                                                  func (*OrderBy) Reset

                                                                                                                  func (m *OrderBy) Reset()

                                                                                                                  func (*OrderBy) String

                                                                                                                  func (m *OrderBy) String() string

                                                                                                                  func (*OrderBy) XXX_DiscardUnknown

                                                                                                                  func (m *OrderBy) XXX_DiscardUnknown()

                                                                                                                  func (*OrderBy) XXX_Marshal

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

                                                                                                                  func (*OrderBy) XXX_Merge

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

                                                                                                                  func (*OrderBy) XXX_Size

                                                                                                                  func (m *OrderBy) XXX_Size() int

                                                                                                                  func (*OrderBy) XXX_Unmarshal

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

                                                                                                                  type Record

                                                                                                                  type Record struct {
                                                                                                                  	Values               map[string]*Value `` /* 153-byte string literal not displayed */
                                                                                                                  	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
                                                                                                                  	XXX_unrecognized     []byte            `json:"-"`
                                                                                                                  	XXX_sizecache        int32             `json:"-"`
                                                                                                                  }

                                                                                                                    Record is the type defining a record in a table. The keys of the map are the keys of the record, and the values of the map are the values of the record.

                                                                                                                    func FromRecord

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

                                                                                                                      FromRecord converts a record.Record to a *Record.

                                                                                                                      func (*Record) Descriptor

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

                                                                                                                      func (*Record) GetValues

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

                                                                                                                      func (*Record) ProtoMessage

                                                                                                                      func (*Record) ProtoMessage()

                                                                                                                      func (*Record) Reset

                                                                                                                      func (m *Record) Reset()

                                                                                                                      func (*Record) String

                                                                                                                      func (m *Record) String() string

                                                                                                                      func (*Record) XXX_DiscardUnknown

                                                                                                                      func (m *Record) XXX_DiscardUnknown()

                                                                                                                      func (*Record) XXX_Marshal

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

                                                                                                                      func (*Record) XXX_Merge

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

                                                                                                                      func (*Record) XXX_Size

                                                                                                                      func (m *Record) XXX_Size() int

                                                                                                                      func (*Record) XXX_Unmarshal

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

                                                                                                                      type TableNames

                                                                                                                      type TableNames struct {
                                                                                                                      	Name                 []string `protobuf:"bytes,1,rep,name=name,proto3" json:"name,omitempty"`
                                                                                                                      	XXX_NoUnkeyedLiteral struct{} `json:"-"`
                                                                                                                      	XXX_unrecognized     []byte   `json:"-"`
                                                                                                                      	XXX_sizecache        int32    `json:"-"`
                                                                                                                      }

                                                                                                                        TableNames encodes a list of table names.

                                                                                                                        func (*TableNames) Descriptor

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

                                                                                                                        func (*TableNames) GetName

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

                                                                                                                        func (*TableNames) ProtoMessage

                                                                                                                        func (*TableNames) ProtoMessage()

                                                                                                                        func (*TableNames) Reset

                                                                                                                        func (m *TableNames) Reset()

                                                                                                                        func (*TableNames) String

                                                                                                                        func (m *TableNames) String() string

                                                                                                                        func (*TableNames) XXX_DiscardUnknown

                                                                                                                        func (m *TableNames) XXX_DiscardUnknown()

                                                                                                                        func (*TableNames) XXX_Marshal

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

                                                                                                                        func (*TableNames) XXX_Merge

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

                                                                                                                        func (*TableNames) XXX_Size

                                                                                                                        func (m *TableNames) XXX_Size() int

                                                                                                                        func (*TableNames) XXX_Unmarshal

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

                                                                                                                        type UnimplementedKvdbServer

                                                                                                                        type UnimplementedKvdbServer struct {
                                                                                                                        }

                                                                                                                          UnimplementedKvdbServer can be embedded to have forward compatible implementations.

                                                                                                                          func (*UnimplementedKvdbServer) AddIndex

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

                                                                                                                          func (*UnimplementedKvdbServer) AddUniqueIndex

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

                                                                                                                          func (*UnimplementedKvdbServer) CountWhere

                                                                                                                          func (*UnimplementedKvdbServer) CreateTable

                                                                                                                          func (*UnimplementedKvdbServer) DeleteIndex

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

                                                                                                                          func (*UnimplementedKvdbServer) DeleteTable

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

                                                                                                                          func (*UnimplementedKvdbServer) DeleteWhere

                                                                                                                          func (*UnimplementedKvdbServer) DescribeTable

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

                                                                                                                          func (*UnimplementedKvdbServer) Insert

                                                                                                                          func (*UnimplementedKvdbServer) ListIndices

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

                                                                                                                          func (*UnimplementedKvdbServer) ListTables

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

                                                                                                                          func (*UnimplementedKvdbServer) SelectWhereLimit

                                                                                                                          func (*UnimplementedKvdbServer) UpdateWhere

                                                                                                                          type Value

                                                                                                                          type Value struct {
                                                                                                                          	Type Value_Type `protobuf:"varint,1,opt,name=type,proto3,enum=kvdb.Value_Type" json:"type,omitempty"`
                                                                                                                          	// Types that are valid to be assigned to Value:
                                                                                                                          	//	*Value_Int32Value
                                                                                                                          	//	*Value_Int64Value
                                                                                                                          	//	*Value_Uint32Value
                                                                                                                          	//	*Value_Uint64Value
                                                                                                                          	//	*Value_BoolValue
                                                                                                                          	//	*Value_DoubleValue
                                                                                                                          	//	*Value_StringValue
                                                                                                                          	//	*Value_BytesValue
                                                                                                                          	Value                isValue_Value `protobuf_oneof:"value"`
                                                                                                                          	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
                                                                                                                          	XXX_unrecognized     []byte        `json:"-"`
                                                                                                                          	XXX_sizecache        int32         `json:"-"`
                                                                                                                          }

                                                                                                                            Value describes a value in a record.

                                                                                                                            func (*Value) Descriptor

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

                                                                                                                            func (*Value) GetBoolValue

                                                                                                                            func (m *Value) GetBoolValue() bool

                                                                                                                            func (*Value) GetBytesValue

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

                                                                                                                            func (*Value) GetDoubleValue

                                                                                                                            func (m *Value) GetDoubleValue() float64

                                                                                                                            func (*Value) GetInt32Value

                                                                                                                            func (m *Value) GetInt32Value() int32

                                                                                                                            func (*Value) GetInt64Value

                                                                                                                            func (m *Value) GetInt64Value() int64

                                                                                                                            func (*Value) GetStringValue

                                                                                                                            func (m *Value) GetStringValue() string

                                                                                                                            func (*Value) GetType

                                                                                                                            func (m *Value) GetType() Value_Type

                                                                                                                            func (*Value) GetUint32Value

                                                                                                                            func (m *Value) GetUint32Value() uint32

                                                                                                                            func (*Value) GetUint64Value

                                                                                                                            func (m *Value) GetUint64Value() uint64

                                                                                                                            func (*Value) GetValue

                                                                                                                            func (m *Value) GetValue() isValue_Value

                                                                                                                            func (*Value) ProtoMessage

                                                                                                                            func (*Value) ProtoMessage()

                                                                                                                            func (*Value) Reset

                                                                                                                            func (m *Value) Reset()

                                                                                                                            func (*Value) String

                                                                                                                            func (m *Value) String() string

                                                                                                                            func (*Value) XXX_DiscardUnknown

                                                                                                                            func (m *Value) XXX_DiscardUnknown()

                                                                                                                            func (*Value) XXX_Marshal

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

                                                                                                                            func (*Value) XXX_Merge

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

                                                                                                                            func (*Value) XXX_OneofWrappers

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

                                                                                                                              XXX_OneofWrappers is for the internal use of the proto package.

                                                                                                                              func (*Value) XXX_Size

                                                                                                                              func (m *Value) XXX_Size() int

                                                                                                                              func (*Value) XXX_Unmarshal

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

                                                                                                                              type Value_BoolValue

                                                                                                                              type Value_BoolValue struct {
                                                                                                                              	BoolValue bool `protobuf:"varint,6,opt,name=bool_value,json=boolValue,proto3,oneof"`
                                                                                                                              }

                                                                                                                              type Value_BytesValue

                                                                                                                              type Value_BytesValue struct {
                                                                                                                              	BytesValue []byte `protobuf:"bytes,9,opt,name=bytes_value,json=bytesValue,proto3,oneof"`
                                                                                                                              }

                                                                                                                              type Value_DoubleValue

                                                                                                                              type Value_DoubleValue struct {
                                                                                                                              	DoubleValue float64 `protobuf:"fixed64,7,opt,name=double_value,json=doubleValue,proto3,oneof"`
                                                                                                                              }

                                                                                                                              type Value_Int32Value

                                                                                                                              type Value_Int32Value struct {
                                                                                                                              	Int32Value int32 `protobuf:"varint,2,opt,name=int32_value,json=int32Value,proto3,oneof"`
                                                                                                                              }

                                                                                                                              type Value_Int64Value

                                                                                                                              type Value_Int64Value struct {
                                                                                                                              	Int64Value int64 `protobuf:"varint,3,opt,name=int64_value,json=int64Value,proto3,oneof"`
                                                                                                                              }

                                                                                                                              type Value_StringValue

                                                                                                                              type Value_StringValue struct {
                                                                                                                              	StringValue string `protobuf:"bytes,8,opt,name=string_value,json=stringValue,proto3,oneof"`
                                                                                                                              }

                                                                                                                              type Value_Type

                                                                                                                              type Value_Type int32

                                                                                                                                Type enumerates the possible value types

                                                                                                                                const (
                                                                                                                                	Value_UNDEFINED Value_Type = 0
                                                                                                                                	Value_INT       Value_Type = 1
                                                                                                                                	Value_INT8      Value_Type = 2
                                                                                                                                	Value_INT16     Value_Type = 3
                                                                                                                                	Value_INT32     Value_Type = 4
                                                                                                                                	Value_INT64     Value_Type = 5
                                                                                                                                	Value_UINT      Value_Type = 6
                                                                                                                                	Value_UINT8     Value_Type = 7
                                                                                                                                	Value_UINT16    Value_Type = 8
                                                                                                                                	Value_UINT32    Value_Type = 9
                                                                                                                                	Value_UINT64    Value_Type = 10
                                                                                                                                	Value_BOOL      Value_Type = 11
                                                                                                                                	Value_FLOAT64   Value_Type = 12
                                                                                                                                	Value_STRING    Value_Type = 13
                                                                                                                                	Value_BYTESLICE Value_Type = 14
                                                                                                                                )

                                                                                                                                func (Value_Type) EnumDescriptor

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

                                                                                                                                func (Value_Type) String

                                                                                                                                func (x Value_Type) String() string

                                                                                                                                type Value_Uint32Value

                                                                                                                                type Value_Uint32Value struct {
                                                                                                                                	Uint32Value uint32 `protobuf:"varint,4,opt,name=uint32_value,json=uint32Value,proto3,oneof"`
                                                                                                                                }

                                                                                                                                type Value_Uint64Value

                                                                                                                                type Value_Uint64Value struct {
                                                                                                                                	Uint64Value uint64 `protobuf:"varint,5,opt,name=uint64_value,json=uint64Value,proto3,oneof"`
                                                                                                                                }