protocol

type AddScoresRequest struct {
	Collection string   `protobuf:"bytes,1,opt,name=collection,proto3" json:"collection,omitempty"`
	Subset     string   `protobuf:"bytes,2,opt,name=subset,proto3" json:"subset,omitempty"`
	Documents  []*Score `protobuf:"bytes,3,rep,name=documents,proto3" json:"documents,omitempty"`
	// contains filtered or unexported fields
}

type AddScoresResponse struct {
	// contains filtered or unexported fields
}

type AddTimeSeriesPointsRequest struct {
	Points []*TimeSeriesPoint `protobuf:"bytes,1,rep,name=points,proto3" json:"points,omitempty"`
	// contains filtered or unexported fields
}

type AddTimeSeriesPointsResponse struct {
	// contains filtered or unexported fields
}

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

type BatchGetItemsResponse struct {
	Items []*Item `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
	// contains filtered or unexported fields
}

type BatchInsertFeedbackRequest struct {
	Feedback   []*Feedback `protobuf:"bytes,1,rep,name=feedback,proto3" json:"feedback,omitempty"`
	InsertUser bool        `protobuf:"varint,2,opt,name=insert_user,json=insertUser,proto3" json:"insert_user,omitempty"`
	InsertItem bool        `protobuf:"varint,3,opt,name=insert_item,json=insertItem,proto3" json:"insert_item,omitempty"`
	Overwrite  bool        `protobuf:"varint,4,opt,name=overwrite,proto3" json:"overwrite,omitempty"`
	// contains filtered or unexported fields
}

type BatchInsertFeedbackResponse struct {
	// contains filtered or unexported fields
}

type BatchInsertItemsRequest struct {
	Items []*Item `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
	// contains filtered or unexported fields
}

type BatchInsertItemsResponse struct {
	// contains filtered or unexported fields
}

type BatchInsertUsersRequest struct {
	Users []*User `protobuf:"bytes,1,rep,name=users,proto3" json:"users,omitempty"`
	// contains filtered or unexported fields
}

type BatchInsertUsersResponse struct {
	// contains filtered or unexported fields
}

type BlobStoreClient interface {
	UploadBlob(ctx context.Context, opts ...grpc.CallOption) (grpc.ClientStreamingClient[UploadBlobRequest, UploadBlobResponse], error)
	DownloadBlob(ctx context.Context, in *DownloadBlobRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[DownloadBlobResponse], error)
	ListBlobs(ctx context.Context, in *ListBlobsRequest, opts ...grpc.CallOption) (*ListBlobsResponse, error)
	RemoveBlob(ctx context.Context, in *RemoveBlobRequest, opts ...grpc.CallOption) (*RemoveBlobResponse, error)
}

type BlobStoreServer interface {
	UploadBlob(grpc.ClientStreamingServer[UploadBlobRequest, UploadBlobResponse]) error
	DownloadBlob(*DownloadBlobRequest, grpc.ServerStreamingServer[DownloadBlobResponse]) error
	ListBlobs(context.Context, *ListBlobsRequest) (*ListBlobsResponse, error)
	RemoveBlob(context.Context, *RemoveBlobRequest) (*RemoveBlobResponse, error)
	// contains filtered or unexported methods
}

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 {
	Ping(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*PingResponse, error)
	Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error)
	Set(ctx context.Context, in *SetRequest, opts ...grpc.CallOption) (*SetResponse, error)
	Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*DeleteResponse, error)
	Push(ctx context.Context, in *PushRequest, opts ...grpc.CallOption) (*PushResponse, error)
	Pop(ctx context.Context, in *PopRequest, opts ...grpc.CallOption) (*PopResponse, error)
	Remain(ctx context.Context, in *RemainRequest, opts ...grpc.CallOption) (*RemainResponse, error)
	AddScores(ctx context.Context, in *AddScoresRequest, opts ...grpc.CallOption) (*AddScoresResponse, error)
	SearchScores(ctx context.Context, in *SearchScoresRequest, opts ...grpc.CallOption) (*SearchScoresResponse, error)
	DeleteScores(ctx context.Context, in *DeleteScoresRequest, opts ...grpc.CallOption) (*DeleteScoresResponse, error)
	UpdateScores(ctx context.Context, in *UpdateScoresRequest, opts ...grpc.CallOption) (*UpdateScoresResponse, error)
	ScanScores(ctx context.Context, in *ScanScoresRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[ScanScoresResponse], error)
	AddTimeSeriesPoints(ctx context.Context, in *AddTimeSeriesPointsRequest, opts ...grpc.CallOption) (*AddTimeSeriesPointsResponse, error)
	GetTimeSeriesPoints(ctx context.Context, in *GetTimeSeriesPointsRequest, opts ...grpc.CallOption) (*GetTimeSeriesPointsResponse, error)
}

type CacheStoreServer interface {
	Ping(context.Context, *PingRequest) (*PingResponse, error)
	Get(context.Context, *GetRequest) (*GetResponse, error)
	Set(context.Context, *SetRequest) (*SetResponse, error)
	Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)
	Push(context.Context, *PushRequest) (*PushResponse, error)
	Pop(context.Context, *PopRequest) (*PopResponse, error)
	Remain(context.Context, *RemainRequest) (*RemainResponse, error)
	AddScores(context.Context, *AddScoresRequest) (*AddScoresResponse, error)
	SearchScores(context.Context, *SearchScoresRequest) (*SearchScoresResponse, error)
	DeleteScores(context.Context, *DeleteScoresRequest) (*DeleteScoresResponse, error)
	UpdateScores(context.Context, *UpdateScoresRequest) (*UpdateScoresResponse, error)
	ScanScores(*ScanScoresRequest, grpc.ServerStreamingServer[ScanScoresResponse]) error
	AddTimeSeriesPoints(context.Context, *AddTimeSeriesPointsRequest) (*AddTimeSeriesPointsResponse, error)
	GetTimeSeriesPoints(context.Context, *GetTimeSeriesPointsRequest) (*GetTimeSeriesPointsResponse, error)
	// contains filtered or unexported methods
}

type CacheStore_ScanScoresClient = grpc.ServerStreamingClient[ScanScoresResponse]

type CacheStore_ScanScoresServer = grpc.ServerStreamingServer[ScanScoresResponse]

type CountFeedbackRequest struct {
	// contains filtered or unexported fields
}

type CountFeedbackResponse struct {
	Count int32 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

type CountItemsRequest struct {
	// contains filtered or unexported fields
}

type CountItemsResponse struct {
	Count int32 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

type CountUsersRequest struct {
	// contains filtered or unexported fields
}

type CountUsersResponse struct {
	Count int32 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

type DataStoreClient interface {
	Ping(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*PingResponse, error)
	BatchInsertItems(ctx context.Context, in *BatchInsertItemsRequest, opts ...grpc.CallOption) (*BatchInsertItemsResponse, error)
	BatchGetItems(ctx context.Context, in *BatchGetItemsRequest, opts ...grpc.CallOption) (*BatchGetItemsResponse, error)
	DeleteItem(ctx context.Context, in *DeleteItemRequest, opts ...grpc.CallOption) (*DeleteItemResponse, error)
	GetItem(ctx context.Context, in *GetItemRequest, opts ...grpc.CallOption) (*GetItemResponse, error)
	ModifyItem(ctx context.Context, in *ModifyItemRequest, opts ...grpc.CallOption) (*ModifyItemResponse, error)
	GetItems(ctx context.Context, in *GetItemsRequest, opts ...grpc.CallOption) (*GetItemsResponse, error)
	GetItemFeedback(ctx context.Context, in *GetItemFeedbackRequest, opts ...grpc.CallOption) (*GetFeedbackResponse, error)
	BatchInsertUsers(ctx context.Context, in *BatchInsertUsersRequest, opts ...grpc.CallOption) (*BatchInsertUsersResponse, error)
	DeleteUser(ctx context.Context, in *DeleteUserRequest, opts ...grpc.CallOption) (*DeleteUserResponse, error)
	GetUser(ctx context.Context, in *GetUserRequest, opts ...grpc.CallOption) (*GetUserResponse, error)
	ModifyUser(ctx context.Context, in *ModifyUserRequest, opts ...grpc.CallOption) (*ModifyUserResponse, error)
	GetUsers(ctx context.Context, in *GetUsersRequest, opts ...grpc.CallOption) (*GetUsersResponse, error)
	GetUserFeedback(ctx context.Context, in *GetUserFeedbackRequest, opts ...grpc.CallOption) (*GetFeedbackResponse, error)
	GetUserItemFeedback(ctx context.Context, in *GetUserItemFeedbackRequest, opts ...grpc.CallOption) (*GetFeedbackResponse, error)
	DeleteUserItemFeedback(ctx context.Context, in *DeleteUserItemFeedbackRequest, opts ...grpc.CallOption) (*DeleteUserItemFeedbackResponse, error)
	BatchInsertFeedback(ctx context.Context, in *BatchInsertFeedbackRequest, opts ...grpc.CallOption) (*BatchInsertFeedbackResponse, error)
	GetFeedback(ctx context.Context, in *GetFeedbackRequest, opts ...grpc.CallOption) (*GetFeedbackResponse, error)
	GetUserStream(ctx context.Context, in *GetUserStreamRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[GetUserStreamResponse], error)
	GetItemStream(ctx context.Context, in *GetItemStreamRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[GetItemStreamResponse], error)
	GetFeedbackStream(ctx context.Context, in *GetFeedbackStreamRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[GetFeedbackStreamResponse], error)
	CountUsers(ctx context.Context, in *CountUsersRequest, opts ...grpc.CallOption) (*CountUsersResponse, error)
	CountItems(ctx context.Context, in *CountItemsRequest, opts ...grpc.CallOption) (*CountItemsResponse, error)
	CountFeedback(ctx context.Context, in *CountFeedbackRequest, opts ...grpc.CallOption) (*CountFeedbackResponse, error)
	GetLatestItems(ctx context.Context, in *GetLatestItemsRequest, opts ...grpc.CallOption) (*GetLatestItemsResponse, error)
}

type DataStoreServer interface {
	Ping(context.Context, *PingRequest) (*PingResponse, error)
	BatchInsertItems(context.Context, *BatchInsertItemsRequest) (*BatchInsertItemsResponse, error)
	BatchGetItems(context.Context, *BatchGetItemsRequest) (*BatchGetItemsResponse, error)
	DeleteItem(context.Context, *DeleteItemRequest) (*DeleteItemResponse, error)
	GetItem(context.Context, *GetItemRequest) (*GetItemResponse, error)
	ModifyItem(context.Context, *ModifyItemRequest) (*ModifyItemResponse, error)
	GetItems(context.Context, *GetItemsRequest) (*GetItemsResponse, error)
	GetItemFeedback(context.Context, *GetItemFeedbackRequest) (*GetFeedbackResponse, error)
	BatchInsertUsers(context.Context, *BatchInsertUsersRequest) (*BatchInsertUsersResponse, error)
	DeleteUser(context.Context, *DeleteUserRequest) (*DeleteUserResponse, error)
	GetUser(context.Context, *GetUserRequest) (*GetUserResponse, error)
	ModifyUser(context.Context, *ModifyUserRequest) (*ModifyUserResponse, error)
	GetUsers(context.Context, *GetUsersRequest) (*GetUsersResponse, error)
	GetUserFeedback(context.Context, *GetUserFeedbackRequest) (*GetFeedbackResponse, error)
	GetUserItemFeedback(context.Context, *GetUserItemFeedbackRequest) (*GetFeedbackResponse, error)
	DeleteUserItemFeedback(context.Context, *DeleteUserItemFeedbackRequest) (*DeleteUserItemFeedbackResponse, error)
	BatchInsertFeedback(context.Context, *BatchInsertFeedbackRequest) (*BatchInsertFeedbackResponse, error)
	GetFeedback(context.Context, *GetFeedbackRequest) (*GetFeedbackResponse, error)
	GetUserStream(*GetUserStreamRequest, grpc.ServerStreamingServer[GetUserStreamResponse]) error
	GetItemStream(*GetItemStreamRequest, grpc.ServerStreamingServer[GetItemStreamResponse]) error
	GetFeedbackStream(*GetFeedbackStreamRequest, grpc.ServerStreamingServer[GetFeedbackStreamResponse]) error
	CountUsers(context.Context, *CountUsersRequest) (*CountUsersResponse, error)
	CountItems(context.Context, *CountItemsRequest) (*CountItemsResponse, error)
	CountFeedback(context.Context, *CountFeedbackRequest) (*CountFeedbackResponse, error)
	GetLatestItems(context.Context, *GetLatestItemsRequest) (*GetLatestItemsResponse, error)
	// contains filtered or unexported methods
}

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 `protobuf:"bytes,1,opt,name=item_id,json=itemId,proto3" json:"item_id,omitempty"`
	// contains filtered or unexported fields
}

type DeleteItemResponse struct {
	// contains filtered or unexported fields
}

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

type DeleteResponse struct {
	// contains filtered or unexported fields
}

type DeleteScoresRequest struct {
	Collection []string        `protobuf:"bytes,1,rep,name=collection,proto3" json:"collection,omitempty"`
	Condition  *ScoreCondition `protobuf:"bytes,2,opt,name=condition,proto3" json:"condition,omitempty"`
	// contains filtered or unexported fields
}

type DeleteScoresResponse struct {
	// contains filtered or unexported fields
}

type DeleteUserItemFeedbackRequest struct {
	UserId        string   `protobuf:"bytes,1,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	ItemId        string   `protobuf:"bytes,2,opt,name=item_id,json=itemId,proto3" json:"item_id,omitempty"`
	FeedbackTypes []string `protobuf:"bytes,3,rep,name=feedback_types,json=feedbackTypes,proto3" json:"feedback_types,omitempty"`
	// contains filtered or unexported fields
}

type DeleteUserItemFeedbackResponse struct {
	Count int32 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

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

type DeleteUserResponse struct {
	// contains filtered or unexported fields
}

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

type DownloadBlobResponse struct {
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

type ExpressionType int32

type Feedback struct {
	Namespace    string                 `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	FeedbackType string                 `protobuf:"bytes,2,opt,name=feedback_type,json=feedbackType,proto3" json:"feedback_type,omitempty"`
	UserId       string                 `protobuf:"bytes,3,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	ItemId       string                 `protobuf:"bytes,4,opt,name=item_id,json=itemId,proto3" json:"item_id,omitempty"`
	Value        float64                `protobuf:"fixed64,5,opt,name=value,proto3" json:"value,omitempty"`
	Timestamp    *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Comment      string                 `protobuf:"bytes,7,opt,name=comment,proto3" json:"comment,omitempty"`
	Updated      *timestamppb.Timestamp `protobuf:"bytes,8,opt,name=updated,proto3" json:"updated,omitempty"`
	// contains filtered or unexported fields
}

type FeedbackTypeExpression struct {
	FeedbackType   string         `protobuf:"bytes,1,opt,name=feedback_type,json=feedbackType,proto3" json:"feedback_type,omitempty"`
	ExpressionType ExpressionType `` /* 133-byte string literal not displayed */
	Value          float64        `protobuf:"fixed64,3,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

type Fragment struct {
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

type GetFeedbackRequest struct {
	Cursor        string                    `protobuf:"bytes,1,opt,name=cursor,proto3" json:"cursor,omitempty"`
	N             int32                     `protobuf:"varint,2,opt,name=n,proto3" json:"n,omitempty"`
	BeginTime     *timestamppb.Timestamp    `protobuf:"bytes,3,opt,name=begin_time,json=beginTime,proto3" json:"begin_time,omitempty"`
	EndTime       *timestamppb.Timestamp    `protobuf:"bytes,4,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	FeedbackTypes []*FeedbackTypeExpression `protobuf:"bytes,5,rep,name=feedback_types,json=feedbackTypes,proto3" json:"feedback_types,omitempty"`
	// contains filtered or unexported fields
}

type GetFeedbackResponse struct {
	Cursor   string      `protobuf:"bytes,1,opt,name=cursor,proto3" json:"cursor,omitempty"`
	Feedback []*Feedback `protobuf:"bytes,2,rep,name=feedback,proto3" json:"feedback,omitempty"`
	// contains filtered or unexported fields
}

type GetFeedbackStreamRequest struct {
	BatchSize   int32        `protobuf:"varint,1,opt,name=batch_size,json=batchSize,proto3" json:"batch_size,omitempty"`
	ScanOptions *ScanOptions `protobuf:"bytes,2,opt,name=scan_options,json=scanOptions,proto3" json:"scan_options,omitempty"`
	// contains filtered or unexported fields
}

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

type GetItemFeedbackRequest struct {
	ItemId        string                    `protobuf:"bytes,1,opt,name=item_id,json=itemId,proto3" json:"item_id,omitempty"`
	FeedbackTypes []*FeedbackTypeExpression `protobuf:"bytes,2,rep,name=feedback_types,json=feedbackTypes,proto3" json:"feedback_types,omitempty"`
	// contains filtered or unexported fields
}

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

type GetItemResponse struct {
	Item *Item `protobuf:"bytes,1,opt,name=item,proto3,oneof" json:"item,omitempty"`
	// contains filtered or unexported fields
}

type GetItemStreamRequest struct {
	BatchSize int32                  `protobuf:"varint,1,opt,name=batch_size,json=batchSize,proto3" json:"batch_size,omitempty"`
	TimeLimit *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time_limit,json=timeLimit,proto3" json:"time_limit,omitempty"`
	// contains filtered or unexported fields
}

type GetItemStreamResponse struct {
	Items []*Item `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
	// contains filtered or unexported fields
}

type GetItemsRequest struct {
	Cursor    string                 `protobuf:"bytes,1,opt,name=cursor,proto3" json:"cursor,omitempty"`
	N         int32                  `protobuf:"varint,2,opt,name=n,proto3" json:"n,omitempty"`
	BeginTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=begin_time,json=beginTime,proto3" json:"begin_time,omitempty"`
	// contains filtered or unexported fields
}

type GetItemsResponse struct {
	Cursor string  `protobuf:"bytes,1,opt,name=cursor,proto3" json:"cursor,omitempty"`
	Items  []*Item `protobuf:"bytes,2,rep,name=items,proto3" json:"items,omitempty"`
	// contains filtered or unexported fields
}

type GetLatestItemsRequest struct {
	N          int32    `protobuf:"varint,1,opt,name=n,proto3" json:"n,omitempty"`
	Categories []string `protobuf:"bytes,2,rep,name=categories,proto3" json:"categories,omitempty"`
	// contains filtered or unexported fields
}

type GetLatestItemsResponse struct {
	Items []*Item `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
	// contains filtered or unexported fields
}

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

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

type GetTimeSeriesPointsRequest struct {
	Name     string                 `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Begin    *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=begin,proto3" json:"begin,omitempty"`
	End      *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=end,proto3" json:"end,omitempty"`
	Duration int64                  `protobuf:"varint,4,opt,name=duration,proto3" json:"duration,omitempty"`
	// contains filtered or unexported fields
}

type GetTimeSeriesPointsResponse struct {
	Points []*TimeSeriesPoint `protobuf:"bytes,1,rep,name=points,proto3" json:"points,omitempty"`
	// contains filtered or unexported fields
}

type GetUserFeedbackRequest struct {
	UserId        string                    `protobuf:"bytes,1,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	EndTime       *timestamppb.Timestamp    `protobuf:"bytes,2,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	FeedbackTypes []*FeedbackTypeExpression `protobuf:"bytes,3,rep,name=feedback_types,json=feedbackTypes,proto3" json:"feedback_types,omitempty"`
	// contains filtered or unexported fields
}

type GetUserItemFeedbackRequest struct {
	UserId        string                    `protobuf:"bytes,1,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	ItemId        string                    `protobuf:"bytes,2,opt,name=item_id,json=itemId,proto3" json:"item_id,omitempty"`
	FeedbackTypes []*FeedbackTypeExpression `protobuf:"bytes,3,rep,name=feedback_types,json=feedbackTypes,proto3" json:"feedback_types,omitempty"`
	// contains filtered or unexported fields
}

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

type GetUserResponse struct {
	User *User `protobuf:"bytes,1,opt,name=user,proto3,oneof" json:"user,omitempty"`
	// contains filtered or unexported fields
}

type GetUserStreamRequest struct {
	BatchSize int32 `protobuf:"varint,1,opt,name=batch_size,json=batchSize,proto3" json:"batch_size,omitempty"`
	// contains filtered or unexported fields
}

type GetUserStreamResponse struct {
	Users []*User `protobuf:"bytes,1,rep,name=users,proto3" json:"users,omitempty"`
	// contains filtered or unexported fields
}

type GetUsersRequest struct {
	Cursor string `protobuf:"bytes,1,opt,name=cursor,proto3" json:"cursor,omitempty"`
	N      int32  `protobuf:"varint,2,opt,name=n,proto3" json:"n,omitempty"`
	// contains filtered or unexported fields
}

type GetUsersResponse struct {
	Cursor string  `protobuf:"bytes,1,opt,name=cursor,proto3" json:"cursor,omitempty"`
	Users  []*User `protobuf:"bytes,2,rep,name=users,proto3" json:"users,omitempty"`
	// contains filtered or unexported fields
}