v1

type BubbleChartAppendRequest struct {
	Entries []*ChartEntry `protobuf:"bytes,1,rep,name=entries,proto3" json:"entries,omitempty"`
	Options *ChartOptions `protobuf:"bytes,10,opt,name=options,proto3" json:"options,omitempty"`
	Key     *ChartKey     `protobuf:"bytes,11,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

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

type BubbleChartClient interface {
	// append entries to the end of chart
	Append(ctx context.Context, in *BubbleChartAppendRequest, opts ...grpc.CallOption) (*BubbleChartAppendResponse, error)
	// swap 2 entries by id
	SwapById(ctx context.Context, in *BubbleChartSwapByIdRequest, opts ...grpc.CallOption) (*BubbleChartSwapByIdResponse, error)
	// swap 2 entries by rank
	SwapByRank(ctx context.Context, in *BubbleChartSwapByRankRequest, opts ...grpc.CallOption) (*BubbleChartSwapByRankResponse, error)
	// get entries by range
	GetRange(ctx context.Context, in *BubbleChartGetRangeRequest, opts ...grpc.CallOption) (*BubbleChartGetRangeResponse, error)
	// get entries by id
	GetById(ctx context.Context, in *BubbleChartGetByIdRequest, opts ...grpc.CallOption) (*BubbleChartGetByIdResponse, error)
	// remove entries by id
	RemoveById(ctx context.Context, in *BubbleChartRemoveByIdRequest, opts ...grpc.CallOption) (*BubbleChartRemoveByIdResponse, error)
	// set entry info by id
	SetInfo(ctx context.Context, in *BubbleChartSetInfoRequest, opts ...grpc.CallOption) (*BubbleChartSetInfoResponse, error)
}

type BubbleChartGetByIdRequest struct {
	Ids     []string      `protobuf:"bytes,1,rep,name=ids,proto3" json:"ids,omitempty"`
	Options *ChartOptions `protobuf:"bytes,10,opt,name=options,proto3" json:"options,omitempty"`
	Key     *ChartKey     `protobuf:"bytes,11,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

type BubbleChartGetByIdResponse struct {
	Entries []*ChartEntry `protobuf:"bytes,1,rep,name=entries,proto3" json:"entries,omitempty"`
	// contains filtered or unexported fields
}

type BubbleChartGetRangeRequest struct {
	Offset  int32         `protobuf:"varint,1,opt,name=offset,proto3" json:"offset,omitempty"`
	Count   int32         `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
	Options *ChartOptions `protobuf:"bytes,10,opt,name=options,proto3" json:"options,omitempty"`
	Key     *ChartKey     `protobuf:"bytes,11,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

type BubbleChartGetRangeResponse struct {
	Entries []*ChartEntry `protobuf:"bytes,1,rep,name=entries,proto3" json:"entries,omitempty"`
	// contains filtered or unexported fields
}

type BubbleChartRemoveByIdRequest struct {
	Ids     []string      `protobuf:"bytes,1,rep,name=ids,proto3" json:"ids,omitempty"`
	Options *ChartOptions `protobuf:"bytes,10,opt,name=options,proto3" json:"options,omitempty"`
	Key     *ChartKey     `protobuf:"bytes,11,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

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

type BubbleChartServer interface {
	// append entries to the end of chart
	Append(context.Context, *BubbleChartAppendRequest) (*BubbleChartAppendResponse, error)
	// swap 2 entries by id
	SwapById(context.Context, *BubbleChartSwapByIdRequest) (*BubbleChartSwapByIdResponse, error)
	// swap 2 entries by rank
	SwapByRank(context.Context, *BubbleChartSwapByRankRequest) (*BubbleChartSwapByRankResponse, error)
	// get entries by range
	GetRange(context.Context, *BubbleChartGetRangeRequest) (*BubbleChartGetRangeResponse, error)
	// get entries by id
	GetById(context.Context, *BubbleChartGetByIdRequest) (*BubbleChartGetByIdResponse, error)
	// remove entries by id
	RemoveById(context.Context, *BubbleChartRemoveByIdRequest) (*BubbleChartRemoveByIdResponse, error)
	// set entry info by id
	SetInfo(context.Context, *BubbleChartSetInfoRequest) (*BubbleChartSetInfoResponse, error)
	// contains filtered or unexported methods
}

type BubbleChartSetInfoRequest struct {
	Entries []*ChartEntry `protobuf:"bytes,1,rep,name=entries,proto3" json:"entries,omitempty"`
	Options *ChartOptions `protobuf:"bytes,10,opt,name=options,proto3" json:"options,omitempty"`
	Key     *ChartKey     `protobuf:"bytes,11,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

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

type BubbleChartSwapByIdRequest struct {
	Id0     string        `protobuf:"bytes,1,opt,name=id0,proto3" json:"id0,omitempty"`
	Id1     string        `protobuf:"bytes,2,opt,name=id1,proto3" json:"id1,omitempty"`
	Options *ChartOptions `protobuf:"bytes,10,opt,name=options,proto3" json:"options,omitempty"`
	Key     *ChartKey     `protobuf:"bytes,11,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

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

type BubbleChartSwapByRankRequest struct {
	Rank0   int32         `protobuf:"varint,1,opt,name=rank0,proto3" json:"rank0,omitempty"`
	Rank1   int32         `protobuf:"varint,2,opt,name=rank1,proto3" json:"rank1,omitempty"`
	Options *ChartOptions `protobuf:"bytes,10,opt,name=options,proto3" json:"options,omitempty"`
	Key     *ChartKey     `protobuf:"bytes,11,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

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

type ChartEntry struct {
	Rank  int32  `protobuf:"varint,1,opt,name=rank,proto3" json:"rank,omitempty"`
	Id    string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	Info  string `protobuf:"bytes,3,opt,name=info,proto3" json:"info,omitempty"`
	Score int64  `protobuf:"varint,4,opt,name=score,proto3" json:"score,omitempty"`
	// contains filtered or unexported fields
}

type ChartKey struct {

	//string app_id   = 1;
	Name   string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Suffix string `protobuf:"bytes,3,opt,name=suffix,proto3" json:"suffix,omitempty"`
	// contains filtered or unexported fields
}

type ChartOptions struct {

	// maximal entries in the chart
	Capacity int32 `protobuf:"varint,1,opt,name=capacity,proto3" json:"capacity,omitempty"`
	// duplicate from this name IF CHART NOT EXISTS
	// can only duplicate from chart which has the same name
	ConstructFrom *ChartKey `protobuf:"bytes,2,opt,name=construct_from,json=constructFrom,proto3" json:"construct_from,omitempty"`
	// chart expire at timestamp
	ExpireAt int64 `protobuf:"varint,3,opt,name=expire_at,json=expireAt,proto3" json:"expire_at,omitempty"`
	// chart expire after duration, if expire_at set, this option was ignored
	IdleExpire int64 `protobuf:"varint,4,opt,name=idle_expire,json=idleExpire,proto3" json:"idle_expire,omitempty"`
	// contains filtered or unexported fields
}

type DatabaseClient interface {
	RegisterSchema(ctx context.Context, in *DatabaseRegisterSchemaRequest, opts ...grpc.CallOption) (*DatabaseRegisterSchemaResponse, error)
	Get(ctx context.Context, in *DatabaseGetRequest, opts ...grpc.CallOption) (*DatabaseGetResponse, error)
	Set(ctx context.Context, in *DatabaseSetRequest, opts ...grpc.CallOption) (*DatabaseSetResponse, error)
}

type DatabaseGetRequest struct {
	Key           *EntryKey  `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	AddIfNotFound *anypb.Any `protobuf:"bytes,9,opt,name=add_if_not_found,json=addIfNotFound,proto3" json:"add_if_not_found,omitempty"`
	// 如果设置lock_options会在获取数据之前尝试获取id对应的互斥锁
	// 如果上锁失败，数据将不会获取
	LockOptions *DistlockLockOptions `protobuf:"bytes,11,opt,name=lock_options,json=lockOptions,proto3" json:"lock_options,omitempty"`
	// contains filtered or unexported fields
}

type DatabaseGetResponse struct {
	Revision  int64      `protobuf:"varint,8,opt,name=revision,proto3" json:"revision,omitempty"` // data revision
	Data      *anypb.Any `protobuf:"bytes,9,opt,name=data,proto3" json:"data,omitempty"`
	LockToken *anypb.Any `protobuf:"bytes,10,opt,name=lock_token,json=lockToken,proto3" json:"lock_token,omitempty"`
	// contains filtered or unexported fields
}

type DatabaseRegisterSchemaRequest struct {

	// proto file descriptor set
	DescriptorSet *descriptorpb.FileDescriptorSet `protobuf:"bytes,1,opt,name=descriptor_set,json=descriptorSet,proto3" json:"descriptor_set,omitempty"`
	// proto message name
	MessageName string `protobuf:"bytes,2,opt,name=message_name,json=messageName,proto3" json:"message_name,omitempty"`
	// contains filtered or unexported fields
}

type DatabaseRegisterSchemaResponse struct {

	// unique identifier for registered proto
	Schema string `protobuf:"bytes,1,opt,name=schema,proto3" json:"schema,omitempty"`
	// contains filtered or unexported fields
}

type DatabaseServer interface {
	RegisterSchema(context.Context, *DatabaseRegisterSchemaRequest) (*DatabaseRegisterSchemaResponse, error)
	Get(context.Context, *DatabaseGetRequest) (*DatabaseGetResponse, error)
	Set(context.Context, *DatabaseSetRequest) (*DatabaseSetResponse, error)
	// contains filtered or unexported methods
}

type DatabaseSetRequest struct {
	Key  *EntryKey  `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Data *anypb.Any `protobuf:"bytes,9,opt,name=data,proto3" json:"data,omitempty"`
	// 获取到的互斥锁，更新数据前会校验锁是否有效，如果锁无效则不会更新数据。
	// 如果不设置，数据则会被强制更新。
	// 每次更新都会重置锁的TTL，即使更新失败。
	LockToken *anypb.Any `protobuf:"bytes,10,opt,name=lock_token,json=lockToken,proto3" json:"lock_token,omitempty"`
	// 设置unlock_options会在操作完成时解锁，要求lock_token有效
	UnlockOptions *DistlockUnlockOptions `protobuf:"bytes,11,opt,name=unlock_options,json=unlockOptions,proto3" json:"unlock_options,omitempty"`
	// contains filtered or unexported fields
}

type DatabaseSetResponse struct {
	Revision int64 `protobuf:"varint,8,opt,name=revision,proto3" json:"revision,omitempty"` // data revision after setting
	// contains filtered or unexported fields
}

type DistlockClient interface {
	Lock(ctx context.Context, in *DistlockLockRequest, opts ...grpc.CallOption) (*DistlockLockResponse, error)
	Unlock(ctx context.Context, in *DistlockUnlockRequest, opts ...grpc.CallOption) (*DistlockUnlockResponse, error)
}

type DistlockLockOptions struct {

	// 自动超时时间
	TimeoutMilliseconds int32 `protobuf:"varint,1,opt,name=timeout_milliseconds,json=timeoutMilliseconds,proto3" json:"timeout_milliseconds,omitempty"`
	// contains filtered or unexported fields
}

type DistlockLockRequest struct {
	Key *EntryKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// 如果需要锁，这个结构必须有，即使不需要改变options参数
	LockOptions *DistlockLockOptions `protobuf:"bytes,11,opt,name=lock_options,json=lockOptions,proto3" json:"lock_options,omitempty"`
	// contains filtered or unexported fields
}

type DistlockLockResponse struct {

	// 获取到的互斥锁，你不需要知道这是个什么，在解锁时候传回来就行了
	LockToken *anypb.Any `protobuf:"bytes,10,opt,name=lock_token,json=lockToken,proto3" json:"lock_token,omitempty"`
	// contains filtered or unexported fields
}

type DistlockServer interface {
	Lock(context.Context, *DistlockLockRequest) (*DistlockLockResponse, error)
	Unlock(context.Context, *DistlockUnlockRequest) (*DistlockUnlockResponse, error)
	// contains filtered or unexported methods
}

type DistlockUnlockOptions struct {

	// 即使操作失败，依然释放锁
	EvenOnFailure bool `protobuf:"varint,1,opt,name=even_on_failure,json=evenOnFailure,proto3" json:"even_on_failure,omitempty"`
	// contains filtered or unexported fields
}

type DistlockUnlockRequest struct {
	Key           *EntryKey              `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	LockToken     *anypb.Any             `protobuf:"bytes,10,opt,name=lock_token,json=lockToken,proto3" json:"lock_token,omitempty"`
	UnlockOptions *DistlockUnlockOptions `protobuf:"bytes,11,opt,name=unlock_options,json=unlockOptions,proto3" json:"unlock_options,omitempty"`
	// contains filtered or unexported fields
}

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

type EntryKey struct {

	// Entry kind used to store respectively
	// It's normally mapped to the table name
	Kind string `protobuf:"bytes,1,opt,name=kind,proto3" json:"kind,omitempty"`
	// Entry ID used to identify each other
	// It's normally mapped to the unique key in table
	Id string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

type GatewayBroadcastRequest struct {
	Key  string     `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Data *anypb.Any `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

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

type GatewayClient interface {
	////////////////////////////////////////////////////////////////////////////
	// Methods access from client side
	////////////////////////////////////////////////////////////////////////////
	// Establish the back pushing stream
	Connect(ctx context.Context, in *GatewayConnectRequest, opts ...grpc.CallOption) (Gateway_ConnectClient, error)
	////////////////////////////////////////////////////////////////////////////
	// Methods access from server side
	////////////////////////////////////////////////////////////////////////////
	// Send message to client
	Send(ctx context.Context, in *GatewaySendRequest, opts ...grpc.CallOption) (*GatewaySendResponse, error)
	// Let a certain client to subscribe broadcast channels
	Subscribe(ctx context.Context, in *GatewaySubscribeRequest, opts ...grpc.CallOption) (*GatewaySubscribeResponse, error)
	// let a certain client to unsubscribe broadcast channels
	Unsubscribe(ctx context.Context, in *GatewayUnsubscribeRequest, opts ...grpc.CallOption) (*GatewayUnsubscribeResponse, error)
	// Broadcast to a channel
	Broadcast(ctx context.Context, in *GatewayBroadcastRequest, opts ...grpc.CallOption) (*GatewayBroadcastResponse, error)
}

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

type GatewaySendRequest struct {
	Data *anypb.Any `protobuf:"bytes,10,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

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

type GatewayServer interface {
	////////////////////////////////////////////////////////////////////////////
	// Methods access from client side
	////////////////////////////////////////////////////////////////////////////
	// Establish the back pushing stream
	Connect(*GatewayConnectRequest, Gateway_ConnectServer) error
	////////////////////////////////////////////////////////////////////////////
	// Methods access from server side
	////////////////////////////////////////////////////////////////////////////
	// Send message to client
	Send(context.Context, *GatewaySendRequest) (*GatewaySendResponse, error)
	// Let a certain client to subscribe broadcast channels
	Subscribe(context.Context, *GatewaySubscribeRequest) (*GatewaySubscribeResponse, error)
	// let a certain client to unsubscribe broadcast channels
	Unsubscribe(context.Context, *GatewayUnsubscribeRequest) (*GatewayUnsubscribeResponse, error)
	// Broadcast to a channel
	Broadcast(context.Context, *GatewayBroadcastRequest) (*GatewayBroadcastResponse, error)
	// contains filtered or unexported methods
}

type GatewaySubscribeRequest struct {
	Keys []string `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"`
	// contains filtered or unexported fields
}

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

type GatewayUnsubscribeRequest struct {
	Keys []string `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"`
	// contains filtered or unexported fields
}

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

type Gateway_ConnectClient interface {
	Recv() (*anypb.Any, error)
	grpc.ClientStream
}

type Gateway_ConnectServer interface {
	Send(*anypb.Any) error
	grpc.ServerStream
}

type LeaderboardClient interface {
	// set entry score by id
	// set entry info if info field not empty
	SetScore(ctx context.Context, in *LeaderboardSetScoreRequest, opts ...grpc.CallOption) (*LeaderboardSetScoreResponse, error)
	// incr entry score by id, if id not exists, add it with score
	// set entry info if info filed not empty
	IncrScore(ctx context.Context, in *LeaderboardIncrScoreRequest, opts ...grpc.CallOption) (*LeaderboardIncrScoreResponse, error)
	// get entries by range
	GetRange(ctx context.Context, in *LeaderboardGetRangeRequest, opts ...grpc.CallOption) (*LeaderboardGetRangeResponse, error)
	// get entries by id
	GetById(ctx context.Context, in *LeaderboardGetByIdRequest, opts ...grpc.CallOption) (*LeaderboardGetByIdResponse, error)
	// remove entries by id
	RemoveById(ctx context.Context, in *LeaderboardRemoveByIdRequest, opts ...grpc.CallOption) (*LeaderboardRemoveByIdResponse, error)
	// set entry info by id
	SetInfo(ctx context.Context, in *LeaderboardSetInfoRequest, opts ...grpc.CallOption) (*LeaderboardSetInfoResponse, error)
}

type LeaderboardGetByIdRequest struct {
	Ids     []string      `protobuf:"bytes,1,rep,name=ids,proto3" json:"ids,omitempty"`
	Options *ChartOptions `protobuf:"bytes,10,opt,name=options,proto3" json:"options,omitempty"`
	Key     *ChartKey     `protobuf:"bytes,11,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

type LeaderboardGetByIdResponse struct {
	Entries []*ChartEntry `protobuf:"bytes,1,rep,name=entries,proto3" json:"entries,omitempty"`
	// contains filtered or unexported fields
}

type LeaderboardGetRangeRequest struct {
	Offset  int32         `protobuf:"varint,1,opt,name=offset,proto3" json:"offset,omitempty"`
	Count   int32         `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
	Options *ChartOptions `protobuf:"bytes,10,opt,name=options,proto3" json:"options,omitempty"`
	Key     *ChartKey     `protobuf:"bytes,11,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

type LeaderboardGetRangeResponse struct {
	Entries []*ChartEntry `protobuf:"bytes,1,rep,name=entries,proto3" json:"entries,omitempty"`
	// contains filtered or unexported fields
}

type LeaderboardIncrScoreRequest struct {
	Entries []*ChartEntry `protobuf:"bytes,1,rep,name=entries,proto3" json:"entries,omitempty"`
	Options *ChartOptions `protobuf:"bytes,10,opt,name=options,proto3" json:"options,omitempty"`
	Key     *ChartKey     `protobuf:"bytes,11,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

type LeaderboardIncrScoreResponse struct {
	Entries []*ChartEntry `protobuf:"bytes,2,rep,name=entries,proto3" json:"entries,omitempty"`
	// contains filtered or unexported fields
}

type LeaderboardRemoveByIdRequest struct {
	Ids     []string      `protobuf:"bytes,1,rep,name=ids,proto3" json:"ids,omitempty"`
	Options *ChartOptions `protobuf:"bytes,10,opt,name=options,proto3" json:"options,omitempty"`
	Key     *ChartKey     `protobuf:"bytes,11,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

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

type LeaderboardServer interface {
	// set entry score by id
	// set entry info if info field not empty
	SetScore(context.Context, *LeaderboardSetScoreRequest) (*LeaderboardSetScoreResponse, error)
	// incr entry score by id, if id not exists, add it with score
	// set entry info if info filed not empty
	IncrScore(context.Context, *LeaderboardIncrScoreRequest) (*LeaderboardIncrScoreResponse, error)
	// get entries by range
	GetRange(context.Context, *LeaderboardGetRangeRequest) (*LeaderboardGetRangeResponse, error)
	// get entries by id
	GetById(context.Context, *LeaderboardGetByIdRequest) (*LeaderboardGetByIdResponse, error)
	// remove entries by id
	RemoveById(context.Context, *LeaderboardRemoveByIdRequest) (*LeaderboardRemoveByIdResponse, error)
	// set entry info by id
	SetInfo(context.Context, *LeaderboardSetInfoRequest) (*LeaderboardSetInfoResponse, error)
	// contains filtered or unexported methods
}

type LeaderboardSetInfoRequest struct {
	Entries []*ChartEntry `protobuf:"bytes,1,rep,name=entries,proto3" json:"entries,omitempty"`
	Options *ChartOptions `protobuf:"bytes,10,opt,name=options,proto3" json:"options,omitempty"`
	Key     *ChartKey     `protobuf:"bytes,11,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

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

type LeaderboardSetScoreRequest struct {
	Entries []*ChartEntry `protobuf:"bytes,1,rep,name=entries,proto3" json:"entries,omitempty"`
	Options *ChartOptions `protobuf:"bytes,10,opt,name=options,proto3" json:"options,omitempty"`
	Key     *ChartKey     `protobuf:"bytes,11,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

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

type LoginStateProperties struct {

	// acct id can be taken over if duplicated
	TakeOverAcctIdIfDuplicated bool `` /* 148-byte string literal not displayed */
	// contains filtered or unexported fields
}

type Mail struct {
	Id   string     `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Data *anypb.Any `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

type MailboxClient interface {
	List(ctx context.Context, in *MailboxListRequest, opts ...grpc.CallOption) (*MailboxListResponse, error)
	Push(ctx context.Context, in *MailboxPushRequest, opts ...grpc.CallOption) (*MailboxPushResponse, error)
	Pull(ctx context.Context, in *MailboxPullRequest, opts ...grpc.CallOption) (*MailboxPullResponse, error)
}

type MailboxListRequest struct {
	Key *EntryKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

type MailboxListResponse struct {
	Mails []*Mail `protobuf:"bytes,1,rep,name=mails,proto3" json:"mails,omitempty"`
	// contains filtered or unexported fields
}

type MailboxPullRequest struct {
	Key *EntryKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Ids []string  `protobuf:"bytes,2,rep,name=ids,proto3" json:"ids,omitempty"`
	// contains filtered or unexported fields
}

type MailboxPullResponse struct {
	PulledIds []string `protobuf:"bytes,1,rep,name=pulled_ids,json=pulledIds,proto3" json:"pulled_ids,omitempty"` // pulled id list
	// contains filtered or unexported fields
}

type MailboxPushRequest struct {
	Key      *EntryKey  `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Data     *anypb.Any `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	Capacity int32      `protobuf:"varint,3,opt,name=capacity,proto3" json:"capacity,omitempty"` // maximum mails to keep
	// contains filtered or unexported fields
}

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