v1

package
v0.0.0-...-8671a8c Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 21, 2023 License: Apache-2.0 Imports: 10 Imported by: 12

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrorCode_name = map[int32]string{
		0:     "ErrorCodeNone",
		70001: "ErrorCodeBan",
	}
	ErrorCode_value = map[string]int32{
		"ErrorCodeNone": 0,
		"ErrorCodeBan":  70001,
	}
)

Enum value maps for ErrorCode.

View Source 
var (
	PurchaseState_name = map[int32]string{
		0: "PurchaseStateUnspecified",
		1: "PurchaseStatePending",
		2: "PurchaseStateCanceled",
		3: "PurchaseStatePaid",
		4: "PurchaseStateFulfilled",
	}
	PurchaseState_value = map[string]int32{
		"PurchaseStateUnspecified": 0,
		"PurchaseStatePending":     1,
		"PurchaseStateCanceled":    2,
		"PurchaseStatePaid":        3,
		"PurchaseStateFulfilled":   4,
	}
)

Enum value maps for PurchaseState.

View Source 
var BubbleChart_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "libra.v1.BubbleChart",
	HandlerType: (*BubbleChartServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Append",
			Handler:    _BubbleChart_Append_Handler,
		},
		{
			MethodName: "SwapById",
			Handler:    _BubbleChart_SwapById_Handler,
		},
		{
			MethodName: "SwapByRank",
			Handler:    _BubbleChart_SwapByRank_Handler,
		},
		{
			MethodName: "GetRange",
			Handler:    _BubbleChart_GetRange_Handler,
		},
		{
			MethodName: "GetById",
			Handler:    _BubbleChart_GetById_Handler,
		},
		{
			MethodName: "RemoveById",
			Handler:    _BubbleChart_RemoveById_Handler,
		},
		{
			MethodName: "SetInfo",
			Handler:    _BubbleChart_SetInfo_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "libra/v1/bubble_chart.proto",
}

BubbleChart_ServiceDesc is the grpc.ServiceDesc for BubbleChart service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var Cache_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "libra.v1.Cache",
	HandlerType: (*CacheServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Get",
			Handler:    _Cache_Get_Handler,
		},
		{
			MethodName: "Set",
			Handler:    _Cache_Set_Handler,
		},
		{
			MethodName: "Add",
			Handler:    _Cache_Add_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "libra/v1/cache.proto",
}

Cache_ServiceDesc is the grpc.ServiceDesc for Cache service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var Database_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "libra.v1.Database",
	HandlerType: (*DatabaseServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "RegisterSchema",
			Handler:    _Database_RegisterSchema_Handler,
		},
		{
			MethodName: "Get",
			Handler:    _Database_Get_Handler,
		},
		{
			MethodName: "Set",
			Handler:    _Database_Set_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "libra/v1/database.proto",
}

Database_ServiceDesc is the grpc.ServiceDesc for Database service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var Distlock_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "libra.v1.Distlock",
	HandlerType: (*DistlockServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Lock",
			Handler:    _Distlock_Lock_Handler,
		},
		{
			MethodName: "Unlock",
			Handler:    _Distlock_Unlock_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "libra/v1/distlock.proto",
}

Distlock_ServiceDesc is the grpc.ServiceDesc for Distlock service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var FileService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "libra.v1.FileService",
	HandlerType: (*FileServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Get",
			Handler:    _FileService_Get_Handler,
		},
		{
			MethodName: "Put",
			Handler:    _FileService_Put_Handler,
		},
		{
			MethodName: "Del",
			Handler:    _FileService_Del_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "libra/v1/file.proto",
}

FileService_ServiceDesc is the grpc.ServiceDesc for FileService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_libra_v1_bubble_chart_proto protoreflect.FileDescriptor
View Source 
var File_libra_v1_cache_proto protoreflect.FileDescriptor
View Source 
var File_libra_v1_chart_proto protoreflect.FileDescriptor
View Source 
var File_libra_v1_database_proto protoreflect.FileDescriptor
View Source 
var File_libra_v1_distlock_proto protoreflect.FileDescriptor
View Source 
var File_libra_v1_entry_key_proto protoreflect.FileDescriptor
View Source 
var File_libra_v1_error_proto protoreflect.FileDescriptor
View Source 
var File_libra_v1_file_proto protoreflect.FileDescriptor
View Source 
var File_libra_v1_gateway_proto protoreflect.FileDescriptor
View Source 
var File_libra_v1_gift_proto protoreflect.FileDescriptor
View Source 
var File_libra_v1_indexing_proto protoreflect.FileDescriptor
View Source 
var File_libra_v1_leaderboard_proto protoreflect.FileDescriptor
View Source 
var File_libra_v1_mailbox_proto protoreflect.FileDescriptor
View Source 
var File_libra_v1_pubsub_proto protoreflect.FileDescriptor
View Source 
var File_libra_v1_purchase_proto protoreflect.FileDescriptor
View Source 
var File_libra_v1_role_proto protoreflect.FileDescriptor
View Source 
var File_libra_v1_user_proto protoreflect.FileDescriptor
View Source 
var Gateway_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "libra.v1.Gateway",
	HandlerType: (*GatewayServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Send",
			Handler:    _Gateway_Send_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Watch",
			Handler:       _Gateway_Watch_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "libra/v1/gateway.proto",
}

Gateway_ServiceDesc is the grpc.ServiceDesc for Gateway service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var Gift_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "libra.v1.Gift",
	HandlerType: (*GiftServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Create",
			Handler:    _Gift_Create_Handler,
		},
		{
			MethodName: "Revoke",
			Handler:    _Gift_Revoke_Handler,
		},
		{
			MethodName: "Update",
			Handler:    _Gift_Update_Handler,
		},
		{
			MethodName: "Search",
			Handler:    _Gift_Search_Handler,
		},
		{
			MethodName: "Verify",
			Handler:    _Gift_Verify_Handler,
		},
		{
			MethodName: "Redeem",
			Handler:    _Gift_Redeem_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "libra/v1/gift.proto",
}

Gift_ServiceDesc is the grpc.ServiceDesc for Gift service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var Leaderboard_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "libra.v1.Leaderboard",
	HandlerType: (*LeaderboardServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Set",
			Handler:    _Leaderboard_Set_Handler,
		},
		{
			MethodName: "SetInfo",
			Handler:    _Leaderboard_SetInfo_Handler,
		},
		{
			MethodName: "GetByRank",
			Handler:    _Leaderboard_GetByRank_Handler,
		},
		{
			MethodName: "GetById",
			Handler:    _Leaderboard_GetById_Handler,
		},
		{
			MethodName: "GetByScore",
			Handler:    _Leaderboard_GetByScore_Handler,
		},
		{
			MethodName: "RemoveById",
			Handler:    _Leaderboard_RemoveById_Handler,
		},
		{
			MethodName: "Touch",
			Handler:    _Leaderboard_Touch_Handler,
		},
		{
			MethodName: "SetScore",
			Handler:    _Leaderboard_SetScore_Handler,
		},
		{
			MethodName: "GetRange",
			Handler:    _Leaderboard_GetRange_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "libra/v1/leaderboard.proto",
}

Leaderboard_ServiceDesc is the grpc.ServiceDesc for Leaderboard service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var Mailbox_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "libra.v1.Mailbox",
	HandlerType: (*MailboxServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "List",
			Handler:    _Mailbox_List_Handler,
		},
		{
			MethodName: "Pull",
			Handler:    _Mailbox_Pull_Handler,
		},
		{
			MethodName: "Send",
			Handler:    _Mailbox_Send_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "libra/v1/mailbox.proto",
}

Mailbox_ServiceDesc is the grpc.ServiceDesc for Mailbox service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var Order_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "libra.v1.Order",
	HandlerType: (*OrderServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Get",
			Handler:    _Order_Get_Handler,
		},
		{
			MethodName: "Create",
			Handler:    _Order_Create_Handler,
		},
		{
			MethodName: "Cancel",
			Handler:    _Order_Cancel_Handler,
		},
		{
			MethodName: "Pay",
			Handler:    _Order_Pay_Handler,
		},
		{
			MethodName: "Fulfill",
			Handler:    _Order_Fulfill_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "libra/v1/purchase.proto",
}

Order_ServiceDesc is the grpc.ServiceDesc for Order service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var PubSubService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "libra.v1.PubSubService",
	HandlerType: (*PubSubServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Publish",
			Handler:    _PubSubService_Publish_Handler,
		},
		{
			MethodName: "Consume",
			Handler:    _PubSubService_Consume_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Subscribe",
			Handler:       _PubSubService_Subscribe_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "libra/v1/pubsub.proto",
}

PubSubService_ServiceDesc is the grpc.ServiceDesc for PubSubService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var Role_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "libra.v1.Role",
	HandlerType: (*RoleServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Get",
			Handler:    _Role_Get_Handler,
		},
		{
			MethodName: "List",
			Handler:    _Role_List_Handler,
		},
		{
			MethodName: "Create",
			Handler:    _Role_Create_Handler,
		},
		{
			MethodName: "SignIn",
			Handler:    _Role_SignIn_Handler,
		},
		{
			MethodName: "SetMetadata",
			Handler:    _Role_SetMetadata_Handler,
		},
		{
			MethodName: "GetMetadata",
			Handler:    _Role_GetMetadata_Handler,
		},
		{
			MethodName: "AlterIndex",
			Handler:    _Role_AlterIndex_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "libra/v1/role.proto",
}

Role_ServiceDesc is the grpc.ServiceDesc for Role service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var SubstrIndex1Service_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "libra.v1.SubstrIndex1Service",
	HandlerType: (*SubstrIndex1ServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Update",
			Handler:    _SubstrIndex1Service_Update_Handler,
		},
		{
			MethodName: "Remove",
			Handler:    _SubstrIndex1Service_Remove_Handler,
		},
		{
			MethodName: "Search",
			Handler:    _SubstrIndex1Service_Search_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "libra/v1/indexing.proto",
}

SubstrIndex1Service_ServiceDesc is the grpc.ServiceDesc for SubstrIndex1Service service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var User_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "libra.v1.User",
	HandlerType: (*UserServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Get",
			Handler:    _User_Get_Handler,
		},
		{
			MethodName: "Query",
			Handler:    _User_Query_Handler,
		},
		{
			MethodName: "Ban",
			Handler:    _User_Ban_Handler,
		},
		{
			MethodName: "Block",
			Handler:    _User_Block_Handler,
		},
		{
			MethodName: "BindAcctId",
			Handler:    _User_BindAcctId_Handler,
		},
		{
			MethodName: "Login",
			Handler:    _User_Login_Handler,
		},
		{
			MethodName: "Logout",
			Handler:    _User_Logout_Handler,
		},
		{
			MethodName: "Bind",
			Handler:    _User_Bind_Handler,
		},
		{
			MethodName: "Unbind",
			Handler:    _User_Unbind_Handler,
		},
		{
			MethodName: "SetMetadata",
			Handler:    _User_SetMetadata_Handler,
		},
		{
			MethodName: "GetMetadata",
			Handler:    _User_GetMetadata_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "libra/v1/user.proto",
}

User_ServiceDesc is the grpc.ServiceDesc for User service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterBubbleChartServer 

func RegisterBubbleChartServer(s grpc.ServiceRegistrar, srv BubbleChartServer)

func RegisterCacheServer 

func RegisterCacheServer(s grpc.ServiceRegistrar, srv CacheServer)

func RegisterDatabaseServer 

func RegisterDatabaseServer(s grpc.ServiceRegistrar, srv DatabaseServer)

func RegisterDistlockServer 

func RegisterDistlockServer(s grpc.ServiceRegistrar, srv DistlockServer)

func RegisterFileServiceServer 

func RegisterFileServiceServer(s grpc.ServiceRegistrar, srv FileServiceServer)

func RegisterGatewayServer 

func RegisterGatewayServer(s grpc.ServiceRegistrar, srv GatewayServer)

func RegisterGiftServer 

func RegisterGiftServer(s grpc.ServiceRegistrar, srv GiftServer)

func RegisterLeaderboardServer 

func RegisterLeaderboardServer(s grpc.ServiceRegistrar, srv LeaderboardServer)

func RegisterMailboxServer 

func RegisterMailboxServer(s grpc.ServiceRegistrar, srv MailboxServer)

func RegisterOrderServer 

func RegisterOrderServer(s grpc.ServiceRegistrar, srv OrderServer)

func RegisterPubSubServiceServer 

func RegisterPubSubServiceServer(s grpc.ServiceRegistrar, srv PubSubServiceServer)

func RegisterRoleServer 

func RegisterRoleServer(s grpc.ServiceRegistrar, srv RoleServer)

func RegisterSubstrIndex1ServiceServer 

func RegisterSubstrIndex1ServiceServer(s grpc.ServiceRegistrar, srv SubstrIndex1ServiceServer)

func RegisterUserServer 

func RegisterUserServer(s grpc.ServiceRegistrar, srv UserServer)

Types

type BanErrorDetail 

type BanErrorDetail struct {
	UserId string `protobuf:"bytes,1,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	BanTo  int32  `protobuf:"varint,2,opt,name=ban_to,json=banTo,proto3" json:"ban_to,omitempty"`
	BanFor string `protobuf:"bytes,3,opt,name=ban_for,json=banFor,proto3" json:"ban_for,omitempty"`
	// contains filtered or unexported fields
}

ErrorCodeBan

func (*BanErrorDetail) Descriptor deprecated 

func (*BanErrorDetail) Descriptor() ([]byte, []int)

Deprecated: Use BanErrorDetail.ProtoReflect.Descriptor instead.

func (*BanErrorDetail) GetBanFor 

func (x *BanErrorDetail) GetBanFor() string

func (*BanErrorDetail) GetBanTo 

func (x *BanErrorDetail) GetBanTo() int32

func (*BanErrorDetail) GetUserId 

func (x *BanErrorDetail) GetUserId() string

func (*BanErrorDetail) ProtoMessage 

func (*BanErrorDetail) ProtoMessage()

func (*BanErrorDetail) ProtoReflect 

func (x *BanErrorDetail) ProtoReflect() protoreflect.Message

func (*BanErrorDetail) Reset 

func (x *BanErrorDetail) Reset()

func (*BanErrorDetail) String 

func (x *BanErrorDetail) String() string

type BubbleChartAppendRequest 

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
}

func (*BubbleChartAppendRequest) Descriptor deprecated 

func (*BubbleChartAppendRequest) Descriptor() ([]byte, []int)

Deprecated: Use BubbleChartAppendRequest.ProtoReflect.Descriptor instead.

func (*BubbleChartAppendRequest) GetEntries 

func (x *BubbleChartAppendRequest) GetEntries() []*ChartEntry

func (*BubbleChartAppendRequest) GetKey 

func (x *BubbleChartAppendRequest) GetKey() *ChartKey

func (*BubbleChartAppendRequest) GetOptions 

func (x *BubbleChartAppendRequest) GetOptions() *ChartOptions

func (*BubbleChartAppendRequest) ProtoMessage 

func (*BubbleChartAppendRequest) ProtoMessage()

func (*BubbleChartAppendRequest) ProtoReflect 

func (x *BubbleChartAppendRequest) ProtoReflect() protoreflect.Message

func (*BubbleChartAppendRequest) Reset 

func (x *BubbleChartAppendRequest) Reset()

func (*BubbleChartAppendRequest) String 

func (x *BubbleChartAppendRequest) String() string

type BubbleChartAppendResponse 

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

func (*BubbleChartAppendResponse) Descriptor deprecated 

func (*BubbleChartAppendResponse) Descriptor() ([]byte, []int)

Deprecated: Use BubbleChartAppendResponse.ProtoReflect.Descriptor instead.

func (*BubbleChartAppendResponse) ProtoMessage 

func (*BubbleChartAppendResponse) ProtoMessage()

func (*BubbleChartAppendResponse) ProtoReflect 

func (x *BubbleChartAppendResponse) ProtoReflect() protoreflect.Message

func (*BubbleChartAppendResponse) Reset 

func (x *BubbleChartAppendResponse) Reset()

func (*BubbleChartAppendResponse) String 

func (x *BubbleChartAppendResponse) String() string

type BubbleChartClient 

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)
}

BubbleChartClient is the client API for BubbleChart service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewBubbleChartClient 

func NewBubbleChartClient(cc grpc.ClientConnInterface) BubbleChartClient

type BubbleChartGetByIdRequest 

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
}

func (*BubbleChartGetByIdRequest) Descriptor deprecated 

func (*BubbleChartGetByIdRequest) Descriptor() ([]byte, []int)

Deprecated: Use BubbleChartGetByIdRequest.ProtoReflect.Descriptor instead.

func (*BubbleChartGetByIdRequest) GetIds 

func (x *BubbleChartGetByIdRequest) GetIds() []string

func (*BubbleChartGetByIdRequest) GetKey 

func (x *BubbleChartGetByIdRequest) GetKey() *ChartKey

func (*BubbleChartGetByIdRequest) GetOptions 

func (x *BubbleChartGetByIdRequest) GetOptions() *ChartOptions

func (*BubbleChartGetByIdRequest) ProtoMessage 

func (*BubbleChartGetByIdRequest) ProtoMessage()

func (*BubbleChartGetByIdRequest) ProtoReflect 

func (x *BubbleChartGetByIdRequest) ProtoReflect() protoreflect.Message

func (*BubbleChartGetByIdRequest) Reset 

func (x *BubbleChartGetByIdRequest) Reset()

func (*BubbleChartGetByIdRequest) String 

func (x *BubbleChartGetByIdRequest) String() string

type BubbleChartGetByIdResponse 

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

func (*BubbleChartGetByIdResponse) Descriptor deprecated 

func (*BubbleChartGetByIdResponse) Descriptor() ([]byte, []int)

Deprecated: Use BubbleChartGetByIdResponse.ProtoReflect.Descriptor instead.

func (*BubbleChartGetByIdResponse) GetEntries 

func (x *BubbleChartGetByIdResponse) GetEntries() []*ChartEntry

func (*BubbleChartGetByIdResponse) ProtoMessage 

func (*BubbleChartGetByIdResponse) ProtoMessage()

func (*BubbleChartGetByIdResponse) ProtoReflect 

func (x *BubbleChartGetByIdResponse) ProtoReflect() protoreflect.Message

func (*BubbleChartGetByIdResponse) Reset 

func (x *BubbleChartGetByIdResponse) Reset()

func (*BubbleChartGetByIdResponse) String 

func (x *BubbleChartGetByIdResponse) String() string

type BubbleChartGetRangeRequest 

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
}

func (*BubbleChartGetRangeRequest) Descriptor deprecated 

func (*BubbleChartGetRangeRequest) Descriptor() ([]byte, []int)

Deprecated: Use BubbleChartGetRangeRequest.ProtoReflect.Descriptor instead.

func (*BubbleChartGetRangeRequest) GetCount 

func (x *BubbleChartGetRangeRequest) GetCount() int32

func (*BubbleChartGetRangeRequest) GetKey 

func (x *BubbleChartGetRangeRequest) GetKey() *ChartKey

func (*BubbleChartGetRangeRequest) GetOffset 

func (x *BubbleChartGetRangeRequest) GetOffset() int32

func (*BubbleChartGetRangeRequest) GetOptions 

func (x *BubbleChartGetRangeRequest) GetOptions() *ChartOptions

func (*BubbleChartGetRangeRequest) ProtoMessage 

func (*BubbleChartGetRangeRequest) ProtoMessage()

func (*BubbleChartGetRangeRequest) ProtoReflect 

func (x *BubbleChartGetRangeRequest) ProtoReflect() protoreflect.Message

func (*BubbleChartGetRangeRequest) Reset 

func (x *BubbleChartGetRangeRequest) Reset()

func (*BubbleChartGetRangeRequest) String 

func (x *BubbleChartGetRangeRequest) String() string

type BubbleChartGetRangeResponse 

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

func (*BubbleChartGetRangeResponse) Descriptor deprecated 

func (*BubbleChartGetRangeResponse) Descriptor() ([]byte, []int)

Deprecated: Use BubbleChartGetRangeResponse.ProtoReflect.Descriptor instead.

func (*BubbleChartGetRangeResponse) GetEntries 

func (x *BubbleChartGetRangeResponse) GetEntries() []*ChartEntry

func (*BubbleChartGetRangeResponse) ProtoMessage 

func (*BubbleChartGetRangeResponse) ProtoMessage()

func (*BubbleChartGetRangeResponse) ProtoReflect 

func (x *BubbleChartGetRangeResponse) ProtoReflect() protoreflect.Message

func (*BubbleChartGetRangeResponse) Reset 

func (x *BubbleChartGetRangeResponse) Reset()

func (*BubbleChartGetRangeResponse) String 

func (x *BubbleChartGetRangeResponse) String() string

type BubbleChartRemoveByIdRequest 

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
}

func (*BubbleChartRemoveByIdRequest) Descriptor deprecated 

func (*BubbleChartRemoveByIdRequest) Descriptor() ([]byte, []int)

Deprecated: Use BubbleChartRemoveByIdRequest.ProtoReflect.Descriptor instead.

func (*BubbleChartRemoveByIdRequest) GetIds 

func (x *BubbleChartRemoveByIdRequest) GetIds() []string

func (*BubbleChartRemoveByIdRequest) GetKey 

func (x *BubbleChartRemoveByIdRequest) GetKey() *ChartKey

func (*BubbleChartRemoveByIdRequest) GetOptions 

func (x *BubbleChartRemoveByIdRequest) GetOptions() *ChartOptions

func (*BubbleChartRemoveByIdRequest) ProtoMessage 

func (*BubbleChartRemoveByIdRequest) ProtoMessage()

func (*BubbleChartRemoveByIdRequest) ProtoReflect 

func (x *BubbleChartRemoveByIdRequest) ProtoReflect() protoreflect.Message

func (*BubbleChartRemoveByIdRequest) Reset 

func (x *BubbleChartRemoveByIdRequest) Reset()

func (*BubbleChartRemoveByIdRequest) String 

func (x *BubbleChartRemoveByIdRequest) String() string

type BubbleChartRemoveByIdResponse 

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

func (*BubbleChartRemoveByIdResponse) Descriptor deprecated 

func (*BubbleChartRemoveByIdResponse) Descriptor() ([]byte, []int)

Deprecated: Use BubbleChartRemoveByIdResponse.ProtoReflect.Descriptor instead.

func (*BubbleChartRemoveByIdResponse) ProtoMessage 

func (*BubbleChartRemoveByIdResponse) ProtoMessage()

func (*BubbleChartRemoveByIdResponse) ProtoReflect 

func (x *BubbleChartRemoveByIdResponse) ProtoReflect() protoreflect.Message

func (*BubbleChartRemoveByIdResponse) Reset 

func (x *BubbleChartRemoveByIdResponse) Reset()

func (*BubbleChartRemoveByIdResponse) String 

func (x *BubbleChartRemoveByIdResponse) String() string

type BubbleChartServer 

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
}

BubbleChartServer is the server API for BubbleChart service. All implementations must embed UnimplementedBubbleChartServer for forward compatibility

type BubbleChartSetInfoRequest 

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
}

func (*BubbleChartSetInfoRequest) Descriptor deprecated 

func (*BubbleChartSetInfoRequest) Descriptor() ([]byte, []int)

Deprecated: Use BubbleChartSetInfoRequest.ProtoReflect.Descriptor instead.

func (*BubbleChartSetInfoRequest) GetEntries 

func (x *BubbleChartSetInfoRequest) GetEntries() []*ChartEntry

func (*BubbleChartSetInfoRequest) GetKey 

func (x *BubbleChartSetInfoRequest) GetKey() *ChartKey

func (*BubbleChartSetInfoRequest) GetOptions 

func (x *BubbleChartSetInfoRequest) GetOptions() *ChartOptions

func (*BubbleChartSetInfoRequest) ProtoMessage 

func (*BubbleChartSetInfoRequest) ProtoMessage()

func (*BubbleChartSetInfoRequest) ProtoReflect 

func (x *BubbleChartSetInfoRequest) ProtoReflect() protoreflect.Message

func (*BubbleChartSetInfoRequest) Reset 

func (x *BubbleChartSetInfoRequest) Reset()

func (*BubbleChartSetInfoRequest) String 

func (x *BubbleChartSetInfoRequest) String() string

type BubbleChartSetInfoResponse 

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

func (*BubbleChartSetInfoResponse) Descriptor deprecated 

func (*BubbleChartSetInfoResponse) Descriptor() ([]byte, []int)

Deprecated: Use BubbleChartSetInfoResponse.ProtoReflect.Descriptor instead.

func (*BubbleChartSetInfoResponse) ProtoMessage 

func (*BubbleChartSetInfoResponse) ProtoMessage()

func (*BubbleChartSetInfoResponse) ProtoReflect 

func (x *BubbleChartSetInfoResponse) ProtoReflect() protoreflect.Message

func (*BubbleChartSetInfoResponse) Reset 

func (x *BubbleChartSetInfoResponse) Reset()

func (*BubbleChartSetInfoResponse) String 

func (x *BubbleChartSetInfoResponse) String() string

type BubbleChartSwapByIdRequest 

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
}

func (*BubbleChartSwapByIdRequest) Descriptor deprecated 

func (*BubbleChartSwapByIdRequest) Descriptor() ([]byte, []int)

Deprecated: Use BubbleChartSwapByIdRequest.ProtoReflect.Descriptor instead.

func (*BubbleChartSwapByIdRequest) GetId0 

func (x *BubbleChartSwapByIdRequest) GetId0() string

func (*BubbleChartSwapByIdRequest) GetId1 

func (x *BubbleChartSwapByIdRequest) GetId1() string

func (*BubbleChartSwapByIdRequest) GetKey 

func (x *BubbleChartSwapByIdRequest) GetKey() *ChartKey

func (*BubbleChartSwapByIdRequest) GetOptions 

func (x *BubbleChartSwapByIdRequest) GetOptions() *ChartOptions

func (*BubbleChartSwapByIdRequest) ProtoMessage 

func (*BubbleChartSwapByIdRequest) ProtoMessage()

func (*BubbleChartSwapByIdRequest) ProtoReflect 

func (x *BubbleChartSwapByIdRequest) ProtoReflect() protoreflect.Message

func (*BubbleChartSwapByIdRequest) Reset 

func (x *BubbleChartSwapByIdRequest) Reset()

func (*BubbleChartSwapByIdRequest) String 

func (x *BubbleChartSwapByIdRequest) String() string

type BubbleChartSwapByIdResponse 

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

func (*BubbleChartSwapByIdResponse) Descriptor deprecated 

func (*BubbleChartSwapByIdResponse) Descriptor() ([]byte, []int)

Deprecated: Use BubbleChartSwapByIdResponse.ProtoReflect.Descriptor instead.

func (*BubbleChartSwapByIdResponse) ProtoMessage 

func (*BubbleChartSwapByIdResponse) ProtoMessage()

func (*BubbleChartSwapByIdResponse) ProtoReflect 

func (x *BubbleChartSwapByIdResponse) ProtoReflect() protoreflect.Message

func (*BubbleChartSwapByIdResponse) Reset 

func (x *BubbleChartSwapByIdResponse) Reset()

func (*BubbleChartSwapByIdResponse) String 

func (x *BubbleChartSwapByIdResponse) String() string

type BubbleChartSwapByRankRequest 

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
}

func (*BubbleChartSwapByRankRequest) Descriptor deprecated 

func (*BubbleChartSwapByRankRequest) Descriptor() ([]byte, []int)

Deprecated: Use BubbleChartSwapByRankRequest.ProtoReflect.Descriptor instead.

func (*BubbleChartSwapByRankRequest) GetKey 

func (x *BubbleChartSwapByRankRequest) GetKey() *ChartKey

func (*BubbleChartSwapByRankRequest) GetOptions 

func (x *BubbleChartSwapByRankRequest) GetOptions() *ChartOptions

func (*BubbleChartSwapByRankRequest) GetRank0 

func (x *BubbleChartSwapByRankRequest) GetRank0() int32

func (*BubbleChartSwapByRankRequest) GetRank1 

func (x *BubbleChartSwapByRankRequest) GetRank1() int32

func (*BubbleChartSwapByRankRequest) ProtoMessage 

func (*BubbleChartSwapByRankRequest) ProtoMessage()

func (*BubbleChartSwapByRankRequest) ProtoReflect 

func (x *BubbleChartSwapByRankRequest) ProtoReflect() protoreflect.Message

func (*BubbleChartSwapByRankRequest) Reset 

func (x *BubbleChartSwapByRankRequest) Reset()

func (*BubbleChartSwapByRankRequest) String 

func (x *BubbleChartSwapByRankRequest) String() string

type BubbleChartSwapByRankResponse 

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

func (*BubbleChartSwapByRankResponse) Descriptor deprecated 

func (*BubbleChartSwapByRankResponse) Descriptor() ([]byte, []int)

Deprecated: Use BubbleChartSwapByRankResponse.ProtoReflect.Descriptor instead.

func (*BubbleChartSwapByRankResponse) ProtoMessage 

func (*BubbleChartSwapByRankResponse) ProtoMessage()

func (*BubbleChartSwapByRankResponse) ProtoReflect 

func (x *BubbleChartSwapByRankResponse) ProtoReflect() protoreflect.Message

func (*BubbleChartSwapByRankResponse) Reset 

func (x *BubbleChartSwapByRankResponse) Reset()

func (*BubbleChartSwapByRankResponse) String 

func (x *BubbleChartSwapByRankResponse) String() string

type CacheAddRequest 

type CacheAddRequest struct {
	Key     string                   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value   []byte                   `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	Options *CacheAddRequest_Options `protobuf:"bytes,3,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*CacheAddRequest) Descriptor deprecated 

func (*CacheAddRequest) Descriptor() ([]byte, []int)

Deprecated: Use CacheAddRequest.ProtoReflect.Descriptor instead.

func (*CacheAddRequest) GetKey 

func (x *CacheAddRequest) GetKey() string

func (*CacheAddRequest) GetOptions 

func (x *CacheAddRequest) GetOptions() *CacheAddRequest_Options

func (*CacheAddRequest) GetValue 

func (x *CacheAddRequest) GetValue() []byte

func (*CacheAddRequest) ProtoMessage 

func (*CacheAddRequest) ProtoMessage()

func (*CacheAddRequest) ProtoReflect 

func (x *CacheAddRequest) ProtoReflect() protoreflect.Message

func (*CacheAddRequest) Reset 

func (x *CacheAddRequest) Reset()

func (*CacheAddRequest) String 

func (x *CacheAddRequest) String() string

type CacheAddRequest_Options 

type CacheAddRequest_Options struct {
	TimeoutMilliseconds int32 `protobuf:"varint,1,opt,name=timeout_milliseconds,json=timeoutMilliseconds,proto3" json:"timeout_milliseconds,omitempty"`
	// contains filtered or unexported fields
}

func (*CacheAddRequest_Options) Descriptor deprecated 

func (*CacheAddRequest_Options) Descriptor() ([]byte, []int)

Deprecated: Use CacheAddRequest_Options.ProtoReflect.Descriptor instead.

func (*CacheAddRequest_Options) GetTimeoutMilliseconds 

func (x *CacheAddRequest_Options) GetTimeoutMilliseconds() int32

func (*CacheAddRequest_Options) ProtoMessage 

func (*CacheAddRequest_Options) ProtoMessage()

func (*CacheAddRequest_Options) ProtoReflect 

func (x *CacheAddRequest_Options) ProtoReflect() protoreflect.Message

func (*CacheAddRequest_Options) Reset 

func (x *CacheAddRequest_Options) Reset()

func (*CacheAddRequest_Options) String 

func (x *CacheAddRequest_Options) String() string

type CacheAddResponse 

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

func (*CacheAddResponse) Descriptor deprecated 

func (*CacheAddResponse) Descriptor() ([]byte, []int)

Deprecated: Use CacheAddResponse.ProtoReflect.Descriptor instead.

func (*CacheAddResponse) ProtoMessage 

func (*CacheAddResponse) ProtoMessage()

func (*CacheAddResponse) ProtoReflect 

func (x *CacheAddResponse) ProtoReflect() protoreflect.Message

func (*CacheAddResponse) Reset 

func (x *CacheAddResponse) Reset()

func (*CacheAddResponse) String 

func (x *CacheAddResponse) String() string

type CacheClient 

type CacheClient interface {
	// 获取缓存
	Get(ctx context.Context, in *CacheGetRequest, opts ...grpc.CallOption) (*CacheGetResponse, error)
	// 设置缓存
	Set(ctx context.Context, in *CacheSetRequest, opts ...grpc.CallOption) (*CacheSetResponse, error)
	// 新增缓存
	Add(ctx context.Context, in *CacheAddRequest, opts ...grpc.CallOption) (*CacheAddResponse, error)
}

CacheClient is the client API for Cache service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewCacheClient 

func NewCacheClient(cc grpc.ClientConnInterface) CacheClient

type CacheGetRequest 

type CacheGetRequest struct {
	Key     string                   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Options *CacheGetRequest_Options `protobuf:"bytes,10,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*CacheGetRequest) Descriptor deprecated 

func (*CacheGetRequest) Descriptor() ([]byte, []int)

Deprecated: Use CacheGetRequest.ProtoReflect.Descriptor instead.

func (*CacheGetRequest) GetKey 

func (x *CacheGetRequest) GetKey() string

func (*CacheGetRequest) GetOptions 

func (x *CacheGetRequest) GetOptions() *CacheGetRequest_Options

func (*CacheGetRequest) ProtoMessage 

func (*CacheGetRequest) ProtoMessage()

func (*CacheGetRequest) ProtoReflect 

func (x *CacheGetRequest) ProtoReflect() protoreflect.Message

func (*CacheGetRequest) Reset 

func (x *CacheGetRequest) Reset()

func (*CacheGetRequest) String 

func (x *CacheGetRequest) String() string

type CacheGetRequest_Options 

type CacheGetRequest_Options struct {

	// Polling in C# cause NotFound exception which lead to high latency
	RegardNotFoundAsEmpty bool `` /* 131-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*CacheGetRequest_Options) Descriptor deprecated 

func (*CacheGetRequest_Options) Descriptor() ([]byte, []int)

Deprecated: Use CacheGetRequest_Options.ProtoReflect.Descriptor instead.

func (*CacheGetRequest_Options) GetRegardNotFoundAsEmpty 

func (x *CacheGetRequest_Options) GetRegardNotFoundAsEmpty() bool

func (*CacheGetRequest_Options) ProtoMessage 

func (*CacheGetRequest_Options) ProtoMessage()

func (*CacheGetRequest_Options) ProtoReflect 

func (x *CacheGetRequest_Options) ProtoReflect() protoreflect.Message

func (*CacheGetRequest_Options) Reset 

func (x *CacheGetRequest_Options) Reset()

func (*CacheGetRequest_Options) String 

func (x *CacheGetRequest_Options) String() string

type CacheGetResponse 

type CacheGetResponse struct {
	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*CacheGetResponse) Descriptor deprecated 

func (*CacheGetResponse) Descriptor() ([]byte, []int)

Deprecated: Use CacheGetResponse.ProtoReflect.Descriptor instead.

func (*CacheGetResponse) GetValue 

func (x *CacheGetResponse) GetValue() []byte

func (*CacheGetResponse) ProtoMessage 

func (*CacheGetResponse) ProtoMessage()

func (*CacheGetResponse) ProtoReflect 

func (x *CacheGetResponse) ProtoReflect() protoreflect.Message

func (*CacheGetResponse) Reset 

func (x *CacheGetResponse) Reset()

func (*CacheGetResponse) String 

func (x *CacheGetResponse) String() string

type CacheOptions 

type CacheOptions struct {
	TimeoutMilliseconds int32 `protobuf:"varint,1,opt,name=timeout_milliseconds,json=timeoutMilliseconds,proto3" json:"timeout_milliseconds,omitempty"`
	// contains filtered or unexported fields
}

func (*CacheOptions) Descriptor deprecated 

func (*CacheOptions) Descriptor() ([]byte, []int)

Deprecated: Use CacheOptions.ProtoReflect.Descriptor instead.

func (*CacheOptions) GetTimeoutMilliseconds 

func (x *CacheOptions) GetTimeoutMilliseconds() int32

func (*CacheOptions) ProtoMessage 

func (*CacheOptions) ProtoMessage()

func (*CacheOptions) ProtoReflect 

func (x *CacheOptions) ProtoReflect() protoreflect.Message

func (*CacheOptions) Reset 

func (x *CacheOptions) Reset()

func (*CacheOptions) String 

func (x *CacheOptions) String() string

type CacheServer 

type CacheServer interface {
	// 获取缓存
	Get(context.Context, *CacheGetRequest) (*CacheGetResponse, error)
	// 设置缓存
	Set(context.Context, *CacheSetRequest) (*CacheSetResponse, error)
	// 新增缓存
	Add(context.Context, *CacheAddRequest) (*CacheAddResponse, error)
	// contains filtered or unexported methods
}

CacheServer is the server API for Cache service. All implementations must embed UnimplementedCacheServer for forward compatibility

type CacheSetRequest 

type CacheSetRequest struct {
	Key     string                   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value   []byte                   `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	Options *CacheSetRequest_Options `protobuf:"bytes,3,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*CacheSetRequest) Descriptor deprecated 

func (*CacheSetRequest) Descriptor() ([]byte, []int)

Deprecated: Use CacheSetRequest.ProtoReflect.Descriptor instead.

func (*CacheSetRequest) GetKey 

func (x *CacheSetRequest) GetKey() string

func (*CacheSetRequest) GetOptions 

func (x *CacheSetRequest) GetOptions() *CacheSetRequest_Options

func (*CacheSetRequest) GetValue 

func (x *CacheSetRequest) GetValue() []byte

func (*CacheSetRequest) ProtoMessage 

func (*CacheSetRequest) ProtoMessage()

func (*CacheSetRequest) ProtoReflect 

func (x *CacheSetRequest) ProtoReflect() protoreflect.Message

func (*CacheSetRequest) Reset 

func (x *CacheSetRequest) Reset()

func (*CacheSetRequest) String 

func (x *CacheSetRequest) String() string

type CacheSetRequest_Options 

type CacheSetRequest_Options struct {
	TimeoutMilliseconds int32 `protobuf:"varint,1,opt,name=timeout_milliseconds,json=timeoutMilliseconds,proto3" json:"timeout_milliseconds,omitempty"`
	// contains filtered or unexported fields
}

func (*CacheSetRequest_Options) Descriptor deprecated 

func (*CacheSetRequest_Options) Descriptor() ([]byte, []int)

Deprecated: Use CacheSetRequest_Options.ProtoReflect.Descriptor instead.

func (*CacheSetRequest_Options) GetTimeoutMilliseconds 

func (x *CacheSetRequest_Options) GetTimeoutMilliseconds() int32

func (*CacheSetRequest_Options) ProtoMessage 

func (*CacheSetRequest_Options) ProtoMessage()

func (*CacheSetRequest_Options) ProtoReflect 

func (x *CacheSetRequest_Options) ProtoReflect() protoreflect.Message

func (*CacheSetRequest_Options) Reset 

func (x *CacheSetRequest_Options) Reset()

func (*CacheSetRequest_Options) String 

func (x *CacheSetRequest_Options) String() string

type CacheSetResponse 

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

func (*CacheSetResponse) Descriptor deprecated 

func (*CacheSetResponse) Descriptor() ([]byte, []int)

Deprecated: Use CacheSetResponse.ProtoReflect.Descriptor instead.

func (*CacheSetResponse) ProtoMessage 

func (*CacheSetResponse) ProtoMessage()

func (*CacheSetResponse) ProtoReflect 

func (x *CacheSetResponse) ProtoReflect() protoreflect.Message

func (*CacheSetResponse) Reset 

func (x *CacheSetResponse) Reset()

func (*CacheSetResponse) String 

func (x *CacheSetResponse) String() string

type ChartEntry 

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
}

chart entry

func (*ChartEntry) Descriptor deprecated 

func (*ChartEntry) Descriptor() ([]byte, []int)

Deprecated: Use ChartEntry.ProtoReflect.Descriptor instead.

func (*ChartEntry) GetId 

func (x *ChartEntry) GetId() string

func (*ChartEntry) GetInfo 

func (x *ChartEntry) GetInfo() string

func (*ChartEntry) GetRank 

func (x *ChartEntry) GetRank() int32

func (*ChartEntry) GetScore 

func (x *ChartEntry) GetScore() int64

func (*ChartEntry) ProtoMessage 

func (*ChartEntry) ProtoMessage()

func (*ChartEntry) ProtoReflect 

func (x *ChartEntry) ProtoReflect() protoreflect.Message

func (*ChartEntry) Reset 

func (x *ChartEntry) Reset()

func (*ChartEntry) String 

func (x *ChartEntry) String() string

type ChartKey 

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
}

chart key {app_id:name}[:suffix] 一般情况下，suffix不需要提供，redis集群会以{app_id:name} 的一致性哈希结果对请求进行路由。 但有一种情况需要考虑使用suffix，需要construct_from但时候， 需要保证被复制对象和新生成对象在同一台节点上，这时候就 需要suffix，实现内部会生成{app_id:name}:suffix这样的key， 括号内为redis的hash tag，只用hash tag来进行一致性哈希， 从而保证所有相关对象都在同一节点上。

func (*ChartKey) Descriptor deprecated 

func (*ChartKey) Descriptor() ([]byte, []int)

Deprecated: Use ChartKey.ProtoReflect.Descriptor instead.

func (*ChartKey) GetName 

func (x *ChartKey) GetName() string

func (*ChartKey) GetSuffix 

func (x *ChartKey) GetSuffix() string

func (*ChartKey) ProtoMessage 

func (*ChartKey) ProtoMessage()

func (*ChartKey) ProtoReflect 

func (x *ChartKey) ProtoReflect() protoreflect.Message

func (*ChartKey) Reset 

func (x *ChartKey) Reset()

func (*ChartKey) String 

func (x *ChartKey) String() string

type ChartOptions 

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
	Expire int64 `protobuf:"varint,4,opt,name=expire,proto3" json:"expire,omitempty"`
	// not trim tail if reach capacity, an OutOfRange error will be return
	NoTrim bool `protobuf:"varint,5,opt,name=no_trim,json=noTrim,proto3" json:"no_trim,omitempty"`
	// discard info in query results
	NoInfo bool `protobuf:"varint,6,opt,name=no_info,json=noInfo,proto3" json:"no_info,omitempty"`
	// contains filtered or unexported fields
}

chart options NOTE: 

if options not set, the existed chart keep it's current options
if field of options not set, the existed chart SET THIS OPTION TO DEFAULT

func (*ChartOptions) Descriptor deprecated 

func (*ChartOptions) Descriptor() ([]byte, []int)

Deprecated: Use ChartOptions.ProtoReflect.Descriptor instead.

func (*ChartOptions) GetCapacity 

func (x *ChartOptions) GetCapacity() int32

func (*ChartOptions) GetConstructFrom 

func (x *ChartOptions) GetConstructFrom() *ChartKey

func (*ChartOptions) GetExpire 

func (x *ChartOptions) GetExpire() int64

func (*ChartOptions) GetExpireAt 

func (x *ChartOptions) GetExpireAt() int64

func (*ChartOptions) GetNoInfo 

func (x *ChartOptions) GetNoInfo() bool

func (*ChartOptions) GetNoTrim 

func (x *ChartOptions) GetNoTrim() bool

func (*ChartOptions) ProtoMessage 

func (*ChartOptions) ProtoMessage()

func (*ChartOptions) ProtoReflect 

func (x *ChartOptions) ProtoReflect() protoreflect.Message

func (*ChartOptions) Reset 

func (x *ChartOptions) Reset()

func (*ChartOptions) String 

func (x *ChartOptions) String() string

type DatabaseClient 

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)
}

DatabaseClient is the client API for Database service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewDatabaseClient 

func NewDatabaseClient(cc grpc.ClientConnInterface) DatabaseClient

type DatabaseGetRequest 

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
}

func (*DatabaseGetRequest) Descriptor deprecated 

func (*DatabaseGetRequest) Descriptor() ([]byte, []int)

Deprecated: Use DatabaseGetRequest.ProtoReflect.Descriptor instead.

func (*DatabaseGetRequest) GetAddIfNotFound 

func (x *DatabaseGetRequest) GetAddIfNotFound() *anypb.Any

func (*DatabaseGetRequest) GetKey 

func (x *DatabaseGetRequest) GetKey() *EntryKey

func (*DatabaseGetRequest) GetLockOptions 

func (x *DatabaseGetRequest) GetLockOptions() *DistlockLockOptions

func (*DatabaseGetRequest) ProtoMessage 

func (*DatabaseGetRequest) ProtoMessage()

func (*DatabaseGetRequest) ProtoReflect 

func (x *DatabaseGetRequest) ProtoReflect() protoreflect.Message

func (*DatabaseGetRequest) Reset 

func (x *DatabaseGetRequest) Reset()

func (*DatabaseGetRequest) String 

func (x *DatabaseGetRequest) String() string

type DatabaseGetResponse 

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
}

func (*DatabaseGetResponse) Descriptor deprecated 

func (*DatabaseGetResponse) Descriptor() ([]byte, []int)

Deprecated: Use DatabaseGetResponse.ProtoReflect.Descriptor instead.

func (*DatabaseGetResponse) GetData 

func (x *DatabaseGetResponse) GetData() *anypb.Any

func (*DatabaseGetResponse) GetLockToken 

func (x *DatabaseGetResponse) GetLockToken() *anypb.Any

func (*DatabaseGetResponse) GetRevision 

func (x *DatabaseGetResponse) GetRevision() int64

func (*DatabaseGetResponse) ProtoMessage 

func (*DatabaseGetResponse) ProtoMessage()

func (*DatabaseGetResponse) ProtoReflect 

func (x *DatabaseGetResponse) ProtoReflect() protoreflect.Message

func (*DatabaseGetResponse) Reset 

func (x *DatabaseGetResponse) Reset()

func (*DatabaseGetResponse) String 

func (x *DatabaseGetResponse) String() string

type DatabaseRegisterSchemaRequest 

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
}

func (*DatabaseRegisterSchemaRequest) Descriptor deprecated 

func (*DatabaseRegisterSchemaRequest) Descriptor() ([]byte, []int)

Deprecated: Use DatabaseRegisterSchemaRequest.ProtoReflect.Descriptor instead.

func (*DatabaseRegisterSchemaRequest) GetDescriptorSet 

func (x *DatabaseRegisterSchemaRequest) GetDescriptorSet() *descriptorpb.FileDescriptorSet

func (*DatabaseRegisterSchemaRequest) GetMessageName 

func (x *DatabaseRegisterSchemaRequest) GetMessageName() string

func (*DatabaseRegisterSchemaRequest) ProtoMessage 

func (*DatabaseRegisterSchemaRequest) ProtoMessage()

func (*DatabaseRegisterSchemaRequest) ProtoReflect 

func (x *DatabaseRegisterSchemaRequest) ProtoReflect() protoreflect.Message

func (*DatabaseRegisterSchemaRequest) Reset 

func (x *DatabaseRegisterSchemaRequest) Reset()

func (*DatabaseRegisterSchemaRequest) String 

func (x *DatabaseRegisterSchemaRequest) String() string

type DatabaseRegisterSchemaResponse 

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
}

func (*DatabaseRegisterSchemaResponse) Descriptor deprecated 

func (*DatabaseRegisterSchemaResponse) Descriptor() ([]byte, []int)

Deprecated: Use DatabaseRegisterSchemaResponse.ProtoReflect.Descriptor instead.

func (*DatabaseRegisterSchemaResponse) GetSchema 

func (x *DatabaseRegisterSchemaResponse) GetSchema() string

func (*DatabaseRegisterSchemaResponse) ProtoMessage 

func (*DatabaseRegisterSchemaResponse) ProtoMessage()

func (*DatabaseRegisterSchemaResponse) ProtoReflect 

func (x *DatabaseRegisterSchemaResponse) ProtoReflect() protoreflect.Message

func (*DatabaseRegisterSchemaResponse) Reset 

func (x *DatabaseRegisterSchemaResponse) Reset()

func (*DatabaseRegisterSchemaResponse) String 

func (x *DatabaseRegisterSchemaResponse) String() string

type DatabaseServer 

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
}

DatabaseServer is the server API for Database service. All implementations must embed UnimplementedDatabaseServer for forward compatibility

type DatabaseSetRequest 

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
}

func (*DatabaseSetRequest) Descriptor deprecated 

func (*DatabaseSetRequest) Descriptor() ([]byte, []int)

Deprecated: Use DatabaseSetRequest.ProtoReflect.Descriptor instead.

func (*DatabaseSetRequest) GetData 

func (x *DatabaseSetRequest) GetData() *anypb.Any

func (*DatabaseSetRequest) GetKey 

func (x *DatabaseSetRequest) GetKey() *EntryKey

func (*DatabaseSetRequest) GetLockToken 

func (x *DatabaseSetRequest) GetLockToken() *anypb.Any

func (*DatabaseSetRequest) GetUnlockOptions 

func (x *DatabaseSetRequest) GetUnlockOptions() *DistlockUnlockOptions

func (*DatabaseSetRequest) ProtoMessage 

func (*DatabaseSetRequest) ProtoMessage()

func (*DatabaseSetRequest) ProtoReflect 

func (x *DatabaseSetRequest) ProtoReflect() protoreflect.Message

func (*DatabaseSetRequest) Reset 

func (x *DatabaseSetRequest) Reset()

func (*DatabaseSetRequest) String 

func (x *DatabaseSetRequest) String() string

type DatabaseSetResponse 

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

func (*DatabaseSetResponse) Descriptor deprecated 

func (*DatabaseSetResponse) Descriptor() ([]byte, []int)

Deprecated: Use DatabaseSetResponse.ProtoReflect.Descriptor instead.

func (*DatabaseSetResponse) GetRevision 

func (x *DatabaseSetResponse) GetRevision() int64

func (*DatabaseSetResponse) ProtoMessage 

func (*DatabaseSetResponse) ProtoMessage()

func (*DatabaseSetResponse) ProtoReflect 

func (x *DatabaseSetResponse) ProtoReflect() protoreflect.Message

func (*DatabaseSetResponse) Reset 

func (x *DatabaseSetResponse) Reset()

func (*DatabaseSetResponse) String 

func (x *DatabaseSetResponse) String() string

type DistlockClient 

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)
}

DistlockClient is the client API for Distlock service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewDistlockClient 

func NewDistlockClient(cc grpc.ClientConnInterface) DistlockClient

type DistlockLockOptions 

type DistlockLockOptions struct {

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

func (*DistlockLockOptions) Descriptor deprecated 

func (*DistlockLockOptions) Descriptor() ([]byte, []int)

Deprecated: Use DistlockLockOptions.ProtoReflect.Descriptor instead.

func (*DistlockLockOptions) GetTimeoutMilliseconds 

func (x *DistlockLockOptions) GetTimeoutMilliseconds() int32

func (*DistlockLockOptions) ProtoMessage 

func (*DistlockLockOptions) ProtoMessage()

func (*DistlockLockOptions) ProtoReflect 

func (x *DistlockLockOptions) ProtoReflect() protoreflect.Message

func (*DistlockLockOptions) Reset 

func (x *DistlockLockOptions) Reset()

func (*DistlockLockOptions) String 

func (x *DistlockLockOptions) String() string

type DistlockLockRequest 

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
}

func (*DistlockLockRequest) Descriptor deprecated 

func (*DistlockLockRequest) Descriptor() ([]byte, []int)

Deprecated: Use DistlockLockRequest.ProtoReflect.Descriptor instead.

func (*DistlockLockRequest) GetKey 

func (x *DistlockLockRequest) GetKey() *EntryKey

func (*DistlockLockRequest) GetLockOptions 

func (x *DistlockLockRequest) GetLockOptions() *DistlockLockOptions

func (*DistlockLockRequest) ProtoMessage 

func (*DistlockLockRequest) ProtoMessage()

func (*DistlockLockRequest) ProtoReflect 

func (x *DistlockLockRequest) ProtoReflect() protoreflect.Message

func (*DistlockLockRequest) Reset 

func (x *DistlockLockRequest) Reset()

func (*DistlockLockRequest) String 

func (x *DistlockLockRequest) String() string

type DistlockLockResponse 

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
}

func (*DistlockLockResponse) Descriptor deprecated 

func (*DistlockLockResponse) Descriptor() ([]byte, []int)

Deprecated: Use DistlockLockResponse.ProtoReflect.Descriptor instead.

func (*DistlockLockResponse) GetLockToken 

func (x *DistlockLockResponse) GetLockToken() *anypb.Any

func (*DistlockLockResponse) ProtoMessage 

func (*DistlockLockResponse) ProtoMessage()

func (*DistlockLockResponse) ProtoReflect 

func (x *DistlockLockResponse) ProtoReflect() protoreflect.Message

func (*DistlockLockResponse) Reset 

func (x *DistlockLockResponse) Reset()

func (*DistlockLockResponse) String 

func (x *DistlockLockResponse) String() string

type DistlockServer 

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

DistlockServer is the server API for Distlock service. All implementations must embed UnimplementedDistlockServer for forward compatibility

type DistlockUnlockOptions 

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
}

func (*DistlockUnlockOptions) Descriptor deprecated 

func (*DistlockUnlockOptions) Descriptor() ([]byte, []int)

Deprecated: Use DistlockUnlockOptions.ProtoReflect.Descriptor instead.

func (*DistlockUnlockOptions) GetEvenOnFailure 

func (x *DistlockUnlockOptions) GetEvenOnFailure() bool

func (*DistlockUnlockOptions) ProtoMessage 

func (*DistlockUnlockOptions) ProtoMessage()

func (*DistlockUnlockOptions) ProtoReflect 

func (x *DistlockUnlockOptions) ProtoReflect() protoreflect.Message

func (*DistlockUnlockOptions) Reset 

func (x *DistlockUnlockOptions) Reset()

func (*DistlockUnlockOptions) String 

func (x *DistlockUnlockOptions) String() string

type DistlockUnlockRequest 

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
}

func (*DistlockUnlockRequest) Descriptor deprecated 

func (*DistlockUnlockRequest) Descriptor() ([]byte, []int)

Deprecated: Use DistlockUnlockRequest.ProtoReflect.Descriptor instead.

func (*DistlockUnlockRequest) GetKey 

func (x *DistlockUnlockRequest) GetKey() *EntryKey

func (*DistlockUnlockRequest) GetLockToken 

func (x *DistlockUnlockRequest) GetLockToken() *anypb.Any

func (*DistlockUnlockRequest) GetUnlockOptions 

func (x *DistlockUnlockRequest) GetUnlockOptions() *DistlockUnlockOptions

func (*DistlockUnlockRequest) ProtoMessage 

func (*DistlockUnlockRequest) ProtoMessage()

func (*DistlockUnlockRequest) ProtoReflect 

func (x *DistlockUnlockRequest) ProtoReflect() protoreflect.Message

func (*DistlockUnlockRequest) Reset 

func (x *DistlockUnlockRequest) Reset()

func (*DistlockUnlockRequest) String 

func (x *DistlockUnlockRequest) String() string

type DistlockUnlockResponse 

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

func (*DistlockUnlockResponse) Descriptor deprecated 

func (*DistlockUnlockResponse) Descriptor() ([]byte, []int)

Deprecated: Use DistlockUnlockResponse.ProtoReflect.Descriptor instead.

func (*DistlockUnlockResponse) ProtoMessage 

func (*DistlockUnlockResponse) ProtoMessage()

func (*DistlockUnlockResponse) ProtoReflect 

func (x *DistlockUnlockResponse) ProtoReflect() protoreflect.Message

func (*DistlockUnlockResponse) Reset 

func (x *DistlockUnlockResponse) Reset()

func (*DistlockUnlockResponse) String 

func (x *DistlockUnlockResponse) String() string

type EntryKey 

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
}

used to locate a data entry

func (*EntryKey) Descriptor deprecated 

func (*EntryKey) Descriptor() ([]byte, []int)

Deprecated: Use EntryKey.ProtoReflect.Descriptor instead.

func (*EntryKey) GetId 

func (x *EntryKey) GetId() string

func (*EntryKey) GetKind 

func (x *EntryKey) GetKind() string

func (*EntryKey) ProtoMessage 

func (*EntryKey) ProtoMessage()

func (*EntryKey) ProtoReflect 

func (x *EntryKey) ProtoReflect() protoreflect.Message

func (*EntryKey) Reset 

func (x *EntryKey) Reset()

func (*EntryKey) String 

func (x *EntryKey) String() string

type Envelope 

type Envelope struct {
	Keys []*EntryKey `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"`
	Data *anypb.Any  `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// maximum mails to keep, [1,65534]
	Capacity int32 `protobuf:"varint,3,opt,name=capacity,proto3" json:"capacity,omitempty"`
	// using ring buffer to keep mails, order by (importance,pull order)
	Overridable bool `protobuf:"varint,4,opt,name=overridable,proto3" json:"overridable,omitempty"`
	// mail importance [0,255]
	Importance int32 `protobuf:"varint,5,opt,name=importance,proto3" json:"importance,omitempty"`
	// contains filtered or unexported fields
}

func (*Envelope) Descriptor deprecated 

func (*Envelope) Descriptor() ([]byte, []int)

Deprecated: Use Envelope.ProtoReflect.Descriptor instead.

func (*Envelope) GetCapacity 

func (x *Envelope) GetCapacity() int32

func (*Envelope) GetData 

func (x *Envelope) GetData() *anypb.Any

func (*Envelope) GetImportance 

func (x *Envelope) GetImportance() int32

func (*Envelope) GetKeys 

func (x *Envelope) GetKeys() []*EntryKey

func (*Envelope) GetOverridable 

func (x *Envelope) GetOverridable() bool

func (*Envelope) ProtoMessage 

func (*Envelope) ProtoMessage()

func (*Envelope) ProtoReflect 

func (x *Envelope) ProtoReflect() protoreflect.Message

func (*Envelope) Reset 

func (x *Envelope) Reset()

func (*Envelope) String 

func (x *Envelope) String() string

type ErrorCode 

type ErrorCode int32
const (
	ErrorCode_ErrorCodeNone ErrorCode = 0 // OK
	// PermissionDenied = 7xxxx
	ErrorCode_ErrorCodeBan ErrorCode = 70001
)

func (ErrorCode) Descriptor 

func (ErrorCode) Descriptor() protoreflect.EnumDescriptor

func (ErrorCode) Enum 

func (x ErrorCode) Enum() *ErrorCode

func (ErrorCode) EnumDescriptor deprecated 

func (ErrorCode) EnumDescriptor() ([]byte, []int)

Deprecated: Use ErrorCode.Descriptor instead.

func (ErrorCode) Number 

func (x ErrorCode) Number() protoreflect.EnumNumber

func (ErrorCode) String 

func (x ErrorCode) String() string

func (ErrorCode) Type 

func (ErrorCode) Type() protoreflect.EnumType

type ErrorDetail 

type ErrorDetail struct {
	Code ErrorCode  `protobuf:"varint,1,opt,name=code,proto3,enum=libra.v1.ErrorCode" json:"code,omitempty"`
	Msg  string     `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
	Data *anypb.Any `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*ErrorDetail) Descriptor deprecated 

func (*ErrorDetail) Descriptor() ([]byte, []int)

Deprecated: Use ErrorDetail.ProtoReflect.Descriptor instead.

func (*ErrorDetail) GetCode 

func (x *ErrorDetail) GetCode() ErrorCode

func (*ErrorDetail) GetData 

func (x *ErrorDetail) GetData() *anypb.Any

func (*ErrorDetail) GetMsg 

func (x *ErrorDetail) GetMsg() string

func (*ErrorDetail) ProtoMessage 

func (*ErrorDetail) ProtoMessage()

func (*ErrorDetail) ProtoReflect 

func (x *ErrorDetail) ProtoReflect() protoreflect.Message

func (*ErrorDetail) Reset 

func (x *ErrorDetail) Reset()

func (*ErrorDetail) String 

func (x *ErrorDetail) String() string

type FileData 

type FileData struct {
	Path    string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	Content []byte `protobuf:"bytes,2,opt,name=content,proto3" json:"content,omitempty"`
	// contains filtered or unexported fields
}

func (*FileData) Descriptor deprecated 

func (*FileData) Descriptor() ([]byte, []int)

Deprecated: Use FileData.ProtoReflect.Descriptor instead.

func (*FileData) GetContent 

func (x *FileData) GetContent() []byte

func (*FileData) GetPath 

func (x *FileData) GetPath() string

func (*FileData) ProtoMessage 

func (*FileData) ProtoMessage()

func (*FileData) ProtoReflect 

func (x *FileData) ProtoReflect() protoreflect.Message

func (*FileData) Reset 

func (x *FileData) Reset()

func (*FileData) String 

func (x *FileData) String() string

type FileDelRequest 

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

func (*FileDelRequest) Descriptor deprecated 

func (*FileDelRequest) Descriptor() ([]byte, []int)

Deprecated: Use FileDelRequest.ProtoReflect.Descriptor instead.

func (*FileDelRequest) GetPath 

func (x *FileDelRequest) GetPath() string

func (*FileDelRequest) ProtoMessage 

func (*FileDelRequest) ProtoMessage()

func (*FileDelRequest) ProtoReflect 

func (x *FileDelRequest) ProtoReflect() protoreflect.Message

func (*FileDelRequest) Reset 

func (x *FileDelRequest) Reset()

func (*FileDelRequest) String 

func (x *FileDelRequest) String() string

type FileDelResponse 

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

func (*FileDelResponse) Descriptor deprecated 

func (*FileDelResponse) Descriptor() ([]byte, []int)

Deprecated: Use FileDelResponse.ProtoReflect.Descriptor instead.

func (*FileDelResponse) ProtoMessage 

func (*FileDelResponse) ProtoMessage()

func (*FileDelResponse) ProtoReflect 

func (x *FileDelResponse) ProtoReflect() protoreflect.Message

func (*FileDelResponse) Reset 

func (x *FileDelResponse) Reset()

func (*FileDelResponse) String 

func (x *FileDelResponse) String() string

type FileGetRequest 

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

func (*FileGetRequest) Descriptor deprecated 

func (*FileGetRequest) Descriptor() ([]byte, []int)

Deprecated: Use FileGetRequest.ProtoReflect.Descriptor instead.

func (*FileGetRequest) GetPath 

func (x *FileGetRequest) GetPath() string

func (*FileGetRequest) ProtoMessage 

func (*FileGetRequest) ProtoMessage()

func (*FileGetRequest) ProtoReflect 

func (x *FileGetRequest) ProtoReflect() protoreflect.Message

func (*FileGetRequest) Reset 

func (x *FileGetRequest) Reset()

func (*FileGetRequest) String 

func (x *FileGetRequest) String() string

type FileGetResponse 

type FileGetResponse struct {
	File *FileData `protobuf:"bytes,1,opt,name=File,proto3" json:"File,omitempty"`
	// contains filtered or unexported fields
}

func (*FileGetResponse) Descriptor deprecated 

func (*FileGetResponse) Descriptor() ([]byte, []int)

Deprecated: Use FileGetResponse.ProtoReflect.Descriptor instead.

func (*FileGetResponse) GetFile 

func (x *FileGetResponse) GetFile() *FileData

func (*FileGetResponse) ProtoMessage 

func (*FileGetResponse) ProtoMessage()

func (*FileGetResponse) ProtoReflect 

func (x *FileGetResponse) ProtoReflect() protoreflect.Message

func (*FileGetResponse) Reset 

func (x *FileGetResponse) Reset()

func (*FileGetResponse) String 

func (x *FileGetResponse) String() string

type FilePutRequest 

type FilePutRequest struct {
	File *FileData `protobuf:"bytes,1,opt,name=File,proto3" json:"File,omitempty"`
	// contains filtered or unexported fields
}

func (*FilePutRequest) Descriptor deprecated 

func (*FilePutRequest) Descriptor() ([]byte, []int)

Deprecated: Use FilePutRequest.ProtoReflect.Descriptor instead.

func (*FilePutRequest) GetFile 

func (x *FilePutRequest) GetFile() *FileData

func (*FilePutRequest) ProtoMessage 

func (*FilePutRequest) ProtoMessage()

func (*FilePutRequest) ProtoReflect 

func (x *FilePutRequest) ProtoReflect() protoreflect.Message

func (*FilePutRequest) Reset 

func (x *FilePutRequest) Reset()

func (*FilePutRequest) String 

func (x *FilePutRequest) String() string

type FilePutResponse 

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

func (*FilePutResponse) Descriptor deprecated 

func (*FilePutResponse) Descriptor() ([]byte, []int)

Deprecated: Use FilePutResponse.ProtoReflect.Descriptor instead.

func (*FilePutResponse) ProtoMessage 

func (*FilePutResponse) ProtoMessage()

func (*FilePutResponse) ProtoReflect 

func (x *FilePutResponse) ProtoReflect() protoreflect.Message

func (*FilePutResponse) Reset 

func (x *FilePutResponse) Reset()

func (*FilePutResponse) String 

func (x *FilePutResponse) String() string

type FileServiceClient 

type FileServiceClient interface {
	Get(ctx context.Context, in *FileGetRequest, opts ...grpc.CallOption) (*FileGetResponse, error)
	Put(ctx context.Context, in *FilePutRequest, opts ...grpc.CallOption) (*FilePutResponse, error)
	Del(ctx context.Context, in *FileDelRequest, opts ...grpc.CallOption) (*FileDelResponse, error)
}

FileServiceClient is the client API for FileService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewFileServiceClient 

func NewFileServiceClient(cc grpc.ClientConnInterface) FileServiceClient

type FileServiceServer 

type FileServiceServer interface {
	Get(context.Context, *FileGetRequest) (*FileGetResponse, error)
	Put(context.Context, *FilePutRequest) (*FilePutResponse, error)
	Del(context.Context, *FileDelRequest) (*FileDelResponse, error)
	// contains filtered or unexported methods
}

FileServiceServer is the server API for FileService service. All implementations must embed UnimplementedFileServiceServer for forward compatibility

type GatewayClient 

type GatewayClient interface {
	////////////////////////////////////////////////////////////////////////////
	// Methods access from client side
	////////////////////////////////////////////////////////////////////////////
	// Establish the back pushing stream
	Watch(ctx context.Context, opts ...grpc.CallOption) (Gateway_WatchClient, error)
	////////////////////////////////////////////////////////////////////////////
	// Methods access from server side
	////////////////////////////////////////////////////////////////////////////
	// Send message to client
	Send(ctx context.Context, in *GatewaySendRequest, opts ...grpc.CallOption) (*GatewaySendResponse, error)
}

GatewayClient is the client API for Gateway service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewGatewayClient 

func NewGatewayClient(cc grpc.ClientConnInterface) GatewayClient

type GatewayMessage 

type GatewayMessage struct {
	Topic        string            `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	Id           string            `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	ProducerName string            `protobuf:"bytes,3,opt,name=producer_name,json=producerName,proto3" json:"producer_name,omitempty"`
	EventTime    int64             `protobuf:"varint,4,opt,name=event_time,json=eventTime,proto3" json:"event_time,omitempty"`
	PublishTime  int64             `protobuf:"varint,5,opt,name=publish_time,json=publishTime,proto3" json:"publish_time,omitempty"`
	Properties   map[string]string `` /* 161-byte string literal not displayed */
	Value        *anypb.Any        `protobuf:"bytes,10,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*GatewayMessage) Descriptor deprecated 

func (*GatewayMessage) Descriptor() ([]byte, []int)

Deprecated: Use GatewayMessage.ProtoReflect.Descriptor instead.

func (*GatewayMessage) GetEventTime 

func (x *GatewayMessage) GetEventTime() int64

func (*GatewayMessage) GetId 

func (x *GatewayMessage) GetId() string

func (*GatewayMessage) GetProducerName 

func (x *GatewayMessage) GetProducerName() string

func (*GatewayMessage) GetProperties 

func (x *GatewayMessage) GetProperties() map[string]string

func (*GatewayMessage) GetPublishTime 

func (x *GatewayMessage) GetPublishTime() int64

func (*GatewayMessage) GetTopic 

func (x *GatewayMessage) GetTopic() string

func (*GatewayMessage) GetValue 

func (x *GatewayMessage) GetValue() *anypb.Any

func (*GatewayMessage) ProtoMessage 

func (*GatewayMessage) ProtoMessage()

func (*GatewayMessage) ProtoReflect 

func (x *GatewayMessage) ProtoReflect() protoreflect.Message

func (*GatewayMessage) Reset 

func (x *GatewayMessage) Reset()

func (*GatewayMessage) String 

func (x *GatewayMessage) String() string

type GatewaySendRequest 

type GatewaySendRequest struct {
	MaxLen     int64           `protobuf:"varint,1,opt,name=max_len,json=maxLen,proto3" json:"max_len,omitempty"`
	AutoCreate bool            `protobuf:"varint,2,opt,name=auto_create,json=autoCreate,proto3" json:"auto_create,omitempty"`
	Msg        *GatewayMessage `protobuf:"bytes,10,opt,name=msg,proto3" json:"msg,omitempty"`
	// contains filtered or unexported fields
}

func (*GatewaySendRequest) Descriptor deprecated 

func (*GatewaySendRequest) Descriptor() ([]byte, []int)

Deprecated: Use GatewaySendRequest.ProtoReflect.Descriptor instead.

func (*GatewaySendRequest) GetAutoCreate 

func (x *GatewaySendRequest) GetAutoCreate() bool

func (*GatewaySendRequest) GetMaxLen 

func (x *GatewaySendRequest) GetMaxLen() int64

func (*GatewaySendRequest) GetMsg 

func (x *GatewaySendRequest) GetMsg() *GatewayMessage

func (*GatewaySendRequest) ProtoMessage 

func (*GatewaySendRequest) ProtoMessage()

func (*GatewaySendRequest) ProtoReflect 

func (x *GatewaySendRequest) ProtoReflect() protoreflect.Message

func (*GatewaySendRequest) Reset 

func (x *GatewaySendRequest) Reset()

func (*GatewaySendRequest) String 

func (x *GatewaySendRequest) String() string

type GatewaySendResponse 

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

func (*GatewaySendResponse) Descriptor deprecated 

func (*GatewaySendResponse) Descriptor() ([]byte, []int)

Deprecated: Use GatewaySendResponse.ProtoReflect.Descriptor instead.

func (*GatewaySendResponse) ProtoMessage 

func (*GatewaySendResponse) ProtoMessage()

func (*GatewaySendResponse) ProtoReflect 

func (x *GatewaySendResponse) ProtoReflect() protoreflect.Message

func (*GatewaySendResponse) Reset 

func (x *GatewaySendResponse) Reset()

func (*GatewaySendResponse) String 

func (x *GatewaySendResponse) String() string

type GatewayServer 

type GatewayServer interface {
	////////////////////////////////////////////////////////////////////////////
	// Methods access from client side
	////////////////////////////////////////////////////////////////////////////
	// Establish the back pushing stream
	Watch(Gateway_WatchServer) error
	////////////////////////////////////////////////////////////////////////////
	// Methods access from server side
	////////////////////////////////////////////////////////////////////////////
	// Send message to client
	Send(context.Context, *GatewaySendRequest) (*GatewaySendResponse, error)
	// contains filtered or unexported methods
}

GatewayServer is the server API for Gateway service. All implementations must embed UnimplementedGatewayServer for forward compatibility

type GatewayWatchRequest 

type GatewayWatchRequest struct {
	Topic  string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	Cursor string `protobuf:"bytes,2,opt,name=cursor,proto3" json:"cursor,omitempty"`
	// contains filtered or unexported fields
}

func (*GatewayWatchRequest) Descriptor deprecated 

func (*GatewayWatchRequest) Descriptor() ([]byte, []int)

Deprecated: Use GatewayWatchRequest.ProtoReflect.Descriptor instead.

func (*GatewayWatchRequest) GetCursor 

func (x *GatewayWatchRequest) GetCursor() string

func (*GatewayWatchRequest) GetTopic 

func (x *GatewayWatchRequest) GetTopic() string

func (*GatewayWatchRequest) ProtoMessage 

func (*GatewayWatchRequest) ProtoMessage()

func (*GatewayWatchRequest) ProtoReflect 

func (x *GatewayWatchRequest) ProtoReflect() protoreflect.Message

func (*GatewayWatchRequest) Reset 

func (x *GatewayWatchRequest) Reset()

func (*GatewayWatchRequest) String 

func (x *GatewayWatchRequest) String() string

type Gateway_WatchClient 

type Gateway_WatchClient interface {
	Send(*GatewayWatchRequest) error
	Recv() (*GatewayMessage, error)
	grpc.ClientStream
}

type Gateway_WatchServer 

type Gateway_WatchServer interface {
	Send(*GatewayMessage) error
	Recv() (*GatewayWatchRequest, error)
	grpc.ServerStream
}

type GiftClient 

type GiftClient interface {
	// 创建礼包
	Create(ctx context.Context, in *GiftCreateRequest, opts ...grpc.CallOption) (*GiftCreateResponse, error)
	// 撤销礼包
	Revoke(ctx context.Context, in *GiftRevokeRequest, opts ...grpc.CallOption) (*GiftRevokeResponse, error)
	// 更新礼包
	Update(ctx context.Context, in *GiftUpdateRequest, opts ...grpc.CallOption) (*GiftUpdateResponse, error)
	// 查询礼包
	Search(ctx context.Context, in *GiftSearchRequest, opts ...grpc.CallOption) (*GiftSearchResponse, error)
	// 校验礼包码
	Verify(ctx context.Context, in *GiftVerifyRequest, opts ...grpc.CallOption) (*GiftVerifyResponse, error)
	// 兑换礼包码
	Redeem(ctx context.Context, in *GiftRedeemRequest, opts ...grpc.CallOption) (*GiftRedeemResponse, error)
}

GiftClient is the client API for Gift service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewGiftClient 

func NewGiftClient(cc grpc.ClientConnInterface) GiftClient

type GiftCodeData 

type GiftCodeData struct {
	Code string `protobuf:"bytes,1,opt,name=code,proto3" json:"code,omitempty"`
	// 已兑换标记
	Redeemed bool `protobuf:"varint,2,opt,name=redeemed,proto3" json:"redeemed,omitempty"`
	// contains filtered or unexported fields
}

func (*GiftCodeData) Descriptor deprecated 

func (*GiftCodeData) Descriptor() ([]byte, []int)

Deprecated: Use GiftCodeData.ProtoReflect.Descriptor instead.

func (*GiftCodeData) GetCode 

func (x *GiftCodeData) GetCode() string

func (*GiftCodeData) GetRedeemed 

func (x *GiftCodeData) GetRedeemed() bool

func (*GiftCodeData) ProtoMessage 

func (*GiftCodeData) ProtoMessage()

func (*GiftCodeData) ProtoReflect 

func (x *GiftCodeData) ProtoReflect() protoreflect.Message

func (*GiftCodeData) Reset 

func (x *GiftCodeData) Reset()

func (*GiftCodeData) String 

func (x *GiftCodeData) String() string

type GiftCreateRequest 

type GiftCreateRequest struct {
	Data  *GiftData `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	Codes []string  `protobuf:"bytes,10,rep,name=codes,proto3" json:"codes,omitempty"`
	// contains filtered or unexported fields
}

func (*GiftCreateRequest) Descriptor deprecated 

func (*GiftCreateRequest) Descriptor() ([]byte, []int)

Deprecated: Use GiftCreateRequest.ProtoReflect.Descriptor instead.

func (*GiftCreateRequest) GetCodes 

func (x *GiftCreateRequest) GetCodes() []string

func (*GiftCreateRequest) GetData 

func (x *GiftCreateRequest) GetData() *GiftData

func (*GiftCreateRequest) ProtoMessage 

func (*GiftCreateRequest) ProtoMessage()

func (*GiftCreateRequest) ProtoReflect 

func (x *GiftCreateRequest) ProtoReflect() protoreflect.Message

func (*GiftCreateRequest) Reset 

func (x *GiftCreateRequest) Reset()

func (*GiftCreateRequest) String 

func (x *GiftCreateRequest) String() string

type GiftCreateResponse 

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

func (*GiftCreateResponse) Descriptor deprecated 

func (*GiftCreateResponse) Descriptor() ([]byte, []int)

Deprecated: Use GiftCreateResponse.ProtoReflect.Descriptor instead.

func (*GiftCreateResponse) ProtoMessage 

func (*GiftCreateResponse) ProtoMessage()

func (*GiftCreateResponse) ProtoReflect 

func (x *GiftCreateResponse) ProtoReflect() protoreflect.Message

func (*GiftCreateResponse) Reset 

func (x *GiftCreateResponse) Reset()

func (*GiftCreateResponse) String 

func (x *GiftCreateResponse) String() string

type GiftData 

type GiftData struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// 过期时间
	ExpireAt int64 `protobuf:"varint,2,opt,name=expire_at,json=expireAt,proto3" json:"expire_at,omitempty"`
	// 礼包内容
	Payload *anypb.Any `protobuf:"bytes,10,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

func (*GiftData) Descriptor deprecated 

func (*GiftData) Descriptor() ([]byte, []int)

Deprecated: Use GiftData.ProtoReflect.Descriptor instead.

func (*GiftData) GetExpireAt 

func (x *GiftData) GetExpireAt() int64

func (*GiftData) GetId 

func (x *GiftData) GetId() string

func (*GiftData) GetPayload 

func (x *GiftData) GetPayload() *anypb.Any

func (*GiftData) ProtoMessage 

func (*GiftData) ProtoMessage()

func (*GiftData) ProtoReflect 

func (x *GiftData) ProtoReflect() protoreflect.Message

func (*GiftData) Reset 

func (x *GiftData) Reset()

func (*GiftData) String 

func (x *GiftData) String() string

type GiftListRequest 

type GiftListRequest struct {

	// 不填则返回所有礼包信息，但不返回礼包码(太大了)
	// 填了只返回单个礼包信息，且返回礼包码
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*GiftListRequest) Descriptor deprecated 

func (*GiftListRequest) Descriptor() ([]byte, []int)

Deprecated: Use GiftListRequest.ProtoReflect.Descriptor instead.

func (*GiftListRequest) GetId 

func (x *GiftListRequest) GetId() string

func (*GiftListRequest) ProtoMessage 

func (*GiftListRequest) ProtoMessage()

func (*GiftListRequest) ProtoReflect 

func (x *GiftListRequest) ProtoReflect() protoreflect.Message

func (*GiftListRequest) Reset 

func (x *GiftListRequest) Reset()

func (*GiftListRequest) String 

func (x *GiftListRequest) String() string

type GiftListResponse 

type GiftListResponse struct {
	List []*GiftListResponse_Entry `protobuf:"bytes,1,rep,name=list,proto3" json:"list,omitempty"`
	// contains filtered or unexported fields
}

func (*GiftListResponse) Descriptor deprecated 

func (*GiftListResponse) Descriptor() ([]byte, []int)

Deprecated: Use GiftListResponse.ProtoReflect.Descriptor instead.

func (*GiftListResponse) GetList 

func (x *GiftListResponse) GetList() []*GiftListResponse_Entry

func (*GiftListResponse) ProtoMessage 

func (*GiftListResponse) ProtoMessage()

func (*GiftListResponse) ProtoReflect 

func (x *GiftListResponse) ProtoReflect() protoreflect.Message

func (*GiftListResponse) Reset 

func (x *GiftListResponse) Reset()

func (*GiftListResponse) String 

func (x *GiftListResponse) String() string

type GiftListResponse_Entry 

type GiftListResponse_Entry struct {
	Data *GiftData `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// 只有指定礼包查询才返回
	Codes []string `protobuf:"bytes,2,rep,name=codes,proto3" json:"codes,omitempty"`
	// contains filtered or unexported fields
}

func (*GiftListResponse_Entry) Descriptor deprecated 

func (*GiftListResponse_Entry) Descriptor() ([]byte, []int)

Deprecated: Use GiftListResponse_Entry.ProtoReflect.Descriptor instead.

func (*GiftListResponse_Entry) GetCodes 

func (x *GiftListResponse_Entry) GetCodes() []string

func (*GiftListResponse_Entry) GetData 

func (x *GiftListResponse_Entry) GetData() *GiftData

func (*GiftListResponse_Entry) ProtoMessage 

func (*GiftListResponse_Entry) ProtoMessage()

func (*GiftListResponse_Entry) ProtoReflect 

func (x *GiftListResponse_Entry) ProtoReflect() protoreflect.Message

func (*GiftListResponse_Entry) Reset 

func (x *GiftListResponse_Entry) Reset()

func (*GiftListResponse_Entry) String 

func (x *GiftListResponse_Entry) String() string

type GiftRedeemRequest 

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

func (*GiftRedeemRequest) Descriptor deprecated 

func (*GiftRedeemRequest) Descriptor() ([]byte, []int)

Deprecated: Use GiftRedeemRequest.ProtoReflect.Descriptor instead.

func (*GiftRedeemRequest) GetCode 

func (x *GiftRedeemRequest) GetCode() string

func (*GiftRedeemRequest) ProtoMessage 

func (*GiftRedeemRequest) ProtoMessage()

func (*GiftRedeemRequest) ProtoReflect 

func (x *GiftRedeemRequest) ProtoReflect() protoreflect.Message

func (*GiftRedeemRequest) Reset 

func (x *GiftRedeemRequest) Reset()

func (*GiftRedeemRequest) String 

func (x *GiftRedeemRequest) String() string

type GiftRedeemResponse 

type GiftRedeemResponse struct {
	Data *GiftData `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*GiftRedeemResponse) Descriptor deprecated 

func (*GiftRedeemResponse) Descriptor() ([]byte, []int)

Deprecated: Use GiftRedeemResponse.ProtoReflect.Descriptor instead.

func (*GiftRedeemResponse) GetData 

func (x *GiftRedeemResponse) GetData() *GiftData

func (*GiftRedeemResponse) ProtoMessage 

func (*GiftRedeemResponse) ProtoMessage()

func (*GiftRedeemResponse) ProtoReflect 

func (x *GiftRedeemResponse) ProtoReflect() protoreflect.Message

func (*GiftRedeemResponse) Reset 

func (x *GiftRedeemResponse) Reset()

func (*GiftRedeemResponse) String 

func (x *GiftRedeemResponse) String() string

type GiftRevokeRequest 

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

func (*GiftRevokeRequest) Descriptor deprecated 

func (*GiftRevokeRequest) Descriptor() ([]byte, []int)

Deprecated: Use GiftRevokeRequest.ProtoReflect.Descriptor instead.

func (*GiftRevokeRequest) GetId 

func (x *GiftRevokeRequest) GetId() string

func (*GiftRevokeRequest) ProtoMessage 

func (*GiftRevokeRequest) ProtoMessage()

func (*GiftRevokeRequest) ProtoReflect 

func (x *GiftRevokeRequest) ProtoReflect() protoreflect.Message

func (*GiftRevokeRequest) Reset 

func (x *GiftRevokeRequest) Reset()

func (*GiftRevokeRequest) String 

func (x *GiftRevokeRequest) String() string

type GiftRevokeResponse 

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

func (*GiftRevokeResponse) Descriptor deprecated 

func (*GiftRevokeResponse) Descriptor() ([]byte, []int)

Deprecated: Use GiftRevokeResponse.ProtoReflect.Descriptor instead.

func (*GiftRevokeResponse) ProtoMessage 

func (*GiftRevokeResponse) ProtoMessage()

func (*GiftRevokeResponse) ProtoReflect 

func (x *GiftRevokeResponse) ProtoReflect() protoreflect.Message

func (*GiftRevokeResponse) Reset 

func (x *GiftRevokeResponse) Reset()

func (*GiftRevokeResponse) String 

func (x *GiftRevokeResponse) String() string

type GiftSearchRequest 

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

按顺序判定： 指定礼包ID 返回礼包信息和其中的礼包码 指定礼包码 返回所属礼包信息(没有礼包码) 都不指定 返回所有礼包信息(没有礼包码)

func (*GiftSearchRequest) Descriptor deprecated 

func (*GiftSearchRequest) Descriptor() ([]byte, []int)

Deprecated: Use GiftSearchRequest.ProtoReflect.Descriptor instead.

func (*GiftSearchRequest) GetCode 

func (x *GiftSearchRequest) GetCode() string

func (*GiftSearchRequest) GetId 

func (x *GiftSearchRequest) GetId() string

func (*GiftSearchRequest) ProtoMessage 

func (*GiftSearchRequest) ProtoMessage()

func (*GiftSearchRequest) ProtoReflect 

func (x *GiftSearchRequest) ProtoReflect() protoreflect.Message

func (*GiftSearchRequest) Reset 

func (x *GiftSearchRequest) Reset()

func (*GiftSearchRequest) String 

func (x *GiftSearchRequest) String() string

type GiftSearchResponse 

type GiftSearchResponse struct {
	List []*GiftSearchResponse_Entry `protobuf:"bytes,1,rep,name=list,proto3" json:"list,omitempty"`
	// contains filtered or unexported fields
}

func (*GiftSearchResponse) Descriptor deprecated 

func (*GiftSearchResponse) Descriptor() ([]byte, []int)

Deprecated: Use GiftSearchResponse.ProtoReflect.Descriptor instead.

func (*GiftSearchResponse) GetList 

func (x *GiftSearchResponse) GetList() []*GiftSearchResponse_Entry

func (*GiftSearchResponse) ProtoMessage 

func (*GiftSearchResponse) ProtoMessage()

func (*GiftSearchResponse) ProtoReflect 

func (x *GiftSearchResponse) ProtoReflect() protoreflect.Message

func (*GiftSearchResponse) Reset 

func (x *GiftSearchResponse) Reset()

func (*GiftSearchResponse) String 

func (x *GiftSearchResponse) String() string

type GiftSearchResponse_Entry 

type GiftSearchResponse_Entry struct {
	Data  *GiftData       `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	Codes []*GiftCodeData `protobuf:"bytes,2,rep,name=codes,proto3" json:"codes,omitempty"`
	// contains filtered or unexported fields
}

func (*GiftSearchResponse_Entry) Descriptor deprecated 

func (*GiftSearchResponse_Entry) Descriptor() ([]byte, []int)

Deprecated: Use GiftSearchResponse_Entry.ProtoReflect.Descriptor instead.

func (*GiftSearchResponse_Entry) GetCodes 

func (x *GiftSearchResponse_Entry) GetCodes() []*GiftCodeData

func (*GiftSearchResponse_Entry) GetData 

func (x *GiftSearchResponse_Entry) GetData() *GiftData

func (*GiftSearchResponse_Entry) ProtoMessage 

func (*GiftSearchResponse_Entry) ProtoMessage()

func (*GiftSearchResponse_Entry) ProtoReflect 

func (x *GiftSearchResponse_Entry) ProtoReflect() protoreflect.Message

func (*GiftSearchResponse_Entry) Reset 

func (x *GiftSearchResponse_Entry) Reset()

func (*GiftSearchResponse_Entry) String 

func (x *GiftSearchResponse_Entry) String() string

type GiftServer 

type GiftServer interface {
	// 创建礼包
	Create(context.Context, *GiftCreateRequest) (*GiftCreateResponse, error)
	// 撤销礼包
	Revoke(context.Context, *GiftRevokeRequest) (*GiftRevokeResponse, error)
	// 更新礼包
	Update(context.Context, *GiftUpdateRequest) (*GiftUpdateResponse, error)
	// 查询礼包
	Search(context.Context, *GiftSearchRequest) (*GiftSearchResponse, error)
	// 校验礼包码
	Verify(context.Context, *GiftVerifyRequest) (*GiftVerifyResponse, error)
	// 兑换礼包码
	Redeem(context.Context, *GiftRedeemRequest) (*GiftRedeemResponse, error)
	// contains filtered or unexported methods
}

GiftServer is the server API for Gift service. All implementations must embed UnimplementedGiftServer for forward compatibility

type GiftUpdateRequest 

type GiftUpdateRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// id被忽略，以上面的id为准
	Data *GiftData `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// 向礼包中增加新的礼包码
	// 与已有礼包码重复的会被忽略，但会回复AlreadyExists，
	// 不与已有礼包码重复的会添加，且不因为AlreadyExists而中断。
	CodesToAdd []string `protobuf:"bytes,13,rep,name=codes_to_add,json=codesToAdd,proto3" json:"codes_to_add,omitempty"`
	// 删除礼包码，会在add之前执行
	CodesToDel []string `protobuf:"bytes,14,rep,name=codes_to_del,json=codesToDel,proto3" json:"codes_to_del,omitempty"`
	// contains filtered or unexported fields
}

func (*GiftUpdateRequest) Descriptor deprecated 

func (*GiftUpdateRequest) Descriptor() ([]byte, []int)

Deprecated: Use GiftUpdateRequest.ProtoReflect.Descriptor instead.

func (*GiftUpdateRequest) GetCodesToAdd 

func (x *GiftUpdateRequest) GetCodesToAdd() []string

func (*GiftUpdateRequest) GetCodesToDel 

func (x *GiftUpdateRequest) GetCodesToDel() []string

func (*GiftUpdateRequest) GetData 

func (x *GiftUpdateRequest) GetData() *GiftData

func (*GiftUpdateRequest) GetId 

func (x *GiftUpdateRequest) GetId() string

func (*GiftUpdateRequest) ProtoMessage 

func (*GiftUpdateRequest) ProtoMessage()

func (*GiftUpdateRequest) ProtoReflect 

func (x *GiftUpdateRequest) ProtoReflect() protoreflect.Message

func (*GiftUpdateRequest) Reset 

func (x *GiftUpdateRequest) Reset()

func (*GiftUpdateRequest) String 

func (x *GiftUpdateRequest) String() string

type GiftUpdateResponse 

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

func (*GiftUpdateResponse) Descriptor deprecated 

func (*GiftUpdateResponse) Descriptor() ([]byte, []int)

Deprecated: Use GiftUpdateResponse.ProtoReflect.Descriptor instead.

func (*GiftUpdateResponse) ProtoMessage 

func (*GiftUpdateResponse) ProtoMessage()

func (*GiftUpdateResponse) ProtoReflect 

func (x *GiftUpdateResponse) ProtoReflect() protoreflect.Message

func (*GiftUpdateResponse) Reset 

func (x *GiftUpdateResponse) Reset()

func (*GiftUpdateResponse) String 

func (x *GiftUpdateResponse) String() string

type GiftVerifyRequest 

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

func (*GiftVerifyRequest) Descriptor deprecated 

func (*GiftVerifyRequest) Descriptor() ([]byte, []int)

Deprecated: Use GiftVerifyRequest.ProtoReflect.Descriptor instead.

func (*GiftVerifyRequest) GetCode 

func (x *GiftVerifyRequest) GetCode() string

func (*GiftVerifyRequest) ProtoMessage 

func (*GiftVerifyRequest) ProtoMessage()

func (*GiftVerifyRequest) ProtoReflect 

func (x *GiftVerifyRequest) ProtoReflect() protoreflect.Message

func (*GiftVerifyRequest) Reset 

func (x *GiftVerifyRequest) Reset()

func (*GiftVerifyRequest) String 

func (x *GiftVerifyRequest) String() string

type GiftVerifyResponse 

type GiftVerifyResponse struct {
	Data *GiftData `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*GiftVerifyResponse) Descriptor deprecated 

func (*GiftVerifyResponse) Descriptor() ([]byte, []int)

Deprecated: Use GiftVerifyResponse.ProtoReflect.Descriptor instead.

func (*GiftVerifyResponse) GetData 

func (x *GiftVerifyResponse) GetData() *GiftData

func (*GiftVerifyResponse) ProtoMessage 

func (*GiftVerifyResponse) ProtoMessage()

func (*GiftVerifyResponse) ProtoReflect 

func (x *GiftVerifyResponse) ProtoReflect() protoreflect.Message

func (*GiftVerifyResponse) Reset 

func (x *GiftVerifyResponse) Reset()

func (*GiftVerifyResponse) String 

func (x *GiftVerifyResponse) String() string

type LeaderboardClient 

type LeaderboardClient interface {
	// set entries
	Set(ctx context.Context, in *LeaderboardSetRequest, opts ...grpc.CallOption) (*LeaderboardSetResponse, error)
	// set entry info by id
	SetInfo(ctx context.Context, in *LeaderboardSetInfoRequest, opts ...grpc.CallOption) (*LeaderboardSetInfoResponse, error)
	// get entries by rank
	GetByRank(ctx context.Context, in *LeaderboardGetByRankRequest, opts ...grpc.CallOption) (*LeaderboardGetByRankResponse, error)
	// get entries by id
	GetById(ctx context.Context, in *LeaderboardGetByIdRequest, opts ...grpc.CallOption) (*LeaderboardGetByIdResponse, error)
	// random entries by score
	GetByScore(ctx context.Context, in *LeaderboardGetByScoreRequest, opts ...grpc.CallOption) (*LeaderboardGetByScoreResponse, error)
	// remove entries by id
	RemoveById(ctx context.Context, in *LeaderboardRemoveByIdRequest, opts ...grpc.CallOption) (*LeaderboardRemoveByIdResponse, error)
	// only update metadata of chart
	Touch(ctx context.Context, in *LeaderboardTouchRequest, opts ...grpc.CallOption) (*LeaderboardTouchResponse, error)
	// deprecated, will be removed later
	SetScore(ctx context.Context, in *LeaderboardSetScoreRequest, opts ...grpc.CallOption) (*LeaderboardSetScoreResponse, error)
	// deprecated, will be removed later
	GetRange(ctx context.Context, in *LeaderboardGetRangeRequest, opts ...grpc.CallOption) (*LeaderboardGetRangeResponse, error)
}

LeaderboardClient is the client API for Leaderboard service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewLeaderboardClient 

func NewLeaderboardClient(cc grpc.ClientConnInterface) LeaderboardClient

type LeaderboardGetByIdRequest 

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
}

func (*LeaderboardGetByIdRequest) Descriptor deprecated 

func (*LeaderboardGetByIdRequest) Descriptor() ([]byte, []int)

Deprecated: Use LeaderboardGetByIdRequest.ProtoReflect.Descriptor instead.

func (*LeaderboardGetByIdRequest) GetIds 

func (x *LeaderboardGetByIdRequest) GetIds() []string

func (*LeaderboardGetByIdRequest) GetKey 

func (x *LeaderboardGetByIdRequest) GetKey() *ChartKey

func (*LeaderboardGetByIdRequest) GetOptions 

func (x *LeaderboardGetByIdRequest) GetOptions() *ChartOptions

func (*LeaderboardGetByIdRequest) ProtoMessage 

func (*LeaderboardGetByIdRequest) ProtoMessage()

func (*LeaderboardGetByIdRequest) ProtoReflect 

func (x *LeaderboardGetByIdRequest) ProtoReflect() protoreflect.Message

func (*LeaderboardGetByIdRequest) Reset 

func (x *LeaderboardGetByIdRequest) Reset()

func (*LeaderboardGetByIdRequest) String 

func (x *LeaderboardGetByIdRequest) String() string

type LeaderboardGetByIdResponse 

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

func (*LeaderboardGetByIdResponse) Descriptor deprecated 

func (*LeaderboardGetByIdResponse) Descriptor() ([]byte, []int)

Deprecated: Use LeaderboardGetByIdResponse.ProtoReflect.Descriptor instead.

func (*LeaderboardGetByIdResponse) GetEntries 

func (x *LeaderboardGetByIdResponse) GetEntries() []*ChartEntry

func (*LeaderboardGetByIdResponse) ProtoMessage 

func (*LeaderboardGetByIdResponse) ProtoMessage()

func (*LeaderboardGetByIdResponse) ProtoReflect 

func (x *LeaderboardGetByIdResponse) ProtoReflect() protoreflect.Message

func (*LeaderboardGetByIdResponse) Reset 

func (x *LeaderboardGetByIdResponse) Reset()

func (*LeaderboardGetByIdResponse) String 

func (x *LeaderboardGetByIdResponse) String() string

type LeaderboardGetByRankRequest 

type LeaderboardGetByRankRequest 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
}

func (*LeaderboardGetByRankRequest) Descriptor deprecated 

func (*LeaderboardGetByRankRequest) Descriptor() ([]byte, []int)

Deprecated: Use LeaderboardGetByRankRequest.ProtoReflect.Descriptor instead.

func (*LeaderboardGetByRankRequest) GetCount 

func (x *LeaderboardGetByRankRequest) GetCount() int32

func (*LeaderboardGetByRankRequest) GetKey 

func (x *LeaderboardGetByRankRequest) GetKey() *ChartKey

func (*LeaderboardGetByRankRequest) GetOffset 

func (x *LeaderboardGetByRankRequest) GetOffset() int32

func (*LeaderboardGetByRankRequest) GetOptions 

func (x *LeaderboardGetByRankRequest) GetOptions() *ChartOptions

func (*LeaderboardGetByRankRequest) ProtoMessage 

func (*LeaderboardGetByRankRequest) ProtoMessage()

func (*LeaderboardGetByRankRequest) ProtoReflect 

func (x *LeaderboardGetByRankRequest) ProtoReflect() protoreflect.Message

func (*LeaderboardGetByRankRequest) Reset 

func (x *LeaderboardGetByRankRequest) Reset()

func (*LeaderboardGetByRankRequest) String 

func (x *LeaderboardGetByRankRequest) String() string

type LeaderboardGetByRankResponse 

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

func (*LeaderboardGetByRankResponse) Descriptor deprecated 

func (*LeaderboardGetByRankResponse) Descriptor() ([]byte, []int)

Deprecated: Use LeaderboardGetByRankResponse.ProtoReflect.Descriptor instead.

func (*LeaderboardGetByRankResponse) GetEntries 

func (x *LeaderboardGetByRankResponse) GetEntries() []*ChartEntry

func (*LeaderboardGetByRankResponse) ProtoMessage 

func (*LeaderboardGetByRankResponse) ProtoMessage()

func (*LeaderboardGetByRankResponse) ProtoReflect 

func (x *LeaderboardGetByRankResponse) ProtoReflect() protoreflect.Message

func (*LeaderboardGetByRankResponse) Reset 

func (x *LeaderboardGetByRankResponse) Reset()

func (*LeaderboardGetByRankResponse) String 

func (x *LeaderboardGetByRankResponse) String() string

type LeaderboardGetByScoreRequest 

type LeaderboardGetByScoreRequest struct {
	Intervals []*LeaderboardGetByScoreRequest_Interval `protobuf:"bytes,1,rep,name=intervals,proto3" json:"intervals,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
}

func (*LeaderboardGetByScoreRequest) Descriptor deprecated 

func (*LeaderboardGetByScoreRequest) Descriptor() ([]byte, []int)

Deprecated: Use LeaderboardGetByScoreRequest.ProtoReflect.Descriptor instead.

func (*LeaderboardGetByScoreRequest) GetIntervals 

func (x *LeaderboardGetByScoreRequest) GetIntervals() []*LeaderboardGetByScoreRequest_Interval

func (*LeaderboardGetByScoreRequest) GetKey 

func (x *LeaderboardGetByScoreRequest) GetKey() *ChartKey

func (*LeaderboardGetByScoreRequest) GetOptions 

func (x *LeaderboardGetByScoreRequest) GetOptions() *ChartOptions

func (*LeaderboardGetByScoreRequest) ProtoMessage 

func (*LeaderboardGetByScoreRequest) ProtoMessage()

func (*LeaderboardGetByScoreRequest) ProtoReflect 

func (x *LeaderboardGetByScoreRequest) ProtoReflect() protoreflect.Message

func (*LeaderboardGetByScoreRequest) Reset 

func (x *LeaderboardGetByScoreRequest) Reset()

func (*LeaderboardGetByScoreRequest) String 

func (x *LeaderboardGetByScoreRequest) String() string

type LeaderboardGetByScoreRequest_Interval 

type LeaderboardGetByScoreRequest_Interval struct {
	Min   int64  `protobuf:"varint,1,opt,name=min,proto3" json:"min,omitempty"`
	Max   int64  `protobuf:"varint,2,opt,name=max,proto3" json:"max,omitempty"`
	Count uint32 `protobuf:"varint,3,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

func (*LeaderboardGetByScoreRequest_Interval) Descriptor deprecated 

func (*LeaderboardGetByScoreRequest_Interval) Descriptor() ([]byte, []int)

Deprecated: Use LeaderboardGetByScoreRequest_Interval.ProtoReflect.Descriptor instead.

func (*LeaderboardGetByScoreRequest_Interval) GetCount 

func (x *LeaderboardGetByScoreRequest_Interval) GetCount() uint32

func (*LeaderboardGetByScoreRequest_Interval) GetMax 

func (x *LeaderboardGetByScoreRequest_Interval) GetMax() int64

func (*LeaderboardGetByScoreRequest_Interval) GetMin 

func (x *LeaderboardGetByScoreRequest_Interval) GetMin() int64

func (*LeaderboardGetByScoreRequest_Interval) ProtoMessage 

func (*LeaderboardGetByScoreRequest_Interval) ProtoMessage()

func (*LeaderboardGetByScoreRequest_Interval) ProtoReflect 

func (x *LeaderboardGetByScoreRequest_Interval) ProtoReflect() protoreflect.Message

func (*LeaderboardGetByScoreRequest_Interval) Reset 

func (x *LeaderboardGetByScoreRequest_Interval) Reset()

func (*LeaderboardGetByScoreRequest_Interval) String 

func (x *LeaderboardGetByScoreRequest_Interval) String() string

type LeaderboardGetByScoreResponse 

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

func (*LeaderboardGetByScoreResponse) Descriptor deprecated 

func (*LeaderboardGetByScoreResponse) Descriptor() ([]byte, []int)

Deprecated: Use LeaderboardGetByScoreResponse.ProtoReflect.Descriptor instead.

func (*LeaderboardGetByScoreResponse) GetEntries 

func (x *LeaderboardGetByScoreResponse) GetEntries() []*ChartEntry

func (*LeaderboardGetByScoreResponse) ProtoMessage 

func (*LeaderboardGetByScoreResponse) ProtoMessage()

func (*LeaderboardGetByScoreResponse) ProtoReflect 

func (x *LeaderboardGetByScoreResponse) ProtoReflect() protoreflect.Message

func (*LeaderboardGetByScoreResponse) Reset 

func (x *LeaderboardGetByScoreResponse) Reset()

func (*LeaderboardGetByScoreResponse) String 

func (x *LeaderboardGetByScoreResponse) String() string

type LeaderboardGetRangeRequest 

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
}

deprecated, will be removed later

func (*LeaderboardGetRangeRequest) Descriptor deprecated 

func (*LeaderboardGetRangeRequest) Descriptor() ([]byte, []int)

Deprecated: Use LeaderboardGetRangeRequest.ProtoReflect.Descriptor instead.

func (*LeaderboardGetRangeRequest) GetCount 

func (x *LeaderboardGetRangeRequest) GetCount() int32

func (*LeaderboardGetRangeRequest) GetKey 

func (x *LeaderboardGetRangeRequest) GetKey() *ChartKey

func (*LeaderboardGetRangeRequest) GetOffset 

func (x *LeaderboardGetRangeRequest) GetOffset() int32

func (*LeaderboardGetRangeRequest) GetOptions 

func (x *LeaderboardGetRangeRequest) GetOptions() *ChartOptions

func (*LeaderboardGetRangeRequest) ProtoMessage 

func (*LeaderboardGetRangeRequest) ProtoMessage()

func (*LeaderboardGetRangeRequest) ProtoReflect 

func (x *LeaderboardGetRangeRequest) ProtoReflect() protoreflect.Message

func (*LeaderboardGetRangeRequest) Reset 

func (x *LeaderboardGetRangeRequest) Reset()

func (*LeaderboardGetRangeRequest) String 

func (x *LeaderboardGetRangeRequest) String() string

type LeaderboardGetRangeResponse 

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

deprecated, will be removed later

func (*LeaderboardGetRangeResponse) Descriptor deprecated 

func (*LeaderboardGetRangeResponse) Descriptor() ([]byte, []int)

Deprecated: Use LeaderboardGetRangeResponse.ProtoReflect.Descriptor instead.

func (*LeaderboardGetRangeResponse) GetEntries 

func (x *LeaderboardGetRangeResponse) GetEntries() []*ChartEntry

func (*LeaderboardGetRangeResponse) ProtoMessage 

func (*LeaderboardGetRangeResponse) ProtoMessage()

func (*LeaderboardGetRangeResponse) ProtoReflect 

func (x *LeaderboardGetRangeResponse) ProtoReflect() protoreflect.Message

func (*LeaderboardGetRangeResponse) Reset 

func (x *LeaderboardGetRangeResponse) Reset()

func (*LeaderboardGetRangeResponse) String 

func (x *LeaderboardGetRangeResponse) String() string

type LeaderboardRemoveByIdRequest 

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
}

func (*LeaderboardRemoveByIdRequest) Descriptor deprecated 

func (*LeaderboardRemoveByIdRequest) Descriptor() ([]byte, []int)

Deprecated: Use LeaderboardRemoveByIdRequest.ProtoReflect.Descriptor instead.

func (*LeaderboardRemoveByIdRequest) GetIds 

func (x *LeaderboardRemoveByIdRequest) GetIds() []string

func (*LeaderboardRemoveByIdRequest) GetKey 

func (x *LeaderboardRemoveByIdRequest) GetKey() *ChartKey

func (*LeaderboardRemoveByIdRequest) GetOptions 

func (x *LeaderboardRemoveByIdRequest) GetOptions() *ChartOptions

func (*LeaderboardRemoveByIdRequest) ProtoMessage 

func (*LeaderboardRemoveByIdRequest) ProtoMessage()

func (*LeaderboardRemoveByIdRequest) ProtoReflect 

func (x *LeaderboardRemoveByIdRequest) ProtoReflect() protoreflect.Message

func (*LeaderboardRemoveByIdRequest) Reset 

func (x *LeaderboardRemoveByIdRequest) Reset()

func (*LeaderboardRemoveByIdRequest) String 

func (x *LeaderboardRemoveByIdRequest) String() string

type LeaderboardRemoveByIdResponse 

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

func (*LeaderboardRemoveByIdResponse) Descriptor deprecated 

func (*LeaderboardRemoveByIdResponse) Descriptor() ([]byte, []int)

Deprecated: Use LeaderboardRemoveByIdResponse.ProtoReflect.Descriptor instead.

func (*LeaderboardRemoveByIdResponse) ProtoMessage 

func (*LeaderboardRemoveByIdResponse) ProtoMessage()

func (*LeaderboardRemoveByIdResponse) ProtoReflect 

func (x *LeaderboardRemoveByIdResponse) ProtoReflect() protoreflect.Message

func (*LeaderboardRemoveByIdResponse) Reset 

func (x *LeaderboardRemoveByIdResponse) Reset()

func (*LeaderboardRemoveByIdResponse) String 

func (x *LeaderboardRemoveByIdResponse) String() string

type LeaderboardServer 

type LeaderboardServer interface {
	// set entries
	Set(context.Context, *LeaderboardSetRequest) (*LeaderboardSetResponse, error)
	// set entry info by id
	SetInfo(context.Context, *LeaderboardSetInfoRequest) (*LeaderboardSetInfoResponse, error)
	// get entries by rank
	GetByRank(context.Context, *LeaderboardGetByRankRequest) (*LeaderboardGetByRankResponse, error)
	// get entries by id
	GetById(context.Context, *LeaderboardGetByIdRequest) (*LeaderboardGetByIdResponse, error)
	// random entries by score
	GetByScore(context.Context, *LeaderboardGetByScoreRequest) (*LeaderboardGetByScoreResponse, error)
	// remove entries by id
	RemoveById(context.Context, *LeaderboardRemoveByIdRequest) (*LeaderboardRemoveByIdResponse, error)
	// only update metadata of chart
	Touch(context.Context, *LeaderboardTouchRequest) (*LeaderboardTouchResponse, error)
	// deprecated, will be removed later
	SetScore(context.Context, *LeaderboardSetScoreRequest) (*LeaderboardSetScoreResponse, error)
	// deprecated, will be removed later
	GetRange(context.Context, *LeaderboardGetRangeRequest) (*LeaderboardGetRangeResponse, error)
	// contains filtered or unexported methods
}

LeaderboardServer is the server API for Leaderboard service. All implementations must embed UnimplementedLeaderboardServer for forward compatibility

type LeaderboardSetInfoRequest 

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
}

func (*LeaderboardSetInfoRequest) Descriptor deprecated 

func (*LeaderboardSetInfoRequest) Descriptor() ([]byte, []int)

Deprecated: Use LeaderboardSetInfoRequest.ProtoReflect.Descriptor instead.

func (*LeaderboardSetInfoRequest) GetEntries 

func (x *LeaderboardSetInfoRequest) GetEntries() []*ChartEntry

func (*LeaderboardSetInfoRequest) GetKey 

func (x *LeaderboardSetInfoRequest) GetKey() *ChartKey

func (*LeaderboardSetInfoRequest) GetOptions 

func (x *LeaderboardSetInfoRequest) GetOptions() *ChartOptions

func (*LeaderboardSetInfoRequest) ProtoMessage 

func (*LeaderboardSetInfoRequest) ProtoMessage()

func (*LeaderboardSetInfoRequest) ProtoReflect 

func (x *LeaderboardSetInfoRequest) ProtoReflect() protoreflect.Message

func (*LeaderboardSetInfoRequest) Reset 

func (x *LeaderboardSetInfoRequest) Reset()

func (*LeaderboardSetInfoRequest) String 

func (x *LeaderboardSetInfoRequest) String() string

type LeaderboardSetInfoResponse 

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

func (*LeaderboardSetInfoResponse) Descriptor deprecated 

func (*LeaderboardSetInfoResponse) Descriptor() ([]byte, []int)

Deprecated: Use LeaderboardSetInfoResponse.ProtoReflect.Descriptor instead.

func (*LeaderboardSetInfoResponse) ProtoMessage 

func (*LeaderboardSetInfoResponse) ProtoMessage()

func (*LeaderboardSetInfoResponse) ProtoReflect 

func (x *LeaderboardSetInfoResponse) ProtoReflect() protoreflect.Message

func (*LeaderboardSetInfoResponse) Reset 

func (x *LeaderboardSetInfoResponse) Reset()

func (*LeaderboardSetInfoResponse) String 

func (x *LeaderboardSetInfoResponse) String() string

type LeaderboardSetRequest 

type LeaderboardSetRequest struct {
	Entries    []*ChartEntry `protobuf:"bytes,1,rep,name=entries,proto3" json:"entries,omitempty"`
	OnlyAdd    bool          `protobuf:"varint,4,opt,name=only_add,json=onlyAdd,proto3" json:"only_add,omitempty"`
	OnlyUpdate bool          `protobuf:"varint,5,opt,name=only_update,json=onlyUpdate,proto3" json:"only_update,omitempty"`
	IncrBy     bool          `protobuf:"varint,6,opt,name=incr_by,json=incrBy,proto3" json:"incr_by,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
}

func (*LeaderboardSetRequest) Descriptor deprecated 

func (*LeaderboardSetRequest) Descriptor() ([]byte, []int)

Deprecated: Use LeaderboardSetRequest.ProtoReflect.Descriptor instead.

func (*LeaderboardSetRequest) GetEntries 

func (x *LeaderboardSetRequest) GetEntries() []*ChartEntry

func (*LeaderboardSetRequest) GetIncrBy 

func (x *LeaderboardSetRequest) GetIncrBy() bool

func (*LeaderboardSetRequest) GetKey 

func (x *LeaderboardSetRequest) GetKey() *ChartKey

func (*LeaderboardSetRequest) GetOnlyAdd 

func (x *LeaderboardSetRequest) GetOnlyAdd() bool

func (*LeaderboardSetRequest) GetOnlyUpdate 

func (x *LeaderboardSetRequest) GetOnlyUpdate() bool

func (*LeaderboardSetRequest) GetOptions 

func (x *LeaderboardSetRequest) GetOptions() *ChartOptions

func (*LeaderboardSetRequest) ProtoMessage 

func (*LeaderboardSetRequest) ProtoMessage()

func (*LeaderboardSetRequest) ProtoReflect 

func (x *LeaderboardSetRequest) ProtoReflect() protoreflect.Message

func (*LeaderboardSetRequest) Reset 

func (x *LeaderboardSetRequest) Reset()

func (*LeaderboardSetRequest) String 

func (x *LeaderboardSetRequest) String() string

type LeaderboardSetResponse 

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

func (*LeaderboardSetResponse) Descriptor deprecated 

func (*LeaderboardSetResponse) Descriptor() ([]byte, []int)

Deprecated: Use LeaderboardSetResponse.ProtoReflect.Descriptor instead.

func (*LeaderboardSetResponse) GetEntries 

func (x *LeaderboardSetResponse) GetEntries() []*ChartEntry

func (*LeaderboardSetResponse) ProtoMessage 

func (*LeaderboardSetResponse) ProtoMessage()

func (*LeaderboardSetResponse) ProtoReflect 

func (x *LeaderboardSetResponse) ProtoReflect() protoreflect.Message

func (*LeaderboardSetResponse) Reset 

func (x *LeaderboardSetResponse) Reset()

func (*LeaderboardSetResponse) String 

func (x *LeaderboardSetResponse) String() string

type LeaderboardSetScoreRequest 

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
}

deprecated, will be removed later

func (*LeaderboardSetScoreRequest) Descriptor deprecated 

func (*LeaderboardSetScoreRequest) Descriptor() ([]byte, []int)

Deprecated: Use LeaderboardSetScoreRequest.ProtoReflect.Descriptor instead.

func (*LeaderboardSetScoreRequest) GetEntries 

func (x *LeaderboardSetScoreRequest) GetEntries() []*ChartEntry

func (*LeaderboardSetScoreRequest) GetKey 

func (x *LeaderboardSetScoreRequest) GetKey() *ChartKey

func (*LeaderboardSetScoreRequest) GetOptions 

func (x *LeaderboardSetScoreRequest) GetOptions() *ChartOptions

func (*LeaderboardSetScoreRequest) ProtoMessage 

func (*LeaderboardSetScoreRequest) ProtoMessage()

func (*LeaderboardSetScoreRequest) ProtoReflect 

func (x *LeaderboardSetScoreRequest) ProtoReflect() protoreflect.Message

func (*LeaderboardSetScoreRequest) Reset 

func (x *LeaderboardSetScoreRequest) Reset()

func (*LeaderboardSetScoreRequest) String 

func (x *LeaderboardSetScoreRequest) String() string

type LeaderboardSetScoreResponse 

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

deprecated, will be removed later

func (*LeaderboardSetScoreResponse) Descriptor deprecated 

func (*LeaderboardSetScoreResponse) Descriptor() ([]byte, []int)

Deprecated: Use LeaderboardSetScoreResponse.ProtoReflect.Descriptor instead.

func (*LeaderboardSetScoreResponse) ProtoMessage 

func (*LeaderboardSetScoreResponse) ProtoMessage()

func (*LeaderboardSetScoreResponse) ProtoReflect 

func (x *LeaderboardSetScoreResponse) ProtoReflect() protoreflect.Message

func (*LeaderboardSetScoreResponse) Reset 

func (x *LeaderboardSetScoreResponse) Reset()

func (*LeaderboardSetScoreResponse) String 

func (x *LeaderboardSetScoreResponse) String() string

type LeaderboardTouchRequest 

type LeaderboardTouchRequest struct {
	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
}

func (*LeaderboardTouchRequest) Descriptor deprecated 

func (*LeaderboardTouchRequest) Descriptor() ([]byte, []int)

Deprecated: Use LeaderboardTouchRequest.ProtoReflect.Descriptor instead.

func (*LeaderboardTouchRequest) GetKey 

func (x *LeaderboardTouchRequest) GetKey() *ChartKey

func (*LeaderboardTouchRequest) GetOptions 

func (x *LeaderboardTouchRequest) GetOptions() *ChartOptions

func (*LeaderboardTouchRequest) ProtoMessage 

func (*LeaderboardTouchRequest) ProtoMessage()

func (*LeaderboardTouchRequest) ProtoReflect 

func (x *LeaderboardTouchRequest) ProtoReflect() protoreflect.Message

func (*LeaderboardTouchRequest) Reset 

func (x *LeaderboardTouchRequest) Reset()

func (*LeaderboardTouchRequest) String 

func (x *LeaderboardTouchRequest) String() string

type LeaderboardTouchResponse 

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

func (*LeaderboardTouchResponse) Descriptor deprecated 

func (*LeaderboardTouchResponse) Descriptor() ([]byte, []int)

Deprecated: Use LeaderboardTouchResponse.ProtoReflect.Descriptor instead.

func (*LeaderboardTouchResponse) ProtoMessage 

func (*LeaderboardTouchResponse) ProtoMessage()

func (*LeaderboardTouchResponse) ProtoReflect 

func (x *LeaderboardTouchResponse) ProtoReflect() protoreflect.Message

func (*LeaderboardTouchResponse) Reset 

func (x *LeaderboardTouchResponse) Reset()

func (*LeaderboardTouchResponse) String 

func (x *LeaderboardTouchResponse) String() string

type LoginStateProperties 

type LoginStateProperties struct {

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

State properties affect behavior

func (*LoginStateProperties) Descriptor deprecated 

func (*LoginStateProperties) Descriptor() ([]byte, []int)

Deprecated: Use LoginStateProperties.ProtoReflect.Descriptor instead.

func (*LoginStateProperties) GetTakeOverAcctIdIfDuplicated 

func (x *LoginStateProperties) GetTakeOverAcctIdIfDuplicated() bool

func (*LoginStateProperties) ProtoMessage 

func (*LoginStateProperties) ProtoMessage()

func (*LoginStateProperties) ProtoReflect 

func (x *LoginStateProperties) ProtoReflect() protoreflect.Message

func (*LoginStateProperties) Reset 

func (x *LoginStateProperties) Reset()

func (*LoginStateProperties) String 

func (x *LoginStateProperties) String() string

type Mail 

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
}

func (*Mail) Descriptor deprecated 

func (*Mail) Descriptor() ([]byte, []int)

Deprecated: Use Mail.ProtoReflect.Descriptor instead.

func (*Mail) GetData 

func (x *Mail) GetData() *anypb.Any

func (*Mail) GetId 

func (x *Mail) GetId() string

func (*Mail) ProtoMessage 

func (*Mail) ProtoMessage()

func (*Mail) ProtoReflect 

func (x *Mail) ProtoReflect() protoreflect.Message

func (*Mail) Reset 

func (x *Mail) Reset()

func (*Mail) String 

func (x *Mail) String() string

type MailboxClient 

type MailboxClient interface {
	List(ctx context.Context, in *MailboxListRequest, opts ...grpc.CallOption) (*MailboxListResponse, error)
	//rpc Push(MailboxPushRequest) returns(MailboxPushResponse);
	Pull(ctx context.Context, in *MailboxPullRequest, opts ...grpc.CallOption) (*MailboxPullResponse, error)
	// 支持批量收件人
	Send(ctx context.Context, in *MailboxSendRequest, opts ...grpc.CallOption) (*MailboxSendResponse, error)
}

MailboxClient is the client API for Mailbox service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewMailboxClient 

func NewMailboxClient(cc grpc.ClientConnInterface) MailboxClient

type MailboxListRequest 

type MailboxListRequest struct {
	Key *EntryKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// 获取邮件的数量, 0表示全部
	Count   uint32                      `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
	Options *MailboxListRequest_Options `protobuf:"bytes,10,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*MailboxListRequest) Descriptor deprecated 

func (*MailboxListRequest) Descriptor() ([]byte, []int)

Deprecated: Use MailboxListRequest.ProtoReflect.Descriptor instead.

func (*MailboxListRequest) GetCount 

func (x *MailboxListRequest) GetCount() uint32

func (*MailboxListRequest) GetKey 

func (x *MailboxListRequest) GetKey() *EntryKey

func (*MailboxListRequest) GetOptions 

func (x *MailboxListRequest) GetOptions() *MailboxListRequest_Options

func (*MailboxListRequest) ProtoMessage 

func (*MailboxListRequest) ProtoMessage()

func (*MailboxListRequest) ProtoReflect 

func (x *MailboxListRequest) ProtoReflect() protoreflect.Message

func (*MailboxListRequest) Reset 

func (x *MailboxListRequest) Reset()

func (*MailboxListRequest) String 

func (x *MailboxListRequest) String() string

type MailboxListRequest_Options 

type MailboxListRequest_Options struct {

	// Polling in C# cause NotFound exception which lead to high latency
	RegardNotFoundAsEmpty bool `` /* 131-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*MailboxListRequest_Options) Descriptor deprecated 

func (*MailboxListRequest_Options) Descriptor() ([]byte, []int)

Deprecated: Use MailboxListRequest_Options.ProtoReflect.Descriptor instead.

func (*MailboxListRequest_Options) GetRegardNotFoundAsEmpty 

func (x *MailboxListRequest_Options) GetRegardNotFoundAsEmpty() bool

func (*MailboxListRequest_Options) ProtoMessage 

func (*MailboxListRequest_Options) ProtoMessage()

func (*MailboxListRequest_Options) ProtoReflect 

func (x *MailboxListRequest_Options) ProtoReflect() protoreflect.Message

func (*MailboxListRequest_Options) Reset 

func (x *MailboxListRequest_Options) Reset()

func (*MailboxListRequest_Options) String 

func (x *MailboxListRequest_Options) String() string

type MailboxListResponse 

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

func (*MailboxListResponse) Descriptor deprecated 

func (*MailboxListResponse) Descriptor() ([]byte, []int)

Deprecated: Use MailboxListResponse.ProtoReflect.Descriptor instead.

func (*MailboxListResponse) GetMails 

func (x *MailboxListResponse) GetMails() []*Mail

func (*MailboxListResponse) ProtoMessage 

func (*MailboxListResponse) ProtoMessage()

func (*MailboxListResponse) ProtoReflect 

func (x *MailboxListResponse) ProtoReflect() protoreflect.Message

func (*MailboxListResponse) Reset 

func (x *MailboxListResponse) Reset()

func (*MailboxListResponse) String 

func (x *MailboxListResponse) String() string

type MailboxPullRequest 

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
}

func (*MailboxPullRequest) Descriptor deprecated 

func (*MailboxPullRequest) Descriptor() ([]byte, []int)

Deprecated: Use MailboxPullRequest.ProtoReflect.Descriptor instead.

func (*MailboxPullRequest) GetIds 

func (x *MailboxPullRequest) GetIds() []string

func (*MailboxPullRequest) GetKey 

func (x *MailboxPullRequest) GetKey() *EntryKey

func (*MailboxPullRequest) ProtoMessage 

func (*MailboxPullRequest) ProtoMessage()

func (*MailboxPullRequest) ProtoReflect 

func (x *MailboxPullRequest) ProtoReflect() protoreflect.Message

func (*MailboxPullRequest) Reset 

func (x *MailboxPullRequest) Reset()

func (*MailboxPullRequest) String 

func (x *MailboxPullRequest) String() string

type MailboxPullResponse 

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
}

func (*MailboxPullResponse) Descriptor deprecated 

func (*MailboxPullResponse) Descriptor() ([]byte, []int)

Deprecated: Use MailboxPullResponse.ProtoReflect.Descriptor instead.

func (*MailboxPullResponse) GetPulledIds 

func (x *MailboxPullResponse) GetPulledIds() []string

func (*MailboxPullResponse) ProtoMessage 

func (*MailboxPullResponse) ProtoMessage()

func (*MailboxPullResponse) ProtoReflect 

func (x *MailboxPullResponse) ProtoReflect() protoreflect.Message

func (*MailboxPullResponse) Reset 

func (x *MailboxPullResponse) Reset()

func (*MailboxPullResponse) String 

func (x *MailboxPullResponse) String() string

type MailboxSendRequest 

type MailboxSendRequest struct {
	Envelopes []*Envelope `protobuf:"bytes,1,rep,name=envelopes,proto3" json:"envelopes,omitempty"`
	// contains filtered or unexported fields
}

func (*MailboxSendRequest) Descriptor deprecated 

func (*MailboxSendRequest) Descriptor() ([]byte, []int)

Deprecated: Use MailboxSendRequest.ProtoReflect.Descriptor instead.

func (*MailboxSendRequest) GetEnvelopes 

func (x *MailboxSendRequest) GetEnvelopes() []*Envelope

func (*MailboxSendRequest) ProtoMessage 

func (*MailboxSendRequest) ProtoMessage()

func (*MailboxSendRequest) ProtoReflect 

func (x *MailboxSendRequest) ProtoReflect() protoreflect.Message

func (*MailboxSendRequest) Reset 

func (x *MailboxSendRequest) Reset()

func (*MailboxSendRequest) String 

func (x *MailboxSendRequest) String() string

type MailboxSendResponse 

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

func (*MailboxSendResponse) Descriptor deprecated 

func (*MailboxSendResponse) Descriptor() ([]byte, []int)

Deprecated: Use MailboxSendResponse.ProtoReflect.Descriptor instead.

func (*MailboxSendResponse) ProtoMessage 

func (*MailboxSendResponse) ProtoMessage()

func (*MailboxSendResponse) ProtoReflect 

func (x *MailboxSendResponse) ProtoReflect() protoreflect.Message

func (*MailboxSendResponse) Reset 

func (x *MailboxSendResponse) Reset()

func (*MailboxSendResponse) String 

func (x *MailboxSendResponse) String() string

type MailboxServer 

type MailboxServer interface {
	List(context.Context, *MailboxListRequest) (*MailboxListResponse, error)
	//rpc Push(MailboxPushRequest) returns(MailboxPushResponse);
	Pull(context.Context, *MailboxPullRequest) (*MailboxPullResponse, error)
	// 支持批量收件人
	Send(context.Context, *MailboxSendRequest) (*MailboxSendResponse, error)
	// contains filtered or unexported methods
}

MailboxServer is the server API for Mailbox service. All implementations must embed UnimplementedMailboxServer for forward compatibility

type OrderCancelRequest 

type OrderCancelRequest struct {
	OrderId string `protobuf:"bytes,1,opt,name=order_id,json=orderId,proto3" json:"order_id,omitempty"`
	Reason  string `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

func (*OrderCancelRequest) Descriptor deprecated 

func (*OrderCancelRequest) Descriptor() ([]byte, []int)

Deprecated: Use OrderCancelRequest.ProtoReflect.Descriptor instead.

func (*OrderCancelRequest) GetOrderId 

func (x *OrderCancelRequest) GetOrderId() string

func (*OrderCancelRequest) GetReason 

func (x *OrderCancelRequest) GetReason() string

func (*OrderCancelRequest) ProtoMessage 

func (*OrderCancelRequest) ProtoMessage()

func (*OrderCancelRequest) ProtoReflect 

func (x *OrderCancelRequest) ProtoReflect() protoreflect.Message

func (*OrderCancelRequest) Reset 

func (x *OrderCancelRequest) Reset()

func (*OrderCancelRequest) String 

func (x *OrderCancelRequest) String() string

type OrderCancelResponse 

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

func (*OrderCancelResponse) Descriptor deprecated 

func (*OrderCancelResponse) Descriptor() ([]byte, []int)

Deprecated: Use OrderCancelResponse.ProtoReflect.Descriptor instead.

func (*OrderCancelResponse) ProtoMessage 

func (*OrderCancelResponse) ProtoMessage()

func (*OrderCancelResponse) ProtoReflect 

func (x *OrderCancelResponse) ProtoReflect() protoreflect.Message

func (*OrderCancelResponse) Reset 

func (x *OrderCancelResponse) Reset()

func (*OrderCancelResponse) String 

func (x *OrderCancelResponse) String() string

type OrderClient 

type OrderClient interface {
	// 查询订单
	Get(ctx context.Context, in *OrderGetRequest, opts ...grpc.CallOption) (*OrderGetResponse, error)
	// 创建订单
	Create(ctx context.Context, in *OrderCreateRequest, opts ...grpc.CallOption) (*OrderCreateResponse, error)
	// 取消订单
	Cancel(ctx context.Context, in *OrderCancelRequest, opts ...grpc.CallOption) (*OrderCancelResponse, error)
	// 设置订单已支付
	Pay(ctx context.Context, in *OrderPayRequest, opts ...grpc.CallOption) (*OrderPayResponse, error)
	// 设置订单已完成
	Fulfill(ctx context.Context, in *OrderFulfillRequest, opts ...grpc.CallOption) (*OrderFulfillResponse, error)
}

OrderClient is the client API for Order service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewOrderClient 

func NewOrderClient(cc grpc.ClientConnInterface) OrderClient

type OrderCreateRequest 

type OrderCreateRequest struct {

	// 使用者必须自行保证订单ID的唯一性
	// 如果订单ID已存在，会被认为是同一请求因为某种原因进行重试，
	// 因此会保持先前订单不变但返回创建成功（幂等）。
	OrderId string `protobuf:"bytes,1,opt,name=order_id,json=orderId,proto3" json:"order_id,omitempty"`
	// 货币名称 CNY USD 等
	Currency string `protobuf:"bytes,5,opt,name=currency,proto3" json:"currency,omitempty"`
	// 支付金额
	Price string `protobuf:"bytes,6,opt,name=price,proto3" json:"price,omitempty"`
	// 渠道名称
	ChannelId string `protobuf:"bytes,9,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty"`
	// 商品ID
	ProductId string `protobuf:"bytes,101,opt,name=product_id,json=productId,proto3" json:"product_id,omitempty"`
	// 商品名称
	ProductName string `protobuf:"bytes,102,opt,name=product_name,json=productName,proto3" json:"product_name,omitempty"`
	// 商品数量
	ProductQuantity string `protobuf:"bytes,103,opt,name=product_quantity,json=productQuantity,proto3" json:"product_quantity,omitempty"`
	// 用户ID
	UserId string `protobuf:"bytes,123,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	// 角色ID
	RoleId string `protobuf:"bytes,124,opt,name=role_id,json=roleId,proto3" json:"role_id,omitempty"`
	// contains filtered or unexported fields
}

func (*OrderCreateRequest) Descriptor deprecated 

func (*OrderCreateRequest) Descriptor() ([]byte, []int)

Deprecated: Use OrderCreateRequest.ProtoReflect.Descriptor instead.

func (*OrderCreateRequest) GetChannelId 

func (x *OrderCreateRequest) GetChannelId() string

func (*OrderCreateRequest) GetCurrency 

func (x *OrderCreateRequest) GetCurrency() string

func (*OrderCreateRequest) GetOrderId 

func (x *OrderCreateRequest) GetOrderId() string

func (*OrderCreateRequest) GetPrice 

func (x *OrderCreateRequest) GetPrice() string

func (*OrderCreateRequest) GetProductId 

func (x *OrderCreateRequest) GetProductId() string

func (*OrderCreateRequest) GetProductName 

func (x *OrderCreateRequest) GetProductName() string

func (*OrderCreateRequest) GetProductQuantity 

func (x *OrderCreateRequest) GetProductQuantity() string

func (*OrderCreateRequest) GetRoleId 

func (x *OrderCreateRequest) GetRoleId() string

func (*OrderCreateRequest) GetUserId 

func (x *OrderCreateRequest) GetUserId() string

func (*OrderCreateRequest) ProtoMessage 

func (*OrderCreateRequest) ProtoMessage()

func (*OrderCreateRequest) ProtoReflect 

func (x *OrderCreateRequest) ProtoReflect() protoreflect.Message

func (*OrderCreateRequest) Reset 

func (x *OrderCreateRequest) Reset()

func (*OrderCreateRequest) String 

func (x *OrderCreateRequest) String() string

type OrderCreateResponse 

type OrderCreateResponse struct {
	Data *PurchaseData `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*OrderCreateResponse) Descriptor deprecated 

func (*OrderCreateResponse) Descriptor() ([]byte, []int)

Deprecated: Use OrderCreateResponse.ProtoReflect.Descriptor instead.

func (*OrderCreateResponse) GetData 

func (x *OrderCreateResponse) GetData() *PurchaseData

func (*OrderCreateResponse) ProtoMessage 

func (*OrderCreateResponse) ProtoMessage()

func (*OrderCreateResponse) ProtoReflect 

func (x *OrderCreateResponse) ProtoReflect() protoreflect.Message

func (*OrderCreateResponse) Reset 

func (x *OrderCreateResponse) Reset()

func (*OrderCreateResponse) String 

func (x *OrderCreateResponse) String() string

type OrderFulfillRequest 

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

func (*OrderFulfillRequest) Descriptor deprecated 

func (*OrderFulfillRequest) Descriptor() ([]byte, []int)

Deprecated: Use OrderFulfillRequest.ProtoReflect.Descriptor instead.

func (*OrderFulfillRequest) GetOrderId 

func (x *OrderFulfillRequest) GetOrderId() string

func (*OrderFulfillRequest) ProtoMessage 

func (*OrderFulfillRequest) ProtoMessage()

func (*OrderFulfillRequest) ProtoReflect 

func (x *OrderFulfillRequest) ProtoReflect() protoreflect.Message

func (*OrderFulfillRequest) Reset 

func (x *OrderFulfillRequest) Reset()

func (*OrderFulfillRequest) String 

func (x *OrderFulfillRequest) String() string

type OrderFulfillResponse 

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

func (*OrderFulfillResponse) Descriptor deprecated 

func (*OrderFulfillResponse) Descriptor() ([]byte, []int)

Deprecated: Use OrderFulfillResponse.ProtoReflect.Descriptor instead.

func (*OrderFulfillResponse) ProtoMessage 

func (*OrderFulfillResponse) ProtoMessage()

func (*OrderFulfillResponse) ProtoReflect 

func (x *OrderFulfillResponse) ProtoReflect() protoreflect.Message

func (*OrderFulfillResponse) Reset 

func (x *OrderFulfillResponse) Reset()

func (*OrderFulfillResponse) String 

func (x *OrderFulfillResponse) String() string

type OrderGetRequest 

type OrderGetRequest struct {
	Filters []*OrderGetRequest_Filter `protobuf:"bytes,1,rep,name=filters,proto3" json:"filters,omitempty"`
	// contains filtered or unexported fields
}

func (*OrderGetRequest) Descriptor deprecated 

func (*OrderGetRequest) Descriptor() ([]byte, []int)

Deprecated: Use OrderGetRequest.ProtoReflect.Descriptor instead.

func (*OrderGetRequest) GetFilters 

func (x *OrderGetRequest) GetFilters() []*OrderGetRequest_Filter

func (*OrderGetRequest) ProtoMessage 

func (*OrderGetRequest) ProtoMessage()

func (*OrderGetRequest) ProtoReflect 

func (x *OrderGetRequest) ProtoReflect() protoreflect.Message

func (*OrderGetRequest) Reset 

func (x *OrderGetRequest) Reset()

func (*OrderGetRequest) String 

func (x *OrderGetRequest) String() string

type OrderGetRequest_Filter 

type OrderGetRequest_Filter struct {
	OrderId string `protobuf:"bytes,1,opt,name=order_id,json=orderId,proto3" json:"order_id,omitempty"`
	UserId  string `protobuf:"bytes,2,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	RoleId  string `protobuf:"bytes,3,opt,name=role_id,json=roleId,proto3" json:"role_id,omitempty"`
	State   string `protobuf:"bytes,4,opt,name=state,proto3" json:"state,omitempty"`
	// contains filtered or unexported fields
}

func (*OrderGetRequest_Filter) Descriptor deprecated 

func (*OrderGetRequest_Filter) Descriptor() ([]byte, []int)

Deprecated: Use OrderGetRequest_Filter.ProtoReflect.Descriptor instead.

func (*OrderGetRequest_Filter) GetOrderId 

func (x *OrderGetRequest_Filter) GetOrderId() string

func (*OrderGetRequest_Filter) GetRoleId 

func (x *OrderGetRequest_Filter) GetRoleId() string

func (*OrderGetRequest_Filter) GetState 

func (x *OrderGetRequest_Filter) GetState() string

func (*OrderGetRequest_Filter) GetUserId 

func (x *OrderGetRequest_Filter) GetUserId() string

func (*OrderGetRequest_Filter) ProtoMessage 

func (*OrderGetRequest_Filter) ProtoMessage()

func (*OrderGetRequest_Filter) ProtoReflect 

func (x *OrderGetRequest_Filter) ProtoReflect() protoreflect.Message

func (*OrderGetRequest_Filter) Reset 

func (x *OrderGetRequest_Filter) Reset()

func (*OrderGetRequest_Filter) String 

func (x *OrderGetRequest_Filter) String() string

type OrderGetResponse 

type OrderGetResponse struct {
	Orders []*PurchaseData `protobuf:"bytes,1,rep,name=orders,proto3" json:"orders,omitempty"`
	// contains filtered or unexported fields
}

func (*OrderGetResponse) Descriptor deprecated 

func (*OrderGetResponse) Descriptor() ([]byte, []int)

Deprecated: Use OrderGetResponse.ProtoReflect.Descriptor instead.

func (*OrderGetResponse) GetOrders 

func (x *OrderGetResponse) GetOrders() []*PurchaseData

func (*OrderGetResponse) ProtoMessage 

func (*OrderGetResponse) ProtoMessage()

func (*OrderGetResponse) ProtoReflect 

func (x *OrderGetResponse) ProtoReflect() protoreflect.Message

func (*OrderGetResponse) Reset 

func (x *OrderGetResponse) Reset()

func (*OrderGetResponse) String 

func (x *OrderGetResponse) String() string

type OrderPayRequest 

type OrderPayRequest struct {

	// 订单ID
	OrderId string `protobuf:"bytes,1,opt,name=order_id,json=orderId,proto3" json:"order_id,omitempty"`
	// 支付ID
	TransactionId string `protobuf:"bytes,2,opt,name=transaction_id,json=transactionId,proto3" json:"transaction_id,omitempty"`
	// 支付凭证
	Receipt string `protobuf:"bytes,3,opt,name=receipt,proto3" json:"receipt,omitempty"`
	// contains filtered or unexported fields
}

func (*OrderPayRequest) Descriptor deprecated 

func (*OrderPayRequest) Descriptor() ([]byte, []int)

Deprecated: Use OrderPayRequest.ProtoReflect.Descriptor instead.

func (*OrderPayRequest) GetOrderId 

func (x *OrderPayRequest) GetOrderId() string

func (*OrderPayRequest) GetReceipt 

func (x *OrderPayRequest) GetReceipt() string

func (*OrderPayRequest) GetTransactionId 

func (x *OrderPayRequest) GetTransactionId() string

func (*OrderPayRequest) ProtoMessage 

func (*OrderPayRequest) ProtoMessage()

func (*OrderPayRequest) ProtoReflect 

func (x *OrderPayRequest) ProtoReflect() protoreflect.Message

func (*OrderPayRequest) Reset 

func (x *OrderPayRequest) Reset()

func (*OrderPayRequest) String 

func (x *OrderPayRequest) String() string

type OrderPayResponse 

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

func (*OrderPayResponse) Descriptor deprecated 

func (*OrderPayResponse) Descriptor() ([]byte, []int)

Deprecated: Use OrderPayResponse.ProtoReflect.Descriptor instead.

func (*OrderPayResponse) ProtoMessage 

func (*OrderPayResponse) ProtoMessage()

func (*OrderPayResponse) ProtoReflect 

func (x *OrderPayResponse) ProtoReflect() protoreflect.Message

func (*OrderPayResponse) Reset 

func (x *OrderPayResponse) Reset()

func (*OrderPayResponse) String 

func (x *OrderPayResponse) String() string

type OrderServer 

type OrderServer interface {
	// 查询订单
	Get(context.Context, *OrderGetRequest) (*OrderGetResponse, error)
	// 创建订单
	Create(context.Context, *OrderCreateRequest) (*OrderCreateResponse, error)
	// 取消订单
	Cancel(context.Context, *OrderCancelRequest) (*OrderCancelResponse, error)
	// 设置订单已支付
	Pay(context.Context, *OrderPayRequest) (*OrderPayResponse, error)
	// 设置订单已完成
	Fulfill(context.Context, *OrderFulfillRequest) (*OrderFulfillResponse, error)
	// contains filtered or unexported methods
}

OrderServer is the server API for Order service. All implementations must embed UnimplementedOrderServer for forward compatibility

type PubSub 

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

func (*PubSub) Descriptor deprecated 

func (*PubSub) Descriptor() ([]byte, []int)

Deprecated: Use PubSub.ProtoReflect.Descriptor instead.

func (*PubSub) ProtoMessage 

func (*PubSub) ProtoMessage()

func (*PubSub) ProtoReflect 

func (x *PubSub) ProtoReflect() protoreflect.Message

func (*PubSub) Reset 

func (x *PubSub) Reset()

func (*PubSub) String 

func (x *PubSub) String() string

type PubSubServiceClient 

type PubSubServiceClient interface {
	// 发布
	Publish(ctx context.Context, in *PubSub_PublishRequest, opts ...grpc.CallOption) (*PubSub_PublishResponse, error)
	// 订阅
	Subscribe(ctx context.Context, in *PubSub_SubscribeRequest, opts ...grpc.CallOption) (PubSubService_SubscribeClient, error)
	// 消费，如果当时不可消费则阻塞等待直到超时或有可用信息
	Consume(ctx context.Context, in *PubSub_ConsumeRequest, opts ...grpc.CallOption) (*PubSub_ConsumeResponse, error)
}

PubSubServiceClient is the client API for PubSubService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewPubSubServiceClient 

func NewPubSubServiceClient(cc grpc.ClientConnInterface) PubSubServiceClient

type PubSubServiceServer 

type PubSubServiceServer interface {
	// 发布
	Publish(context.Context, *PubSub_PublishRequest) (*PubSub_PublishResponse, error)
	// 订阅
	Subscribe(*PubSub_SubscribeRequest, PubSubService_SubscribeServer) error
	// 消费，如果当时不可消费则阻塞等待直到超时或有可用信息
	Consume(context.Context, *PubSub_ConsumeRequest) (*PubSub_ConsumeResponse, error)
	// contains filtered or unexported methods
}

PubSubServiceServer is the server API for PubSubService service. All implementations must embed UnimplementedPubSubServiceServer for forward compatibility

type PubSubService_SubscribeClient 

type PubSubService_SubscribeClient interface {
	Recv() (*PubSub_SubscribeResponse, error)
	grpc.ClientStream
}

type PubSubService_SubscribeServer 

type PubSubService_SubscribeServer interface {
	Send(*PubSub_SubscribeResponse) error
	grpc.ServerStream
}

type PubSub_Ack 

type PubSub_Ack struct {

	// 主题
	Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	// 消费组
	GroupId int32 `protobuf:"varint,2,opt,name=group_id,json=groupId,proto3" json:"group_id,omitempty"`
	// 确认的消息ID
	MsgIds []string `protobuf:"bytes,3,rep,name=msg_ids,json=msgIds,proto3" json:"msg_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*PubSub_Ack) Descriptor deprecated 

func (*PubSub_Ack) Descriptor() ([]byte, []int)

Deprecated: Use PubSub_Ack.ProtoReflect.Descriptor instead.

func (*PubSub_Ack) GetGroupId 

func (x *PubSub_Ack) GetGroupId() int32

func (*PubSub_Ack) GetMsgIds 

func (x *PubSub_Ack) GetMsgIds() []string

func (*PubSub_Ack) GetTopic 

func (x *PubSub_Ack) GetTopic() string

func (*PubSub_Ack) ProtoMessage 

func (*PubSub_Ack) ProtoMessage()

func (*PubSub_Ack) ProtoReflect 

func (x *PubSub_Ack) ProtoReflect() protoreflect.Message

func (*PubSub_Ack) Reset 

func (x *PubSub_Ack) Reset()

func (*PubSub_Ack) String 

func (x *PubSub_Ack) String() string

type PubSub_ConsumeRequest 

type PubSub_ConsumeRequest struct {

	// 消费
	Consumptions []*PubSub_Consumption `protobuf:"bytes,1,rep,name=consumptions,proto3" json:"consumptions,omitempty"`
	// 确认消息处理完成
	Acks []*PubSub_Ack `protobuf:"bytes,10,rep,name=acks,proto3" json:"acks,omitempty"`
	// contains filtered or unexported fields
}

func (*PubSub_ConsumeRequest) Descriptor deprecated 

func (*PubSub_ConsumeRequest) Descriptor() ([]byte, []int)

Deprecated: Use PubSub_ConsumeRequest.ProtoReflect.Descriptor instead.

func (*PubSub_ConsumeRequest) GetAcks 

func (x *PubSub_ConsumeRequest) GetAcks() []*PubSub_Ack

func (*PubSub_ConsumeRequest) GetConsumptions 

func (x *PubSub_ConsumeRequest) GetConsumptions() []*PubSub_Consumption

func (*PubSub_ConsumeRequest) ProtoMessage 

func (*PubSub_ConsumeRequest) ProtoMessage()

func (*PubSub_ConsumeRequest) ProtoReflect 

func (x *PubSub_ConsumeRequest) ProtoReflect() protoreflect.Message

func (*PubSub_ConsumeRequest) Reset 

func (x *PubSub_ConsumeRequest) Reset()

func (*PubSub_ConsumeRequest) String 

func (x *PubSub_ConsumeRequest) String() string

type PubSub_ConsumeResponse 

type PubSub_ConsumeResponse struct {
	Msgs []*PubSub_Msg `protobuf:"bytes,1,rep,name=msgs,proto3" json:"msgs,omitempty"`
	// contains filtered or unexported fields
}

func (*PubSub_ConsumeResponse) Descriptor deprecated 

func (*PubSub_ConsumeResponse) Descriptor() ([]byte, []int)

Deprecated: Use PubSub_ConsumeResponse.ProtoReflect.Descriptor instead.

func (*PubSub_ConsumeResponse) GetMsgs 

func (x *PubSub_ConsumeResponse) GetMsgs() []*PubSub_Msg

func (*PubSub_ConsumeResponse) ProtoMessage 

func (*PubSub_ConsumeResponse) ProtoMessage()

func (*PubSub_ConsumeResponse) ProtoReflect 

func (x *PubSub_ConsumeResponse) ProtoReflect() protoreflect.Message

func (*PubSub_ConsumeResponse) Reset 

func (x *PubSub_ConsumeResponse) Reset()

func (*PubSub_ConsumeResponse) String 

func (x *PubSub_ConsumeResponse) String() string

type PubSub_Consumption 

type PubSub_Consumption struct {

	// 主题
	Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	// 消费组
	GroupId int32 `protobuf:"varint,2,opt,name=group_id,json=groupId,proto3" json:"group_id,omitempty"`
	// 消费处理响应超时时间(毫秒)
	AckTimeout int64 `protobuf:"varint,3,opt,name=ack_timeout,json=ackTimeout,proto3" json:"ack_timeout,omitempty"`
	// contains filtered or unexported fields
}

func (*PubSub_Consumption) Descriptor deprecated 

func (*PubSub_Consumption) Descriptor() ([]byte, []int)

Deprecated: Use PubSub_Consumption.ProtoReflect.Descriptor instead.

func (*PubSub_Consumption) GetAckTimeout 

func (x *PubSub_Consumption) GetAckTimeout() int64

func (*PubSub_Consumption) GetGroupId 

func (x *PubSub_Consumption) GetGroupId() int32

func (*PubSub_Consumption) GetTopic 

func (x *PubSub_Consumption) GetTopic() string

func (*PubSub_Consumption) ProtoMessage 

func (*PubSub_Consumption) ProtoMessage()

func (*PubSub_Consumption) ProtoReflect 

func (x *PubSub_Consumption) ProtoReflect() protoreflect.Message

func (*PubSub_Consumption) Reset 

func (x *PubSub_Consumption) Reset()

func (*PubSub_Consumption) String 

func (x *PubSub_Consumption) String() string

type PubSub_Msg 

type PubSub_Msg struct {

	// 生产者
	Producer string `protobuf:"bytes,1,opt,name=producer,proto3" json:"producer,omitempty"`
	// 产生时间
	ProduceAt int64 `protobuf:"varint,2,opt,name=produce_at,json=produceAt,proto3" json:"produce_at,omitempty"`
	// 消息载荷
	//
	// Types that are assignable to Value:
	//	*PubSub_Msg_Bin
	//	*PubSub_Msg_Str
	//	*PubSub_Msg_Any
	Value isPubSub_Msg_Value `protobuf_oneof:"value"`
	// 主题
	Topic string `protobuf:"bytes,10,opt,name=topic,proto3" json:"topic,omitempty"`
	// 消息ID
	// 在Subscribe/Consume回复中自动填充
	// Publish填充此字段无效
	Id string `protobuf:"bytes,11,opt,name=id,proto3" json:"id,omitempty"`
	// 消费者组
	// 在Consume回复中自动填充
	// Publish填充此字段无效
	GroupId int32 `protobuf:"varint,12,opt,name=group_id,json=groupId,proto3" json:"group_id,omitempty"`
	// contains filtered or unexported fields
}

消息结构

func (*PubSub_Msg) Descriptor deprecated 

func (*PubSub_Msg) Descriptor() ([]byte, []int)

Deprecated: Use PubSub_Msg.ProtoReflect.Descriptor instead.

func (*PubSub_Msg) GetAny 

func (x *PubSub_Msg) GetAny() *anypb.Any

func (*PubSub_Msg) GetBin 

func (x *PubSub_Msg) GetBin() []byte

func (*PubSub_Msg) GetGroupId 

func (x *PubSub_Msg) GetGroupId() int32

func (*PubSub_Msg) GetId 

func (x *PubSub_Msg) GetId() string

func (*PubSub_Msg) GetProduceAt 

func (x *PubSub_Msg) GetProduceAt() int64

func (*PubSub_Msg) GetProducer 

func (x *PubSub_Msg) GetProducer() string

func (*PubSub_Msg) GetStr 

func (x *PubSub_Msg) GetStr() string

func (*PubSub_Msg) GetTopic 

func (x *PubSub_Msg) GetTopic() string

func (*PubSub_Msg) GetValue 

func (m *PubSub_Msg) GetValue() isPubSub_Msg_Value

func (*PubSub_Msg) ProtoMessage 

func (*PubSub_Msg) ProtoMessage()

func (*PubSub_Msg) ProtoReflect 

func (x *PubSub_Msg) ProtoReflect() protoreflect.Message

func (*PubSub_Msg) Reset 

func (x *PubSub_Msg) Reset()

func (*PubSub_Msg) String 

func (x *PubSub_Msg) String() string

type PubSub_Msg_Any 

type PubSub_Msg_Any struct {
	// PB载荷
	Any *anypb.Any `protobuf:"bytes,9,opt,name=any,proto3,oneof"`
}

type PubSub_Msg_Bin 

type PubSub_Msg_Bin struct {
	// 二进制载荷
	Bin []byte `protobuf:"bytes,7,opt,name=bin,proto3,oneof"`
}

type PubSub_Msg_Str 

type PubSub_Msg_Str struct {
	// 字符串载荷
	Str string `protobuf:"bytes,8,opt,name=str,proto3,oneof"`
}

type PubSub_Publication 

type PubSub_Publication struct {

	// 主题
	Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	// 允许跨应用发送消息
	AppId string `protobuf:"bytes,2,opt,name=app_id,json=appId,proto3" json:"app_id,omitempty"`
	// 自动创建主题
	AutoCreateTopic bool `protobuf:"varint,7,opt,name=auto_create_topic,json=autoCreateTopic,proto3" json:"auto_create_topic,omitempty"`
	// 消息最大保存数量
	MaxLen int32 `protobuf:"varint,8,opt,name=max_len,json=maxLen,proto3" json:"max_len,omitempty"`
	// 消息最长保存时间(毫秒)
	MaxTtl int64 `protobuf:"varint,9,opt,name=max_ttl,json=maxTtl,proto3" json:"max_ttl,omitempty"`
	// 主题下的消息
	Msgs []*PubSub_Msg `protobuf:"bytes,15,rep,name=msgs,proto3" json:"msgs,omitempty"`
	// contains filtered or unexported fields
}

func (*PubSub_Publication) Descriptor deprecated 

func (*PubSub_Publication) Descriptor() ([]byte, []int)

Deprecated: Use PubSub_Publication.ProtoReflect.Descriptor instead.

func (*PubSub_Publication) GetAppId 

func (x *PubSub_Publication) GetAppId() string

func (*PubSub_Publication) GetAutoCreateTopic 

func (x *PubSub_Publication) GetAutoCreateTopic() bool

func (*PubSub_Publication) GetMaxLen 

func (x *PubSub_Publication) GetMaxLen() int32

func (*PubSub_Publication) GetMaxTtl 

func (x *PubSub_Publication) GetMaxTtl() int64

func (*PubSub_Publication) GetMsgs 

func (x *PubSub_Publication) GetMsgs() []*PubSub_Msg

func (*PubSub_Publication) GetTopic 

func (x *PubSub_Publication) GetTopic() string

func (*PubSub_Publication) ProtoMessage 

func (*PubSub_Publication) ProtoMessage()

func (*PubSub_Publication) ProtoReflect 

func (x *PubSub_Publication) ProtoReflect() protoreflect.Message

func (*PubSub_Publication) Reset 

func (x *PubSub_Publication) Reset()

func (*PubSub_Publication) String 

func (x *PubSub_Publication) String() string

type PubSub_PublishRequest 

type PubSub_PublishRequest struct {
	Publications []*PubSub_Publication `protobuf:"bytes,1,rep,name=publications,proto3" json:"publications,omitempty"`
	Delay        int64                 `protobuf:"varint,2,opt,name=delay,proto3" json:"delay,omitempty"` // 延迟发送(秒)
	// contains filtered or unexported fields
}

func (*PubSub_PublishRequest) Descriptor deprecated 

func (*PubSub_PublishRequest) Descriptor() ([]byte, []int)

Deprecated: Use PubSub_PublishRequest.ProtoReflect.Descriptor instead.

func (*PubSub_PublishRequest) GetDelay 

func (x *PubSub_PublishRequest) GetDelay() int64

func (*PubSub_PublishRequest) GetPublications 

func (x *PubSub_PublishRequest) GetPublications() []*PubSub_Publication

func (*PubSub_PublishRequest) ProtoMessage 

func (*PubSub_PublishRequest) ProtoMessage()

func (*PubSub_PublishRequest) ProtoReflect 

func (x *PubSub_PublishRequest) ProtoReflect() protoreflect.Message

func (*PubSub_PublishRequest) Reset 

func (x *PubSub_PublishRequest) Reset()

func (*PubSub_PublishRequest) String 

func (x *PubSub_PublishRequest) String() string

type PubSub_PublishResponse 

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

func (*PubSub_PublishResponse) Descriptor deprecated 

func (*PubSub_PublishResponse) Descriptor() ([]byte, []int)

Deprecated: Use PubSub_PublishResponse.ProtoReflect.Descriptor instead.

func (*PubSub_PublishResponse) ProtoMessage 

func (*PubSub_PublishResponse) ProtoMessage()

func (*PubSub_PublishResponse) ProtoReflect 

func (x *PubSub_PublishResponse) ProtoReflect() protoreflect.Message

func (*PubSub_PublishResponse) Reset 

func (x *PubSub_PublishResponse) Reset()

func (*PubSub_PublishResponse) String 

func (x *PubSub_PublishResponse) String() string

type PubSub_SubscribeRequest 

type PubSub_SubscribeRequest struct {
	Subscriptions []*PubSub_Subscription `protobuf:"bytes,1,rep,name=subscriptions,proto3" json:"subscriptions,omitempty"`
	// contains filtered or unexported fields
}

func (*PubSub_SubscribeRequest) Descriptor deprecated 

func (*PubSub_SubscribeRequest) Descriptor() ([]byte, []int)

Deprecated: Use PubSub_SubscribeRequest.ProtoReflect.Descriptor instead.

func (*PubSub_SubscribeRequest) GetSubscriptions 

func (x *PubSub_SubscribeRequest) GetSubscriptions() []*PubSub_Subscription

func (*PubSub_SubscribeRequest) ProtoMessage 

func (*PubSub_SubscribeRequest) ProtoMessage()

func (*PubSub_SubscribeRequest) ProtoReflect 

func (x *PubSub_SubscribeRequest) ProtoReflect() protoreflect.Message

func (*PubSub_SubscribeRequest) Reset 

func (x *PubSub_SubscribeRequest) Reset()

func (*PubSub_SubscribeRequest) String 

func (x *PubSub_SubscribeRequest) String() string

type PubSub_SubscribeResponse 

type PubSub_SubscribeResponse struct {
	Msgs []*PubSub_Msg `protobuf:"bytes,1,rep,name=msgs,proto3" json:"msgs,omitempty"`
	// contains filtered or unexported fields
}

func (*PubSub_SubscribeResponse) Descriptor deprecated 

func (*PubSub_SubscribeResponse) Descriptor() ([]byte, []int)

Deprecated: Use PubSub_SubscribeResponse.ProtoReflect.Descriptor instead.

func (*PubSub_SubscribeResponse) GetMsgs 

func (x *PubSub_SubscribeResponse) GetMsgs() []*PubSub_Msg

func (*PubSub_SubscribeResponse) ProtoMessage 

func (*PubSub_SubscribeResponse) ProtoMessage()

func (*PubSub_SubscribeResponse) ProtoReflect 

func (x *PubSub_SubscribeResponse) ProtoReflect() protoreflect.Message

func (*PubSub_SubscribeResponse) Reset 

func (x *PubSub_SubscribeResponse) Reset()

func (*PubSub_SubscribeResponse) String 

func (x *PubSub_SubscribeResponse) String() string

type PubSub_Subscription 

type PubSub_Subscription struct {

	// 主题
	Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	// 每次读取的最大数量(防止包体过大)
	BatchSize int32 `protobuf:"varint,10,opt,name=batch_size,json=batchSize,proto3" json:"batch_size,omitempty"`
	// 指定ID之后(不包含指定ID)
	AfterId string `protobuf:"bytes,11,opt,name=after_id,json=afterId,proto3" json:"after_id,omitempty"`
	// 指定毫秒时间戳开始
	SinceMilliTimestamp int64 `protobuf:"varint,12,opt,name=since_milli_timestamp,json=sinceMilliTimestamp,proto3" json:"since_milli_timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*PubSub_Subscription) Descriptor deprecated 

func (*PubSub_Subscription) Descriptor() ([]byte, []int)

Deprecated: Use PubSub_Subscription.ProtoReflect.Descriptor instead.

func (*PubSub_Subscription) GetAfterId 

func (x *PubSub_Subscription) GetAfterId() string

func (*PubSub_Subscription) GetBatchSize 

func (x *PubSub_Subscription) GetBatchSize() int32

func (*PubSub_Subscription) GetSinceMilliTimestamp 

func (x *PubSub_Subscription) GetSinceMilliTimestamp() int64

func (*PubSub_Subscription) GetTopic 

func (x *PubSub_Subscription) GetTopic() string

func (*PubSub_Subscription) ProtoMessage 

func (*PubSub_Subscription) ProtoMessage()

func (*PubSub_Subscription) ProtoReflect 

func (x *PubSub_Subscription) ProtoReflect() protoreflect.Message

func (*PubSub_Subscription) Reset 

func (x *PubSub_Subscription) Reset()

func (*PubSub_Subscription) String 

func (x *PubSub_Subscription) String() string

type PurchaseData 

type PurchaseData struct {

	// 订单ID
	OrderId string `protobuf:"bytes,1,opt,name=order_id,json=orderId,proto3" json:"order_id,omitempty"`
	// 订单状态
	State PurchaseState `protobuf:"varint,2,opt,name=state,proto3,enum=libra.v1.PurchaseState" json:"state,omitempty"`
	// 创建时间
	CreateAt int64 `protobuf:"varint,3,opt,name=create_at,json=createAt,proto3" json:"create_at,omitempty"`
	// 货币名称 CNY USD 等
	Currency string `protobuf:"bytes,5,opt,name=currency,proto3" json:"currency,omitempty"`
	// 支付金额
	Price string `protobuf:"bytes,6,opt,name=price,proto3" json:"price,omitempty"`
	// 应用ID
	AppId string `protobuf:"bytes,7,opt,name=app_id,json=appId,proto3" json:"app_id,omitempty"`
	// 渠道名称
	ChannelId string `protobuf:"bytes,9,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty"`
	// 取消购买时间
	CancelAt int64 `protobuf:"varint,30,opt,name=cancel_at,json=cancelAt,proto3" json:"cancel_at,omitempty"`
	// 取消原因
	CancelReason string `protobuf:"bytes,31,opt,name=cancel_reason,json=cancelReason,proto3" json:"cancel_reason,omitempty"`
	// 支付时间
	PayAt int64 `protobuf:"varint,40,opt,name=pay_at,json=payAt,proto3" json:"pay_at,omitempty"`
	// 支付ID
	TransactionId string `protobuf:"bytes,41,opt,name=transaction_id,json=transactionId,proto3" json:"transaction_id,omitempty"`
	// 支付凭证
	Receipt string `protobuf:"bytes,42,opt,name=receipt,proto3" json:"receipt,omitempty"`
	// 发货时间
	FulfillAt int64 `protobuf:"varint,50,opt,name=fulfill_at,json=fulfillAt,proto3" json:"fulfill_at,omitempty"`
	// 透传
	//string payload = 100;
	// 商品ID
	ProductId string `protobuf:"bytes,101,opt,name=product_id,json=productId,proto3" json:"product_id,omitempty"`
	// 商品名称
	ProductName string `protobuf:"bytes,102,opt,name=product_name,json=productName,proto3" json:"product_name,omitempty"`
	// 商品数量
	ProductQuantity string `protobuf:"bytes,103,opt,name=product_quantity,json=productQuantity,proto3" json:"product_quantity,omitempty"`
	// 用户ID
	UserId string `protobuf:"bytes,123,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	// 角色ID
	RoleId string `protobuf:"bytes,124,opt,name=role_id,json=roleId,proto3" json:"role_id,omitempty"`
	// contains filtered or unexported fields
}

func (*PurchaseData) Descriptor deprecated 

func (*PurchaseData) Descriptor() ([]byte, []int)

Deprecated: Use PurchaseData.ProtoReflect.Descriptor instead.

func (*PurchaseData) GetAppId 

func (x *PurchaseData) GetAppId() string

func (*PurchaseData) GetCancelAt 

func (x *PurchaseData) GetCancelAt() int64

func (*PurchaseData) GetCancelReason 

func (x *PurchaseData) GetCancelReason() string

func (*PurchaseData) GetChannelId 

func (x *PurchaseData) GetChannelId() string

func (*PurchaseData) GetCreateAt 

func (x *PurchaseData) GetCreateAt() int64

func (*PurchaseData) GetCurrency 

func (x *PurchaseData) GetCurrency() string

func (*PurchaseData) GetFulfillAt 

func (x *PurchaseData) GetFulfillAt() int64

func (*PurchaseData) GetOrderId 

func (x *PurchaseData) GetOrderId() string

func (*PurchaseData) GetPayAt 

func (x *PurchaseData) GetPayAt() int64

func (*PurchaseData) GetPrice 

func (x *PurchaseData) GetPrice() string

func (*PurchaseData) GetProductId 

func (x *PurchaseData) GetProductId() string

func (*PurchaseData) GetProductName 

func (x *PurchaseData) GetProductName() string

func (*PurchaseData) GetProductQuantity 

func (x *PurchaseData) GetProductQuantity() string

func (*PurchaseData) GetReceipt 

func (x *PurchaseData) GetReceipt() string

func (*PurchaseData) GetRoleId 

func (x *PurchaseData) GetRoleId() string

func (*PurchaseData) GetState 

func (x *PurchaseData) GetState() PurchaseState

func (*PurchaseData) GetTransactionId 

func (x *PurchaseData) GetTransactionId() string

func (*PurchaseData) GetUserId 

func (x *PurchaseData) GetUserId() string

func (*PurchaseData) ProtoMessage 

func (*PurchaseData) ProtoMessage()

func (*PurchaseData) ProtoReflect 

func (x *PurchaseData) ProtoReflect() protoreflect.Message

func (*PurchaseData) Reset 

func (x *PurchaseData) Reset()

func (*PurchaseData) String 

func (x *PurchaseData) String() string

type PurchaseState 

type PurchaseState int32
const (
	PurchaseState_PurchaseStateUnspecified PurchaseState = 0
	// 订单已创建，等待后续操作
	PurchaseState_PurchaseStatePending PurchaseState = 1
	// 用户取消订单
	PurchaseState_PurchaseStateCanceled PurchaseState = 2
	// 订单已支付
	PurchaseState_PurchaseStatePaid PurchaseState = 3
	// 订单已发货
	PurchaseState_PurchaseStateFulfilled PurchaseState = 4
)

func (PurchaseState) Descriptor 

func (PurchaseState) Descriptor() protoreflect.EnumDescriptor

func (PurchaseState) Enum 

func (x PurchaseState) Enum() *PurchaseState

func (PurchaseState) EnumDescriptor deprecated 

func (PurchaseState) EnumDescriptor() ([]byte, []int)

Deprecated: Use PurchaseState.Descriptor instead.

func (PurchaseState) Number 

func (x PurchaseState) Number() protoreflect.EnumNumber

func (PurchaseState) String 

func (x PurchaseState) String() string

func (PurchaseState) Type 

func (PurchaseState) Type() protoreflect.EnumType

type RoleAlterIndexRequest 

type RoleAlterIndexRequest struct {
	RoleId string `protobuf:"bytes,1,opt,name=role_id,json=roleId,proto3" json:"role_id,omitempty"`
	Index  uint32 `protobuf:"varint,2,opt,name=index,proto3" json:"index,omitempty"`
	// contains filtered or unexported fields
}

func (*RoleAlterIndexRequest) Descriptor deprecated 

func (*RoleAlterIndexRequest) Descriptor() ([]byte, []int)

Deprecated: Use RoleAlterIndexRequest.ProtoReflect.Descriptor instead.

func (*RoleAlterIndexRequest) GetIndex 

func (x *RoleAlterIndexRequest) GetIndex() uint32

func (*RoleAlterIndexRequest) GetRoleId 

func (x *RoleAlterIndexRequest) GetRoleId() string

func (*RoleAlterIndexRequest) ProtoMessage 

func (*RoleAlterIndexRequest) ProtoMessage()

func (*RoleAlterIndexRequest) ProtoReflect 

func (x *RoleAlterIndexRequest) ProtoReflect() protoreflect.Message

func (*RoleAlterIndexRequest) Reset 

func (x *RoleAlterIndexRequest) Reset()

func (*RoleAlterIndexRequest) String 

func (x *RoleAlterIndexRequest) String() string

type RoleAlterIndexResponse 

type RoleAlterIndexResponse struct {
	Role *RoleData `protobuf:"bytes,1,opt,name=role,proto3" json:"role,omitempty"`
	// contains filtered or unexported fields
}

func (*RoleAlterIndexResponse) Descriptor deprecated 

func (*RoleAlterIndexResponse) Descriptor() ([]byte, []int)

Deprecated: Use RoleAlterIndexResponse.ProtoReflect.Descriptor instead.

func (*RoleAlterIndexResponse) GetRole 

func (x *RoleAlterIndexResponse) GetRole() *RoleData

func (*RoleAlterIndexResponse) ProtoMessage 

func (*RoleAlterIndexResponse) ProtoMessage()

func (*RoleAlterIndexResponse) ProtoReflect 

func (x *RoleAlterIndexResponse) ProtoReflect() protoreflect.Message

func (*RoleAlterIndexResponse) Reset 

func (x *RoleAlterIndexResponse) Reset()

func (*RoleAlterIndexResponse) String 

func (x *RoleAlterIndexResponse) String() string

type RoleClient 

type RoleClient interface {
	Get(ctx context.Context, in *RoleGetRequest, opts ...grpc.CallOption) (*RoleGetResponse, error)
	List(ctx context.Context, in *RoleListRequest, opts ...grpc.CallOption) (*RoleListResponse, error)
	Create(ctx context.Context, in *RoleCreateRequest, opts ...grpc.CallOption) (*RoleCreateResponse, error)
	SignIn(ctx context.Context, in *RoleSignInRequest, opts ...grpc.CallOption) (*RoleSignInResponse, error)
	SetMetadata(ctx context.Context, in *RoleSetMetadataRequest, opts ...grpc.CallOption) (*RoleSetMetadataResponse, error)
	GetMetadata(ctx context.Context, in *RoleGetMetadataRequest, opts ...grpc.CallOption) (*RoleGetMetadataResponse, error)
	// 修改角色index
	AlterIndex(ctx context.Context, in *RoleAlterIndexRequest, opts ...grpc.CallOption) (*RoleAlterIndexResponse, error)
}

RoleClient is the client API for Role service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewRoleClient 

func NewRoleClient(cc grpc.ClientConnInterface) RoleClient

type RoleCreateRequest 

type RoleCreateRequest struct {
	Index    uint32            `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"`
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	UserId   string            `protobuf:"bytes,3,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	// contains filtered or unexported fields
}

func (*RoleCreateRequest) Descriptor deprecated 

func (*RoleCreateRequest) Descriptor() ([]byte, []int)

Deprecated: Use RoleCreateRequest.ProtoReflect.Descriptor instead.

func (*RoleCreateRequest) GetIndex 

func (x *RoleCreateRequest) GetIndex() uint32

func (*RoleCreateRequest) GetMetadata 

func (x *RoleCreateRequest) GetMetadata() map[string]string

func (*RoleCreateRequest) GetUserId 

func (x *RoleCreateRequest) GetUserId() string

func (*RoleCreateRequest) ProtoMessage 

func (*RoleCreateRequest) ProtoMessage()

func (*RoleCreateRequest) ProtoReflect 

func (x *RoleCreateRequest) ProtoReflect() protoreflect.Message

func (*RoleCreateRequest) Reset 

func (x *RoleCreateRequest) Reset()

func (*RoleCreateRequest) String 

func (x *RoleCreateRequest) String() string

type RoleCreateResponse 

type RoleCreateResponse struct {
	Role *RoleData `protobuf:"bytes,1,opt,name=role,proto3" json:"role,omitempty"`
	// contains filtered or unexported fields
}

func (*RoleCreateResponse) Descriptor deprecated 

func (*RoleCreateResponse) Descriptor() ([]byte, []int)

Deprecated: Use RoleCreateResponse.ProtoReflect.Descriptor instead.

func (*RoleCreateResponse) GetRole 

func (x *RoleCreateResponse) GetRole() *RoleData

func (*RoleCreateResponse) ProtoMessage 

func (*RoleCreateResponse) ProtoMessage()

func (*RoleCreateResponse) ProtoReflect 

func (x *RoleCreateResponse) ProtoReflect() protoreflect.Message

func (*RoleCreateResponse) Reset 

func (x *RoleCreateResponse) Reset()

func (*RoleCreateResponse) String 

func (x *RoleCreateResponse) String() string

type RoleData 

type RoleData struct {
	Id       string            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Index    uint32            `protobuf:"varint,2,opt,name=index,proto3" json:"index,omitempty"`
	UserId   string            `protobuf:"bytes,3,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	CreateAt int64             `protobuf:"varint,5,opt,name=create_at,json=createAt,proto3" json:"create_at,omitempty"`
	SignInAt int64             `protobuf:"varint,6,opt,name=sign_in_at,json=signInAt,proto3" json:"sign_in_at,omitempty"`
	Metadata map[string]string `` /* 158-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*RoleData) Descriptor deprecated 

func (*RoleData) Descriptor() ([]byte, []int)

Deprecated: Use RoleData.ProtoReflect.Descriptor instead.

func (*RoleData) GetCreateAt 

func (x *RoleData) GetCreateAt() int64

func (*RoleData) GetId 

func (x *RoleData) GetId() string

func (*RoleData) GetIndex 

func (x *RoleData) GetIndex() uint32

func (*RoleData) GetMetadata 

func (x *RoleData) GetMetadata() map[string]string

func (*RoleData) GetSignInAt 

func (x *RoleData) GetSignInAt() int64

func (*RoleData) GetUserId 

func (x *RoleData) GetUserId() string

func (*RoleData) ProtoMessage 

func (*RoleData) ProtoMessage()

func (*RoleData) ProtoReflect 

func (x *RoleData) ProtoReflect() protoreflect.Message

func (*RoleData) Reset 

func (x *RoleData) Reset()

func (*RoleData) String 

func (x *RoleData) String() string

type RoleGetMetadataRequest 

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

func (*RoleGetMetadataRequest) Descriptor deprecated 

func (*RoleGetMetadataRequest) Descriptor() ([]byte, []int)

Deprecated: Use RoleGetMetadataRequest.ProtoReflect.Descriptor instead.

func (*RoleGetMetadataRequest) GetKeys 

func (x *RoleGetMetadataRequest) GetKeys() []string

func (*RoleGetMetadataRequest) GetRoleId 

func (x *RoleGetMetadataRequest) GetRoleId() string

func (*RoleGetMetadataRequest) ProtoMessage 

func (*RoleGetMetadataRequest) ProtoMessage()

func (*RoleGetMetadataRequest) ProtoReflect 

func (x *RoleGetMetadataRequest) ProtoReflect() protoreflect.Message

func (*RoleGetMetadataRequest) Reset 

func (x *RoleGetMetadataRequest) Reset()

func (*RoleGetMetadataRequest) String 

func (x *RoleGetMetadataRequest) String() string

type RoleGetMetadataResponse 

type RoleGetMetadataResponse struct {
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*RoleGetMetadataResponse) Descriptor deprecated 

func (*RoleGetMetadataResponse) Descriptor() ([]byte, []int)

Deprecated: Use RoleGetMetadataResponse.ProtoReflect.Descriptor instead.

func (*RoleGetMetadataResponse) GetMetadata 

func (x *RoleGetMetadataResponse) GetMetadata() map[string]string

func (*RoleGetMetadataResponse) ProtoMessage 

func (*RoleGetMetadataResponse) ProtoMessage()

func (*RoleGetMetadataResponse) ProtoReflect 

func (x *RoleGetMetadataResponse) ProtoReflect() protoreflect.Message

func (*RoleGetMetadataResponse) Reset 

func (x *RoleGetMetadataResponse) Reset()

func (*RoleGetMetadataResponse) String 

func (x *RoleGetMetadataResponse) String() string

type RoleGetRequest 

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

func (*RoleGetRequest) Descriptor deprecated 

func (*RoleGetRequest) Descriptor() ([]byte, []int)

Deprecated: Use RoleGetRequest.ProtoReflect.Descriptor instead.

func (*RoleGetRequest) GetIds 

func (x *RoleGetRequest) GetIds() []string

func (*RoleGetRequest) ProtoMessage 

func (*RoleGetRequest) ProtoMessage()

func (*RoleGetRequest) ProtoReflect 

func (x *RoleGetRequest) ProtoReflect() protoreflect.Message

func (*RoleGetRequest) Reset 

func (x *RoleGetRequest) Reset()

func (*RoleGetRequest) String 

func (x *RoleGetRequest) String() string

type RoleGetResponse 

type RoleGetResponse struct {
	Roles []*RoleData `protobuf:"bytes,1,rep,name=roles,proto3" json:"roles,omitempty"`
	// contains filtered or unexported fields
}

func (*RoleGetResponse) Descriptor deprecated 

func (*RoleGetResponse) Descriptor() ([]byte, []int)

Deprecated: Use RoleGetResponse.ProtoReflect.Descriptor instead.

func (*RoleGetResponse) GetRoles 

func (x *RoleGetResponse) GetRoles() []*RoleData

func (*RoleGetResponse) ProtoMessage 

func (*RoleGetResponse) ProtoMessage()

func (*RoleGetResponse) ProtoReflect 

func (x *RoleGetResponse) ProtoReflect() protoreflect.Message

func (*RoleGetResponse) Reset 

func (x *RoleGetResponse) Reset()

func (*RoleGetResponse) String 

func (x *RoleGetResponse) String() string

type RoleListRequest 

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

func (*RoleListRequest) Descriptor deprecated 

func (*RoleListRequest) Descriptor() ([]byte, []int)

Deprecated: Use RoleListRequest.ProtoReflect.Descriptor instead.

func (*RoleListRequest) GetUserId 

func (x *RoleListRequest) GetUserId() string

func (*RoleListRequest) ProtoMessage 

func (*RoleListRequest) ProtoMessage()

func (*RoleListRequest) ProtoReflect 

func (x *RoleListRequest) ProtoReflect() protoreflect.Message

func (*RoleListRequest) Reset 

func (x *RoleListRequest) Reset()

func (*RoleListRequest) String 

func (x *RoleListRequest) String() string

type RoleListResponse 

type RoleListResponse struct {
	Roles       []*RoleData `protobuf:"bytes,1,rep,name=roles,proto3" json:"roles,omitempty"`
	AccessToken string      `protobuf:"bytes,10,opt,name=access_token,json=accessToken,proto3" json:"access_token,omitempty"`
	// contains filtered or unexported fields
}

func (*RoleListResponse) Descriptor deprecated 

func (*RoleListResponse) Descriptor() ([]byte, []int)

Deprecated: Use RoleListResponse.ProtoReflect.Descriptor instead.

func (*RoleListResponse) GetAccessToken 

func (x *RoleListResponse) GetAccessToken() string

func (*RoleListResponse) GetRoles 

func (x *RoleListResponse) GetRoles() []*RoleData

func (*RoleListResponse) ProtoMessage 

func (*RoleListResponse) ProtoMessage()

func (*RoleListResponse) ProtoReflect 

func (x *RoleListResponse) ProtoReflect() protoreflect.Message

func (*RoleListResponse) Reset 

func (x *RoleListResponse) Reset()

func (*RoleListResponse) String 

func (x *RoleListResponse) String() string

type RoleServer 

type RoleServer interface {
	Get(context.Context, *RoleGetRequest) (*RoleGetResponse, error)
	List(context.Context, *RoleListRequest) (*RoleListResponse, error)
	Create(context.Context, *RoleCreateRequest) (*RoleCreateResponse, error)
	SignIn(context.Context, *RoleSignInRequest) (*RoleSignInResponse, error)
	SetMetadata(context.Context, *RoleSetMetadataRequest) (*RoleSetMetadataResponse, error)
	GetMetadata(context.Context, *RoleGetMetadataRequest) (*RoleGetMetadataResponse, error)
	// 修改角色index
	AlterIndex(context.Context, *RoleAlterIndexRequest) (*RoleAlterIndexResponse, error)
	// contains filtered or unexported methods
}

RoleServer is the server API for Role service. All implementations must embed UnimplementedRoleServer for forward compatibility

type RoleSetMetadataRequest 

type RoleSetMetadataRequest struct {
	RoleId   string            `protobuf:"bytes,1,opt,name=role_id,json=roleId,proto3" json:"role_id,omitempty"`
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*RoleSetMetadataRequest) Descriptor deprecated 

func (*RoleSetMetadataRequest) Descriptor() ([]byte, []int)

Deprecated: Use RoleSetMetadataRequest.ProtoReflect.Descriptor instead.

func (*RoleSetMetadataRequest) GetMetadata 

func (x *RoleSetMetadataRequest) GetMetadata() map[string]string

func (*RoleSetMetadataRequest) GetRoleId 

func (x *RoleSetMetadataRequest) GetRoleId() string

func (*RoleSetMetadataRequest) ProtoMessage 

func (*RoleSetMetadataRequest) ProtoMessage()

func (*RoleSetMetadataRequest) ProtoReflect 

func (x *RoleSetMetadataRequest) ProtoReflect() protoreflect.Message

func (*RoleSetMetadataRequest) Reset 

func (x *RoleSetMetadataRequest) Reset()

func (*RoleSetMetadataRequest) String 

func (x *RoleSetMetadataRequest) String() string

type RoleSetMetadataResponse 

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

func (*RoleSetMetadataResponse) Descriptor deprecated 

func (*RoleSetMetadataResponse) Descriptor() ([]byte, []int)

Deprecated: Use RoleSetMetadataResponse.ProtoReflect.Descriptor instead.

func (*RoleSetMetadataResponse) ProtoMessage 

func (*RoleSetMetadataResponse) ProtoMessage()

func (*RoleSetMetadataResponse) ProtoReflect 

func (x *RoleSetMetadataResponse) ProtoReflect() protoreflect.Message

func (*RoleSetMetadataResponse) Reset 

func (x *RoleSetMetadataResponse) Reset()

func (*RoleSetMetadataResponse) String 

func (x *RoleSetMetadataResponse) String() string

type RoleSignInRequest 

type RoleSignInRequest struct {
	RoleId string `protobuf:"bytes,3,opt,name=role_id,json=roleId,proto3" json:"role_id,omitempty"`
	// contains filtered or unexported fields
}

func (*RoleSignInRequest) Descriptor deprecated 

func (*RoleSignInRequest) Descriptor() ([]byte, []int)

Deprecated: Use RoleSignInRequest.ProtoReflect.Descriptor instead.

func (*RoleSignInRequest) GetRoleId 

func (x *RoleSignInRequest) GetRoleId() string

func (*RoleSignInRequest) ProtoMessage 

func (*RoleSignInRequest) ProtoMessage()

func (*RoleSignInRequest) ProtoReflect 

func (x *RoleSignInRequest) ProtoReflect() protoreflect.Message

func (*RoleSignInRequest) Reset 

func (x *RoleSignInRequest) Reset()

func (*RoleSignInRequest) String 

func (x *RoleSignInRequest) String() string

type RoleSignInResponse 

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

func (*RoleSignInResponse) Descriptor deprecated 

func (*RoleSignInResponse) Descriptor() ([]byte, []int)

Deprecated: Use RoleSignInResponse.ProtoReflect.Descriptor instead.

func (*RoleSignInResponse) ProtoMessage 

func (*RoleSignInResponse) ProtoMessage()

func (*RoleSignInResponse) ProtoReflect 

func (x *RoleSignInResponse) ProtoReflect() protoreflect.Message

func (*RoleSignInResponse) Reset 

func (x *RoleSignInResponse) Reset()

func (*RoleSignInResponse) String 

func (x *RoleSignInResponse) String() string

type SubstrIndex1 

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

字串索引

func (*SubstrIndex1) Descriptor deprecated 

func (*SubstrIndex1) Descriptor() ([]byte, []int)

Deprecated: Use SubstrIndex1.ProtoReflect.Descriptor instead.

func (*SubstrIndex1) ProtoMessage 

func (*SubstrIndex1) ProtoMessage()

func (*SubstrIndex1) ProtoReflect 

func (x *SubstrIndex1) ProtoReflect() protoreflect.Message

func (*SubstrIndex1) Reset 

func (x *SubstrIndex1) Reset()

func (*SubstrIndex1) String 

func (x *SubstrIndex1) String() string

type SubstrIndex1ServiceClient 

type SubstrIndex1ServiceClient interface {
	// 更新索引
	Update(ctx context.Context, in *SubstrIndex1_UpdateRequest, opts ...grpc.CallOption) (*SubstrIndex1_UpdateResponse, error)
	// 删除索引
	Remove(ctx context.Context, in *SubstrIndex1_RemoveRequest, opts ...grpc.CallOption) (*SubstrIndex1_RemoveResponse, error)
	// 搜索对象
	Search(ctx context.Context, in *SubstrIndex1_SearchRequest, opts ...grpc.CallOption) (*SubstrIndex1_SearchResponse, error)
}

SubstrIndex1ServiceClient is the client API for SubstrIndex1Service service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewSubstrIndex1ServiceClient 

func NewSubstrIndex1ServiceClient(cc grpc.ClientConnInterface) SubstrIndex1ServiceClient

type SubstrIndex1ServiceServer 

type SubstrIndex1ServiceServer interface {
	// 更新索引
	Update(context.Context, *SubstrIndex1_UpdateRequest) (*SubstrIndex1_UpdateResponse, error)
	// 删除索引
	Remove(context.Context, *SubstrIndex1_RemoveRequest) (*SubstrIndex1_RemoveResponse, error)
	// 搜索对象
	Search(context.Context, *SubstrIndex1_SearchRequest) (*SubstrIndex1_SearchResponse, error)
	// contains filtered or unexported methods
}

SubstrIndex1ServiceServer is the server API for SubstrIndex1Service service. All implementations must embed UnimplementedSubstrIndex1ServiceServer for forward compatibility

type SubstrIndex1_Entry 

type SubstrIndex1_Entry struct {

	// 对象键
	Key *EntryKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// 索引值
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// 对象数据
	Data *anypb.Any `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

模糊字符串索引对象

func (*SubstrIndex1_Entry) Descriptor deprecated 

func (*SubstrIndex1_Entry) Descriptor() ([]byte, []int)

Deprecated: Use SubstrIndex1_Entry.ProtoReflect.Descriptor instead.

func (*SubstrIndex1_Entry) GetData 

func (x *SubstrIndex1_Entry) GetData() *anypb.Any

func (*SubstrIndex1_Entry) GetKey 

func (x *SubstrIndex1_Entry) GetKey() *EntryKey

func (*SubstrIndex1_Entry) GetValue 

func (x *SubstrIndex1_Entry) GetValue() string

func (*SubstrIndex1_Entry) ProtoMessage 

func (*SubstrIndex1_Entry) ProtoMessage()

func (*SubstrIndex1_Entry) ProtoReflect 

func (x *SubstrIndex1_Entry) ProtoReflect() protoreflect.Message

func (*SubstrIndex1_Entry) Reset 

func (x *SubstrIndex1_Entry) Reset()

func (*SubstrIndex1_Entry) String 

func (x *SubstrIndex1_Entry) String() string

type SubstrIndex1_RemoveRequest 

type SubstrIndex1_RemoveRequest struct {
	IndexId string      `protobuf:"bytes,1,opt,name=index_id,json=indexId,proto3" json:"index_id,omitempty"`
	Keys    []*EntryKey `protobuf:"bytes,2,rep,name=keys,proto3" json:"keys,omitempty"`
	// contains filtered or unexported fields
}

func (*SubstrIndex1_RemoveRequest) Descriptor deprecated 

func (*SubstrIndex1_RemoveRequest) Descriptor() ([]byte, []int)

Deprecated: Use SubstrIndex1_RemoveRequest.ProtoReflect.Descriptor instead.

func (*SubstrIndex1_RemoveRequest) GetIndexId 

func (x *SubstrIndex1_RemoveRequest) GetIndexId() string

func (*SubstrIndex1_RemoveRequest) GetKeys 

func (x *SubstrIndex1_RemoveRequest) GetKeys() []*EntryKey

func (*SubstrIndex1_RemoveRequest) ProtoMessage 

func (*SubstrIndex1_RemoveRequest) ProtoMessage()

func (*SubstrIndex1_RemoveRequest) ProtoReflect 

func (x *SubstrIndex1_RemoveRequest) ProtoReflect() protoreflect.Message

func (*SubstrIndex1_RemoveRequest) Reset 

func (x *SubstrIndex1_RemoveRequest) Reset()

func (*SubstrIndex1_RemoveRequest) String 

func (x *SubstrIndex1_RemoveRequest) String() string

type SubstrIndex1_RemoveResponse 

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

func (*SubstrIndex1_RemoveResponse) Descriptor deprecated 

func (*SubstrIndex1_RemoveResponse) Descriptor() ([]byte, []int)

Deprecated: Use SubstrIndex1_RemoveResponse.ProtoReflect.Descriptor instead.

func (*SubstrIndex1_RemoveResponse) ProtoMessage 

func (*SubstrIndex1_RemoveResponse) ProtoMessage()

func (*SubstrIndex1_RemoveResponse) ProtoReflect 

func (x *SubstrIndex1_RemoveResponse) ProtoReflect() protoreflect.Message

func (*SubstrIndex1_RemoveResponse) Reset 

func (x *SubstrIndex1_RemoveResponse) Reset()

func (*SubstrIndex1_RemoveResponse) String 

func (x *SubstrIndex1_RemoveResponse) String() string

type SubstrIndex1_SearchRequest 

type SubstrIndex1_SearchRequest struct {

	// 索引ID
	IndexId string `protobuf:"bytes,1,opt,name=index_id,json=indexId,proto3" json:"index_id,omitempty"`
	// 搜索关键字
	Value string `protobuf:"bytes,10,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*SubstrIndex1_SearchRequest) Descriptor deprecated 

func (*SubstrIndex1_SearchRequest) Descriptor() ([]byte, []int)

Deprecated: Use SubstrIndex1_SearchRequest.ProtoReflect.Descriptor instead.

func (*SubstrIndex1_SearchRequest) GetIndexId 

func (x *SubstrIndex1_SearchRequest) GetIndexId() string

func (*SubstrIndex1_SearchRequest) GetValue 

func (x *SubstrIndex1_SearchRequest) GetValue() string

func (*SubstrIndex1_SearchRequest) ProtoMessage 

func (*SubstrIndex1_SearchRequest) ProtoMessage()

func (*SubstrIndex1_SearchRequest) ProtoReflect 

func (x *SubstrIndex1_SearchRequest) ProtoReflect() protoreflect.Message

func (*SubstrIndex1_SearchRequest) Reset 

func (x *SubstrIndex1_SearchRequest) Reset()

func (*SubstrIndex1_SearchRequest) String 

func (x *SubstrIndex1_SearchRequest) String() string

type SubstrIndex1_SearchResponse 

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

func (*SubstrIndex1_SearchResponse) Descriptor deprecated 

func (*SubstrIndex1_SearchResponse) Descriptor() ([]byte, []int)

Deprecated: Use SubstrIndex1_SearchResponse.ProtoReflect.Descriptor instead.

func (*SubstrIndex1_SearchResponse) GetEntries 

func (x *SubstrIndex1_SearchResponse) GetEntries() []*SubstrIndex1_Entry

func (*SubstrIndex1_SearchResponse) ProtoMessage 

func (*SubstrIndex1_SearchResponse) ProtoMessage()

func (*SubstrIndex1_SearchResponse) ProtoReflect 

func (x *SubstrIndex1_SearchResponse) ProtoReflect() protoreflect.Message

func (*SubstrIndex1_SearchResponse) Reset 

func (x *SubstrIndex1_SearchResponse) Reset()

func (*SubstrIndex1_SearchResponse) String 

func (x *SubstrIndex1_SearchResponse) String() string

type SubstrIndex1_UpdateRequest 

type SubstrIndex1_UpdateRequest struct {

	// 索引ID
	IndexId string `protobuf:"bytes,1,opt,name=index_id,json=indexId,proto3" json:"index_id,omitempty"`
	// 要索引的对象
	Entry *SubstrIndex1_Entry `protobuf:"bytes,10,opt,name=entry,proto3" json:"entry,omitempty"`
	// contains filtered or unexported fields
}

func (*SubstrIndex1_UpdateRequest) Descriptor deprecated 

func (*SubstrIndex1_UpdateRequest) Descriptor() ([]byte, []int)

Deprecated: Use SubstrIndex1_UpdateRequest.ProtoReflect.Descriptor instead.

func (*SubstrIndex1_UpdateRequest) GetEntry 

func (x *SubstrIndex1_UpdateRequest) GetEntry() *SubstrIndex1_Entry

func (*SubstrIndex1_UpdateRequest) GetIndexId 

func (x *SubstrIndex1_UpdateRequest) GetIndexId() string

func (*SubstrIndex1_UpdateRequest) ProtoMessage 

func (*SubstrIndex1_UpdateRequest) ProtoMessage()

func (*SubstrIndex1_UpdateRequest) ProtoReflect 

func (x *SubstrIndex1_UpdateRequest) ProtoReflect() protoreflect.Message

func (*SubstrIndex1_UpdateRequest) Reset 

func (x *SubstrIndex1_UpdateRequest) Reset()

func (*SubstrIndex1_UpdateRequest) String 

func (x *SubstrIndex1_UpdateRequest) String() string

type SubstrIndex1_UpdateResponse 

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

func (*SubstrIndex1_UpdateResponse) Descriptor deprecated 

func (*SubstrIndex1_UpdateResponse) Descriptor() ([]byte, []int)

Deprecated: Use SubstrIndex1_UpdateResponse.ProtoReflect.Descriptor instead.

func (*SubstrIndex1_UpdateResponse) ProtoMessage 

func (*SubstrIndex1_UpdateResponse) ProtoMessage()

func (*SubstrIndex1_UpdateResponse) ProtoReflect 

func (x *SubstrIndex1_UpdateResponse) ProtoReflect() protoreflect.Message

func (*SubstrIndex1_UpdateResponse) Reset 

func (x *SubstrIndex1_UpdateResponse) Reset()

func (*SubstrIndex1_UpdateResponse) String 

func (x *SubstrIndex1_UpdateResponse) String() string

type UniformLoginState 

type UniformLoginState struct {

	// User which matchs one of the accts will be selected,
	// then all of the accts will be bind to this user.
	// All accts must be mapped to exact 0 or 1 user.
	// All accts will be bind to this user.
	AcctIds []string `protobuf:"bytes,1,rep,name=acct_ids,json=acctIds,proto3" json:"acct_ids,omitempty"`
	// user ip
	UserIp string `protobuf:"bytes,2,opt,name=user_ip,json=userIp,proto3" json:"user_ip,omitempty"`
	// acct details, self-describing
	AcctDetails map[string]string `` /* 182-byte string literal not displayed */
	// inherent properties of state
	Properties *LoginStateProperties `protobuf:"bytes,10,opt,name=properties,proto3" json:"properties,omitempty"`
	// timestamp when signature signed
	Timestamp int64 `protobuf:"varint,13,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// random string max length to 32 bytes
	// 16 bytes length at least is recommended
	Nonce string `protobuf:"bytes,14,opt,name=nonce,proto3" json:"nonce,omitempty"`
	// the signature should be signed at SERVER SIDE,
	// no matter the login request was sent from client or server.
	Signature string `protobuf:"bytes,15,opt,name=signature,proto3" json:"signature,omitempty"`
	// contains filtered or unexported fields
}

Librad not implement any account (check) system, the real account state should be verified via a third-party server, then send a login request to librad to fetch passport(token).

func (*UniformLoginState) Descriptor deprecated 

func (*UniformLoginState) Descriptor() ([]byte, []int)

Deprecated: Use UniformLoginState.ProtoReflect.Descriptor instead.

func (*UniformLoginState) GetAcctDetails 

func (x *UniformLoginState) GetAcctDetails() map[string]string

func (*UniformLoginState) GetAcctIds 

func (x *UniformLoginState) GetAcctIds() []string

func (*UniformLoginState) GetNonce 

func (x *UniformLoginState) GetNonce() string

func (*UniformLoginState) GetProperties 

func (x *UniformLoginState) GetProperties() *LoginStateProperties

func (*UniformLoginState) GetSignature 

func (x *UniformLoginState) GetSignature() string

func (*UniformLoginState) GetTimestamp 

func (x *UniformLoginState) GetTimestamp() int64

func (*UniformLoginState) GetUserIp 

func (x *UniformLoginState) GetUserIp() string

func (*UniformLoginState) ProtoMessage 

func (*UniformLoginState) ProtoMessage()

func (*UniformLoginState) ProtoReflect 

func (x *UniformLoginState) ProtoReflect() protoreflect.Message

func (*UniformLoginState) Reset 

func (x *UniformLoginState) Reset()

func (*UniformLoginState) String 

func (x *UniformLoginState) String() string

type UnimplementedBubbleChartServer 

type UnimplementedBubbleChartServer struct {
}

UnimplementedBubbleChartServer must be embedded to have forward compatible implementations.

func (UnimplementedBubbleChartServer) Append 

func (UnimplementedBubbleChartServer) Append(context.Context, *BubbleChartAppendRequest) (*BubbleChartAppendResponse, error)

func (UnimplementedBubbleChartServer) GetById 

func (UnimplementedBubbleChartServer) GetById(context.Context, *BubbleChartGetByIdRequest) (*BubbleChartGetByIdResponse, error)

func (UnimplementedBubbleChartServer) GetRange 

func (UnimplementedBubbleChartServer) GetRange(context.Context, *BubbleChartGetRangeRequest) (*BubbleChartGetRangeResponse, error)

func (UnimplementedBubbleChartServer) RemoveById 

func (UnimplementedBubbleChartServer) RemoveById(context.Context, *BubbleChartRemoveByIdRequest) (*BubbleChartRemoveByIdResponse, error)

func (UnimplementedBubbleChartServer) SetInfo 

func (UnimplementedBubbleChartServer) SetInfo(context.Context, *BubbleChartSetInfoRequest) (*BubbleChartSetInfoResponse, error)

func (UnimplementedBubbleChartServer) SwapById 

func (UnimplementedBubbleChartServer) SwapById(context.Context, *BubbleChartSwapByIdRequest) (*BubbleChartSwapByIdResponse, error)

func (UnimplementedBubbleChartServer) SwapByRank 

func (UnimplementedBubbleChartServer) SwapByRank(context.Context, *BubbleChartSwapByRankRequest) (*BubbleChartSwapByRankResponse, error)

type UnimplementedCacheServer 

type UnimplementedCacheServer struct {
}

UnimplementedCacheServer must be embedded to have forward compatible implementations.

func (UnimplementedCacheServer) Add 

func (UnimplementedCacheServer) Add(context.Context, *CacheAddRequest) (*CacheAddResponse, error)

func (UnimplementedCacheServer) Get 

func (UnimplementedCacheServer) Get(context.Context, *CacheGetRequest) (*CacheGetResponse, error)

func (UnimplementedCacheServer) Set 

func (UnimplementedCacheServer) Set(context.Context, *CacheSetRequest) (*CacheSetResponse, error)

type UnimplementedDatabaseServer 

type UnimplementedDatabaseServer struct {
}

UnimplementedDatabaseServer must be embedded to have forward compatible implementations.

func (UnimplementedDatabaseServer) Get 

func (UnimplementedDatabaseServer) Get(context.Context, *DatabaseGetRequest) (*DatabaseGetResponse, error)

func (UnimplementedDatabaseServer) RegisterSchema 

func (UnimplementedDatabaseServer) RegisterSchema(context.Context, *DatabaseRegisterSchemaRequest) (*DatabaseRegisterSchemaResponse, error)

func (UnimplementedDatabaseServer) Set 

func (UnimplementedDatabaseServer) Set(context.Context, *DatabaseSetRequest) (*DatabaseSetResponse, error)

type UnimplementedDistlockServer 

type UnimplementedDistlockServer struct {
}

UnimplementedDistlockServer must be embedded to have forward compatible implementations.

func (UnimplementedDistlockServer) Lock 

func (UnimplementedDistlockServer) Lock(context.Context, *DistlockLockRequest) (*DistlockLockResponse, error)

func (UnimplementedDistlockServer) Unlock 

func (UnimplementedDistlockServer) Unlock(context.Context, *DistlockUnlockRequest) (*DistlockUnlockResponse, error)

type UnimplementedFileServiceServer 

type UnimplementedFileServiceServer struct {
}

UnimplementedFileServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedFileServiceServer) Del 

func (UnimplementedFileServiceServer) Del(context.Context, *FileDelRequest) (*FileDelResponse, error)

func (UnimplementedFileServiceServer) Get 

func (UnimplementedFileServiceServer) Get(context.Context, *FileGetRequest) (*FileGetResponse, error)

func (UnimplementedFileServiceServer) Put 

func (UnimplementedFileServiceServer) Put(context.Context, *FilePutRequest) (*FilePutResponse, error)

type UnimplementedGatewayServer 

type UnimplementedGatewayServer struct {
}

UnimplementedGatewayServer must be embedded to have forward compatible implementations.

func (UnimplementedGatewayServer) Send 

func (UnimplementedGatewayServer) Send(context.Context, *GatewaySendRequest) (*GatewaySendResponse, error)

func (UnimplementedGatewayServer) Watch 

func (UnimplementedGatewayServer) Watch(Gateway_WatchServer) error

type UnimplementedGiftServer 

type UnimplementedGiftServer struct {
}

UnimplementedGiftServer must be embedded to have forward compatible implementations.

func (UnimplementedGiftServer) Create 

func (UnimplementedGiftServer) Create(context.Context, *GiftCreateRequest) (*GiftCreateResponse, error)

func (UnimplementedGiftServer) Redeem 

func (UnimplementedGiftServer) Redeem(context.Context, *GiftRedeemRequest) (*GiftRedeemResponse, error)

func (UnimplementedGiftServer) Revoke 

func (UnimplementedGiftServer) Revoke(context.Context, *GiftRevokeRequest) (*GiftRevokeResponse, error)

func (UnimplementedGiftServer) Search 

func (UnimplementedGiftServer) Search(context.Context, *GiftSearchRequest) (*GiftSearchResponse, error)

func (UnimplementedGiftServer) Update 

func (UnimplementedGiftServer) Update(context.Context, *GiftUpdateRequest) (*GiftUpdateResponse, error)

func (UnimplementedGiftServer) Verify 

func (UnimplementedGiftServer) Verify(context.Context, *GiftVerifyRequest) (*GiftVerifyResponse, error)

type UnimplementedLeaderboardServer 

type UnimplementedLeaderboardServer struct {
}

UnimplementedLeaderboardServer must be embedded to have forward compatible implementations.

func (UnimplementedLeaderboardServer) GetById 

func (UnimplementedLeaderboardServer) GetById(context.Context, *LeaderboardGetByIdRequest) (*LeaderboardGetByIdResponse, error)

func (UnimplementedLeaderboardServer) GetByRank 

func (UnimplementedLeaderboardServer) GetByRank(context.Context, *LeaderboardGetByRankRequest) (*LeaderboardGetByRankResponse, error)

func (UnimplementedLeaderboardServer) GetByScore 

func (UnimplementedLeaderboardServer) GetByScore(context.Context, *LeaderboardGetByScoreRequest) (*LeaderboardGetByScoreResponse, error)

func (UnimplementedLeaderboardServer) GetRange 

func (UnimplementedLeaderboardServer) GetRange(context.Context, *LeaderboardGetRangeRequest) (*LeaderboardGetRangeResponse, error)

func (UnimplementedLeaderboardServer) RemoveById 

func (UnimplementedLeaderboardServer) RemoveById(context.Context, *LeaderboardRemoveByIdRequest) (*LeaderboardRemoveByIdResponse, error)

func (UnimplementedLeaderboardServer) Set 

func (UnimplementedLeaderboardServer) Set(context.Context, *LeaderboardSetRequest) (*LeaderboardSetResponse, error)

func (UnimplementedLeaderboardServer) SetInfo 

func (UnimplementedLeaderboardServer) SetInfo(context.Context, *LeaderboardSetInfoRequest) (*LeaderboardSetInfoResponse, error)

func (UnimplementedLeaderboardServer) SetScore 

func (UnimplementedLeaderboardServer) SetScore(context.Context, *LeaderboardSetScoreRequest) (*LeaderboardSetScoreResponse, error)

func (UnimplementedLeaderboardServer) Touch 

func (UnimplementedLeaderboardServer) Touch(context.Context, *LeaderboardTouchRequest) (*LeaderboardTouchResponse, error)

type UnimplementedMailboxServer 

type UnimplementedMailboxServer struct {
}

UnimplementedMailboxServer must be embedded to have forward compatible implementations.

func (UnimplementedMailboxServer) List 

func (UnimplementedMailboxServer) List(context.Context, *MailboxListRequest) (*MailboxListResponse, error)

func (UnimplementedMailboxServer) Pull 

func (UnimplementedMailboxServer) Pull(context.Context, *MailboxPullRequest) (*MailboxPullResponse, error)

func (UnimplementedMailboxServer) Send 

func (UnimplementedMailboxServer) Send(context.Context, *MailboxSendRequest) (*MailboxSendResponse, error)

type UnimplementedOrderServer 

type UnimplementedOrderServer struct {
}

UnimplementedOrderServer must be embedded to have forward compatible implementations.

func (UnimplementedOrderServer) Cancel 

func (UnimplementedOrderServer) Cancel(context.Context, *OrderCancelRequest) (*OrderCancelResponse, error)

func (UnimplementedOrderServer) Create 

func (UnimplementedOrderServer) Create(context.Context, *OrderCreateRequest) (*OrderCreateResponse, error)

func (UnimplementedOrderServer) Fulfill 

func (UnimplementedOrderServer) Fulfill(context.Context, *OrderFulfillRequest) (*OrderFulfillResponse, error)

func (UnimplementedOrderServer) Get 

func (UnimplementedOrderServer) Get(context.Context, *OrderGetRequest) (*OrderGetResponse, error)

func (UnimplementedOrderServer) Pay 

func (UnimplementedOrderServer) Pay(context.Context, *OrderPayRequest) (*OrderPayResponse, error)

type UnimplementedPubSubServiceServer 

type UnimplementedPubSubServiceServer struct {
}

UnimplementedPubSubServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedPubSubServiceServer) Consume 

func (UnimplementedPubSubServiceServer) Consume(context.Context, *PubSub_ConsumeRequest) (*PubSub_ConsumeResponse, error)

func (UnimplementedPubSubServiceServer) Publish 

func (UnimplementedPubSubServiceServer) Publish(context.Context, *PubSub_PublishRequest) (*PubSub_PublishResponse, error)

func (UnimplementedPubSubServiceServer) Subscribe 

func (UnimplementedPubSubServiceServer) Subscribe(*PubSub_SubscribeRequest, PubSubService_SubscribeServer) error

type UnimplementedRoleServer 

type UnimplementedRoleServer struct {
}

UnimplementedRoleServer must be embedded to have forward compatible implementations.

func (UnimplementedRoleServer) AlterIndex 

func (UnimplementedRoleServer) AlterIndex(context.Context, *RoleAlterIndexRequest) (*RoleAlterIndexResponse, error)

func (UnimplementedRoleServer) Create 

func (UnimplementedRoleServer) Create(context.Context, *RoleCreateRequest) (*RoleCreateResponse, error)

func (UnimplementedRoleServer) Get 

func (UnimplementedRoleServer) Get(context.Context, *RoleGetRequest) (*RoleGetResponse, error)

func (UnimplementedRoleServer) GetMetadata 

func (UnimplementedRoleServer) GetMetadata(context.Context, *RoleGetMetadataRequest) (*RoleGetMetadataResponse, error)

func (UnimplementedRoleServer) List 

func (UnimplementedRoleServer) List(context.Context, *RoleListRequest) (*RoleListResponse, error)

func (UnimplementedRoleServer) SetMetadata 

func (UnimplementedRoleServer) SetMetadata(context.Context, *RoleSetMetadataRequest) (*RoleSetMetadataResponse, error)

func (UnimplementedRoleServer) SignIn 

func (UnimplementedRoleServer) SignIn(context.Context, *RoleSignInRequest) (*RoleSignInResponse, error)

type UnimplementedSubstrIndex1ServiceServer 

type UnimplementedSubstrIndex1ServiceServer struct {
}

UnimplementedSubstrIndex1ServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedSubstrIndex1ServiceServer) Remove 

func (UnimplementedSubstrIndex1ServiceServer) Remove(context.Context, *SubstrIndex1_RemoveRequest) (*SubstrIndex1_RemoveResponse, error)

func (UnimplementedSubstrIndex1ServiceServer) Search 

func (UnimplementedSubstrIndex1ServiceServer) Search(context.Context, *SubstrIndex1_SearchRequest) (*SubstrIndex1_SearchResponse, error)

func (UnimplementedSubstrIndex1ServiceServer) Update 

func (UnimplementedSubstrIndex1ServiceServer) Update(context.Context, *SubstrIndex1_UpdateRequest) (*SubstrIndex1_UpdateResponse, error)

type UnimplementedUserServer 

type UnimplementedUserServer struct {
}

UnimplementedUserServer must be embedded to have forward compatible implementations.

func (UnimplementedUserServer) Ban 

func (UnimplementedUserServer) Ban(context.Context, *UserBanRequest) (*UserBanResponse, error)

func (UnimplementedUserServer) Bind 

func (UnimplementedUserServer) Bind(context.Context, *UserBindRequest) (*UserBindResponse, error)

func (UnimplementedUserServer) BindAcctId 

func (UnimplementedUserServer) BindAcctId(context.Context, *UserBindAcctIdRequest) (*UserBindAcctIdResponse, error)

func (UnimplementedUserServer) Block 

func (UnimplementedUserServer) Block(context.Context, *UserBlockRequest) (*UserBlockResponse, error)

func (UnimplementedUserServer) Get 

func (UnimplementedUserServer) Get(context.Context, *UserGetRequest) (*UserGetResponse, error)

func (UnimplementedUserServer) GetMetadata 

func (UnimplementedUserServer) GetMetadata(context.Context, *UserGetMetadataRequest) (*UserGetMetadataResponse, error)

func (UnimplementedUserServer) Login 

func (UnimplementedUserServer) Login(context.Context, *UserLoginRequest) (*UserLoginResponse, error)

func (UnimplementedUserServer) Logout 

func (UnimplementedUserServer) Logout(context.Context, *UserLogoutRequest) (*UserLogoutResponse, error)

func (UnimplementedUserServer) Query 

func (UnimplementedUserServer) Query(context.Context, *UserQueryRequest) (*UserQueryResponse, error)

func (UnimplementedUserServer) SetMetadata 

func (UnimplementedUserServer) SetMetadata(context.Context, *UserSetMetadataRequest) (*UserSetMetadataResponse, error)

func (UnimplementedUserServer) Unbind 

func (UnimplementedUserServer) Unbind(context.Context, *UserUnbindRequest) (*UserUnbindResponse, error)

type UnsafeBubbleChartServer 

type UnsafeBubbleChartServer interface {
	// contains filtered or unexported methods
}

UnsafeBubbleChartServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to BubbleChartServer will result in compilation errors.

type UnsafeCacheServer 

type UnsafeCacheServer interface {
	// contains filtered or unexported methods
}

UnsafeCacheServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to CacheServer will result in compilation errors.

type UnsafeDatabaseServer 

type UnsafeDatabaseServer interface {
	// contains filtered or unexported methods
}

UnsafeDatabaseServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DatabaseServer will result in compilation errors.

type UnsafeDistlockServer 

type UnsafeDistlockServer interface {
	// contains filtered or unexported methods
}

UnsafeDistlockServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DistlockServer will result in compilation errors.

type UnsafeFileServiceServer 

type UnsafeFileServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeFileServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to FileServiceServer will result in compilation errors.

type UnsafeGatewayServer 

type UnsafeGatewayServer interface {
	// contains filtered or unexported methods
}

UnsafeGatewayServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to GatewayServer will result in compilation errors.

type UnsafeGiftServer 

type UnsafeGiftServer interface {
	// contains filtered or unexported methods
}

UnsafeGiftServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to GiftServer will result in compilation errors.

type UnsafeLeaderboardServer 

type UnsafeLeaderboardServer interface {
	// contains filtered or unexported methods
}

UnsafeLeaderboardServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to LeaderboardServer will result in compilation errors.

type UnsafeMailboxServer 

type UnsafeMailboxServer interface {
	// contains filtered or unexported methods
}

UnsafeMailboxServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to MailboxServer will result in compilation errors.

type UnsafeOrderServer 

type UnsafeOrderServer interface {
	// contains filtered or unexported methods
}

UnsafeOrderServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to OrderServer will result in compilation errors.

type UnsafePubSubServiceServer 

type UnsafePubSubServiceServer interface {
	// contains filtered or unexported methods
}

UnsafePubSubServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to PubSubServiceServer will result in compilation errors.

type UnsafeRoleServer 

type UnsafeRoleServer interface {
	// contains filtered or unexported methods
}

UnsafeRoleServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to RoleServer will result in compilation errors.

type UnsafeSubstrIndex1ServiceServer 

type UnsafeSubstrIndex1ServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeSubstrIndex1ServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to SubstrIndex1ServiceServer will result in compilation errors.

type UnsafeUserServer 

type UnsafeUserServer interface {
	// contains filtered or unexported methods
}

UnsafeUserServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to UserServer will result in compilation errors.

type UserBanRequest 

type UserBanRequest struct {
	UserIds []string `protobuf:"bytes,1,rep,name=user_ids,json=userIds,proto3" json:"user_ids,omitempty"`
	Seconds int64    `protobuf:"varint,2,opt,name=seconds,proto3" json:"seconds,omitempty"` // unban if less than 0
	Reason  string   `protobuf:"bytes,3,opt,name=reason,proto3" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

func (*UserBanRequest) Descriptor deprecated 

func (*UserBanRequest) Descriptor() ([]byte, []int)

Deprecated: Use UserBanRequest.ProtoReflect.Descriptor instead.

func (*UserBanRequest) GetReason 

func (x *UserBanRequest) GetReason() string

func (*UserBanRequest) GetSeconds 

func (x *UserBanRequest) GetSeconds() int64

func (*UserBanRequest) GetUserIds 

func (x *UserBanRequest) GetUserIds() []string

func (*UserBanRequest) ProtoMessage 

func (*UserBanRequest) ProtoMessage()

func (*UserBanRequest) ProtoReflect 

func (x *UserBanRequest) ProtoReflect() protoreflect.Message

func (*UserBanRequest) Reset 

func (x *UserBanRequest) Reset()

func (*UserBanRequest) String 

func (x *UserBanRequest) String() string

type UserBanResponse 

type UserBanResponse struct {
	States []*UserBanState `protobuf:"bytes,1,rep,name=states,proto3" json:"states,omitempty"`
	// contains filtered or unexported fields
}

func (*UserBanResponse) Descriptor deprecated 

func (*UserBanResponse) Descriptor() ([]byte, []int)

Deprecated: Use UserBanResponse.ProtoReflect.Descriptor instead.

func (*UserBanResponse) GetStates 

func (x *UserBanResponse) GetStates() []*UserBanState

func (*UserBanResponse) ProtoMessage 

func (*UserBanResponse) ProtoMessage()

func (*UserBanResponse) ProtoReflect 

func (x *UserBanResponse) ProtoReflect() protoreflect.Message

func (*UserBanResponse) Reset 

func (x *UserBanResponse) Reset()

func (*UserBanResponse) String 

func (x *UserBanResponse) String() string

type UserBanState 

type UserBanState struct {
	Id     string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	BanTo  int64  `protobuf:"varint,2,opt,name=ban_to,json=banTo,proto3" json:"ban_to,omitempty"`
	BanFor string `protobuf:"bytes,3,opt,name=ban_for,json=banFor,proto3" json:"ban_for,omitempty"`
	BanAt  int64  `protobuf:"varint,4,opt,name=ban_at,json=banAt,proto3" json:"ban_at,omitempty"`
	// contains filtered or unexported fields
}

func (*UserBanState) Descriptor deprecated 

func (*UserBanState) Descriptor() ([]byte, []int)

Deprecated: Use UserBanState.ProtoReflect.Descriptor instead.

func (*UserBanState) GetBanAt 

func (x *UserBanState) GetBanAt() int64

func (*UserBanState) GetBanFor 

func (x *UserBanState) GetBanFor() string

func (*UserBanState) GetBanTo 

func (x *UserBanState) GetBanTo() int64

func (*UserBanState) GetId 

func (x *UserBanState) GetId() string

func (*UserBanState) ProtoMessage 

func (*UserBanState) ProtoMessage()

func (*UserBanState) ProtoReflect 

func (x *UserBanState) ProtoReflect() protoreflect.Message

func (*UserBanState) Reset 

func (x *UserBanState) Reset()

func (*UserBanState) String 

func (x *UserBanState) String() string

type UserBindAcctIdRequest 

type UserBindAcctIdRequest struct {
	UserId                     string   `protobuf:"bytes,1,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`    // 目标用户
	AcctIds                    []string `protobuf:"bytes,2,rep,name=acct_ids,json=acctIds,proto3" json:"acct_ids,omitempty"` // 要转移的账号
	TakeOverAcctIdIfDuplicated bool     ``                                                                                   /* 148-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*UserBindAcctIdRequest) Descriptor deprecated 

func (*UserBindAcctIdRequest) Descriptor() ([]byte, []int)

Deprecated: Use UserBindAcctIdRequest.ProtoReflect.Descriptor instead.

func (*UserBindAcctIdRequest) GetAcctIds 

func (x *UserBindAcctIdRequest) GetAcctIds() []string

func (*UserBindAcctIdRequest) GetTakeOverAcctIdIfDuplicated 

func (x *UserBindAcctIdRequest) GetTakeOverAcctIdIfDuplicated() bool

func (*UserBindAcctIdRequest) GetUserId 

func (x *UserBindAcctIdRequest) GetUserId() string

func (*UserBindAcctIdRequest) ProtoMessage 

func (*UserBindAcctIdRequest) ProtoMessage()

func (*UserBindAcctIdRequest) ProtoReflect 

func (x *UserBindAcctIdRequest) ProtoReflect() protoreflect.Message

func (*UserBindAcctIdRequest) Reset 

func (x *UserBindAcctIdRequest) Reset()

func (*UserBindAcctIdRequest) String 

func (x *UserBindAcctIdRequest) String() string

type UserBindAcctIdResponse 

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

func (*UserBindAcctIdResponse) Descriptor deprecated 

func (*UserBindAcctIdResponse) Descriptor() ([]byte, []int)

Deprecated: Use UserBindAcctIdResponse.ProtoReflect.Descriptor instead.

func (*UserBindAcctIdResponse) ProtoMessage 

func (*UserBindAcctIdResponse) ProtoMessage()

func (*UserBindAcctIdResponse) ProtoReflect 

func (x *UserBindAcctIdResponse) ProtoReflect() protoreflect.Message

func (*UserBindAcctIdResponse) Reset 

func (x *UserBindAcctIdResponse) Reset()

func (*UserBindAcctIdResponse) String 

func (x *UserBindAcctIdResponse) String() string

type UserBindRequest 

type UserBindRequest struct {
	UserId string     `protobuf:"bytes,1,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	State  *anypb.Any `protobuf:"bytes,2,opt,name=state,proto3" json:"state,omitempty"`
	// contains filtered or unexported fields
}

func (*UserBindRequest) Descriptor deprecated 

func (*UserBindRequest) Descriptor() ([]byte, []int)

Deprecated: Use UserBindRequest.ProtoReflect.Descriptor instead.

func (*UserBindRequest) GetState 

func (x *UserBindRequest) GetState() *anypb.Any

func (*UserBindRequest) GetUserId 

func (x *UserBindRequest) GetUserId() string

func (*UserBindRequest) ProtoMessage 

func (*UserBindRequest) ProtoMessage()

func (*UserBindRequest) ProtoReflect 

func (x *UserBindRequest) ProtoReflect() protoreflect.Message

func (*UserBindRequest) Reset 

func (x *UserBindRequest) Reset()

func (*UserBindRequest) String 

func (x *UserBindRequest) String() string

type UserBindResponse 

type UserBindResponse struct {
	AcctIds []string `protobuf:"bytes,1,rep,name=acct_ids,json=acctIds,proto3" json:"acct_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*UserBindResponse) Descriptor deprecated 

func (*UserBindResponse) Descriptor() ([]byte, []int)

Deprecated: Use UserBindResponse.ProtoReflect.Descriptor instead.

func (*UserBindResponse) GetAcctIds 

func (x *UserBindResponse) GetAcctIds() []string

func (*UserBindResponse) ProtoMessage 

func (*UserBindResponse) ProtoMessage()

func (*UserBindResponse) ProtoReflect 

func (x *UserBindResponse) ProtoReflect() protoreflect.Message

func (*UserBindResponse) Reset 

func (x *UserBindResponse) Reset()

func (*UserBindResponse) String 

func (x *UserBindResponse) String() string

type UserBlockRequest 

type UserBlockRequest struct {
	Keys      []string `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"`
	Seconds   int64    `protobuf:"varint,2,opt,name=seconds,proto3" json:"seconds,omitempty"` // unban if less than 0
	Reason    string   `protobuf:"bytes,3,opt,name=reason,proto3" json:"reason,omitempty"`
	AcctIds   []string `protobuf:"bytes,8,rep,name=acct_ids,json=acctIds,proto3" json:"acct_ids,omitempty"`
	DeviceIds []string `protobuf:"bytes,9,rep,name=device_ids,json=deviceIds,proto3" json:"device_ids,omitempty"`
	ClientIps []string `protobuf:"bytes,10,rep,name=client_ips,json=clientIps,proto3" json:"client_ips,omitempty"`
	// contains filtered or unexported fields
}

func (*UserBlockRequest) Descriptor deprecated 

func (*UserBlockRequest) Descriptor() ([]byte, []int)

Deprecated: Use UserBlockRequest.ProtoReflect.Descriptor instead.

func (*UserBlockRequest) GetAcctIds 

func (x *UserBlockRequest) GetAcctIds() []string

func (*UserBlockRequest) GetClientIps 

func (x *UserBlockRequest) GetClientIps() []string

func (*UserBlockRequest) GetDeviceIds 

func (x *UserBlockRequest) GetDeviceIds() []string

func (*UserBlockRequest) GetKeys 

func (x *UserBlockRequest) GetKeys() []string

func (*UserBlockRequest) GetReason 

func (x *UserBlockRequest) GetReason() string

func (*UserBlockRequest) GetSeconds 

func (x *UserBlockRequest) GetSeconds() int64

func (*UserBlockRequest) ProtoMessage 

func (*UserBlockRequest) ProtoMessage()

func (*UserBlockRequest) ProtoReflect 

func (x *UserBlockRequest) ProtoReflect() protoreflect.Message

func (*UserBlockRequest) Reset 

func (x *UserBlockRequest) Reset()

func (*UserBlockRequest) String 

func (x *UserBlockRequest) String() string

type UserBlockResponse 

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

func (*UserBlockResponse) Descriptor deprecated 

func (*UserBlockResponse) Descriptor() ([]byte, []int)

Deprecated: Use UserBlockResponse.ProtoReflect.Descriptor instead.

func (*UserBlockResponse) ProtoMessage 

func (*UserBlockResponse) ProtoMessage()

func (*UserBlockResponse) ProtoReflect 

func (x *UserBlockResponse) ProtoReflect() protoreflect.Message

func (*UserBlockResponse) Reset 

func (x *UserBlockResponse) Reset()

func (*UserBlockResponse) String 

func (x *UserBlockResponse) String() string

type UserClient 

type UserClient interface {
	// 查询详细信息
	Get(ctx context.Context, in *UserGetRequest, opts ...grpc.CallOption) (*UserGetResponse, error)
	// 扩展查询
	Query(ctx context.Context, in *UserQueryRequest, opts ...grpc.CallOption) (*UserQueryResponse, error)
	// 封禁
	Ban(ctx context.Context, in *UserBanRequest, opts ...grpc.CallOption) (*UserBanResponse, error)
	// 扩展封禁
	Block(ctx context.Context, in *UserBlockRequest, opts ...grpc.CallOption) (*UserBlockResponse, error)
	// 绑定
	BindAcctId(ctx context.Context, in *UserBindAcctIdRequest, opts ...grpc.CallOption) (*UserBindAcctIdResponse, error)
	Login(ctx context.Context, in *UserLoginRequest, opts ...grpc.CallOption) (*UserLoginResponse, error)
	Logout(ctx context.Context, in *UserLogoutRequest, opts ...grpc.CallOption) (*UserLogoutResponse, error)
	Bind(ctx context.Context, in *UserBindRequest, opts ...grpc.CallOption) (*UserBindResponse, error)
	Unbind(ctx context.Context, in *UserUnbindRequest, opts ...grpc.CallOption) (*UserUnbindResponse, error)
	SetMetadata(ctx context.Context, in *UserSetMetadataRequest, opts ...grpc.CallOption) (*UserSetMetadataResponse, error)
	GetMetadata(ctx context.Context, in *UserGetMetadataRequest, opts ...grpc.CallOption) (*UserGetMetadataResponse, error)
}

UserClient is the client API for User service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewUserClient 

func NewUserClient(cc grpc.ClientConnInterface) UserClient

type UserData 

type UserData struct {
	Id       string            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	AcctIds  []string          `protobuf:"bytes,4,rep,name=acct_ids,json=acctIds,proto3" json:"acct_ids,omitempty"`
	CreateAt int64             `protobuf:"varint,5,opt,name=create_at,json=createAt,proto3" json:"create_at,omitempty"`
	LoginAt  int64             `protobuf:"varint,6,opt,name=login_at,json=loginAt,proto3" json:"login_at,omitempty"`
	LoginIp  string            `protobuf:"bytes,7,opt,name=login_ip,json=loginIp,proto3" json:"login_ip,omitempty"`
	BanTo    int64             `protobuf:"varint,8,opt,name=ban_to,json=banTo,proto3" json:"ban_to,omitempty"`
	BanFor   string            `protobuf:"bytes,9,opt,name=ban_for,json=banFor,proto3" json:"ban_for,omitempty"`
	BanAt    int64             `protobuf:"varint,10,opt,name=ban_at,json=banAt,proto3" json:"ban_at,omitempty"`
	Metadata map[string]string `` /* 158-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*UserData) Descriptor deprecated 

func (*UserData) Descriptor() ([]byte, []int)

Deprecated: Use UserData.ProtoReflect.Descriptor instead.

func (*UserData) GetAcctIds 

func (x *UserData) GetAcctIds() []string

func (*UserData) GetBanAt 

func (x *UserData) GetBanAt() int64

func (*UserData) GetBanFor 

func (x *UserData) GetBanFor() string

func (*UserData) GetBanTo 

func (x *UserData) GetBanTo() int64

func (*UserData) GetCreateAt 

func (x *UserData) GetCreateAt() int64

func (*UserData) GetId 

func (x *UserData) GetId() string

func (*UserData) GetLoginAt 

func (x *UserData) GetLoginAt() int64

func (*UserData) GetLoginIp 

func (x *UserData) GetLoginIp() string

func (*UserData) GetMetadata 

func (x *UserData) GetMetadata() map[string]string

func (*UserData) ProtoMessage 

func (*UserData) ProtoMessage()

func (*UserData) ProtoReflect 

func (x *UserData) ProtoReflect() protoreflect.Message

func (*UserData) Reset 

func (x *UserData) Reset()

func (*UserData) String 

func (x *UserData) String() string

type UserGetMetadataRequest 

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

func (*UserGetMetadataRequest) Descriptor deprecated 

func (*UserGetMetadataRequest) Descriptor() ([]byte, []int)

Deprecated: Use UserGetMetadataRequest.ProtoReflect.Descriptor instead.

func (*UserGetMetadataRequest) GetKeys 

func (x *UserGetMetadataRequest) GetKeys() []string

func (*UserGetMetadataRequest) GetUserId 

func (x *UserGetMetadataRequest) GetUserId() string

func (*UserGetMetadataRequest) ProtoMessage 

func (*UserGetMetadataRequest) ProtoMessage()

func (*UserGetMetadataRequest) ProtoReflect 

func (x *UserGetMetadataRequest) ProtoReflect() protoreflect.Message

func (*UserGetMetadataRequest) Reset 

func (x *UserGetMetadataRequest) Reset()

func (*UserGetMetadataRequest) String 

func (x *UserGetMetadataRequest) String() string

type UserGetMetadataResponse 

type UserGetMetadataResponse struct {
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*UserGetMetadataResponse) Descriptor deprecated 

func (*UserGetMetadataResponse) Descriptor() ([]byte, []int)

Deprecated: Use UserGetMetadataResponse.ProtoReflect.Descriptor instead.

func (*UserGetMetadataResponse) GetMetadata 

func (x *UserGetMetadataResponse) GetMetadata() map[string]string

func (*UserGetMetadataResponse) ProtoMessage 

func (*UserGetMetadataResponse) ProtoMessage()

func (*UserGetMetadataResponse) ProtoReflect 

func (x *UserGetMetadataResponse) ProtoReflect() protoreflect.Message

func (*UserGetMetadataResponse) Reset 

func (x *UserGetMetadataResponse) Reset()

func (*UserGetMetadataResponse) String 

func (x *UserGetMetadataResponse) String() string

type UserGetRequest 

type UserGetRequest struct {
	Ids     []string                `protobuf:"bytes,1,rep,name=ids,proto3" json:"ids,omitempty"`
	Options *UserGetRequest_Options `protobuf:"bytes,10,opt,name=options,proto3" json:"options,omitempty"` // get options
	// contains filtered or unexported fields
}

func (*UserGetRequest) Descriptor deprecated 

func (*UserGetRequest) Descriptor() ([]byte, []int)

Deprecated: Use UserGetRequest.ProtoReflect.Descriptor instead.

func (*UserGetRequest) GetIds 

func (x *UserGetRequest) GetIds() []string

func (*UserGetRequest) GetOptions 

func (x *UserGetRequest) GetOptions() *UserGetRequest_Options

func (*UserGetRequest) ProtoMessage 

func (*UserGetRequest) ProtoMessage()

func (*UserGetRequest) ProtoReflect 

func (x *UserGetRequest) ProtoReflect() protoreflect.Message

func (*UserGetRequest) Reset 

func (x *UserGetRequest) Reset()

func (*UserGetRequest) String 

func (x *UserGetRequest) String() string

type UserGetRequest_Options 

type UserGetRequest_Options struct {
	Fuzzy     bool `protobuf:"varint,1,opt,name=fuzzy,proto3" json:"fuzzy,omitempty"`                          // id may be user or role
	WithRoles bool `protobuf:"varint,2,opt,name=with_roles,json=withRoles,proto3" json:"with_roles,omitempty"` // get user and related roles
	// contains filtered or unexported fields
}

func (*UserGetRequest_Options) Descriptor deprecated 

func (*UserGetRequest_Options) Descriptor() ([]byte, []int)

Deprecated: Use UserGetRequest_Options.ProtoReflect.Descriptor instead.

func (*UserGetRequest_Options) GetFuzzy 

func (x *UserGetRequest_Options) GetFuzzy() bool

func (*UserGetRequest_Options) GetWithRoles 

func (x *UserGetRequest_Options) GetWithRoles() bool

func (*UserGetRequest_Options) ProtoMessage 

func (*UserGetRequest_Options) ProtoMessage()

func (*UserGetRequest_Options) ProtoReflect 

func (x *UserGetRequest_Options) ProtoReflect() protoreflect.Message

func (*UserGetRequest_Options) Reset 

func (x *UserGetRequest_Options) Reset()

func (*UserGetRequest_Options) String 

func (x *UserGetRequest_Options) String() string

type UserGetResponse 

type UserGetResponse struct {
	Users []*UserData `protobuf:"bytes,1,rep,name=users,proto3" json:"users,omitempty"`
	Roles []*RoleData `protobuf:"bytes,2,rep,name=roles,proto3" json:"roles,omitempty"`
	// contains filtered or unexported fields
}

func (*UserGetResponse) Descriptor deprecated 

func (*UserGetResponse) Descriptor() ([]byte, []int)

Deprecated: Use UserGetResponse.ProtoReflect.Descriptor instead.

func (*UserGetResponse) GetRoles 

func (x *UserGetResponse) GetRoles() []*RoleData

func (*UserGetResponse) GetUsers 

func (x *UserGetResponse) GetUsers() []*UserData

func (*UserGetResponse) ProtoMessage 

func (*UserGetResponse) ProtoMessage()

func (*UserGetResponse) ProtoReflect 

func (x *UserGetResponse) ProtoReflect() protoreflect.Message

func (*UserGetResponse) Reset 

func (x *UserGetResponse) Reset()

func (*UserGetResponse) String 

func (x *UserGetResponse) String() string

type UserLoginRequest 

type UserLoginRequest struct {
	AppId  string                   `protobuf:"bytes,1,opt,name=app_id,json=appId,proto3" json:"app_id,omitempty"`
	State  *anypb.Any               `protobuf:"bytes,2,opt,name=state,proto3" json:"state,omitempty"`
	Device *UserLoginRequest_Device `protobuf:"bytes,5,opt,name=device,proto3" json:"device,omitempty"`
	Client *UserLoginRequest_Client `protobuf:"bytes,6,opt,name=client,proto3" json:"client,omitempty"`
	// options
	CreateIfNotFound bool `protobuf:"varint,10,opt,name=create_if_not_found,json=createIfNotFound,proto3" json:"create_if_not_found,omitempty"`
	// contains filtered or unexported fields
}

func (*UserLoginRequest) Descriptor deprecated 

func (*UserLoginRequest) Descriptor() ([]byte, []int)

Deprecated: Use UserLoginRequest.ProtoReflect.Descriptor instead.

func (*UserLoginRequest) GetAppId 

func (x *UserLoginRequest) GetAppId() string

func (*UserLoginRequest) GetClient 

func (x *UserLoginRequest) GetClient() *UserLoginRequest_Client

func (*UserLoginRequest) GetCreateIfNotFound 

func (x *UserLoginRequest) GetCreateIfNotFound() bool

func (*UserLoginRequest) GetDevice 

func (x *UserLoginRequest) GetDevice() *UserLoginRequest_Device

func (*UserLoginRequest) GetState 

func (x *UserLoginRequest) GetState() *anypb.Any

func (*UserLoginRequest) ProtoMessage 

func (*UserLoginRequest) ProtoMessage()

func (*UserLoginRequest) ProtoReflect 

func (x *UserLoginRequest) ProtoReflect() protoreflect.Message

func (*UserLoginRequest) Reset 

func (x *UserLoginRequest) Reset()

func (*UserLoginRequest) String 

func (x *UserLoginRequest) String() string

type UserLoginRequest_Client 

type UserLoginRequest_Client struct {
	Ip      string `protobuf:"bytes,1,opt,name=ip,proto3" json:"ip,omitempty"`
	Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

客户端信息

func (*UserLoginRequest_Client) Descriptor deprecated 

func (*UserLoginRequest_Client) Descriptor() ([]byte, []int)

Deprecated: Use UserLoginRequest_Client.ProtoReflect.Descriptor instead.

func (*UserLoginRequest_Client) GetIp 

func (x *UserLoginRequest_Client) GetIp() string

func (*UserLoginRequest_Client) GetVersion 

func (x *UserLoginRequest_Client) GetVersion() string

func (*UserLoginRequest_Client) ProtoMessage 

func (*UserLoginRequest_Client) ProtoMessage()

func (*UserLoginRequest_Client) ProtoReflect 

func (x *UserLoginRequest_Client) ProtoReflect() protoreflect.Message

func (*UserLoginRequest_Client) Reset 

func (x *UserLoginRequest_Client) Reset()

func (*UserLoginRequest_Client) String 

func (x *UserLoginRequest_Client) String() string

type UserLoginRequest_Device 

type UserLoginRequest_Device struct {
	Id    string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name  string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Model string `protobuf:"bytes,3,opt,name=model,proto3" json:"model,omitempty"`
	Os    string `protobuf:"bytes,4,opt,name=os,proto3" json:"os,omitempty"`
	// contains filtered or unexported fields
}

设备信息

func (*UserLoginRequest_Device) Descriptor deprecated 

func (*UserLoginRequest_Device) Descriptor() ([]byte, []int)

Deprecated: Use UserLoginRequest_Device.ProtoReflect.Descriptor instead.

func (*UserLoginRequest_Device) GetId 

func (x *UserLoginRequest_Device) GetId() string

func (*UserLoginRequest_Device) GetModel 

func (x *UserLoginRequest_Device) GetModel() string

func (*UserLoginRequest_Device) GetName 

func (x *UserLoginRequest_Device) GetName() string

func (*UserLoginRequest_Device) GetOs 

func (x *UserLoginRequest_Device) GetOs() string

func (*UserLoginRequest_Device) ProtoMessage 

func (*UserLoginRequest_Device) ProtoMessage()

func (*UserLoginRequest_Device) ProtoReflect 

func (x *UserLoginRequest_Device) ProtoReflect() protoreflect.Message

func (*UserLoginRequest_Device) Reset 

func (x *UserLoginRequest_Device) Reset()

func (*UserLoginRequest_Device) String 

func (x *UserLoginRequest_Device) String() string

type UserLoginResponse 

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

func (*UserLoginResponse) Descriptor deprecated 

func (*UserLoginResponse) Descriptor() ([]byte, []int)

Deprecated: Use UserLoginResponse.ProtoReflect.Descriptor instead.

func (*UserLoginResponse) GetUser 

func (x *UserLoginResponse) GetUser() *UserData

func (*UserLoginResponse) ProtoMessage 

func (*UserLoginResponse) ProtoMessage()

func (*UserLoginResponse) ProtoReflect 

func (x *UserLoginResponse) ProtoReflect() protoreflect.Message

func (*UserLoginResponse) Reset 

func (x *UserLoginResponse) Reset()

func (*UserLoginResponse) String 

func (x *UserLoginResponse) String() string

type UserLogoutRequest 

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

func (*UserLogoutRequest) Descriptor deprecated 

func (*UserLogoutRequest) Descriptor() ([]byte, []int)

Deprecated: Use UserLogoutRequest.ProtoReflect.Descriptor instead.

func (*UserLogoutRequest) GetUserId 

func (x *UserLogoutRequest) GetUserId() string

func (*UserLogoutRequest) ProtoMessage 

func (*UserLogoutRequest) ProtoMessage()

func (*UserLogoutRequest) ProtoReflect 

func (x *UserLogoutRequest) ProtoReflect() protoreflect.Message

func (*UserLogoutRequest) Reset 

func (x *UserLogoutRequest) Reset()

func (*UserLogoutRequest) String 

func (x *UserLogoutRequest) String() string

type UserLogoutResponse 

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

func (*UserLogoutResponse) Descriptor deprecated 

func (*UserLogoutResponse) Descriptor() ([]byte, []int)

Deprecated: Use UserLogoutResponse.ProtoReflect.Descriptor instead.

func (*UserLogoutResponse) ProtoMessage 

func (*UserLogoutResponse) ProtoMessage()

func (*UserLogoutResponse) ProtoReflect 

func (x *UserLogoutResponse) ProtoReflect() protoreflect.Message

func (*UserLogoutResponse) Reset 

func (x *UserLogoutResponse) Reset()

func (*UserLogoutResponse) String 

func (x *UserLogoutResponse) String() string

type UserQueryRequest 

type UserQueryRequest struct {
	Options *UserQueryRequest_Options `protobuf:"bytes,1,opt,name=options,proto3" json:"options,omitempty"`
	Filters *UserQueryRequest_Filters `protobuf:"bytes,2,opt,name=filters,proto3" json:"filters,omitempty"`
	// contains filtered or unexported fields
}

func (*UserQueryRequest) Descriptor deprecated 

func (*UserQueryRequest) Descriptor() ([]byte, []int)

Deprecated: Use UserQueryRequest.ProtoReflect.Descriptor instead.

func (*UserQueryRequest) GetFilters 

func (x *UserQueryRequest) GetFilters() *UserQueryRequest_Filters

func (*UserQueryRequest) GetOptions 

func (x *UserQueryRequest) GetOptions() *UserQueryRequest_Options

func (*UserQueryRequest) ProtoMessage 

func (*UserQueryRequest) ProtoMessage()

func (*UserQueryRequest) ProtoReflect 

func (x *UserQueryRequest) ProtoReflect() protoreflect.Message

func (*UserQueryRequest) Reset 

func (x *UserQueryRequest) Reset()

func (*UserQueryRequest) String 

func (x *UserQueryRequest) String() string

type UserQueryRequest_Filters 

type UserQueryRequest_Filters struct {
	AcctDetails map[string]string `` /* 182-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*UserQueryRequest_Filters) Descriptor deprecated 

func (*UserQueryRequest_Filters) Descriptor() ([]byte, []int)

Deprecated: Use UserQueryRequest_Filters.ProtoReflect.Descriptor instead.

func (*UserQueryRequest_Filters) GetAcctDetails 

func (x *UserQueryRequest_Filters) GetAcctDetails() map[string]string

func (*UserQueryRequest_Filters) ProtoMessage 

func (*UserQueryRequest_Filters) ProtoMessage()

func (*UserQueryRequest_Filters) ProtoReflect 

func (x *UserQueryRequest_Filters) ProtoReflect() protoreflect.Message

func (*UserQueryRequest_Filters) Reset 

func (x *UserQueryRequest_Filters) Reset()

func (*UserQueryRequest_Filters) String 

func (x *UserQueryRequest_Filters) String() string

type UserQueryRequest_Options 

type UserQueryRequest_Options struct {
	WithRoles bool `protobuf:"varint,2,opt,name=with_roles,json=withRoles,proto3" json:"with_roles,omitempty"`
	// contains filtered or unexported fields
}

func (*UserQueryRequest_Options) Descriptor deprecated 

func (*UserQueryRequest_Options) Descriptor() ([]byte, []int)

Deprecated: Use UserQueryRequest_Options.ProtoReflect.Descriptor instead.

func (*UserQueryRequest_Options) GetWithRoles 

func (x *UserQueryRequest_Options) GetWithRoles() bool

func (*UserQueryRequest_Options) ProtoMessage 

func (*UserQueryRequest_Options) ProtoMessage()

func (*UserQueryRequest_Options) ProtoReflect 

func (x *UserQueryRequest_Options) ProtoReflect() protoreflect.Message

func (*UserQueryRequest_Options) Reset 

func (x *UserQueryRequest_Options) Reset()

func (*UserQueryRequest_Options) String 

func (x *UserQueryRequest_Options) String() string

type UserQueryResponse 

type UserQueryResponse struct {
	Users []*UserData `protobuf:"bytes,1,rep,name=users,proto3" json:"users,omitempty"`
	Roles []*RoleData `protobuf:"bytes,2,rep,name=roles,proto3" json:"roles,omitempty"`
	// contains filtered or unexported fields
}

func (*UserQueryResponse) Descriptor deprecated 

func (*UserQueryResponse) Descriptor() ([]byte, []int)

Deprecated: Use UserQueryResponse.ProtoReflect.Descriptor instead.

func (*UserQueryResponse) GetRoles 

func (x *UserQueryResponse) GetRoles() []*RoleData

func (*UserQueryResponse) GetUsers 

func (x *UserQueryResponse) GetUsers() []*UserData

func (*UserQueryResponse) ProtoMessage 

func (*UserQueryResponse) ProtoMessage()

func (*UserQueryResponse) ProtoReflect 

func (x *UserQueryResponse) ProtoReflect() protoreflect.Message

func (*UserQueryResponse) Reset 

func (x *UserQueryResponse) Reset()

func (*UserQueryResponse) String 

func (x *UserQueryResponse) String() string

type UserServer 

type UserServer interface {
	// 查询详细信息
	Get(context.Context, *UserGetRequest) (*UserGetResponse, error)
	// 扩展查询
	Query(context.Context, *UserQueryRequest) (*UserQueryResponse, error)
	// 封禁
	Ban(context.Context, *UserBanRequest) (*UserBanResponse, error)
	// 扩展封禁
	Block(context.Context, *UserBlockRequest) (*UserBlockResponse, error)
	// 绑定
	BindAcctId(context.Context, *UserBindAcctIdRequest) (*UserBindAcctIdResponse, error)
	Login(context.Context, *UserLoginRequest) (*UserLoginResponse, error)
	Logout(context.Context, *UserLogoutRequest) (*UserLogoutResponse, error)
	Bind(context.Context, *UserBindRequest) (*UserBindResponse, error)
	Unbind(context.Context, *UserUnbindRequest) (*UserUnbindResponse, error)
	SetMetadata(context.Context, *UserSetMetadataRequest) (*UserSetMetadataResponse, error)
	GetMetadata(context.Context, *UserGetMetadataRequest) (*UserGetMetadataResponse, error)
	// contains filtered or unexported methods
}

UserServer is the server API for User service. All implementations must embed UnimplementedUserServer for forward compatibility

type UserSetMetadataRequest 

type UserSetMetadataRequest struct {
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	UserId   string            `protobuf:"bytes,2,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	// contains filtered or unexported fields
}

func (*UserSetMetadataRequest) Descriptor deprecated 

func (*UserSetMetadataRequest) Descriptor() ([]byte, []int)

Deprecated: Use UserSetMetadataRequest.ProtoReflect.Descriptor instead.

func (*UserSetMetadataRequest) GetMetadata 

func (x *UserSetMetadataRequest) GetMetadata() map[string]string

func (*UserSetMetadataRequest) GetUserId 

func (x *UserSetMetadataRequest) GetUserId() string

func (*UserSetMetadataRequest) ProtoMessage 

func (*UserSetMetadataRequest) ProtoMessage()

func (*UserSetMetadataRequest) ProtoReflect 

func (x *UserSetMetadataRequest) ProtoReflect() protoreflect.Message

func (*UserSetMetadataRequest) Reset 

func (x *UserSetMetadataRequest) Reset()

func (*UserSetMetadataRequest) String 

func (x *UserSetMetadataRequest) String() string

type UserSetMetadataResponse 

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

func (*UserSetMetadataResponse) Descriptor deprecated 

func (*UserSetMetadataResponse) Descriptor() ([]byte, []int)

Deprecated: Use UserSetMetadataResponse.ProtoReflect.Descriptor instead.

func (*UserSetMetadataResponse) ProtoMessage 

func (*UserSetMetadataResponse) ProtoMessage()

func (*UserSetMetadataResponse) ProtoReflect 

func (x *UserSetMetadataResponse) ProtoReflect() protoreflect.Message

func (*UserSetMetadataResponse) Reset 

func (x *UserSetMetadataResponse) Reset()

func (*UserSetMetadataResponse) String 

func (x *UserSetMetadataResponse) String() string

type UserUnbindRequest 

type UserUnbindRequest struct {
	AcctIds []string `protobuf:"bytes,1,rep,name=acct_ids,json=acctIds,proto3" json:"acct_ids,omitempty"`
	UserId  string   `protobuf:"bytes,2,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	// contains filtered or unexported fields
}

func (*UserUnbindRequest) Descriptor deprecated 

func (*UserUnbindRequest) Descriptor() ([]byte, []int)

Deprecated: Use UserUnbindRequest.ProtoReflect.Descriptor instead.

func (*UserUnbindRequest) GetAcctIds 

func (x *UserUnbindRequest) GetAcctIds() []string

func (*UserUnbindRequest) GetUserId 

func (x *UserUnbindRequest) GetUserId() string

func (*UserUnbindRequest) ProtoMessage 

func (*UserUnbindRequest) ProtoMessage()

func (*UserUnbindRequest) ProtoReflect 

func (x *UserUnbindRequest) ProtoReflect() protoreflect.Message

func (*UserUnbindRequest) Reset 

func (x *UserUnbindRequest) Reset()

func (*UserUnbindRequest) String 

func (x *UserUnbindRequest) String() string

type UserUnbindResponse 

type UserUnbindResponse struct {
	AcctIds []string `protobuf:"bytes,1,rep,name=acct_ids,json=acctIds,proto3" json:"acct_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*UserUnbindResponse) Descriptor deprecated 

func (*UserUnbindResponse) Descriptor() ([]byte, []int)

Deprecated: Use UserUnbindResponse.ProtoReflect.Descriptor instead.

func (*UserUnbindResponse) GetAcctIds 

func (x *UserUnbindResponse) GetAcctIds() []string

func (*UserUnbindResponse) ProtoMessage 

func (*UserUnbindResponse) ProtoMessage()

func (*UserUnbindResponse) ProtoReflect 

func (x *UserUnbindResponse) ProtoReflect() protoreflect.Message

func (*UserUnbindResponse) Reset 

func (x *UserUnbindResponse) Reset()

func (*UserUnbindResponse) String 

func (x *UserUnbindResponse) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.