kvdbrpc

type Condition struct {
	Type Condition_CondType `protobuf:"varint,1,opt,name=type,proto3,enum=kvdb.Condition_CondType" json:"type,omitempty"` // The condition type
	// Types that are assignable to Value:
	//
	//	*Condition_ManyConditionsValue
	//	*Condition_LhsLowerUpperValue
	//	*Condition_BoolValue
	//	*Condition_LhsManyValuesValue
	//	*Condition_LeafValue
	//	*Condition_LhsBoolValue
	Value isCondition_Value `protobuf_oneof:"value"`
	// contains filtered or unexported fields
}

type ConditionAndReplacement struct {
	Condition   *Condition `protobuf:"bytes,1,opt,name=condition,proto3" json:"condition,omitempty"`     // The condition to match against
	Replacement *Record    `protobuf:"bytes,2,opt,name=replacement,proto3" json:"replacement,omitempty"` // The replacement values
	// contains filtered or unexported fields
}

type ConditionTemplateAndOrder struct {
	Condition *Condition `protobuf:"bytes,1,opt,name=condition,proto3" json:"condition,omitempty"` // The condition to match against
	Template  *Record    `protobuf:"bytes,2,opt,name=template,proto3" json:"template,omitempty"`   // A template for the returned records
	Order     *OrderBy   `protobuf:"bytes,3,opt,name=order,proto3" json:"order,omitempty"`         // The sort order
	// contains filtered or unexported fields
}

type ConditionTemplateOrderAndLimit struct {
	Condition *Condition `protobuf:"bytes,1,opt,name=condition,proto3" json:"condition,omitempty"` // The condition to match against
	Template  *Record    `protobuf:"bytes,2,opt,name=template,proto3" json:"template,omitempty"`   // A template for the returned records
	Order     *OrderBy   `protobuf:"bytes,3,opt,name=order,proto3" json:"order,omitempty"`         // The sort order
	Limit     int64      `protobuf:"varint,4,opt,name=limit,proto3" json:"limit,omitempty"`        // Limit the number of records to return (a
	// contains filtered or unexported fields
}

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

type Condition_CondType int32

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

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

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

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

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

type DatabaseNames struct {
	Name []string `protobuf:"bytes,1,rep,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

type Direction struct {
	Direction bool `protobuf:"varint,1,opt,name=direction,proto3" json:"direction,omitempty"`
	// contains filtered or unexported fields
}

type HasRecord struct {
	HasRecord bool    `protobuf:"varint,1,opt,name=has_record,json=hasRecord,proto3" json:"has_record,omitempty"` // Is there a record?
	Record    *Record `protobuf:"bytes,2,opt,name=record,proto3" json:"record,omitempty"`                         // The associated record
	// contains filtered or unexported fields
}

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

type IndexList struct {
	List []*Index `protobuf:"bytes,1,rep,name=list,proto3" json:"list,omitempty"`
	// contains filtered or unexported fields
}

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

type KeyList struct {
	List []*Key `protobuf:"bytes,1,rep,name=list,proto3" json:"list,omitempty"`
	// contains filtered or unexported fields
}

type KvdbClient interface {
	// ListDatabases returns the available databases.
	ListDatabases(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*DatabaseNames, error)
	// ListTables returns the tables in the database.
	// Note that 'db_name' must be set.
	ListTables(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*TableNames, error)
	// CreateTable creates a table with the given name and template.
	// Note that 'db_name' must be set.
	CreateTable(ctx context.Context, in *NameAndTemplate, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// DeleteTable deletes the table with the given name.
	// Note that 'db_name' must be set.
	DeleteTable(ctx context.Context, in *Name, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// RenameTable changes the name of a table in the database.
	// Note that 'db_name' must be set.
	RenameTable(ctx context.Context, in *SrcAndDstNames, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// DescribeTable returns a best-guess template for the data in the table.
	// Note that 'db_name' and 'table_name' must be set.
	DescribeTable(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*Record, error)
	// CountWhere returns the number of records in the table that match the
	// given condition.
	// Note that 'db_name' and 'table_name' must be set.
	CountWhere(ctx context.Context, in *Condition, opts ...grpc.CallOption) (*NumberOfRecords, error)
	// Insert inserts the records from stream into the table.
	// Note that 'db_name' and 'table_name' must be set.
	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.
	// Note that 'db_name' and 'table_name' must be set.
	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.
	// Note that 'db_name' and 'table_name' must be set.
	SelectWhereLimit(ctx context.Context, in *ConditionTemplateOrderAndLimit, opts ...grpc.CallOption) (Kvdb_SelectWhereLimitClient, error)
	// SelectOneWhere returns zero or one records, encoded in a HasRecord,
	// matching the given condition. The returned record will be in the form
	// specified by the given template.
	// Note that 'db_name' and 'table_name' must be set.
	SelectOneWhere(ctx context.Context, in *ConditionTemplateAndOrder, opts ...grpc.CallOption) (*HasRecord, error)
	// DeleteWhere deletes those records in the table that match the given
	// condition. Returns the number of records deleted.
	// Note that 'db_name' and 'table_name' must be set.
	DeleteWhere(ctx context.Context, in *Condition, opts ...grpc.CallOption) (*NumberOfRecords, error)
	// AddIndex adds an index on the given key.
	// Note that 'db_name' and 'table_name' must be set.
	AddIndex(ctx context.Context, in *Index, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// DeleteIndex deletes the index on the given key.
	// Note that 'db_name' and 'table_name' must be set.
	DeleteIndex(ctx context.Context, in *Index, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// ListIndices lists the keys for which indices are present.
	// Note that 'db_name' and 'table_name' must be set.
	ListIndices(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*IndexList, error)
	// AddKeys updates each record r in the table, adding any keys in the given
	// record that are not already present along with the corresponding values.
	// Any keys that are already present in r will be left unmodified.
	// Note that 'db_name' and 'table_name' must be set.
	AddKeys(ctx context.Context, in *Record, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// DeleteKeys updates all records in the table, deleting the specified keys
	// if present.
	// Note that 'db_name' and 'table_name' must be set.
	DeleteKeys(ctx context.Context, in *KeyList, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// DeleteDatabase deletes the database 'db_name'
	DeleteDatabase(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// CreateDatabase creates the database 'db_name'
	CreateDatabase(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

type KvdbServer interface {
	// ListDatabases returns the available databases.
	ListDatabases(context.Context, *emptypb.Empty) (*DatabaseNames, error)
	// ListTables returns the tables in the database.
	// Note that 'db_name' must be set.
	ListTables(context.Context, *emptypb.Empty) (*TableNames, error)
	// CreateTable creates a table with the given name and template.
	// Note that 'db_name' must be set.
	CreateTable(context.Context, *NameAndTemplate) (*emptypb.Empty, error)
	// DeleteTable deletes the table with the given name.
	// Note that 'db_name' must be set.
	DeleteTable(context.Context, *Name) (*emptypb.Empty, error)
	// RenameTable changes the name of a table in the database.
	// Note that 'db_name' must be set.
	RenameTable(context.Context, *SrcAndDstNames) (*emptypb.Empty, error)
	// DescribeTable returns a best-guess template for the data in the table.
	// Note that 'db_name' and 'table_name' must be set.
	DescribeTable(context.Context, *emptypb.Empty) (*Record, error)
	// CountWhere returns the number of records in the table that match the
	// given condition.
	// Note that 'db_name' and 'table_name' must be set.
	CountWhere(context.Context, *Condition) (*NumberOfRecords, error)
	// Insert inserts the records from stream into the table.
	// Note that 'db_name' and 'table_name' must be set.
	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.
	// Note that 'db_name' and 'table_name' must be set.
	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.
	// Note that 'db_name' and 'table_name' must be set.
	SelectWhereLimit(*ConditionTemplateOrderAndLimit, Kvdb_SelectWhereLimitServer) error
	// SelectOneWhere returns zero or one records, encoded in a HasRecord,
	// matching the given condition. The returned record will be in the form
	// specified by the given template.
	// Note that 'db_name' and 'table_name' must be set.
	SelectOneWhere(context.Context, *ConditionTemplateAndOrder) (*HasRecord, error)
	// DeleteWhere deletes those records in the table that match the given
	// condition. Returns the number of records deleted.
	// Note that 'db_name' and 'table_name' must be set.
	DeleteWhere(context.Context, *Condition) (*NumberOfRecords, error)
	// AddIndex adds an index on the given key.
	// Note that 'db_name' and 'table_name' must be set.
	AddIndex(context.Context, *Index) (*emptypb.Empty, error)
	// DeleteIndex deletes the index on the given key.
	// Note that 'db_name' and 'table_name' must be set.
	DeleteIndex(context.Context, *Index) (*emptypb.Empty, error)
	// ListIndices lists the keys for which indices are present.
	// Note that 'db_name' and 'table_name' must be set.
	ListIndices(context.Context, *emptypb.Empty) (*IndexList, error)
	// AddKeys updates each record r in the table, adding any keys in the given
	// record that are not already present along with the corresponding values.
	// Any keys that are already present in r will be left unmodified.
	// Note that 'db_name' and 'table_name' must be set.
	AddKeys(context.Context, *Record) (*emptypb.Empty, error)
	// DeleteKeys updates all records in the table, deleting the specified keys
	// if present.
	// Note that 'db_name' and 'table_name' must be set.
	DeleteKeys(context.Context, *KeyList) (*emptypb.Empty, error)
	// DeleteDatabase deletes the database 'db_name'
	DeleteDatabase(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
	// CreateDatabase creates the database 'db_name'
	CreateDatabase(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
	// contains filtered or unexported methods
}

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

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

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

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

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"`
	// contains filtered or unexported fields
}

type LeafOperator_LeafType int32

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"`
	// contains filtered or unexported fields
}

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"`
	// contains filtered or unexported fields
}

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"`
	// contains filtered or unexported fields
}

type ManyConditions struct {
	Cond []*Condition `protobuf:"bytes,1,rep,name=cond,proto3" json:"cond,omitempty"`
	// contains filtered or unexported fields
}

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

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"`
	// contains filtered or unexported fields
}

type NumberOfRecords struct {
	N int64 `protobuf:"varint,1,opt,name=n,proto3" json:"n,omitempty"` // The number of matching records
	// contains filtered or unexported fields
}

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"`
	// contains filtered or unexported fields
}

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

type Record struct {
	Values map[string]*Value `` // The map of record keys to values
	/* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

type SrcAndDstNames struct {
	Src string `protobuf:"bytes,1,opt,name=src,proto3" json:"src,omitempty"`
	Dst string `protobuf:"bytes,2,opt,name=dst,proto3" json:"dst,omitempty"`
	// contains filtered or unexported fields
}

type TableNames struct {
	Name []string `protobuf:"bytes,1,rep,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedKvdbServer struct {
}

type UnsafeKvdbServer interface {
	// contains filtered or unexported methods
}

type Value struct {
	Type Value_Type `protobuf:"varint,1,opt,name=type,proto3,enum=kvdb.Value_Type" json:"type,omitempty"` // The value type
	// Types that are assignable to Value:
	//
	//	*Value_Int32Value
	//	*Value_Int64Value
	//	*Value_Uint32Value
	//	*Value_Uint64Value
	//	*Value_BoolValue
	//	*Value_DoubleValue
	//	*Value_StringValue
	//	*Value_BytesValue
	Value isValue_Value `protobuf_oneof:"value"`
	// contains filtered or unexported fields
}

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

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

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

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

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

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

type Value_Type int32

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

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