Versions in this module Expand all Collapse all v0 v0.5.6 Mar 19, 2026 v0.5.5 Mar 7, 2026 Changes in this version + const VectorStore_AddCollection_FullMethodName + const VectorStore_AddVectors_FullMethodName + const VectorStore_DeleteCollection_FullMethodName + const VectorStore_DeleteVectors_FullMethodName + const VectorStore_ListCollections_FullMethodName + const VectorStore_QueryVectors_FullMethodName + var Distance_name = map[int32]string + var Distance_value = map[string]int32 + var File_vector_store_proto protoreflect.FileDescriptor + var VectorStore_ServiceDesc = grpc.ServiceDesc + func RegisterVectorStoreServer(s grpc.ServiceRegistrar, srv VectorStoreServer) + type AddCollectionRequest struct + Dimensions int32 + Distance Distance + Name string + func (*AddCollectionRequest) Descriptor() ([]byte, []int) + func (*AddCollectionRequest) ProtoMessage() + func (x *AddCollectionRequest) GetDimensions() int32 + func (x *AddCollectionRequest) GetDistance() Distance + func (x *AddCollectionRequest) GetName() string + func (x *AddCollectionRequest) ProtoReflect() protoreflect.Message + func (x *AddCollectionRequest) Reset() + func (x *AddCollectionRequest) String() string + type AddCollectionResponse struct + func (*AddCollectionResponse) Descriptor() ([]byte, []int) + func (*AddCollectionResponse) ProtoMessage() + func (x *AddCollectionResponse) ProtoReflect() protoreflect.Message + func (x *AddCollectionResponse) Reset() + func (x *AddCollectionResponse) String() string + type AddVectorsRequest struct + Collection string + Vectors []*Vector + func (*AddVectorsRequest) Descriptor() ([]byte, []int) + func (*AddVectorsRequest) ProtoMessage() + func (x *AddVectorsRequest) GetCollection() string + func (x *AddVectorsRequest) GetVectors() []*Vector + func (x *AddVectorsRequest) ProtoReflect() protoreflect.Message + func (x *AddVectorsRequest) Reset() + func (x *AddVectorsRequest) String() string + type AddVectorsResponse struct + func (*AddVectorsResponse) Descriptor() ([]byte, []int) + func (*AddVectorsResponse) ProtoMessage() + func (x *AddVectorsResponse) ProtoReflect() protoreflect.Message + func (x *AddVectorsResponse) Reset() + func (x *AddVectorsResponse) String() string + type DeleteCollectionRequest struct + Name string + func (*DeleteCollectionRequest) Descriptor() ([]byte, []int) + func (*DeleteCollectionRequest) ProtoMessage() + func (x *DeleteCollectionRequest) GetName() string + func (x *DeleteCollectionRequest) ProtoReflect() protoreflect.Message + func (x *DeleteCollectionRequest) Reset() + func (x *DeleteCollectionRequest) String() string + type DeleteCollectionResponse struct + func (*DeleteCollectionResponse) Descriptor() ([]byte, []int) + func (*DeleteCollectionResponse) ProtoMessage() + func (x *DeleteCollectionResponse) ProtoReflect() protoreflect.Message + func (x *DeleteCollectionResponse) Reset() + func (x *DeleteCollectionResponse) String() string + type DeleteVectorsRequest struct + Collection string + Timestamp *timestamppb.Timestamp + func (*DeleteVectorsRequest) Descriptor() ([]byte, []int) + func (*DeleteVectorsRequest) ProtoMessage() + func (x *DeleteVectorsRequest) GetCollection() string + func (x *DeleteVectorsRequest) GetTimestamp() *timestamppb.Timestamp + func (x *DeleteVectorsRequest) ProtoReflect() protoreflect.Message + func (x *DeleteVectorsRequest) Reset() + func (x *DeleteVectorsRequest) String() string + type DeleteVectorsResponse struct + func (*DeleteVectorsResponse) Descriptor() ([]byte, []int) + func (*DeleteVectorsResponse) ProtoMessage() + func (x *DeleteVectorsResponse) ProtoReflect() protoreflect.Message + func (x *DeleteVectorsResponse) Reset() + func (x *DeleteVectorsResponse) String() string + type Distance int32 + const Distance_Cosine + const Distance_Dot + const Distance_Euclidean + const Distance_Unknown + func (Distance) Descriptor() protoreflect.EnumDescriptor + func (Distance) EnumDescriptor() ([]byte, []int) + func (Distance) Type() protoreflect.EnumType + func (x Distance) Enum() *Distance + func (x Distance) Number() protoreflect.EnumNumber + func (x Distance) String() string + type ListCollectionsRequest struct + func (*ListCollectionsRequest) Descriptor() ([]byte, []int) + func (*ListCollectionsRequest) ProtoMessage() + func (x *ListCollectionsRequest) ProtoReflect() protoreflect.Message + func (x *ListCollectionsRequest) Reset() + func (x *ListCollectionsRequest) String() string + type ListCollectionsResponse struct + Collections []string + func (*ListCollectionsResponse) Descriptor() ([]byte, []int) + func (*ListCollectionsResponse) ProtoMessage() + func (x *ListCollectionsResponse) GetCollections() []string + func (x *ListCollectionsResponse) ProtoReflect() protoreflect.Message + func (x *ListCollectionsResponse) Reset() + func (x *ListCollectionsResponse) String() string + type QueryVectorsRequest struct + Categories []string + Collection string + Query []float32 + TopK int32 + func (*QueryVectorsRequest) Descriptor() ([]byte, []int) + func (*QueryVectorsRequest) ProtoMessage() + func (x *QueryVectorsRequest) GetCategories() []string + func (x *QueryVectorsRequest) GetCollection() string + func (x *QueryVectorsRequest) GetQuery() []float32 + func (x *QueryVectorsRequest) GetTopK() int32 + func (x *QueryVectorsRequest) ProtoReflect() protoreflect.Message + func (x *QueryVectorsRequest) Reset() + func (x *QueryVectorsRequest) String() string + type QueryVectorsResponse struct + Vectors []*Vector + func (*QueryVectorsResponse) Descriptor() ([]byte, []int) + func (*QueryVectorsResponse) ProtoMessage() + func (x *QueryVectorsResponse) GetVectors() []*Vector + func (x *QueryVectorsResponse) ProtoReflect() protoreflect.Message + func (x *QueryVectorsResponse) Reset() + func (x *QueryVectorsResponse) String() string + type UnimplementedVectorStoreServer struct + func (UnimplementedVectorStoreServer) AddCollection(context.Context, *AddCollectionRequest) (*AddCollectionResponse, error) + func (UnimplementedVectorStoreServer) AddVectors(context.Context, *AddVectorsRequest) (*AddVectorsResponse, error) + func (UnimplementedVectorStoreServer) DeleteCollection(context.Context, *DeleteCollectionRequest) (*DeleteCollectionResponse, error) + func (UnimplementedVectorStoreServer) DeleteVectors(context.Context, *DeleteVectorsRequest) (*DeleteVectorsResponse, error) + func (UnimplementedVectorStoreServer) ListCollections(context.Context, *ListCollectionsRequest) (*ListCollectionsResponse, error) + func (UnimplementedVectorStoreServer) QueryVectors(context.Context, *QueryVectorsRequest) (*QueryVectorsResponse, error) + type UnsafeVectorStoreServer interface + type Vector struct + Categories []string + Id string + Timestamp *timestamppb.Timestamp + Values []float32 + func (*Vector) Descriptor() ([]byte, []int) + func (*Vector) ProtoMessage() + func (x *Vector) GetCategories() []string + func (x *Vector) GetId() string + func (x *Vector) GetTimestamp() *timestamppb.Timestamp + func (x *Vector) GetValues() []float32 + func (x *Vector) ProtoReflect() protoreflect.Message + func (x *Vector) Reset() + func (x *Vector) String() string + type VectorStoreClient interface + AddCollection func(ctx context.Context, in *AddCollectionRequest, opts ...grpc.CallOption) (*AddCollectionResponse, error) + AddVectors func(ctx context.Context, in *AddVectorsRequest, opts ...grpc.CallOption) (*AddVectorsResponse, error) + DeleteCollection func(ctx context.Context, in *DeleteCollectionRequest, opts ...grpc.CallOption) (*DeleteCollectionResponse, error) + DeleteVectors func(ctx context.Context, in *DeleteVectorsRequest, opts ...grpc.CallOption) (*DeleteVectorsResponse, error) + ListCollections func(ctx context.Context, in *ListCollectionsRequest, opts ...grpc.CallOption) (*ListCollectionsResponse, error) + QueryVectors func(ctx context.Context, in *QueryVectorsRequest, opts ...grpc.CallOption) (*QueryVectorsResponse, error) + func NewVectorStoreClient(cc grpc.ClientConnInterface) VectorStoreClient + type VectorStoreServer interface + AddCollection func(context.Context, *AddCollectionRequest) (*AddCollectionResponse, error) + AddVectors func(context.Context, *AddVectorsRequest) (*AddVectorsResponse, error) + DeleteCollection func(context.Context, *DeleteCollectionRequest) (*DeleteCollectionResponse, error) + DeleteVectors func(context.Context, *DeleteVectorsRequest) (*DeleteVectorsResponse, error) + ListCollections func(context.Context, *ListCollectionsRequest) (*ListCollectionsResponse, error) + QueryVectors func(context.Context, *QueryVectorsRequest) (*QueryVectorsResponse, error) v0.5.4 Feb 2, 2026 v0.5.3 Jan 31, 2026 v0.5.2 Jan 17, 2026 v0.5.1 Dec 20, 2025 v0.5.0 Dec 15, 2025 Changes in this version + const BlobStore_DownloadBlob_FullMethodName + const BlobStore_ListBlobs_FullMethodName + const BlobStore_RemoveBlob_FullMethodName + const BlobStore_UploadBlob_FullMethodName + const CacheStore_AddScores_FullMethodName + const CacheStore_AddTimeSeriesPoints_FullMethodName + const CacheStore_DeleteScores_FullMethodName + const CacheStore_Delete_FullMethodName + const CacheStore_GetTimeSeriesPoints_FullMethodName + const CacheStore_Get_FullMethodName + const CacheStore_Ping_FullMethodName + const CacheStore_Pop_FullMethodName + const CacheStore_Push_FullMethodName + const CacheStore_Remain_FullMethodName + const CacheStore_ScanScores_FullMethodName + const CacheStore_SearchScores_FullMethodName + const CacheStore_Set_FullMethodName + const CacheStore_UpdateScores_FullMethodName + const DataStore_BatchGetItems_FullMethodName + const DataStore_BatchInsertFeedback_FullMethodName + const DataStore_BatchInsertItems_FullMethodName + const DataStore_BatchInsertUsers_FullMethodName + const DataStore_CountFeedback_FullMethodName + const DataStore_CountItems_FullMethodName + const DataStore_CountUsers_FullMethodName + const DataStore_DeleteItem_FullMethodName + const DataStore_DeleteUserItemFeedback_FullMethodName + const DataStore_DeleteUser_FullMethodName + const DataStore_GetFeedbackStream_FullMethodName + const DataStore_GetFeedback_FullMethodName + const DataStore_GetItemFeedback_FullMethodName + const DataStore_GetItemStream_FullMethodName + const DataStore_GetItem_FullMethodName + const DataStore_GetItems_FullMethodName + const DataStore_GetLatestItems_FullMethodName + const DataStore_GetUserFeedback_FullMethodName + const DataStore_GetUserItemFeedback_FullMethodName + const DataStore_GetUserStream_FullMethodName + const DataStore_GetUser_FullMethodName + const DataStore_GetUsers_FullMethodName + const DataStore_ModifyItem_FullMethodName + const DataStore_ModifyUser_FullMethodName + const DataStore_Ping_FullMethodName + const Master_GetMeta_FullMethodName + const Master_PushProgress_FullMethodName + var BlobStore_ServiceDesc = grpc.ServiceDesc + var CacheStore_ServiceDesc = grpc.ServiceDesc + var DataStore_ServiceDesc = grpc.ServiceDesc + var ExpressionType_name = map[int32]string + var ExpressionType_value = map[string]int32 + var File_cache_store_proto protoreflect.FileDescriptor + var File_data_store_proto protoreflect.FileDescriptor + var File_encoding_proto protoreflect.FileDescriptor + var File_protocol_proto protoreflect.FileDescriptor + var Master_ServiceDesc = grpc.ServiceDesc + var NodeType_name = map[int32]string + var NodeType_value = map[string]int32 + func RegisterBlobStoreServer(s grpc.ServiceRegistrar, srv BlobStoreServer) + func RegisterCacheStoreServer(s grpc.ServiceRegistrar, srv CacheStoreServer) + func RegisterDataStoreServer(s grpc.ServiceRegistrar, srv DataStoreServer) + func RegisterMasterServer(s grpc.ServiceRegistrar, srv MasterServer) + type AddScoresRequest struct + Collection string + Documents []*Score + Subset string + func (*AddScoresRequest) Descriptor() ([]byte, []int) + func (*AddScoresRequest) ProtoMessage() + func (x *AddScoresRequest) GetCollection() string + func (x *AddScoresRequest) GetDocuments() []*Score + func (x *AddScoresRequest) GetSubset() string + func (x *AddScoresRequest) ProtoReflect() protoreflect.Message + func (x *AddScoresRequest) Reset() + func (x *AddScoresRequest) String() string + type AddScoresResponse struct + func (*AddScoresResponse) Descriptor() ([]byte, []int) + func (*AddScoresResponse) ProtoMessage() + func (x *AddScoresResponse) ProtoReflect() protoreflect.Message + func (x *AddScoresResponse) Reset() + func (x *AddScoresResponse) String() string + type AddTimeSeriesPointsRequest struct + Points []*TimeSeriesPoint + func (*AddTimeSeriesPointsRequest) Descriptor() ([]byte, []int) + func (*AddTimeSeriesPointsRequest) ProtoMessage() + func (x *AddTimeSeriesPointsRequest) GetPoints() []*TimeSeriesPoint + func (x *AddTimeSeriesPointsRequest) ProtoReflect() protoreflect.Message + func (x *AddTimeSeriesPointsRequest) Reset() + func (x *AddTimeSeriesPointsRequest) String() string + type AddTimeSeriesPointsResponse struct + func (*AddTimeSeriesPointsResponse) Descriptor() ([]byte, []int) + func (*AddTimeSeriesPointsResponse) ProtoMessage() + func (x *AddTimeSeriesPointsResponse) ProtoReflect() protoreflect.Message + func (x *AddTimeSeriesPointsResponse) Reset() + func (x *AddTimeSeriesPointsResponse) String() string + type BatchGetItemsRequest struct + ItemIds []string + func (*BatchGetItemsRequest) Descriptor() ([]byte, []int) + func (*BatchGetItemsRequest) ProtoMessage() + func (x *BatchGetItemsRequest) GetItemIds() []string + func (x *BatchGetItemsRequest) ProtoReflect() protoreflect.Message + func (x *BatchGetItemsRequest) Reset() + func (x *BatchGetItemsRequest) String() string + type BatchGetItemsResponse struct + Items []*Item + func (*BatchGetItemsResponse) Descriptor() ([]byte, []int) + func (*BatchGetItemsResponse) ProtoMessage() + func (x *BatchGetItemsResponse) GetItems() []*Item + func (x *BatchGetItemsResponse) ProtoReflect() protoreflect.Message + func (x *BatchGetItemsResponse) Reset() + func (x *BatchGetItemsResponse) String() string + type BatchInsertFeedbackRequest struct + Feedback []*Feedback + InsertItem bool + InsertUser bool + Overwrite bool + func (*BatchInsertFeedbackRequest) Descriptor() ([]byte, []int) + func (*BatchInsertFeedbackRequest) ProtoMessage() + func (x *BatchInsertFeedbackRequest) GetFeedback() []*Feedback + func (x *BatchInsertFeedbackRequest) GetInsertItem() bool + func (x *BatchInsertFeedbackRequest) GetInsertUser() bool + func (x *BatchInsertFeedbackRequest) GetOverwrite() bool + func (x *BatchInsertFeedbackRequest) ProtoReflect() protoreflect.Message + func (x *BatchInsertFeedbackRequest) Reset() + func (x *BatchInsertFeedbackRequest) String() string + type BatchInsertFeedbackResponse struct + func (*BatchInsertFeedbackResponse) Descriptor() ([]byte, []int) + func (*BatchInsertFeedbackResponse) ProtoMessage() + func (x *BatchInsertFeedbackResponse) ProtoReflect() protoreflect.Message + func (x *BatchInsertFeedbackResponse) Reset() + func (x *BatchInsertFeedbackResponse) String() string + type BatchInsertItemsRequest struct + Items []*Item + func (*BatchInsertItemsRequest) Descriptor() ([]byte, []int) + func (*BatchInsertItemsRequest) ProtoMessage() + func (x *BatchInsertItemsRequest) GetItems() []*Item + func (x *BatchInsertItemsRequest) ProtoReflect() protoreflect.Message + func (x *BatchInsertItemsRequest) Reset() + func (x *BatchInsertItemsRequest) String() string + type BatchInsertItemsResponse struct + func (*BatchInsertItemsResponse) Descriptor() ([]byte, []int) + func (*BatchInsertItemsResponse) ProtoMessage() + func (x *BatchInsertItemsResponse) ProtoReflect() protoreflect.Message + func (x *BatchInsertItemsResponse) Reset() + func (x *BatchInsertItemsResponse) String() string + type BatchInsertUsersRequest struct + Users []*User + func (*BatchInsertUsersRequest) Descriptor() ([]byte, []int) + func (*BatchInsertUsersRequest) ProtoMessage() + func (x *BatchInsertUsersRequest) GetUsers() []*User + func (x *BatchInsertUsersRequest) ProtoReflect() protoreflect.Message + func (x *BatchInsertUsersRequest) Reset() + func (x *BatchInsertUsersRequest) String() string + type BatchInsertUsersResponse struct + func (*BatchInsertUsersResponse) Descriptor() ([]byte, []int) + func (*BatchInsertUsersResponse) ProtoMessage() + func (x *BatchInsertUsersResponse) ProtoReflect() protoreflect.Message + func (x *BatchInsertUsersResponse) Reset() + func (x *BatchInsertUsersResponse) String() string + type BlobStoreClient interface + DownloadBlob func(ctx context.Context, in *DownloadBlobRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[DownloadBlobResponse], error) + ListBlobs func(ctx context.Context, in *ListBlobsRequest, opts ...grpc.CallOption) (*ListBlobsResponse, error) + RemoveBlob func(ctx context.Context, in *RemoveBlobRequest, opts ...grpc.CallOption) (*RemoveBlobResponse, error) + UploadBlob func(ctx context.Context, opts ...grpc.CallOption) (grpc.ClientStreamingClient[UploadBlobRequest, UploadBlobResponse], error) + func NewBlobStoreClient(cc grpc.ClientConnInterface) BlobStoreClient + type BlobStoreServer interface + DownloadBlob func(*DownloadBlobRequest, grpc.ServerStreamingServer[DownloadBlobResponse]) error + ListBlobs func(context.Context, *ListBlobsRequest) (*ListBlobsResponse, error) + RemoveBlob func(context.Context, *RemoveBlobRequest) (*RemoveBlobResponse, error) + UploadBlob func(grpc.ClientStreamingServer[UploadBlobRequest, UploadBlobResponse]) error + type BlobStore_DownloadBlobClient = grpc.ServerStreamingClient[DownloadBlobResponse] + type BlobStore_DownloadBlobServer = grpc.ServerStreamingServer[DownloadBlobResponse] + type BlobStore_UploadBlobClient = grpc.ClientStreamingClient[UploadBlobRequest, UploadBlobResponse] + type BlobStore_UploadBlobServer = grpc.ClientStreamingServer[UploadBlobRequest, UploadBlobResponse] + type CacheStoreClient interface + AddScores func(ctx context.Context, in *AddScoresRequest, opts ...grpc.CallOption) (*AddScoresResponse, error) + AddTimeSeriesPoints func(ctx context.Context, in *AddTimeSeriesPointsRequest, opts ...grpc.CallOption) (*AddTimeSeriesPointsResponse, error) + Delete func(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*DeleteResponse, error) + DeleteScores func(ctx context.Context, in *DeleteScoresRequest, opts ...grpc.CallOption) (*DeleteScoresResponse, error) + Get func(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error) + GetTimeSeriesPoints func(ctx context.Context, in *GetTimeSeriesPointsRequest, opts ...grpc.CallOption) (*GetTimeSeriesPointsResponse, error) + Ping func(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*PingResponse, error) + Pop func(ctx context.Context, in *PopRequest, opts ...grpc.CallOption) (*PopResponse, error) + Push func(ctx context.Context, in *PushRequest, opts ...grpc.CallOption) (*PushResponse, error) + Remain func(ctx context.Context, in *RemainRequest, opts ...grpc.CallOption) (*RemainResponse, error) + ScanScores func(ctx context.Context, in *ScanScoresRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[ScanScoresResponse], error) + SearchScores func(ctx context.Context, in *SearchScoresRequest, opts ...grpc.CallOption) (*SearchScoresResponse, error) + Set func(ctx context.Context, in *SetRequest, opts ...grpc.CallOption) (*SetResponse, error) + UpdateScores func(ctx context.Context, in *UpdateScoresRequest, opts ...grpc.CallOption) (*UpdateScoresResponse, error) + func NewCacheStoreClient(cc grpc.ClientConnInterface) CacheStoreClient + type CacheStoreServer interface + AddScores func(context.Context, *AddScoresRequest) (*AddScoresResponse, error) + AddTimeSeriesPoints func(context.Context, *AddTimeSeriesPointsRequest) (*AddTimeSeriesPointsResponse, error) + Delete func(context.Context, *DeleteRequest) (*DeleteResponse, error) + DeleteScores func(context.Context, *DeleteScoresRequest) (*DeleteScoresResponse, error) + Get func(context.Context, *GetRequest) (*GetResponse, error) + GetTimeSeriesPoints func(context.Context, *GetTimeSeriesPointsRequest) (*GetTimeSeriesPointsResponse, error) + Ping func(context.Context, *PingRequest) (*PingResponse, error) + Pop func(context.Context, *PopRequest) (*PopResponse, error) + Push func(context.Context, *PushRequest) (*PushResponse, error) + Remain func(context.Context, *RemainRequest) (*RemainResponse, error) + ScanScores func(*ScanScoresRequest, grpc.ServerStreamingServer[ScanScoresResponse]) error + SearchScores func(context.Context, *SearchScoresRequest) (*SearchScoresResponse, error) + Set func(context.Context, *SetRequest) (*SetResponse, error) + UpdateScores func(context.Context, *UpdateScoresRequest) (*UpdateScoresResponse, error) + type CacheStore_ScanScoresClient = grpc.ServerStreamingClient[ScanScoresResponse] + type CacheStore_ScanScoresServer = grpc.ServerStreamingServer[ScanScoresResponse] + type CountFeedbackRequest struct + func (*CountFeedbackRequest) Descriptor() ([]byte, []int) + func (*CountFeedbackRequest) ProtoMessage() + func (x *CountFeedbackRequest) ProtoReflect() protoreflect.Message + func (x *CountFeedbackRequest) Reset() + func (x *CountFeedbackRequest) String() string + type CountFeedbackResponse struct + Count int32 + func (*CountFeedbackResponse) Descriptor() ([]byte, []int) + func (*CountFeedbackResponse) ProtoMessage() + func (x *CountFeedbackResponse) GetCount() int32 + func (x *CountFeedbackResponse) ProtoReflect() protoreflect.Message + func (x *CountFeedbackResponse) Reset() + func (x *CountFeedbackResponse) String() string + type CountItemsRequest struct + func (*CountItemsRequest) Descriptor() ([]byte, []int) + func (*CountItemsRequest) ProtoMessage() + func (x *CountItemsRequest) ProtoReflect() protoreflect.Message + func (x *CountItemsRequest) Reset() + func (x *CountItemsRequest) String() string + type CountItemsResponse struct + Count int32 + func (*CountItemsResponse) Descriptor() ([]byte, []int) + func (*CountItemsResponse) ProtoMessage() + func (x *CountItemsResponse) GetCount() int32 + func (x *CountItemsResponse) ProtoReflect() protoreflect.Message + func (x *CountItemsResponse) Reset() + func (x *CountItemsResponse) String() string + type CountUsersRequest struct + func (*CountUsersRequest) Descriptor() ([]byte, []int) + func (*CountUsersRequest) ProtoMessage() + func (x *CountUsersRequest) ProtoReflect() protoreflect.Message + func (x *CountUsersRequest) Reset() + func (x *CountUsersRequest) String() string + type CountUsersResponse struct + Count int32 + func (*CountUsersResponse) Descriptor() ([]byte, []int) + func (*CountUsersResponse) ProtoMessage() + func (x *CountUsersResponse) GetCount() int32 + func (x *CountUsersResponse) ProtoReflect() protoreflect.Message + func (x *CountUsersResponse) Reset() + func (x *CountUsersResponse) String() string + type DataStoreClient interface + BatchGetItems func(ctx context.Context, in *BatchGetItemsRequest, opts ...grpc.CallOption) (*BatchGetItemsResponse, error) + BatchInsertFeedback func(ctx context.Context, in *BatchInsertFeedbackRequest, opts ...grpc.CallOption) (*BatchInsertFeedbackResponse, error) + BatchInsertItems func(ctx context.Context, in *BatchInsertItemsRequest, opts ...grpc.CallOption) (*BatchInsertItemsResponse, error) + BatchInsertUsers func(ctx context.Context, in *BatchInsertUsersRequest, opts ...grpc.CallOption) (*BatchInsertUsersResponse, error) + CountFeedback func(ctx context.Context, in *CountFeedbackRequest, opts ...grpc.CallOption) (*CountFeedbackResponse, error) + CountItems func(ctx context.Context, in *CountItemsRequest, opts ...grpc.CallOption) (*CountItemsResponse, error) + CountUsers func(ctx context.Context, in *CountUsersRequest, opts ...grpc.CallOption) (*CountUsersResponse, error) + DeleteItem func(ctx context.Context, in *DeleteItemRequest, opts ...grpc.CallOption) (*DeleteItemResponse, error) + DeleteUser func(ctx context.Context, in *DeleteUserRequest, opts ...grpc.CallOption) (*DeleteUserResponse, error) + DeleteUserItemFeedback func(ctx context.Context, in *DeleteUserItemFeedbackRequest, ...) (*DeleteUserItemFeedbackResponse, error) + GetFeedback func(ctx context.Context, in *GetFeedbackRequest, opts ...grpc.CallOption) (*GetFeedbackResponse, error) + GetFeedbackStream func(ctx context.Context, in *GetFeedbackStreamRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[GetFeedbackStreamResponse], error) + GetItem func(ctx context.Context, in *GetItemRequest, opts ...grpc.CallOption) (*GetItemResponse, error) + GetItemFeedback func(ctx context.Context, in *GetItemFeedbackRequest, opts ...grpc.CallOption) (*GetFeedbackResponse, error) + GetItemStream func(ctx context.Context, in *GetItemStreamRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[GetItemStreamResponse], error) + GetItems func(ctx context.Context, in *GetItemsRequest, opts ...grpc.CallOption) (*GetItemsResponse, error) + GetLatestItems func(ctx context.Context, in *GetLatestItemsRequest, opts ...grpc.CallOption) (*GetLatestItemsResponse, error) + GetUser func(ctx context.Context, in *GetUserRequest, opts ...grpc.CallOption) (*GetUserResponse, error) + GetUserFeedback func(ctx context.Context, in *GetUserFeedbackRequest, opts ...grpc.CallOption) (*GetFeedbackResponse, error) + GetUserItemFeedback func(ctx context.Context, in *GetUserItemFeedbackRequest, opts ...grpc.CallOption) (*GetFeedbackResponse, error) + GetUserStream func(ctx context.Context, in *GetUserStreamRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[GetUserStreamResponse], error) + GetUsers func(ctx context.Context, in *GetUsersRequest, opts ...grpc.CallOption) (*GetUsersResponse, error) + ModifyItem func(ctx context.Context, in *ModifyItemRequest, opts ...grpc.CallOption) (*ModifyItemResponse, error) + ModifyUser func(ctx context.Context, in *ModifyUserRequest, opts ...grpc.CallOption) (*ModifyUserResponse, error) + Ping func(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*PingResponse, error) + func NewDataStoreClient(cc grpc.ClientConnInterface) DataStoreClient + type DataStoreServer interface + BatchGetItems func(context.Context, *BatchGetItemsRequest) (*BatchGetItemsResponse, error) + BatchInsertFeedback func(context.Context, *BatchInsertFeedbackRequest) (*BatchInsertFeedbackResponse, error) + BatchInsertItems func(context.Context, *BatchInsertItemsRequest) (*BatchInsertItemsResponse, error) + BatchInsertUsers func(context.Context, *BatchInsertUsersRequest) (*BatchInsertUsersResponse, error) + CountFeedback func(context.Context, *CountFeedbackRequest) (*CountFeedbackResponse, error) + CountItems func(context.Context, *CountItemsRequest) (*CountItemsResponse, error) + CountUsers func(context.Context, *CountUsersRequest) (*CountUsersResponse, error) + DeleteItem func(context.Context, *DeleteItemRequest) (*DeleteItemResponse, error) + DeleteUser func(context.Context, *DeleteUserRequest) (*DeleteUserResponse, error) + DeleteUserItemFeedback func(context.Context, *DeleteUserItemFeedbackRequest) (*DeleteUserItemFeedbackResponse, error) + GetFeedback func(context.Context, *GetFeedbackRequest) (*GetFeedbackResponse, error) + GetFeedbackStream func(*GetFeedbackStreamRequest, ...) error + GetItem func(context.Context, *GetItemRequest) (*GetItemResponse, error) + GetItemFeedback func(context.Context, *GetItemFeedbackRequest) (*GetFeedbackResponse, error) + GetItemStream func(*GetItemStreamRequest, grpc.ServerStreamingServer[GetItemStreamResponse]) error + GetItems func(context.Context, *GetItemsRequest) (*GetItemsResponse, error) + GetLatestItems func(context.Context, *GetLatestItemsRequest) (*GetLatestItemsResponse, error) + GetUser func(context.Context, *GetUserRequest) (*GetUserResponse, error) + GetUserFeedback func(context.Context, *GetUserFeedbackRequest) (*GetFeedbackResponse, error) + GetUserItemFeedback func(context.Context, *GetUserItemFeedbackRequest) (*GetFeedbackResponse, error) + GetUserStream func(*GetUserStreamRequest, grpc.ServerStreamingServer[GetUserStreamResponse]) error + GetUsers func(context.Context, *GetUsersRequest) (*GetUsersResponse, error) + ModifyItem func(context.Context, *ModifyItemRequest) (*ModifyItemResponse, error) + ModifyUser func(context.Context, *ModifyUserRequest) (*ModifyUserResponse, error) + Ping func(context.Context, *PingRequest) (*PingResponse, error) + type DataStore_GetFeedbackStreamClient = grpc.ServerStreamingClient[GetFeedbackStreamResponse] + type DataStore_GetFeedbackStreamServer = grpc.ServerStreamingServer[GetFeedbackStreamResponse] + type DataStore_GetItemStreamClient = grpc.ServerStreamingClient[GetItemStreamResponse] + type DataStore_GetItemStreamServer = grpc.ServerStreamingServer[GetItemStreamResponse] + type DataStore_GetUserStreamClient = grpc.ServerStreamingClient[GetUserStreamResponse] + type DataStore_GetUserStreamServer = grpc.ServerStreamingServer[GetUserStreamResponse] + type DeleteItemRequest struct + ItemId string + func (*DeleteItemRequest) Descriptor() ([]byte, []int) + func (*DeleteItemRequest) ProtoMessage() + func (x *DeleteItemRequest) GetItemId() string + func (x *DeleteItemRequest) ProtoReflect() protoreflect.Message + func (x *DeleteItemRequest) Reset() + func (x *DeleteItemRequest) String() string + type DeleteItemResponse struct + func (*DeleteItemResponse) Descriptor() ([]byte, []int) + func (*DeleteItemResponse) ProtoMessage() + func (x *DeleteItemResponse) ProtoReflect() protoreflect.Message + func (x *DeleteItemResponse) Reset() + func (x *DeleteItemResponse) String() string + type DeleteRequest struct + Name string + func (*DeleteRequest) Descriptor() ([]byte, []int) + func (*DeleteRequest) ProtoMessage() + func (x *DeleteRequest) GetName() string + func (x *DeleteRequest) ProtoReflect() protoreflect.Message + func (x *DeleteRequest) Reset() + func (x *DeleteRequest) String() string + type DeleteResponse struct + func (*DeleteResponse) Descriptor() ([]byte, []int) + func (*DeleteResponse) ProtoMessage() + func (x *DeleteResponse) ProtoReflect() protoreflect.Message + func (x *DeleteResponse) Reset() + func (x *DeleteResponse) String() string + type DeleteScoresRequest struct + Collection []string + Condition *ScoreCondition + func (*DeleteScoresRequest) Descriptor() ([]byte, []int) + func (*DeleteScoresRequest) ProtoMessage() + func (x *DeleteScoresRequest) GetCollection() []string + func (x *DeleteScoresRequest) GetCondition() *ScoreCondition + func (x *DeleteScoresRequest) ProtoReflect() protoreflect.Message + func (x *DeleteScoresRequest) Reset() + func (x *DeleteScoresRequest) String() string + type DeleteScoresResponse struct + func (*DeleteScoresResponse) Descriptor() ([]byte, []int) + func (*DeleteScoresResponse) ProtoMessage() + func (x *DeleteScoresResponse) ProtoReflect() protoreflect.Message + func (x *DeleteScoresResponse) Reset() + func (x *DeleteScoresResponse) String() string + type DeleteUserItemFeedbackRequest struct + FeedbackTypes []string + ItemId string + UserId string + func (*DeleteUserItemFeedbackRequest) Descriptor() ([]byte, []int) + func (*DeleteUserItemFeedbackRequest) ProtoMessage() + func (x *DeleteUserItemFeedbackRequest) GetFeedbackTypes() []string + func (x *DeleteUserItemFeedbackRequest) GetItemId() string + func (x *DeleteUserItemFeedbackRequest) GetUserId() string + func (x *DeleteUserItemFeedbackRequest) ProtoReflect() protoreflect.Message + func (x *DeleteUserItemFeedbackRequest) Reset() + func (x *DeleteUserItemFeedbackRequest) String() string + type DeleteUserItemFeedbackResponse struct + Count int32 + func (*DeleteUserItemFeedbackResponse) Descriptor() ([]byte, []int) + func (*DeleteUserItemFeedbackResponse) ProtoMessage() + func (x *DeleteUserItemFeedbackResponse) GetCount() int32 + func (x *DeleteUserItemFeedbackResponse) ProtoReflect() protoreflect.Message + func (x *DeleteUserItemFeedbackResponse) Reset() + func (x *DeleteUserItemFeedbackResponse) String() string + type DeleteUserRequest struct + UserId string + func (*DeleteUserRequest) Descriptor() ([]byte, []int) + func (*DeleteUserRequest) ProtoMessage() + func (x *DeleteUserRequest) GetUserId() string + func (x *DeleteUserRequest) ProtoReflect() protoreflect.Message + func (x *DeleteUserRequest) Reset() + func (x *DeleteUserRequest) String() string + type DeleteUserResponse struct + func (*DeleteUserResponse) Descriptor() ([]byte, []int) + func (*DeleteUserResponse) ProtoMessage() + func (x *DeleteUserResponse) ProtoReflect() protoreflect.Message + func (x *DeleteUserResponse) Reset() + func (x *DeleteUserResponse) String() string + type DownloadBlobRequest struct + Name string + func (*DownloadBlobRequest) Descriptor() ([]byte, []int) + func (*DownloadBlobRequest) ProtoMessage() + func (x *DownloadBlobRequest) GetName() string + func (x *DownloadBlobRequest) ProtoReflect() protoreflect.Message + func (x *DownloadBlobRequest) Reset() + func (x *DownloadBlobRequest) String() string + type DownloadBlobResponse struct + Data []byte + func (*DownloadBlobResponse) Descriptor() ([]byte, []int) + func (*DownloadBlobResponse) ProtoMessage() + func (x *DownloadBlobResponse) GetData() []byte + func (x *DownloadBlobResponse) ProtoReflect() protoreflect.Message + func (x *DownloadBlobResponse) Reset() + func (x *DownloadBlobResponse) String() string + type ExpressionType int32 + const ExpressionType_Greater + const ExpressionType_GreaterOrEqual + const ExpressionType_Less + const ExpressionType_LessOrEqual + const ExpressionType_None + func (ExpressionType) Descriptor() protoreflect.EnumDescriptor + func (ExpressionType) EnumDescriptor() ([]byte, []int) + func (ExpressionType) Type() protoreflect.EnumType + func (x ExpressionType) Enum() *ExpressionType + func (x ExpressionType) Number() protoreflect.EnumNumber + func (x ExpressionType) String() string + type Feedback struct + Comment string + FeedbackType string + ItemId string + Namespace string + Timestamp *timestamppb.Timestamp + Updated *timestamppb.Timestamp + UserId string + Value float64 + func (*Feedback) Descriptor() ([]byte, []int) + func (*Feedback) ProtoMessage() + func (x *Feedback) GetComment() string + func (x *Feedback) GetFeedbackType() string + func (x *Feedback) GetItemId() string + func (x *Feedback) GetNamespace() string + func (x *Feedback) GetTimestamp() *timestamppb.Timestamp + func (x *Feedback) GetUpdated() *timestamppb.Timestamp + func (x *Feedback) GetUserId() string + func (x *Feedback) GetValue() float64 + func (x *Feedback) ProtoReflect() protoreflect.Message + func (x *Feedback) Reset() + func (x *Feedback) String() string + type FeedbackTypeExpression struct + ExpressionType ExpressionType + FeedbackType string + Value float64 + func (*FeedbackTypeExpression) Descriptor() ([]byte, []int) + func (*FeedbackTypeExpression) ProtoMessage() + func (x *FeedbackTypeExpression) GetExpressionType() ExpressionType + func (x *FeedbackTypeExpression) GetFeedbackType() string + func (x *FeedbackTypeExpression) GetValue() float64 + func (x *FeedbackTypeExpression) ProtoReflect() protoreflect.Message + func (x *FeedbackTypeExpression) Reset() + func (x *FeedbackTypeExpression) String() string + type Fragment struct + Data []byte + func (*Fragment) Descriptor() ([]byte, []int) + func (*Fragment) ProtoMessage() + func (x *Fragment) GetData() []byte + func (x *Fragment) ProtoReflect() protoreflect.Message + func (x *Fragment) Reset() + func (x *Fragment) String() string + type GetFeedbackRequest struct + BeginTime *timestamppb.Timestamp + Cursor string + EndTime *timestamppb.Timestamp + FeedbackTypes []*FeedbackTypeExpression + N int32 + func (*GetFeedbackRequest) Descriptor() ([]byte, []int) + func (*GetFeedbackRequest) ProtoMessage() + func (x *GetFeedbackRequest) GetBeginTime() *timestamppb.Timestamp + func (x *GetFeedbackRequest) GetCursor() string + func (x *GetFeedbackRequest) GetEndTime() *timestamppb.Timestamp + func (x *GetFeedbackRequest) GetFeedbackTypes() []*FeedbackTypeExpression + func (x *GetFeedbackRequest) GetN() int32 + func (x *GetFeedbackRequest) ProtoReflect() protoreflect.Message + func (x *GetFeedbackRequest) Reset() + func (x *GetFeedbackRequest) String() string + type GetFeedbackResponse struct + Cursor string + Feedback []*Feedback + func (*GetFeedbackResponse) Descriptor() ([]byte, []int) + func (*GetFeedbackResponse) ProtoMessage() + func (x *GetFeedbackResponse) GetCursor() string + func (x *GetFeedbackResponse) GetFeedback() []*Feedback + func (x *GetFeedbackResponse) ProtoReflect() protoreflect.Message + func (x *GetFeedbackResponse) Reset() + func (x *GetFeedbackResponse) String() string + type GetFeedbackStreamRequest struct + BatchSize int32 + ScanOptions *ScanOptions + func (*GetFeedbackStreamRequest) Descriptor() ([]byte, []int) + func (*GetFeedbackStreamRequest) ProtoMessage() + func (x *GetFeedbackStreamRequest) GetBatchSize() int32 + func (x *GetFeedbackStreamRequest) GetScanOptions() *ScanOptions + func (x *GetFeedbackStreamRequest) ProtoReflect() protoreflect.Message + func (x *GetFeedbackStreamRequest) Reset() + func (x *GetFeedbackStreamRequest) String() string + type GetFeedbackStreamResponse struct + Feedback []*Feedback + func (*GetFeedbackStreamResponse) Descriptor() ([]byte, []int) + func (*GetFeedbackStreamResponse) ProtoMessage() + func (x *GetFeedbackStreamResponse) GetFeedback() []*Feedback + func (x *GetFeedbackStreamResponse) ProtoReflect() protoreflect.Message + func (x *GetFeedbackStreamResponse) Reset() + func (x *GetFeedbackStreamResponse) String() string + type GetItemFeedbackRequest struct + FeedbackTypes []*FeedbackTypeExpression + ItemId string + func (*GetItemFeedbackRequest) Descriptor() ([]byte, []int) + func (*GetItemFeedbackRequest) ProtoMessage() + func (x *GetItemFeedbackRequest) GetFeedbackTypes() []*FeedbackTypeExpression + func (x *GetItemFeedbackRequest) GetItemId() string + func (x *GetItemFeedbackRequest) ProtoReflect() protoreflect.Message + func (x *GetItemFeedbackRequest) Reset() + func (x *GetItemFeedbackRequest) String() string + type GetItemRequest struct + ItemId string + func (*GetItemRequest) Descriptor() ([]byte, []int) + func (*GetItemRequest) ProtoMessage() + func (x *GetItemRequest) GetItemId() string + func (x *GetItemRequest) ProtoReflect() protoreflect.Message + func (x *GetItemRequest) Reset() + func (x *GetItemRequest) String() string + type GetItemResponse struct + Item *Item + func (*GetItemResponse) Descriptor() ([]byte, []int) + func (*GetItemResponse) ProtoMessage() + func (x *GetItemResponse) GetItem() *Item + func (x *GetItemResponse) ProtoReflect() protoreflect.Message + func (x *GetItemResponse) Reset() + func (x *GetItemResponse) String() string + type GetItemStreamRequest struct + BatchSize int32 + TimeLimit *timestamppb.Timestamp + func (*GetItemStreamRequest) Descriptor() ([]byte, []int) + func (*GetItemStreamRequest) ProtoMessage() + func (x *GetItemStreamRequest) GetBatchSize() int32 + func (x *GetItemStreamRequest) GetTimeLimit() *timestamppb.Timestamp + func (x *GetItemStreamRequest) ProtoReflect() protoreflect.Message + func (x *GetItemStreamRequest) Reset() + func (x *GetItemStreamRequest) String() string + type GetItemStreamResponse struct + Items []*Item + func (*GetItemStreamResponse) Descriptor() ([]byte, []int) + func (*GetItemStreamResponse) ProtoMessage() + func (x *GetItemStreamResponse) GetItems() []*Item + func (x *GetItemStreamResponse) ProtoReflect() protoreflect.Message + func (x *GetItemStreamResponse) Reset() + func (x *GetItemStreamResponse) String() string + type GetItemsRequest struct + BeginTime *timestamppb.Timestamp + Cursor string + N int32 + func (*GetItemsRequest) Descriptor() ([]byte, []int) + func (*GetItemsRequest) ProtoMessage() + func (x *GetItemsRequest) GetBeginTime() *timestamppb.Timestamp + func (x *GetItemsRequest) GetCursor() string + func (x *GetItemsRequest) GetN() int32 + func (x *GetItemsRequest) ProtoReflect() protoreflect.Message + func (x *GetItemsRequest) Reset() + func (x *GetItemsRequest) String() string + type GetItemsResponse struct + Cursor string + Items []*Item + func (*GetItemsResponse) Descriptor() ([]byte, []int) + func (*GetItemsResponse) ProtoMessage() + func (x *GetItemsResponse) GetCursor() string + func (x *GetItemsResponse) GetItems() []*Item + func (x *GetItemsResponse) ProtoReflect() protoreflect.Message + func (x *GetItemsResponse) Reset() + func (x *GetItemsResponse) String() string + type GetLatestItemsRequest struct + Categories []string + N int32 + func (*GetLatestItemsRequest) Descriptor() ([]byte, []int) + func (*GetLatestItemsRequest) ProtoMessage() + func (x *GetLatestItemsRequest) GetCategories() []string + func (x *GetLatestItemsRequest) GetN() int32 + func (x *GetLatestItemsRequest) ProtoReflect() protoreflect.Message + func (x *GetLatestItemsRequest) Reset() + func (x *GetLatestItemsRequest) String() string + type GetLatestItemsResponse struct + Items []*Item + func (*GetLatestItemsResponse) Descriptor() ([]byte, []int) + func (*GetLatestItemsResponse) ProtoMessage() + func (x *GetLatestItemsResponse) GetItems() []*Item + func (x *GetLatestItemsResponse) ProtoReflect() protoreflect.Message + func (x *GetLatestItemsResponse) Reset() + func (x *GetLatestItemsResponse) String() string + type GetRequest struct + Name string + func (*GetRequest) Descriptor() ([]byte, []int) + func (*GetRequest) ProtoMessage() + func (x *GetRequest) GetName() string + func (x *GetRequest) ProtoReflect() protoreflect.Message + func (x *GetRequest) Reset() + func (x *GetRequest) String() string + type GetResponse struct + Value *string + func (*GetResponse) Descriptor() ([]byte, []int) + func (*GetResponse) ProtoMessage() + func (x *GetResponse) GetValue() string + func (x *GetResponse) ProtoReflect() protoreflect.Message + func (x *GetResponse) Reset() + func (x *GetResponse) String() string + type GetTimeSeriesPointsRequest struct + Begin *timestamppb.Timestamp + Duration int64 + End *timestamppb.Timestamp + Name string + func (*GetTimeSeriesPointsRequest) Descriptor() ([]byte, []int) + func (*GetTimeSeriesPointsRequest) ProtoMessage() + func (x *GetTimeSeriesPointsRequest) GetBegin() *timestamppb.Timestamp + func (x *GetTimeSeriesPointsRequest) GetDuration() int64 + func (x *GetTimeSeriesPointsRequest) GetEnd() *timestamppb.Timestamp + func (x *GetTimeSeriesPointsRequest) GetName() string + func (x *GetTimeSeriesPointsRequest) ProtoReflect() protoreflect.Message + func (x *GetTimeSeriesPointsRequest) Reset() + func (x *GetTimeSeriesPointsRequest) String() string + type GetTimeSeriesPointsResponse struct + Points []*TimeSeriesPoint + func (*GetTimeSeriesPointsResponse) Descriptor() ([]byte, []int) + func (*GetTimeSeriesPointsResponse) ProtoMessage() + func (x *GetTimeSeriesPointsResponse) GetPoints() []*TimeSeriesPoint + func (x *GetTimeSeriesPointsResponse) ProtoReflect() protoreflect.Message + func (x *GetTimeSeriesPointsResponse) Reset() + func (x *GetTimeSeriesPointsResponse) String() string + type GetUserFeedbackRequest struct + EndTime *timestamppb.Timestamp + FeedbackTypes []*FeedbackTypeExpression + UserId string + func (*GetUserFeedbackRequest) Descriptor() ([]byte, []int) + func (*GetUserFeedbackRequest) ProtoMessage() + func (x *GetUserFeedbackRequest) GetEndTime() *timestamppb.Timestamp + func (x *GetUserFeedbackRequest) GetFeedbackTypes() []*FeedbackTypeExpression + func (x *GetUserFeedbackRequest) GetUserId() string + func (x *GetUserFeedbackRequest) ProtoReflect() protoreflect.Message + func (x *GetUserFeedbackRequest) Reset() + func (x *GetUserFeedbackRequest) String() string + type GetUserItemFeedbackRequest struct + FeedbackTypes []*FeedbackTypeExpression + ItemId string + UserId string + func (*GetUserItemFeedbackRequest) Descriptor() ([]byte, []int) + func (*GetUserItemFeedbackRequest) ProtoMessage() + func (x *GetUserItemFeedbackRequest) GetFeedbackTypes() []*FeedbackTypeExpression + func (x *GetUserItemFeedbackRequest) GetItemId() string + func (x *GetUserItemFeedbackRequest) GetUserId() string + func (x *GetUserItemFeedbackRequest) ProtoReflect() protoreflect.Message + func (x *GetUserItemFeedbackRequest) Reset() + func (x *GetUserItemFeedbackRequest) String() string + type GetUserRequest struct + UserId string + func (*GetUserRequest) Descriptor() ([]byte, []int) + func (*GetUserRequest) ProtoMessage() + func (x *GetUserRequest) GetUserId() string + func (x *GetUserRequest) ProtoReflect() protoreflect.Message + func (x *GetUserRequest) Reset() + func (x *GetUserRequest) String() string + type GetUserResponse struct + User *User + func (*GetUserResponse) Descriptor() ([]byte, []int) + func (*GetUserResponse) ProtoMessage() + func (x *GetUserResponse) GetUser() *User + func (x *GetUserResponse) ProtoReflect() protoreflect.Message + func (x *GetUserResponse) Reset() + func (x *GetUserResponse) String() string + type GetUserStreamRequest struct + BatchSize int32 + func (*GetUserStreamRequest) Descriptor() ([]byte, []int) + func (*GetUserStreamRequest) ProtoMessage() + func (x *GetUserStreamRequest) GetBatchSize() int32 + func (x *GetUserStreamRequest) ProtoReflect() protoreflect.Message + func (x *GetUserStreamRequest) Reset() + func (x *GetUserStreamRequest) String() string + type GetUserStreamResponse struct + Users []*User + func (*GetUserStreamResponse) Descriptor() ([]byte, []int) + func (*GetUserStreamResponse) ProtoMessage() + func (x *GetUserStreamResponse) GetUsers() []*User + func (x *GetUserStreamResponse) ProtoReflect() protoreflect.Message + func (x *GetUserStreamResponse) Reset() + func (x *GetUserStreamResponse) String() string + type GetUsersRequest struct + Cursor string + N int32 + func (*GetUsersRequest) Descriptor() ([]byte, []int) + func (*GetUsersRequest) ProtoMessage() + func (x *GetUsersRequest) GetCursor() string + func (x *GetUsersRequest) GetN() int32 + func (x *GetUsersRequest) ProtoReflect() protoreflect.Message + func (x *GetUsersRequest) Reset() + func (x *GetUsersRequest) String() string + type GetUsersResponse struct + Cursor string + Users []*User + func (*GetUsersResponse) Descriptor() ([]byte, []int) + func (*GetUsersResponse) ProtoMessage() + func (x *GetUsersResponse) GetCursor() string + func (x *GetUsersResponse) GetUsers() []*User + func (x *GetUsersResponse) ProtoReflect() protoreflect.Message + func (x *GetUsersResponse) Reset() + func (x *GetUsersResponse) String() string + type Item struct + Categories []string + Comment string + IsHidden bool + ItemId string + Labels []byte + Namespace string + Timestamp *timestamppb.Timestamp + func (*Item) Descriptor() ([]byte, []int) + func (*Item) ProtoMessage() + func (x *Item) GetCategories() []string + func (x *Item) GetComment() string + func (x *Item) GetIsHidden() bool + func (x *Item) GetItemId() string + func (x *Item) GetLabels() []byte + func (x *Item) GetNamespace() string + func (x *Item) GetTimestamp() *timestamppb.Timestamp + func (x *Item) ProtoReflect() protoreflect.Message + func (x *Item) Reset() + func (x *Item) String() string + type ItemPatch struct + Categories []string + Comment *string + IsHidden *bool + Labels []byte + Timestamp *timestamppb.Timestamp + func (*ItemPatch) Descriptor() ([]byte, []int) + func (*ItemPatch) ProtoMessage() + func (x *ItemPatch) GetCategories() []string + func (x *ItemPatch) GetComment() string + func (x *ItemPatch) GetIsHidden() bool + func (x *ItemPatch) GetLabels() []byte + func (x *ItemPatch) GetTimestamp() *timestamppb.Timestamp + func (x *ItemPatch) ProtoReflect() protoreflect.Message + func (x *ItemPatch) Reset() + func (x *ItemPatch) String() string + type LatentFactor struct + Data []float32 + Id string + func (*LatentFactor) Descriptor() ([]byte, []int) + func (*LatentFactor) ProtoMessage() + func (x *LatentFactor) GetData() []float32 + func (x *LatentFactor) GetId() string + func (x *LatentFactor) ProtoReflect() protoreflect.Message + func (x *LatentFactor) Reset() + func (x *LatentFactor) String() string + type ListBlobsRequest struct + func (*ListBlobsRequest) Descriptor() ([]byte, []int) + func (*ListBlobsRequest) ProtoMessage() + func (x *ListBlobsRequest) ProtoReflect() protoreflect.Message + func (x *ListBlobsRequest) Reset() + func (x *ListBlobsRequest) String() string + type ListBlobsResponse struct + Names []string + func (*ListBlobsResponse) Descriptor() ([]byte, []int) + func (*ListBlobsResponse) ProtoMessage() + func (x *ListBlobsResponse) GetNames() []string + func (x *ListBlobsResponse) ProtoReflect() protoreflect.Message + func (x *ListBlobsResponse) Reset() + func (x *ListBlobsResponse) String() string + type MasterClient interface + GetMeta func(ctx context.Context, in *NodeInfo, opts ...grpc.CallOption) (*Meta, error) + PushProgress func(ctx context.Context, in *PushProgressRequest, opts ...grpc.CallOption) (*PushProgressResponse, error) + func NewMasterClient(cc grpc.ClientConnInterface) MasterClient + type MasterServer interface + GetMeta func(context.Context, *NodeInfo) (*Meta, error) + PushProgress func(context.Context, *PushProgressRequest) (*PushProgressResponse, error) + type Meta struct + ClickThroughRateModelId int64 + CollaborativeFilteringModelId int64 + Config string + Me string + Servers []string + Workers []string + func (*Meta) Descriptor() ([]byte, []int) + func (*Meta) ProtoMessage() + func (x *Meta) GetClickThroughRateModelId() int64 + func (x *Meta) GetCollaborativeFilteringModelId() int64 + func (x *Meta) GetConfig() string + func (x *Meta) GetMe() string + func (x *Meta) GetServers() []string + func (x *Meta) GetWorkers() []string + func (x *Meta) ProtoReflect() protoreflect.Message + func (x *Meta) Reset() + func (x *Meta) String() string + type ModifyItemRequest struct + ItemId string + Patch *ItemPatch + func (*ModifyItemRequest) Descriptor() ([]byte, []int) + func (*ModifyItemRequest) ProtoMessage() + func (x *ModifyItemRequest) GetItemId() string + func (x *ModifyItemRequest) GetPatch() *ItemPatch + func (x *ModifyItemRequest) ProtoReflect() protoreflect.Message + func (x *ModifyItemRequest) Reset() + func (x *ModifyItemRequest) String() string + type ModifyItemResponse struct + func (*ModifyItemResponse) Descriptor() ([]byte, []int) + func (*ModifyItemResponse) ProtoMessage() + func (x *ModifyItemResponse) ProtoReflect() protoreflect.Message + func (x *ModifyItemResponse) Reset() + func (x *ModifyItemResponse) String() string + type ModifyUserRequest struct + Patch *UserPatch + UserId string + func (*ModifyUserRequest) Descriptor() ([]byte, []int) + func (*ModifyUserRequest) ProtoMessage() + func (x *ModifyUserRequest) GetPatch() *UserPatch + func (x *ModifyUserRequest) GetUserId() string + func (x *ModifyUserRequest) ProtoReflect() protoreflect.Message + func (x *ModifyUserRequest) Reset() + func (x *ModifyUserRequest) String() string + type ModifyUserResponse struct + func (*ModifyUserResponse) Descriptor() ([]byte, []int) + func (*ModifyUserResponse) ProtoMessage() + func (x *ModifyUserResponse) ProtoReflect() protoreflect.Message + func (x *ModifyUserResponse) Reset() + func (x *ModifyUserResponse) String() string + type NodeInfo struct + BinaryVersion string + Hostname string + NodeType NodeType + Uuid string + func (*NodeInfo) Descriptor() ([]byte, []int) + func (*NodeInfo) ProtoMessage() + func (x *NodeInfo) GetBinaryVersion() string + func (x *NodeInfo) GetHostname() string + func (x *NodeInfo) GetNodeType() NodeType + func (x *NodeInfo) GetUuid() string + func (x *NodeInfo) ProtoReflect() protoreflect.Message + func (x *NodeInfo) Reset() + func (x *NodeInfo) String() string + type NodeType int32 + const NodeType_Client + const NodeType_Server + const NodeType_Worker + func (NodeType) Descriptor() protoreflect.EnumDescriptor + func (NodeType) EnumDescriptor() ([]byte, []int) + func (NodeType) Type() protoreflect.EnumType + func (x NodeType) Enum() *NodeType + func (x NodeType) Number() protoreflect.EnumNumber + func (x NodeType) String() string + type PingRequest struct + func (*PingRequest) Descriptor() ([]byte, []int) + func (*PingRequest) ProtoMessage() + func (x *PingRequest) ProtoReflect() protoreflect.Message + func (x *PingRequest) Reset() + func (x *PingRequest) String() string + type PingResponse struct + func (*PingResponse) Descriptor() ([]byte, []int) + func (*PingResponse) ProtoMessage() + func (x *PingResponse) ProtoReflect() protoreflect.Message + func (x *PingResponse) Reset() + func (x *PingResponse) String() string + type PopRequest struct + Name string + func (*PopRequest) Descriptor() ([]byte, []int) + func (*PopRequest) ProtoMessage() + func (x *PopRequest) GetName() string + func (x *PopRequest) ProtoReflect() protoreflect.Message + func (x *PopRequest) Reset() + func (x *PopRequest) String() string + type PopResponse struct + Value *string + func (*PopResponse) Descriptor() ([]byte, []int) + func (*PopResponse) ProtoMessage() + func (x *PopResponse) GetValue() string + func (x *PopResponse) ProtoReflect() protoreflect.Message + func (x *PopResponse) Reset() + func (x *PopResponse) String() string + type Progress struct + Count int64 + Error string + FinishTime int64 + Name string + StartTime int64 + Status string + Total int64 + Tracer string + func (*Progress) Descriptor() ([]byte, []int) + func (*Progress) ProtoMessage() + func (x *Progress) GetCount() int64 + func (x *Progress) GetError() string + func (x *Progress) GetFinishTime() int64 + func (x *Progress) GetName() string + func (x *Progress) GetStartTime() int64 + func (x *Progress) GetStatus() string + func (x *Progress) GetTotal() int64 + func (x *Progress) GetTracer() string + func (x *Progress) ProtoReflect() protoreflect.Message + func (x *Progress) Reset() + func (x *Progress) String() string + type PushProgressRequest struct + Progress []*Progress + func (*PushProgressRequest) Descriptor() ([]byte, []int) + func (*PushProgressRequest) ProtoMessage() + func (x *PushProgressRequest) GetProgress() []*Progress + func (x *PushProgressRequest) ProtoReflect() protoreflect.Message + func (x *PushProgressRequest) Reset() + func (x *PushProgressRequest) String() string + type PushProgressResponse struct + func (*PushProgressResponse) Descriptor() ([]byte, []int) + func (*PushProgressResponse) ProtoMessage() + func (x *PushProgressResponse) ProtoReflect() protoreflect.Message + func (x *PushProgressResponse) Reset() + func (x *PushProgressResponse) String() string + type PushRequest struct + Name string + Value string + func (*PushRequest) Descriptor() ([]byte, []int) + func (*PushRequest) ProtoMessage() + func (x *PushRequest) GetName() string + func (x *PushRequest) GetValue() string + func (x *PushRequest) ProtoReflect() protoreflect.Message + func (x *PushRequest) Reset() + func (x *PushRequest) String() string + type PushResponse struct + func (*PushResponse) Descriptor() ([]byte, []int) + func (*PushResponse) ProtoMessage() + func (x *PushResponse) ProtoReflect() protoreflect.Message + func (x *PushResponse) Reset() + func (x *PushResponse) String() string + type RemainRequest struct + Name string + func (*RemainRequest) Descriptor() ([]byte, []int) + func (*RemainRequest) ProtoMessage() + func (x *RemainRequest) GetName() string + func (x *RemainRequest) ProtoReflect() protoreflect.Message + func (x *RemainRequest) Reset() + func (x *RemainRequest) String() string + type RemainResponse struct + Count int64 + func (*RemainResponse) Descriptor() ([]byte, []int) + func (*RemainResponse) ProtoMessage() + func (x *RemainResponse) GetCount() int64 + func (x *RemainResponse) ProtoReflect() protoreflect.Message + func (x *RemainResponse) Reset() + func (x *RemainResponse) String() string + type RemoveBlobRequest struct + Name string + func (*RemoveBlobRequest) Descriptor() ([]byte, []int) + func (*RemoveBlobRequest) ProtoMessage() + func (x *RemoveBlobRequest) GetName() string + func (x *RemoveBlobRequest) ProtoReflect() protoreflect.Message + func (x *RemoveBlobRequest) Reset() + func (x *RemoveBlobRequest) String() string + type RemoveBlobResponse struct + func (*RemoveBlobResponse) Descriptor() ([]byte, []int) + func (*RemoveBlobResponse) ProtoMessage() + func (x *RemoveBlobResponse) ProtoReflect() protoreflect.Message + func (x *RemoveBlobResponse) Reset() + func (x *RemoveBlobResponse) String() string + type ScanOptions struct + BeginItemId *string + BeginTime *timestamppb.Timestamp + BeginUserId *string + EndItemId *string + EndTime *timestamppb.Timestamp + EndUserId *string + FeedbackTypes []*FeedbackTypeExpression + OrderByItemId bool + func (*ScanOptions) Descriptor() ([]byte, []int) + func (*ScanOptions) ProtoMessage() + func (x *ScanOptions) GetBeginItemId() string + func (x *ScanOptions) GetBeginTime() *timestamppb.Timestamp + func (x *ScanOptions) GetBeginUserId() string + func (x *ScanOptions) GetEndItemId() string + func (x *ScanOptions) GetEndTime() *timestamppb.Timestamp + func (x *ScanOptions) GetEndUserId() string + func (x *ScanOptions) GetFeedbackTypes() []*FeedbackTypeExpression + func (x *ScanOptions) GetOrderByItemId() bool + func (x *ScanOptions) ProtoReflect() protoreflect.Message + func (x *ScanOptions) Reset() + func (x *ScanOptions) String() string + type ScanScoresRequest struct + func (*ScanScoresRequest) Descriptor() ([]byte, []int) + func (*ScanScoresRequest) ProtoMessage() + func (x *ScanScoresRequest) ProtoReflect() protoreflect.Message + func (x *ScanScoresRequest) Reset() + func (x *ScanScoresRequest) String() string + type ScanScoresResponse struct + Collection string + Id string + Subset string + Timestamp *timestamppb.Timestamp + func (*ScanScoresResponse) Descriptor() ([]byte, []int) + func (*ScanScoresResponse) ProtoMessage() + func (x *ScanScoresResponse) GetCollection() string + func (x *ScanScoresResponse) GetId() string + func (x *ScanScoresResponse) GetSubset() string + func (x *ScanScoresResponse) GetTimestamp() *timestamppb.Timestamp + func (x *ScanScoresResponse) ProtoReflect() protoreflect.Message + func (x *ScanScoresResponse) Reset() + func (x *ScanScoresResponse) String() string + type Score struct + Categories []string + Id string + IsHidden bool + Score float64 + Timestamp *timestamppb.Timestamp + func (*Score) Descriptor() ([]byte, []int) + func (*Score) ProtoMessage() + func (x *Score) GetCategories() []string + func (x *Score) GetId() string + func (x *Score) GetIsHidden() bool + func (x *Score) GetScore() float64 + func (x *Score) GetTimestamp() *timestamppb.Timestamp + func (x *Score) ProtoReflect() protoreflect.Message + func (x *Score) Reset() + func (x *Score) String() string + type ScoreCondition struct + Before *timestamppb.Timestamp + Id *string + Subset *string + func (*ScoreCondition) Descriptor() ([]byte, []int) + func (*ScoreCondition) ProtoMessage() + func (x *ScoreCondition) GetBefore() *timestamppb.Timestamp + func (x *ScoreCondition) GetId() string + func (x *ScoreCondition) GetSubset() string + func (x *ScoreCondition) ProtoReflect() protoreflect.Message + func (x *ScoreCondition) Reset() + func (x *ScoreCondition) String() string + type ScorePatch struct + Categories []string + IsHidden *bool + Score *float64 + func (*ScorePatch) Descriptor() ([]byte, []int) + func (*ScorePatch) ProtoMessage() + func (x *ScorePatch) GetCategories() []string + func (x *ScorePatch) GetIsHidden() bool + func (x *ScorePatch) GetScore() float64 + func (x *ScorePatch) ProtoReflect() protoreflect.Message + func (x *ScorePatch) Reset() + func (x *ScorePatch) String() string + type SearchScoresRequest struct + Begin int32 + Collection string + End int32 + Query []string + Subset string + func (*SearchScoresRequest) Descriptor() ([]byte, []int) + func (*SearchScoresRequest) ProtoMessage() + func (x *SearchScoresRequest) GetBegin() int32 + func (x *SearchScoresRequest) GetCollection() string + func (x *SearchScoresRequest) GetEnd() int32 + func (x *SearchScoresRequest) GetQuery() []string + func (x *SearchScoresRequest) GetSubset() string + func (x *SearchScoresRequest) ProtoReflect() protoreflect.Message + func (x *SearchScoresRequest) Reset() + func (x *SearchScoresRequest) String() string + type SearchScoresResponse struct + Documents []*Score + func (*SearchScoresResponse) Descriptor() ([]byte, []int) + func (*SearchScoresResponse) ProtoMessage() + func (x *SearchScoresResponse) GetDocuments() []*Score + func (x *SearchScoresResponse) ProtoReflect() protoreflect.Message + func (x *SearchScoresResponse) Reset() + func (x *SearchScoresResponse) String() string + type SetRequest struct + Values []*Value + func (*SetRequest) Descriptor() ([]byte, []int) + func (*SetRequest) ProtoMessage() + func (x *SetRequest) GetValues() []*Value + func (x *SetRequest) ProtoReflect() protoreflect.Message + func (x *SetRequest) Reset() + func (x *SetRequest) String() string + type SetResponse struct + func (*SetResponse) Descriptor() ([]byte, []int) + func (*SetResponse) ProtoMessage() + func (x *SetResponse) ProtoReflect() protoreflect.Message + func (x *SetResponse) Reset() + func (x *SetResponse) String() string + type Tensor struct + Data []float32 + Key []string + Shape []int32 + func (*Tensor) Descriptor() ([]byte, []int) + func (*Tensor) ProtoMessage() + func (x *Tensor) GetData() []float32 + func (x *Tensor) GetKey() []string + func (x *Tensor) GetShape() []int32 + func (x *Tensor) ProtoReflect() protoreflect.Message + func (x *Tensor) Reset() + func (x *Tensor) String() string + type TimeSeriesPoint struct + Name string + Timestamp *timestamppb.Timestamp + Value float64 + func (*TimeSeriesPoint) Descriptor() ([]byte, []int) + func (*TimeSeriesPoint) ProtoMessage() + func (x *TimeSeriesPoint) GetName() string + func (x *TimeSeriesPoint) GetTimestamp() *timestamppb.Timestamp + func (x *TimeSeriesPoint) GetValue() float64 + func (x *TimeSeriesPoint) ProtoReflect() protoreflect.Message + func (x *TimeSeriesPoint) Reset() + func (x *TimeSeriesPoint) String() string + type UnimplementedBlobStoreServer struct + func (UnimplementedBlobStoreServer) DownloadBlob(*DownloadBlobRequest, grpc.ServerStreamingServer[DownloadBlobResponse]) error + func (UnimplementedBlobStoreServer) ListBlobs(context.Context, *ListBlobsRequest) (*ListBlobsResponse, error) + func (UnimplementedBlobStoreServer) RemoveBlob(context.Context, *RemoveBlobRequest) (*RemoveBlobResponse, error) + func (UnimplementedBlobStoreServer) UploadBlob(grpc.ClientStreamingServer[UploadBlobRequest, UploadBlobResponse]) error + type UnimplementedCacheStoreServer struct + func (UnimplementedCacheStoreServer) AddScores(context.Context, *AddScoresRequest) (*AddScoresResponse, error) + func (UnimplementedCacheStoreServer) AddTimeSeriesPoints(context.Context, *AddTimeSeriesPointsRequest) (*AddTimeSeriesPointsResponse, error) + func (UnimplementedCacheStoreServer) Delete(context.Context, *DeleteRequest) (*DeleteResponse, error) + func (UnimplementedCacheStoreServer) DeleteScores(context.Context, *DeleteScoresRequest) (*DeleteScoresResponse, error) + func (UnimplementedCacheStoreServer) Get(context.Context, *GetRequest) (*GetResponse, error) + func (UnimplementedCacheStoreServer) GetTimeSeriesPoints(context.Context, *GetTimeSeriesPointsRequest) (*GetTimeSeriesPointsResponse, error) + func (UnimplementedCacheStoreServer) Ping(context.Context, *PingRequest) (*PingResponse, error) + func (UnimplementedCacheStoreServer) Pop(context.Context, *PopRequest) (*PopResponse, error) + func (UnimplementedCacheStoreServer) Push(context.Context, *PushRequest) (*PushResponse, error) + func (UnimplementedCacheStoreServer) Remain(context.Context, *RemainRequest) (*RemainResponse, error) + func (UnimplementedCacheStoreServer) ScanScores(*ScanScoresRequest, grpc.ServerStreamingServer[ScanScoresResponse]) error + func (UnimplementedCacheStoreServer) SearchScores(context.Context, *SearchScoresRequest) (*SearchScoresResponse, error) + func (UnimplementedCacheStoreServer) Set(context.Context, *SetRequest) (*SetResponse, error) + func (UnimplementedCacheStoreServer) UpdateScores(context.Context, *UpdateScoresRequest) (*UpdateScoresResponse, error) + type UnimplementedDataStoreServer struct + func (UnimplementedDataStoreServer) BatchGetItems(context.Context, *BatchGetItemsRequest) (*BatchGetItemsResponse, error) + func (UnimplementedDataStoreServer) BatchInsertFeedback(context.Context, *BatchInsertFeedbackRequest) (*BatchInsertFeedbackResponse, error) + func (UnimplementedDataStoreServer) BatchInsertItems(context.Context, *BatchInsertItemsRequest) (*BatchInsertItemsResponse, error) + func (UnimplementedDataStoreServer) BatchInsertUsers(context.Context, *BatchInsertUsersRequest) (*BatchInsertUsersResponse, error) + func (UnimplementedDataStoreServer) CountFeedback(context.Context, *CountFeedbackRequest) (*CountFeedbackResponse, error) + func (UnimplementedDataStoreServer) CountItems(context.Context, *CountItemsRequest) (*CountItemsResponse, error) + func (UnimplementedDataStoreServer) CountUsers(context.Context, *CountUsersRequest) (*CountUsersResponse, error) + func (UnimplementedDataStoreServer) DeleteItem(context.Context, *DeleteItemRequest) (*DeleteItemResponse, error) + func (UnimplementedDataStoreServer) DeleteUser(context.Context, *DeleteUserRequest) (*DeleteUserResponse, error) + func (UnimplementedDataStoreServer) DeleteUserItemFeedback(context.Context, *DeleteUserItemFeedbackRequest) (*DeleteUserItemFeedbackResponse, error) + func (UnimplementedDataStoreServer) GetFeedback(context.Context, *GetFeedbackRequest) (*GetFeedbackResponse, error) + func (UnimplementedDataStoreServer) GetFeedbackStream(*GetFeedbackStreamRequest, ...) error + func (UnimplementedDataStoreServer) GetItem(context.Context, *GetItemRequest) (*GetItemResponse, error) + func (UnimplementedDataStoreServer) GetItemFeedback(context.Context, *GetItemFeedbackRequest) (*GetFeedbackResponse, error) + func (UnimplementedDataStoreServer) GetItemStream(*GetItemStreamRequest, grpc.ServerStreamingServer[GetItemStreamResponse]) error + func (UnimplementedDataStoreServer) GetItems(context.Context, *GetItemsRequest) (*GetItemsResponse, error) + func (UnimplementedDataStoreServer) GetLatestItems(context.Context, *GetLatestItemsRequest) (*GetLatestItemsResponse, error) + func (UnimplementedDataStoreServer) GetUser(context.Context, *GetUserRequest) (*GetUserResponse, error) + func (UnimplementedDataStoreServer) GetUserFeedback(context.Context, *GetUserFeedbackRequest) (*GetFeedbackResponse, error) + func (UnimplementedDataStoreServer) GetUserItemFeedback(context.Context, *GetUserItemFeedbackRequest) (*GetFeedbackResponse, error) + func (UnimplementedDataStoreServer) GetUserStream(*GetUserStreamRequest, grpc.ServerStreamingServer[GetUserStreamResponse]) error + func (UnimplementedDataStoreServer) GetUsers(context.Context, *GetUsersRequest) (*GetUsersResponse, error) + func (UnimplementedDataStoreServer) ModifyItem(context.Context, *ModifyItemRequest) (*ModifyItemResponse, error) + func (UnimplementedDataStoreServer) ModifyUser(context.Context, *ModifyUserRequest) (*ModifyUserResponse, error) + func (UnimplementedDataStoreServer) Ping(context.Context, *PingRequest) (*PingResponse, error) + type UnimplementedMasterServer struct + func (UnimplementedMasterServer) GetMeta(context.Context, *NodeInfo) (*Meta, error) + func (UnimplementedMasterServer) PushProgress(context.Context, *PushProgressRequest) (*PushProgressResponse, error) + type UnsafeBlobStoreServer interface + type UnsafeCacheStoreServer interface + type UnsafeDataStoreServer interface + type UnsafeMasterServer interface + type UpdateScoresRequest struct + Collection []string + Id string + Patch *ScorePatch + Subset *string + func (*UpdateScoresRequest) Descriptor() ([]byte, []int) + func (*UpdateScoresRequest) ProtoMessage() + func (x *UpdateScoresRequest) GetCollection() []string + func (x *UpdateScoresRequest) GetId() string + func (x *UpdateScoresRequest) GetPatch() *ScorePatch + func (x *UpdateScoresRequest) GetSubset() string + func (x *UpdateScoresRequest) ProtoReflect() protoreflect.Message + func (x *UpdateScoresRequest) Reset() + func (x *UpdateScoresRequest) String() string + type UpdateScoresResponse struct + func (*UpdateScoresResponse) Descriptor() ([]byte, []int) + func (*UpdateScoresResponse) ProtoMessage() + func (x *UpdateScoresResponse) ProtoReflect() protoreflect.Message + func (x *UpdateScoresResponse) Reset() + func (x *UpdateScoresResponse) String() string + type UploadBlobRequest struct + Data []byte + Name string + Timestamp *timestamppb.Timestamp + func (*UploadBlobRequest) Descriptor() ([]byte, []int) + func (*UploadBlobRequest) ProtoMessage() + func (x *UploadBlobRequest) GetData() []byte + func (x *UploadBlobRequest) GetName() string + func (x *UploadBlobRequest) GetTimestamp() *timestamppb.Timestamp + func (x *UploadBlobRequest) ProtoReflect() protoreflect.Message + func (x *UploadBlobRequest) Reset() + func (x *UploadBlobRequest) String() string + type UploadBlobResponse struct + func (*UploadBlobResponse) Descriptor() ([]byte, []int) + func (*UploadBlobResponse) ProtoMessage() + func (x *UploadBlobResponse) ProtoReflect() protoreflect.Message + func (x *UploadBlobResponse) Reset() + func (x *UploadBlobResponse) String() string + type User struct + Comment string + Labels []byte + Subscribe []string + UserId string + func (*User) Descriptor() ([]byte, []int) + func (*User) ProtoMessage() + func (x *User) GetComment() string + func (x *User) GetLabels() []byte + func (x *User) GetSubscribe() []string + func (x *User) GetUserId() string + func (x *User) ProtoReflect() protoreflect.Message + func (x *User) Reset() + func (x *User) String() string + type UserPatch struct + Comment *string + Labels []byte + Subscribe []string + func (*UserPatch) Descriptor() ([]byte, []int) + func (*UserPatch) ProtoMessage() + func (x *UserPatch) GetComment() string + func (x *UserPatch) GetLabels() []byte + func (x *UserPatch) GetSubscribe() []string + func (x *UserPatch) ProtoReflect() protoreflect.Message + func (x *UserPatch) Reset() + func (x *UserPatch) String() string + type Value struct + Name string + Value string + func (*Value) Descriptor() ([]byte, []int) + func (*Value) ProtoMessage() + func (x *Value) GetName() string + func (x *Value) GetValue() string + func (x *Value) ProtoReflect() protoreflect.Message + func (x *Value) Reset() + func (x *Value) String() string v0.5.0-rc Nov 22, 2025 v0.5.0-alpha.8 Nov 15, 2025 v0.5.0-alpha.7 Nov 2, 2025 v0.5.0-alpha.6 Sep 21, 2025 v0.5.0-alpha.5 Aug 25, 2025 v0.5.0-alpha.4 Aug 15, 2025
Go to main page