Versions in this module Expand all Collapse all v0 v0.1.0 Aug 11, 2026 Changes in this version + const DataService_List_FullMethodName + const DataService_Mutate_FullMethodName + const DataService_Query_FullMethodName + var AggFunc_name = map[int32]string + var AggFunc_value = map[string]int32 + var DataService_ServiceDesc = grpc.ServiceDesc + var File_proto_data_proto protoreflect.FileDescriptor + var FilterOp_name = map[int32]string + var FilterOp_value = map[string]int32 + var Kind_name = map[int32]string + var Kind_value = map[string]int32 + var MutationKind_name = map[int32]string + var MutationKind_value = map[string]int32 + func RegisterDataServiceServer(s grpc.ServiceRegistrar, srv DataServiceServer) + type Agg struct + Field string + Func AggFunc + func (*Agg) Descriptor() ([]byte, []int) + func (*Agg) ProtoMessage() + func (x *Agg) GetField() string + func (x *Agg) GetFunc() AggFunc + func (x *Agg) ProtoReflect() protoreflect.Message + func (x *Agg) Reset() + func (x *Agg) String() string + type AggFunc int32 + const AggFunc_AGG_AVG + const AggFunc_AGG_COUNT + const AggFunc_AGG_MAX + const AggFunc_AGG_MIN + const AggFunc_AGG_SUM + func (AggFunc) Descriptor() protoreflect.EnumDescriptor + func (AggFunc) EnumDescriptor() ([]byte, []int) + func (AggFunc) Type() protoreflect.EnumType + func (x AggFunc) Enum() *AggFunc + func (x AggFunc) Number() protoreflect.EnumNumber + func (x AggFunc) String() string + type DataServiceClient interface + List func(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListResponse, error) + Mutate func(ctx context.Context, in *Mutation, opts ...grpc.CallOption) (*MutateResponse, error) + Query func(ctx context.Context, in *Query, opts ...grpc.CallOption) (*View, error) + func NewDataServiceClient(cc grpc.ClientConnInterface) DataServiceClient + type DataServiceServer interface + List func(context.Context, *ListRequest) (*ListResponse, error) + Mutate func(context.Context, *Mutation) (*MutateResponse, error) + Query func(context.Context, *Query) (*View, error) + type Filter struct + Field string + Op FilterOp + Value *Value + func (*Filter) Descriptor() ([]byte, []int) + func (*Filter) ProtoMessage() + func (x *Filter) GetField() string + func (x *Filter) GetOp() FilterOp + func (x *Filter) GetValue() *Value + func (x *Filter) ProtoReflect() protoreflect.Message + func (x *Filter) Reset() + func (x *Filter) String() string + type FilterOp int32 + const FilterOp_OP_CONTAINS + const FilterOp_OP_EQ + const FilterOp_OP_GE + const FilterOp_OP_GT + const FilterOp_OP_LE + const FilterOp_OP_LT + const FilterOp_OP_NE + func (FilterOp) Descriptor() protoreflect.EnumDescriptor + func (FilterOp) EnumDescriptor() ([]byte, []int) + func (FilterOp) Type() protoreflect.EnumType + func (x FilterOp) Enum() *FilterOp + func (x FilterOp) Number() protoreflect.EnumNumber + func (x FilterOp) String() string + type Group struct + Aggregates map[string]*Value + Key *Value + Rows []*Record + func (*Group) Descriptor() ([]byte, []int) + func (*Group) ProtoMessage() + func (x *Group) GetAggregates() map[string]*Value + func (x *Group) GetKey() *Value + func (x *Group) GetRows() []*Record + func (x *Group) ProtoReflect() protoreflect.Message + func (x *Group) Reset() + func (x *Group) String() string + type Kind int32 + const Kind_KIND_BOOL + const Kind_KIND_FLOAT + const Kind_KIND_INT + const Kind_KIND_STRING + func (Kind) Descriptor() protoreflect.EnumDescriptor + func (Kind) EnumDescriptor() ([]byte, []int) + func (Kind) Type() protoreflect.EnumType + func (x Kind) Enum() *Kind + func (x Kind) Number() protoreflect.EnumNumber + func (x Kind) String() string + type ListRequest struct + func (*ListRequest) Descriptor() ([]byte, []int) + func (*ListRequest) ProtoMessage() + func (x *ListRequest) ProtoReflect() protoreflect.Message + func (x *ListRequest) Reset() + func (x *ListRequest) String() string + type ListResponse struct + Records []*Record + func (*ListResponse) Descriptor() ([]byte, []int) + func (*ListResponse) ProtoMessage() + func (x *ListResponse) GetRecords() []*Record + func (x *ListResponse) ProtoReflect() protoreflect.Message + func (x *ListResponse) Reset() + func (x *ListResponse) String() string + type MutateResponse struct + func (*MutateResponse) Descriptor() ([]byte, []int) + func (*MutateResponse) ProtoMessage() + func (x *MutateResponse) ProtoReflect() protoreflect.Message + func (x *MutateResponse) Reset() + func (x *MutateResponse) String() string + type Mutation struct + Key *Value + Kind MutationKind + Record *Record + func (*Mutation) Descriptor() ([]byte, []int) + func (*Mutation) ProtoMessage() + func (x *Mutation) GetKey() *Value + func (x *Mutation) GetKind() MutationKind + func (x *Mutation) GetRecord() *Record + func (x *Mutation) ProtoReflect() protoreflect.Message + func (x *Mutation) Reset() + func (x *Mutation) String() string + type MutationKind int32 + const MutationKind_MUT_DELETE + const MutationKind_MUT_INSERT + const MutationKind_MUT_UPDATE + func (MutationKind) Descriptor() protoreflect.EnumDescriptor + func (MutationKind) EnumDescriptor() ([]byte, []int) + func (MutationKind) Type() protoreflect.EnumType + func (x MutationKind) Enum() *MutationKind + func (x MutationKind) Number() protoreflect.EnumNumber + func (x MutationKind) String() string + type Query struct + Aggs []*Agg + Filters []*Filter + GroupBy string + Limit int32 + Offset int32 + Sorts []*Sort + func (*Query) Descriptor() ([]byte, []int) + func (*Query) ProtoMessage() + func (x *Query) GetAggs() []*Agg + func (x *Query) GetFilters() []*Filter + func (x *Query) GetGroupBy() string + func (x *Query) GetLimit() int32 + func (x *Query) GetOffset() int32 + func (x *Query) GetSorts() []*Sort + func (x *Query) ProtoReflect() protoreflect.Message + func (x *Query) Reset() + func (x *Query) String() string + type Record struct + Fields map[string]*Value + func (*Record) Descriptor() ([]byte, []int) + func (*Record) ProtoMessage() + func (x *Record) GetFields() map[string]*Value + func (x *Record) ProtoReflect() protoreflect.Message + func (x *Record) Reset() + func (x *Record) String() string + type Sort struct + Desc bool + Field string + func (*Sort) Descriptor() ([]byte, []int) + func (*Sort) ProtoMessage() + func (x *Sort) GetDesc() bool + func (x *Sort) GetField() string + func (x *Sort) ProtoReflect() protoreflect.Message + func (x *Sort) Reset() + func (x *Sort) String() string + type UnimplementedDataServiceServer struct + func (UnimplementedDataServiceServer) List(context.Context, *ListRequest) (*ListResponse, error) + func (UnimplementedDataServiceServer) Mutate(context.Context, *Mutation) (*MutateResponse, error) + func (UnimplementedDataServiceServer) Query(context.Context, *Query) (*View, error) + type UnsafeDataServiceServer interface + type Value struct + Bool bool + Float float64 + Int int64 + Kind Kind + Str string + func (*Value) Descriptor() ([]byte, []int) + func (*Value) ProtoMessage() + func (x *Value) GetBool() bool + func (x *Value) GetFloat() float64 + func (x *Value) GetInt() int64 + func (x *Value) GetKind() Kind + func (x *Value) GetStr() string + func (x *Value) ProtoReflect() protoreflect.Message + func (x *Value) Reset() + func (x *Value) String() string + type View struct + Aggregates map[string]*Value + Grouped bool + Groups []*Group + Rows []*Record + Total int32 + func (*View) Descriptor() ([]byte, []int) + func (*View) ProtoMessage() + func (x *View) GetAggregates() map[string]*Value + func (x *View) GetGrouped() bool + func (x *View) GetGroups() []*Group + func (x *View) GetRows() []*Record + func (x *View) GetTotal() int32 + func (x *View) ProtoReflect() protoreflect.Message + func (x *View) Reset() + func (x *View) String() string