Versions in this module Expand all Collapse all v0 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