protocol

package

Go to main page

Versions in this module

v0

v0.5.7

Apr 15, 2026

Changes in this version

type BatchGetItemsRequest

+ GetOptions *GetOptions

+ func (x *BatchGetItemsRequest) GetGetOptions() *GetOptions

type GetLatestItemsRequest

+ After *timestamppb.Timestamp

+ func (x *GetLatestItemsRequest) GetAfter() *timestamppb.Timestamp

+ type GetOptions struct

+ After *timestamppb.Timestamp

+ Categories []string

+ ReturnId bool

+ SkipHidden bool

+ func (*GetOptions) Descriptor() ([]byte, []int)

+ func (*GetOptions) ProtoMessage()

+ func (x *GetOptions) GetAfter() *timestamppb.Timestamp

+ func (x *GetOptions) GetCategories() []string

+ func (x *GetOptions) GetReturnId() bool

+ func (x *GetOptions) GetSkipHidden() bool

+ func (x *GetOptions) ProtoReflect() protoreflect.Message

+ func (x *GetOptions) Reset()

+ func (x *GetOptions) String() string

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

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL