Documentation
¶
Index ¶
- Constants
- Variables
- func RegisterAuthServer(s grpc.ServiceRegistrar, srv AuthServer)
- func RegisterEventRecorderServer(s grpc.ServiceRegistrar, srv EventRecorderServer)
- func RegisterNotifierServer(s grpc.ServiceRegistrar, srv NotifierServer)
- func RegisterPostmanServer(s grpc.ServiceRegistrar, srv PostmanServer)
- func RegisterRealmServer(s grpc.ServiceRegistrar, srv RealmServer)
- func RegisterServiceDirectoryServer(s grpc.ServiceRegistrar, srv ServiceDirectoryServer)
- func RegisterStreamControllerServer(s grpc.ServiceRegistrar, srv StreamControllerServer)
- type AddServiceResponse
- func (*AddServiceResponse) Descriptor() ([]byte, []int)deprecated
- func (x *AddServiceResponse) GetIsSuccess() bool
- func (*AddServiceResponse) ProtoMessage()
- func (x *AddServiceResponse) ProtoReflect() protoreflect.Message
- func (x *AddServiceResponse) Reset()
- func (x *AddServiceResponse) String() string
- type AuthClient
- type AuthInfo
- func (*AuthInfo) Descriptor() ([]byte, []int)deprecated
- func (x *AuthInfo) GetInfo() *UserInfo
- func (x *AuthInfo) GetNewAccessToken() string
- func (x *AuthInfo) GetNewRefreshToken() string
- func (x *AuthInfo) GetPermissions() []byte
- func (x *AuthInfo) GetTicketId() uint64
- func (*AuthInfo) ProtoMessage()
- func (x *AuthInfo) ProtoReflect() protoreflect.Message
- func (x *AuthInfo) Reset()
- func (x *AuthInfo) String() string
- type AuthReply
- type AuthRequest
- func (*AuthRequest) Descriptor() ([]byte, []int)deprecated
- func (x *AuthRequest) GetAccessToken() string
- func (x *AuthRequest) GetRefreshToken() string
- func (*AuthRequest) ProtoMessage()
- func (x *AuthRequest) ProtoReflect() protoreflect.Message
- func (x *AuthRequest) Reset()
- func (x *AuthRequest) String() string
- type AuthServer
- type CheckPermRequest
- func (*CheckPermRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CheckPermRequest) GetKey() string
- func (x *CheckPermRequest) GetToken() string
- func (x *CheckPermRequest) GetValue() []byte
- func (*CheckPermRequest) ProtoMessage()
- func (x *CheckPermRequest) ProtoReflect() protoreflect.Message
- func (x *CheckPermRequest) Reset()
- func (x *CheckPermRequest) String() string
- type CheckPermResponse
- type CheckRealmPermRequest
- func (*CheckRealmPermRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CheckRealmPermRequest) GetPowerLevel() int32
- func (x *CheckRealmPermRequest) GetRealmId() uint64
- func (x *CheckRealmPermRequest) GetUserId() uint64
- func (*CheckRealmPermRequest) ProtoMessage()
- func (x *CheckRealmPermRequest) ProtoReflect() protoreflect.Message
- func (x *CheckRealmPermRequest) Reset()
- func (x *CheckRealmPermRequest) String() string
- type CheckRealmPermResponse
- func (*CheckRealmPermResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CheckRealmPermResponse) GetIsSuccess() bool
- func (*CheckRealmPermResponse) ProtoMessage()
- func (x *CheckRealmPermResponse) ProtoReflect() protoreflect.Message
- func (x *CheckRealmPermResponse) Reset()
- func (x *CheckRealmPermResponse) String() string
- type CheckUserPermRequest
- func (*CheckUserPermRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CheckUserPermRequest) GetKey() string
- func (x *CheckUserPermRequest) GetOtherId() uint64
- func (x *CheckUserPermRequest) GetUserId() uint64
- func (x *CheckUserPermRequest) GetValue() []byte
- func (*CheckUserPermRequest) ProtoMessage()
- func (x *CheckUserPermRequest) ProtoReflect() protoreflect.Message
- func (x *CheckUserPermRequest) Reset()
- func (x *CheckUserPermRequest) String() string
- type CheckUserPermResponse
- func (*CheckUserPermResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CheckUserPermResponse) GetIsValid() bool
- func (*CheckUserPermResponse) ProtoMessage()
- func (x *CheckUserPermResponse) ProtoReflect() protoreflect.Message
- func (x *CheckUserPermResponse) Reset()
- func (x *CheckUserPermResponse) String() string
- type CountConnectionRequest
- func (*CountConnectionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CountConnectionRequest) GetUserId() uint64
- func (*CountConnectionRequest) ProtoMessage()
- func (x *CountConnectionRequest) ProtoReflect() protoreflect.Message
- func (x *CountConnectionRequest) Reset()
- func (x *CountConnectionRequest) String() string
- type CountConnectionResponse
- func (*CountConnectionResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CountConnectionResponse) GetCount() int64
- func (*CountConnectionResponse) ProtoMessage()
- func (x *CountConnectionResponse) ProtoReflect() protoreflect.Message
- func (x *CountConnectionResponse) Reset()
- func (x *CountConnectionResponse) String() string
- type DeliverEmailBatchRequest
- func (*DeliverEmailBatchRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeliverEmailBatchRequest) GetEmail() *EmailRequest
- func (x *DeliverEmailBatchRequest) GetTo() []string
- func (*DeliverEmailBatchRequest) ProtoMessage()
- func (x *DeliverEmailBatchRequest) ProtoReflect() protoreflect.Message
- func (x *DeliverEmailBatchRequest) Reset()
- func (x *DeliverEmailBatchRequest) String() string
- type DeliverEmailRequest
- func (*DeliverEmailRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeliverEmailRequest) GetEmail() *EmailRequest
- func (x *DeliverEmailRequest) GetTo() string
- func (*DeliverEmailRequest) ProtoMessage()
- func (x *DeliverEmailRequest) ProtoReflect() protoreflect.Message
- func (x *DeliverEmailRequest) Reset()
- func (x *DeliverEmailRequest) String() string
- type DeliverNotificationBatchRequest
- func (*DeliverNotificationBatchRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeliverNotificationBatchRequest) GetDeviceTokens() []string
- func (x *DeliverNotificationBatchRequest) GetNotify() *NotifyRequest
- func (x *DeliverNotificationBatchRequest) GetProviders() []string
- func (*DeliverNotificationBatchRequest) ProtoMessage()
- func (x *DeliverNotificationBatchRequest) ProtoReflect() protoreflect.Message
- func (x *DeliverNotificationBatchRequest) Reset()
- func (x *DeliverNotificationBatchRequest) String() string
- type DeliverNotificationRequest
- func (*DeliverNotificationRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeliverNotificationRequest) GetDeviceToken() string
- func (x *DeliverNotificationRequest) GetNotify() *NotifyRequest
- func (x *DeliverNotificationRequest) GetProvider() string
- func (*DeliverNotificationRequest) ProtoMessage()
- func (x *DeliverNotificationRequest) ProtoReflect() protoreflect.Message
- func (x *DeliverNotificationRequest) Reset()
- func (x *DeliverNotificationRequest) String() string
- type DeliverResponse
- type EmailRequest
- func (*EmailRequest) Descriptor() ([]byte, []int)deprecated
- func (x *EmailRequest) GetHtmlBody() string
- func (x *EmailRequest) GetSubject() string
- func (x *EmailRequest) GetTextBody() string
- func (*EmailRequest) ProtoMessage()
- func (x *EmailRequest) ProtoReflect() protoreflect.Message
- func (x *EmailRequest) Reset()
- func (x *EmailRequest) String() string
- type EventRecorderClient
- type EventRecorderServer
- type GetServiceRequest
- func (*GetServiceRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetServiceRequest) GetId() string
- func (x *GetServiceRequest) GetType() string
- func (*GetServiceRequest) ProtoMessage()
- func (x *GetServiceRequest) ProtoReflect() protoreflect.Message
- func (x *GetServiceRequest) Reset()
- func (x *GetServiceRequest) String() string
- type GetServiceResponse
- func (*GetServiceResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetServiceResponse) GetData() *ServiceInfo
- func (*GetServiceResponse) ProtoMessage()
- func (x *GetServiceResponse) ProtoReflect() protoreflect.Message
- func (x *GetServiceResponse) Reset()
- func (x *GetServiceResponse) String() string
- type ListRealmMemberResponse
- func (*ListRealmMemberResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListRealmMemberResponse) GetData() []*RealmMemberInfo
- func (*ListRealmMemberResponse) ProtoMessage()
- func (x *ListRealmMemberResponse) ProtoReflect() protoreflect.Message
- func (x *ListRealmMemberResponse) Reset()
- func (x *ListRealmMemberResponse) String() string
- type ListRealmRequest
- type ListRealmResponse
- func (*ListRealmResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListRealmResponse) GetData() []*RealmInfo
- func (*ListRealmResponse) ProtoMessage()
- func (x *ListRealmResponse) ProtoReflect() protoreflect.Message
- func (x *ListRealmResponse) Reset()
- func (x *ListRealmResponse) String() string
- type ListServiceRequest
- func (*ListServiceRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListServiceRequest) GetType() string
- func (*ListServiceRequest) ProtoMessage()
- func (x *ListServiceRequest) ProtoReflect() protoreflect.Message
- func (x *ListServiceRequest) Reset()
- func (x *ListServiceRequest) String() string
- type ListServiceResponse
- func (*ListServiceResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListServiceResponse) GetData() []*ServiceInfo
- func (*ListServiceResponse) ProtoMessage()
- func (x *ListServiceResponse) ProtoReflect() protoreflect.Message
- func (x *ListServiceResponse) Reset()
- func (x *ListServiceResponse) String() string
- type ListUserRelativeRequest
- func (*ListUserRelativeRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListUserRelativeRequest) GetIsRelated() bool
- func (x *ListUserRelativeRequest) GetUserId() uint64
- func (*ListUserRelativeRequest) ProtoMessage()
- func (x *ListUserRelativeRequest) ProtoReflect() protoreflect.Message
- func (x *ListUserRelativeRequest) Reset()
- func (x *ListUserRelativeRequest) String() string
- type ListUserRelativeResponse
- func (*ListUserRelativeResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListUserRelativeResponse) GetData() []*SimpleUserInfo
- func (*ListUserRelativeResponse) ProtoMessage()
- func (x *ListUserRelativeResponse) ProtoReflect() protoreflect.Message
- func (x *ListUserRelativeResponse) Reset()
- func (x *ListUserRelativeResponse) String() string
- type LookupRealmRequest
- func (*LookupRealmRequest) Descriptor() ([]byte, []int)deprecated
- func (x *LookupRealmRequest) GetAlias() string
- func (x *LookupRealmRequest) GetId() uint64
- func (x *LookupRealmRequest) GetIsCommunity() bool
- func (x *LookupRealmRequest) GetIsPublic() bool
- func (*LookupRealmRequest) ProtoMessage()
- func (x *LookupRealmRequest) ProtoReflect() protoreflect.Message
- func (x *LookupRealmRequest) Reset()
- func (x *LookupRealmRequest) String() string
- type LookupUserRealmRequest
- func (*LookupUserRealmRequest) Descriptor() ([]byte, []int)deprecated
- func (x *LookupUserRealmRequest) GetUserId() uint64
- func (*LookupUserRealmRequest) ProtoMessage()
- func (x *LookupUserRealmRequest) ProtoReflect() protoreflect.Message
- func (x *LookupUserRealmRequest) Reset()
- func (x *LookupUserRealmRequest) String() string
- type NotifierClient
- type NotifierServer
- type NotifyRequest
- func (*NotifyRequest) Descriptor() ([]byte, []int)deprecated
- func (x *NotifyRequest) GetAvatar() string
- func (x *NotifyRequest) GetBody() string
- func (x *NotifyRequest) GetIsForcePush() bool
- func (x *NotifyRequest) GetIsRealtime() bool
- func (x *NotifyRequest) GetMetadata() []byte
- func (x *NotifyRequest) GetPicture() string
- func (x *NotifyRequest) GetSubtitle() string
- func (x *NotifyRequest) GetTitle() string
- func (x *NotifyRequest) GetTopic() string
- func (*NotifyRequest) ProtoMessage()
- func (x *NotifyRequest) ProtoReflect() protoreflect.Message
- func (x *NotifyRequest) Reset()
- func (x *NotifyRequest) String() string
- type NotifyResponse
- func (*NotifyResponse) Descriptor() ([]byte, []int)deprecated
- func (x *NotifyResponse) GetAffectedCount() int64
- func (x *NotifyResponse) GetIsSuccess() bool
- func (*NotifyResponse) ProtoMessage()
- func (x *NotifyResponse) ProtoReflect() protoreflect.Message
- func (x *NotifyResponse) Reset()
- func (x *NotifyResponse) String() string
- type NotifyUserBatchRequest
- func (*NotifyUserBatchRequest) Descriptor() ([]byte, []int)deprecated
- func (x *NotifyUserBatchRequest) GetNotify() *NotifyRequest
- func (x *NotifyUserBatchRequest) GetUserId() []uint64
- func (*NotifyUserBatchRequest) ProtoMessage()
- func (x *NotifyUserBatchRequest) ProtoReflect() protoreflect.Message
- func (x *NotifyUserBatchRequest) Reset()
- func (x *NotifyUserBatchRequest) String() string
- type NotifyUserRequest
- func (*NotifyUserRequest) Descriptor() ([]byte, []int)deprecated
- func (x *NotifyUserRequest) GetNotify() *NotifyRequest
- func (x *NotifyUserRequest) GetUserId() uint64
- func (*NotifyUserRequest) ProtoMessage()
- func (x *NotifyUserRequest) ProtoReflect() protoreflect.Message
- func (x *NotifyUserRequest) Reset()
- func (x *NotifyUserRequest) String() string
- type PostmanClient
- type PostmanServer
- type PushStreamBatchRequest
- func (*PushStreamBatchRequest) Descriptor() ([]byte, []int)deprecated
- func (x *PushStreamBatchRequest) GetBody() []byte
- func (x *PushStreamBatchRequest) GetClientId() []uint64
- func (x *PushStreamBatchRequest) GetUserId() []uint64
- func (*PushStreamBatchRequest) ProtoMessage()
- func (x *PushStreamBatchRequest) ProtoReflect() protoreflect.Message
- func (x *PushStreamBatchRequest) Reset()
- func (x *PushStreamBatchRequest) String() string
- type PushStreamRequest
- func (*PushStreamRequest) Descriptor() ([]byte, []int)deprecated
- func (x *PushStreamRequest) GetBody() []byte
- func (x *PushStreamRequest) GetClientId() uint64
- func (x *PushStreamRequest) GetUserId() uint64
- func (*PushStreamRequest) ProtoMessage()
- func (x *PushStreamRequest) ProtoReflect() protoreflect.Message
- func (x *PushStreamRequest) Reset()
- func (x *PushStreamRequest) String() string
- type PushStreamResponse
- func (*PushStreamResponse) Descriptor() ([]byte, []int)deprecated
- func (x *PushStreamResponse) GetAffectedCount() int64
- func (x *PushStreamResponse) GetFailedCount() int64
- func (x *PushStreamResponse) GetIsAllSuccess() bool
- func (*PushStreamResponse) ProtoMessage()
- func (x *PushStreamResponse) ProtoReflect() protoreflect.Message
- func (x *PushStreamResponse) Reset()
- func (x *PushStreamResponse) String() string
- type RealmClient
- type RealmInfo
- func (*RealmInfo) Descriptor() ([]byte, []int)deprecated
- func (x *RealmInfo) GetAlias() string
- func (x *RealmInfo) GetDescription() string
- func (x *RealmInfo) GetId() uint64
- func (x *RealmInfo) GetIsCommunity() bool
- func (x *RealmInfo) GetIsPublic() bool
- func (x *RealmInfo) GetName() string
- func (*RealmInfo) ProtoMessage()
- func (x *RealmInfo) ProtoReflect() protoreflect.Message
- func (x *RealmInfo) Reset()
- func (x *RealmInfo) String() string
- type RealmMemberInfo
- func (*RealmMemberInfo) Descriptor() ([]byte, []int)deprecated
- func (x *RealmMemberInfo) GetPowerLevel() int32
- func (x *RealmMemberInfo) GetRealmId() uint64
- func (x *RealmMemberInfo) GetUserId() uint64
- func (*RealmMemberInfo) ProtoMessage()
- func (x *RealmMemberInfo) ProtoReflect() protoreflect.Message
- func (x *RealmMemberInfo) Reset()
- func (x *RealmMemberInfo) String() string
- type RealmMemberLookupRequest
- func (*RealmMemberLookupRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RealmMemberLookupRequest) GetRealmId() uint64
- func (x *RealmMemberLookupRequest) GetUserId() uint64
- func (*RealmMemberLookupRequest) ProtoMessage()
- func (x *RealmMemberLookupRequest) ProtoReflect() protoreflect.Message
- func (x *RealmMemberLookupRequest) Reset()
- func (x *RealmMemberLookupRequest) String() string
- type RealmServer
- type RecordEventRequest
- func (*RecordEventRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RecordEventRequest) GetAction() string
- func (x *RecordEventRequest) GetIp() string
- func (x *RecordEventRequest) GetTarget() string
- func (x *RecordEventRequest) GetUserAgent() string
- func (x *RecordEventRequest) GetUserId() uint64
- func (*RecordEventRequest) ProtoMessage()
- func (x *RecordEventRequest) ProtoReflect() protoreflect.Message
- func (x *RecordEventRequest) Reset()
- func (x *RecordEventRequest) String() string
- type RecordEventResponse
- func (*RecordEventResponse) Descriptor() ([]byte, []int)deprecated
- func (x *RecordEventResponse) GetIsSuccess() bool
- func (*RecordEventResponse) ProtoMessage()
- func (x *RecordEventResponse) ProtoReflect() protoreflect.Message
- func (x *RecordEventResponse) Reset()
- func (x *RecordEventResponse) String() string
- type RemoveServiceRequest
- func (*RemoveServiceRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RemoveServiceRequest) GetId() string
- func (*RemoveServiceRequest) ProtoMessage()
- func (x *RemoveServiceRequest) ProtoReflect() protoreflect.Message
- func (x *RemoveServiceRequest) Reset()
- func (x *RemoveServiceRequest) String() string
- type RemoveServiceResponse
- func (*RemoveServiceResponse) Descriptor() ([]byte, []int)deprecated
- func (x *RemoveServiceResponse) GetIsSuccess() bool
- func (*RemoveServiceResponse) ProtoMessage()
- func (x *RemoveServiceResponse) ProtoReflect() protoreflect.Message
- func (x *RemoveServiceResponse) Reset()
- func (x *RemoveServiceResponse) String() string
- type ServiceDirectoryClient
- type ServiceDirectoryServer
- type ServiceInfo
- func (*ServiceInfo) Descriptor() ([]byte, []int)deprecated
- func (x *ServiceInfo) GetGrpcAddr() string
- func (x *ServiceInfo) GetHttpAddr() string
- func (x *ServiceInfo) GetId() string
- func (x *ServiceInfo) GetLabel() string
- func (x *ServiceInfo) GetType() string
- func (*ServiceInfo) ProtoMessage()
- func (x *ServiceInfo) ProtoReflect() protoreflect.Message
- func (x *ServiceInfo) Reset()
- func (x *ServiceInfo) String() string
- type SimpleUserInfo
- func (*SimpleUserInfo) Descriptor() ([]byte, []int)deprecated
- func (x *SimpleUserInfo) GetId() uint64
- func (x *SimpleUserInfo) GetName() string
- func (x *SimpleUserInfo) GetNick() string
- func (*SimpleUserInfo) ProtoMessage()
- func (x *SimpleUserInfo) ProtoReflect() protoreflect.Message
- func (x *SimpleUserInfo) Reset()
- func (x *SimpleUserInfo) String() string
- type StreamControllerClient
- type StreamControllerServer
- type StreamEventRequest
- func (*StreamEventRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StreamEventRequest) GetClientId() uint64
- func (x *StreamEventRequest) GetEvent() string
- func (x *StreamEventRequest) GetPayload() []byte
- func (x *StreamEventRequest) GetUserId() uint64
- func (*StreamEventRequest) ProtoMessage()
- func (x *StreamEventRequest) ProtoReflect() protoreflect.Message
- func (x *StreamEventRequest) Reset()
- func (x *StreamEventRequest) String() string
- type StreamEventResponse
- type UnimplementedAuthServer
- func (UnimplementedAuthServer) Authenticate(context.Context, *AuthRequest) (*AuthReply, error)
- func (UnimplementedAuthServer) EnsurePermGranted(context.Context, *CheckPermRequest) (*CheckPermResponse, error)
- func (UnimplementedAuthServer) EnsureUserPermGranted(context.Context, *CheckUserPermRequest) (*CheckUserPermResponse, error)
- func (UnimplementedAuthServer) ListUserBlocklist(context.Context, *ListUserRelativeRequest) (*ListUserRelativeResponse, error)
- func (UnimplementedAuthServer) ListUserFriends(context.Context, *ListUserRelativeRequest) (*ListUserRelativeResponse, error)
- type UnimplementedEventRecorderServer
- type UnimplementedNotifierServer
- func (UnimplementedNotifierServer) NotifyAllUser(context.Context, *NotifyRequest) (*NotifyResponse, error)
- func (UnimplementedNotifierServer) NotifyUser(context.Context, *NotifyUserRequest) (*NotifyResponse, error)
- func (UnimplementedNotifierServer) NotifyUserBatch(context.Context, *NotifyUserBatchRequest) (*NotifyResponse, error)
- type UnimplementedPostmanServer
- func (UnimplementedPostmanServer) DeliverEmail(context.Context, *DeliverEmailRequest) (*DeliverResponse, error)
- func (UnimplementedPostmanServer) DeliverEmailBatch(context.Context, *DeliverEmailBatchRequest) (*DeliverResponse, error)
- func (UnimplementedPostmanServer) DeliverNotification(context.Context, *DeliverNotificationRequest) (*DeliverResponse, error)
- func (UnimplementedPostmanServer) DeliverNotificationBatch(context.Context, *DeliverNotificationBatchRequest) (*DeliverResponse, error)
- type UnimplementedRealmServer
- func (UnimplementedRealmServer) CheckRealmMemberPerm(context.Context, *CheckRealmPermRequest) (*CheckRealmPermResponse, error)
- func (UnimplementedRealmServer) GetRealm(context.Context, *LookupRealmRequest) (*RealmInfo, error)
- func (UnimplementedRealmServer) GetRealmMember(context.Context, *RealmMemberLookupRequest) (*RealmMemberInfo, error)
- func (UnimplementedRealmServer) ListAvailableRealm(context.Context, *LookupUserRealmRequest) (*ListRealmResponse, error)
- func (UnimplementedRealmServer) ListCommunityRealm(context.Context, *ListRealmRequest) (*ListRealmResponse, error)
- func (UnimplementedRealmServer) ListOwnedRealm(context.Context, *LookupUserRealmRequest) (*ListRealmResponse, error)
- func (UnimplementedRealmServer) ListRealmMember(context.Context, *RealmMemberLookupRequest) (*ListRealmMemberResponse, error)
- type UnimplementedServiceDirectoryServer
- func (UnimplementedServiceDirectoryServer) AddService(context.Context, *ServiceInfo) (*AddServiceResponse, error)
- func (UnimplementedServiceDirectoryServer) GetService(context.Context, *GetServiceRequest) (*GetServiceResponse, error)
- func (UnimplementedServiceDirectoryServer) ListService(context.Context, *ListServiceRequest) (*ListServiceResponse, error)
- func (UnimplementedServiceDirectoryServer) RemoveService(context.Context, *RemoveServiceRequest) (*RemoveServiceResponse, error)
- type UnimplementedStreamControllerServer
- func (UnimplementedStreamControllerServer) CountStreamConnection(context.Context, *CountConnectionRequest) (*CountConnectionResponse, error)
- func (UnimplementedStreamControllerServer) EmitStreamEvent(context.Context, *StreamEventRequest) (*StreamEventResponse, error)
- func (UnimplementedStreamControllerServer) PushStream(context.Context, *PushStreamRequest) (*PushStreamResponse, error)
- func (UnimplementedStreamControllerServer) PushStreamBatch(context.Context, *PushStreamBatchRequest) (*PushStreamResponse, error)
- type UnsafeAuthServer
- type UnsafeEventRecorderServer
- type UnsafeNotifierServer
- type UnsafePostmanServer
- type UnsafeRealmServer
- type UnsafeServiceDirectoryServer
- type UnsafeStreamControllerServer
- type UserInfo
- func (*UserInfo) Descriptor() ([]byte, []int)deprecated
- func (x *UserInfo) GetAvatar() string
- func (x *UserInfo) GetBanner() string
- func (x *UserInfo) GetDescription() string
- func (x *UserInfo) GetEmail() string
- func (x *UserInfo) GetId() uint64
- func (x *UserInfo) GetName() string
- func (x *UserInfo) GetNick() string
- func (*UserInfo) ProtoMessage()
- func (x *UserInfo) ProtoReflect() protoreflect.Message
- func (x *UserInfo) Reset()
- func (x *UserInfo) String() string
Constants ¶
const ( Auth_Authenticate_FullMethodName = "/proto.Auth/Authenticate" Auth_EnsurePermGranted_FullMethodName = "/proto.Auth/EnsurePermGranted" Auth_EnsureUserPermGranted_FullMethodName = "/proto.Auth/EnsureUserPermGranted" Auth_ListUserFriends_FullMethodName = "/proto.Auth/ListUserFriends" Auth_ListUserBlocklist_FullMethodName = "/proto.Auth/ListUserBlocklist" )
const ( Notifier_NotifyUser_FullMethodName = "/proto.Notifier/NotifyUser" Notifier_NotifyUserBatch_FullMethodName = "/proto.Notifier/NotifyUserBatch" Notifier_NotifyAllUser_FullMethodName = "/proto.Notifier/NotifyAllUser" )
const ( Postman_DeliverNotification_FullMethodName = "/proto.Postman/DeliverNotification" Postman_DeliverNotificationBatch_FullMethodName = "/proto.Postman/DeliverNotificationBatch" Postman_DeliverEmail_FullMethodName = "/proto.Postman/DeliverEmail" Postman_DeliverEmailBatch_FullMethodName = "/proto.Postman/DeliverEmailBatch" )
const ( Realm_ListCommunityRealm_FullMethodName = "/proto.Realm/ListCommunityRealm" Realm_ListAvailableRealm_FullMethodName = "/proto.Realm/ListAvailableRealm" Realm_ListOwnedRealm_FullMethodName = "/proto.Realm/ListOwnedRealm" Realm_GetRealm_FullMethodName = "/proto.Realm/GetRealm" Realm_ListRealmMember_FullMethodName = "/proto.Realm/ListRealmMember" Realm_GetRealmMember_FullMethodName = "/proto.Realm/GetRealmMember" Realm_CheckRealmMemberPerm_FullMethodName = "/proto.Realm/CheckRealmMemberPerm" )
const ( ServiceDirectory_GetService_FullMethodName = "/proto.ServiceDirectory/GetService" ServiceDirectory_ListService_FullMethodName = "/proto.ServiceDirectory/ListService" ServiceDirectory_AddService_FullMethodName = "/proto.ServiceDirectory/AddService" ServiceDirectory_RemoveService_FullMethodName = "/proto.ServiceDirectory/RemoveService" )
const ( StreamController_CountStreamConnection_FullMethodName = "/proto.StreamController/CountStreamConnection" StreamController_PushStream_FullMethodName = "/proto.StreamController/PushStream" StreamController_PushStreamBatch_FullMethodName = "/proto.StreamController/PushStreamBatch" StreamController_EmitStreamEvent_FullMethodName = "/proto.StreamController/EmitStreamEvent" )
const (
EventRecorder_RecordEvent_FullMethodName = "/proto.EventRecorder/RecordEvent"
)
Variables ¶
var Auth_ServiceDesc = grpc.ServiceDesc{ ServiceName: "proto.Auth", HandlerType: (*AuthServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Authenticate", Handler: _Auth_Authenticate_Handler, }, { MethodName: "EnsurePermGranted", Handler: _Auth_EnsurePermGranted_Handler, }, { MethodName: "EnsureUserPermGranted", Handler: _Auth_EnsureUserPermGranted_Handler, }, { MethodName: "ListUserFriends", Handler: _Auth_ListUserFriends_Handler, }, { MethodName: "ListUserBlocklist", Handler: _Auth_ListUserBlocklist_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "auth.proto", }
Auth_ServiceDesc is the grpc.ServiceDesc for Auth service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var EventRecorder_ServiceDesc = grpc.ServiceDesc{ ServiceName: "proto.EventRecorder", HandlerType: (*EventRecorderServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "RecordEvent", Handler: _EventRecorder_RecordEvent_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "record.proto", }
EventRecorder_ServiceDesc is the grpc.ServiceDesc for EventRecorder service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_auth_proto protoreflect.FileDescriptor
var File_notify_proto protoreflect.FileDescriptor
var File_postman_proto protoreflect.FileDescriptor
var File_realm_proto protoreflect.FileDescriptor
var File_record_proto protoreflect.FileDescriptor
var File_services_proto protoreflect.FileDescriptor
var File_stream_proto protoreflect.FileDescriptor
var Notifier_ServiceDesc = grpc.ServiceDesc{ ServiceName: "proto.Notifier", HandlerType: (*NotifierServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "NotifyUser", Handler: _Notifier_NotifyUser_Handler, }, { MethodName: "NotifyUserBatch", Handler: _Notifier_NotifyUserBatch_Handler, }, { MethodName: "NotifyAllUser", Handler: _Notifier_NotifyAllUser_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "notify.proto", }
Notifier_ServiceDesc is the grpc.ServiceDesc for Notifier service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var Postman_ServiceDesc = grpc.ServiceDesc{ ServiceName: "proto.Postman", HandlerType: (*PostmanServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "DeliverNotification", Handler: _Postman_DeliverNotification_Handler, }, { MethodName: "DeliverNotificationBatch", Handler: _Postman_DeliverNotificationBatch_Handler, }, { MethodName: "DeliverEmail", Handler: _Postman_DeliverEmail_Handler, }, { MethodName: "DeliverEmailBatch", Handler: _Postman_DeliverEmailBatch_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "postman.proto", }
Postman_ServiceDesc is the grpc.ServiceDesc for Postman service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var Realm_ServiceDesc = grpc.ServiceDesc{ ServiceName: "proto.Realm", HandlerType: (*RealmServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "ListCommunityRealm", Handler: _Realm_ListCommunityRealm_Handler, }, { MethodName: "ListAvailableRealm", Handler: _Realm_ListAvailableRealm_Handler, }, { MethodName: "ListOwnedRealm", Handler: _Realm_ListOwnedRealm_Handler, }, { MethodName: "GetRealm", Handler: _Realm_GetRealm_Handler, }, { MethodName: "ListRealmMember", Handler: _Realm_ListRealmMember_Handler, }, { MethodName: "GetRealmMember", Handler: _Realm_GetRealmMember_Handler, }, { MethodName: "CheckRealmMemberPerm", Handler: _Realm_CheckRealmMemberPerm_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "realm.proto", }
Realm_ServiceDesc is the grpc.ServiceDesc for Realm service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var ServiceDirectory_ServiceDesc = grpc.ServiceDesc{ ServiceName: "proto.ServiceDirectory", HandlerType: (*ServiceDirectoryServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "GetService", Handler: _ServiceDirectory_GetService_Handler, }, { MethodName: "ListService", Handler: _ServiceDirectory_ListService_Handler, }, { MethodName: "AddService", Handler: _ServiceDirectory_AddService_Handler, }, { MethodName: "RemoveService", Handler: _ServiceDirectory_RemoveService_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "services.proto", }
ServiceDirectory_ServiceDesc is the grpc.ServiceDesc for ServiceDirectory service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var StreamController_ServiceDesc = grpc.ServiceDesc{ ServiceName: "proto.StreamController", HandlerType: (*StreamControllerServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "CountStreamConnection", Handler: _StreamController_CountStreamConnection_Handler, }, { MethodName: "PushStream", Handler: _StreamController_PushStream_Handler, }, { MethodName: "PushStreamBatch", Handler: _StreamController_PushStreamBatch_Handler, }, { MethodName: "EmitStreamEvent", Handler: _StreamController_EmitStreamEvent_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "stream.proto", }
StreamController_ServiceDesc is the grpc.ServiceDesc for StreamController service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterAuthServer ¶
func RegisterAuthServer(s grpc.ServiceRegistrar, srv AuthServer)
func RegisterEventRecorderServer ¶
func RegisterEventRecorderServer(s grpc.ServiceRegistrar, srv EventRecorderServer)
func RegisterNotifierServer ¶
func RegisterNotifierServer(s grpc.ServiceRegistrar, srv NotifierServer)
func RegisterPostmanServer ¶
func RegisterPostmanServer(s grpc.ServiceRegistrar, srv PostmanServer)
func RegisterRealmServer ¶
func RegisterRealmServer(s grpc.ServiceRegistrar, srv RealmServer)
func RegisterServiceDirectoryServer ¶
func RegisterServiceDirectoryServer(s grpc.ServiceRegistrar, srv ServiceDirectoryServer)
func RegisterStreamControllerServer ¶
func RegisterStreamControllerServer(s grpc.ServiceRegistrar, srv StreamControllerServer)
Types ¶
type AddServiceResponse ¶
type AddServiceResponse struct { IsSuccess bool `protobuf:"varint,1,opt,name=is_success,json=isSuccess,proto3" json:"is_success,omitempty"` // contains filtered or unexported fields }
func (*AddServiceResponse) Descriptor
deprecated
func (*AddServiceResponse) Descriptor() ([]byte, []int)
Deprecated: Use AddServiceResponse.ProtoReflect.Descriptor instead.
func (*AddServiceResponse) GetIsSuccess ¶
func (x *AddServiceResponse) GetIsSuccess() bool
func (*AddServiceResponse) ProtoMessage ¶
func (*AddServiceResponse) ProtoMessage()
func (*AddServiceResponse) ProtoReflect ¶
func (x *AddServiceResponse) ProtoReflect() protoreflect.Message
func (*AddServiceResponse) Reset ¶
func (x *AddServiceResponse) Reset()
func (*AddServiceResponse) String ¶
func (x *AddServiceResponse) String() string
type AuthClient ¶
type AuthClient interface { Authenticate(ctx context.Context, in *AuthRequest, opts ...grpc.CallOption) (*AuthReply, error) EnsurePermGranted(ctx context.Context, in *CheckPermRequest, opts ...grpc.CallOption) (*CheckPermResponse, error) EnsureUserPermGranted(ctx context.Context, in *CheckUserPermRequest, opts ...grpc.CallOption) (*CheckUserPermResponse, error) ListUserFriends(ctx context.Context, in *ListUserRelativeRequest, opts ...grpc.CallOption) (*ListUserRelativeResponse, error) ListUserBlocklist(ctx context.Context, in *ListUserRelativeRequest, opts ...grpc.CallOption) (*ListUserRelativeResponse, error) }
AuthClient is the client API for Auth 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 NewAuthClient ¶
func NewAuthClient(cc grpc.ClientConnInterface) AuthClient
type AuthInfo ¶
type AuthInfo struct { Info *UserInfo `protobuf:"bytes,1,opt,name=info,proto3" json:"info,omitempty"` Permissions []byte `protobuf:"bytes,2,opt,name=permissions,proto3" json:"permissions,omitempty"` TicketId uint64 `protobuf:"varint,3,opt,name=ticket_id,json=ticketId,proto3" json:"ticket_id,omitempty"` NewAccessToken *string `protobuf:"bytes,4,opt,name=new_access_token,json=newAccessToken,proto3,oneof" json:"new_access_token,omitempty"` NewRefreshToken *string `protobuf:"bytes,5,opt,name=new_refresh_token,json=newRefreshToken,proto3,oneof" json:"new_refresh_token,omitempty"` // contains filtered or unexported fields }
func (*AuthInfo) Descriptor
deprecated
func (*AuthInfo) GetNewAccessToken ¶
func (*AuthInfo) GetNewRefreshToken ¶
func (*AuthInfo) GetPermissions ¶
func (*AuthInfo) GetTicketId ¶
func (*AuthInfo) ProtoMessage ¶
func (*AuthInfo) ProtoMessage()
func (*AuthInfo) ProtoReflect ¶
func (x *AuthInfo) ProtoReflect() protoreflect.Message
type AuthReply ¶
type AuthReply struct { IsValid bool `protobuf:"varint,1,opt,name=is_valid,json=isValid,proto3" json:"is_valid,omitempty"` Info *AuthInfo `protobuf:"bytes,2,opt,name=info,proto3,oneof" json:"info,omitempty"` // contains filtered or unexported fields }
func (*AuthReply) Descriptor
deprecated
func (*AuthReply) GetIsValid ¶
func (*AuthReply) ProtoMessage ¶
func (*AuthReply) ProtoMessage()
func (*AuthReply) ProtoReflect ¶
func (x *AuthReply) ProtoReflect() protoreflect.Message
type AuthRequest ¶
type AuthRequest struct { AccessToken string `protobuf:"bytes,1,opt,name=access_token,json=accessToken,proto3" json:"access_token,omitempty"` RefreshToken *string `protobuf:"bytes,2,opt,name=refresh_token,json=refreshToken,proto3,oneof" json:"refresh_token,omitempty"` // contains filtered or unexported fields }
func (*AuthRequest) Descriptor
deprecated
func (*AuthRequest) Descriptor() ([]byte, []int)
Deprecated: Use AuthRequest.ProtoReflect.Descriptor instead.
func (*AuthRequest) GetAccessToken ¶
func (x *AuthRequest) GetAccessToken() string
func (*AuthRequest) GetRefreshToken ¶
func (x *AuthRequest) GetRefreshToken() string
func (*AuthRequest) ProtoMessage ¶
func (*AuthRequest) ProtoMessage()
func (*AuthRequest) ProtoReflect ¶
func (x *AuthRequest) ProtoReflect() protoreflect.Message
func (*AuthRequest) Reset ¶
func (x *AuthRequest) Reset()
func (*AuthRequest) String ¶
func (x *AuthRequest) String() string
type AuthServer ¶
type AuthServer interface { Authenticate(context.Context, *AuthRequest) (*AuthReply, error) EnsurePermGranted(context.Context, *CheckPermRequest) (*CheckPermResponse, error) EnsureUserPermGranted(context.Context, *CheckUserPermRequest) (*CheckUserPermResponse, error) ListUserFriends(context.Context, *ListUserRelativeRequest) (*ListUserRelativeResponse, error) ListUserBlocklist(context.Context, *ListUserRelativeRequest) (*ListUserRelativeResponse, error) // contains filtered or unexported methods }
AuthServer is the server API for Auth service. All implementations must embed UnimplementedAuthServer for forward compatibility.
type CheckPermRequest ¶
type CheckPermRequest struct { Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"` Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"` Value []byte `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
func (*CheckPermRequest) Descriptor
deprecated
func (*CheckPermRequest) Descriptor() ([]byte, []int)
Deprecated: Use CheckPermRequest.ProtoReflect.Descriptor instead.
func (*CheckPermRequest) GetKey ¶
func (x *CheckPermRequest) GetKey() string
func (*CheckPermRequest) GetToken ¶
func (x *CheckPermRequest) GetToken() string
func (*CheckPermRequest) GetValue ¶
func (x *CheckPermRequest) GetValue() []byte
func (*CheckPermRequest) ProtoMessage ¶
func (*CheckPermRequest) ProtoMessage()
func (*CheckPermRequest) ProtoReflect ¶
func (x *CheckPermRequest) ProtoReflect() protoreflect.Message
func (*CheckPermRequest) Reset ¶
func (x *CheckPermRequest) Reset()
func (*CheckPermRequest) String ¶
func (x *CheckPermRequest) String() string
type CheckPermResponse ¶
type CheckPermResponse struct { IsValid bool `protobuf:"varint,1,opt,name=is_valid,json=isValid,proto3" json:"is_valid,omitempty"` // contains filtered or unexported fields }
func (*CheckPermResponse) Descriptor
deprecated
func (*CheckPermResponse) Descriptor() ([]byte, []int)
Deprecated: Use CheckPermResponse.ProtoReflect.Descriptor instead.
func (*CheckPermResponse) GetIsValid ¶
func (x *CheckPermResponse) GetIsValid() bool
func (*CheckPermResponse) ProtoMessage ¶
func (*CheckPermResponse) ProtoMessage()
func (*CheckPermResponse) ProtoReflect ¶
func (x *CheckPermResponse) ProtoReflect() protoreflect.Message
func (*CheckPermResponse) Reset ¶
func (x *CheckPermResponse) Reset()
func (*CheckPermResponse) String ¶
func (x *CheckPermResponse) String() string
type CheckRealmPermRequest ¶
type CheckRealmPermRequest struct { RealmId uint64 `protobuf:"varint,1,opt,name=realm_id,json=realmId,proto3" json:"realm_id,omitempty"` UserId uint64 `protobuf:"varint,2,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"` PowerLevel int32 `protobuf:"varint,3,opt,name=power_level,json=powerLevel,proto3" json:"power_level,omitempty"` // contains filtered or unexported fields }
func (*CheckRealmPermRequest) Descriptor
deprecated
func (*CheckRealmPermRequest) Descriptor() ([]byte, []int)
Deprecated: Use CheckRealmPermRequest.ProtoReflect.Descriptor instead.
func (*CheckRealmPermRequest) GetPowerLevel ¶
func (x *CheckRealmPermRequest) GetPowerLevel() int32
func (*CheckRealmPermRequest) GetRealmId ¶
func (x *CheckRealmPermRequest) GetRealmId() uint64
func (*CheckRealmPermRequest) GetUserId ¶
func (x *CheckRealmPermRequest) GetUserId() uint64
func (*CheckRealmPermRequest) ProtoMessage ¶
func (*CheckRealmPermRequest) ProtoMessage()
func (*CheckRealmPermRequest) ProtoReflect ¶
func (x *CheckRealmPermRequest) ProtoReflect() protoreflect.Message
func (*CheckRealmPermRequest) Reset ¶
func (x *CheckRealmPermRequest) Reset()
func (*CheckRealmPermRequest) String ¶
func (x *CheckRealmPermRequest) String() string
type CheckRealmPermResponse ¶
type CheckRealmPermResponse struct { IsSuccess bool `protobuf:"varint,1,opt,name=is_success,json=isSuccess,proto3" json:"is_success,omitempty"` // contains filtered or unexported fields }
func (*CheckRealmPermResponse) Descriptor
deprecated
func (*CheckRealmPermResponse) Descriptor() ([]byte, []int)
Deprecated: Use CheckRealmPermResponse.ProtoReflect.Descriptor instead.
func (*CheckRealmPermResponse) GetIsSuccess ¶
func (x *CheckRealmPermResponse) GetIsSuccess() bool
func (*CheckRealmPermResponse) ProtoMessage ¶
func (*CheckRealmPermResponse) ProtoMessage()
func (*CheckRealmPermResponse) ProtoReflect ¶
func (x *CheckRealmPermResponse) ProtoReflect() protoreflect.Message
func (*CheckRealmPermResponse) Reset ¶
func (x *CheckRealmPermResponse) Reset()
func (*CheckRealmPermResponse) String ¶
func (x *CheckRealmPermResponse) String() string
type CheckUserPermRequest ¶
type CheckUserPermRequest struct { UserId uint64 `protobuf:"varint,1,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"` OtherId uint64 `protobuf:"varint,2,opt,name=other_id,json=otherId,proto3" json:"other_id,omitempty"` Key string `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"` Value []byte `protobuf:"bytes,4,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
func (*CheckUserPermRequest) Descriptor
deprecated
func (*CheckUserPermRequest) Descriptor() ([]byte, []int)
Deprecated: Use CheckUserPermRequest.ProtoReflect.Descriptor instead.
func (*CheckUserPermRequest) GetKey ¶
func (x *CheckUserPermRequest) GetKey() string
func (*CheckUserPermRequest) GetOtherId ¶
func (x *CheckUserPermRequest) GetOtherId() uint64
func (*CheckUserPermRequest) GetUserId ¶
func (x *CheckUserPermRequest) GetUserId() uint64
func (*CheckUserPermRequest) GetValue ¶
func (x *CheckUserPermRequest) GetValue() []byte
func (*CheckUserPermRequest) ProtoMessage ¶
func (*CheckUserPermRequest) ProtoMessage()
func (*CheckUserPermRequest) ProtoReflect ¶
func (x *CheckUserPermRequest) ProtoReflect() protoreflect.Message
func (*CheckUserPermRequest) Reset ¶
func (x *CheckUserPermRequest) Reset()
func (*CheckUserPermRequest) String ¶
func (x *CheckUserPermRequest) String() string
type CheckUserPermResponse ¶
type CheckUserPermResponse struct { IsValid bool `protobuf:"varint,1,opt,name=is_valid,json=isValid,proto3" json:"is_valid,omitempty"` // contains filtered or unexported fields }
func (*CheckUserPermResponse) Descriptor
deprecated
func (*CheckUserPermResponse) Descriptor() ([]byte, []int)
Deprecated: Use CheckUserPermResponse.ProtoReflect.Descriptor instead.
func (*CheckUserPermResponse) GetIsValid ¶
func (x *CheckUserPermResponse) GetIsValid() bool
func (*CheckUserPermResponse) ProtoMessage ¶
func (*CheckUserPermResponse) ProtoMessage()
func (*CheckUserPermResponse) ProtoReflect ¶
func (x *CheckUserPermResponse) ProtoReflect() protoreflect.Message
func (*CheckUserPermResponse) Reset ¶
func (x *CheckUserPermResponse) Reset()
func (*CheckUserPermResponse) String ¶
func (x *CheckUserPermResponse) String() string
type CountConnectionRequest ¶
type CountConnectionRequest struct { UserId uint64 `protobuf:"varint,1,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"` // contains filtered or unexported fields }
func (*CountConnectionRequest) Descriptor
deprecated
func (*CountConnectionRequest) Descriptor() ([]byte, []int)
Deprecated: Use CountConnectionRequest.ProtoReflect.Descriptor instead.
func (*CountConnectionRequest) GetUserId ¶
func (x *CountConnectionRequest) GetUserId() uint64
func (*CountConnectionRequest) ProtoMessage ¶
func (*CountConnectionRequest) ProtoMessage()
func (*CountConnectionRequest) ProtoReflect ¶
func (x *CountConnectionRequest) ProtoReflect() protoreflect.Message
func (*CountConnectionRequest) Reset ¶
func (x *CountConnectionRequest) Reset()
func (*CountConnectionRequest) String ¶
func (x *CountConnectionRequest) String() string
type CountConnectionResponse ¶
type CountConnectionResponse struct { Count int64 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"` // contains filtered or unexported fields }
func (*CountConnectionResponse) Descriptor
deprecated
func (*CountConnectionResponse) Descriptor() ([]byte, []int)
Deprecated: Use CountConnectionResponse.ProtoReflect.Descriptor instead.
func (*CountConnectionResponse) GetCount ¶
func (x *CountConnectionResponse) GetCount() int64
func (*CountConnectionResponse) ProtoMessage ¶
func (*CountConnectionResponse) ProtoMessage()
func (*CountConnectionResponse) ProtoReflect ¶
func (x *CountConnectionResponse) ProtoReflect() protoreflect.Message
func (*CountConnectionResponse) Reset ¶
func (x *CountConnectionResponse) Reset()
func (*CountConnectionResponse) String ¶
func (x *CountConnectionResponse) String() string
type DeliverEmailBatchRequest ¶
type DeliverEmailBatchRequest struct { To []string `protobuf:"bytes,1,rep,name=to,proto3" json:"to,omitempty"` Email *EmailRequest `protobuf:"bytes,2,opt,name=email,proto3" json:"email,omitempty"` // contains filtered or unexported fields }
func (*DeliverEmailBatchRequest) Descriptor
deprecated
func (*DeliverEmailBatchRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeliverEmailBatchRequest.ProtoReflect.Descriptor instead.
func (*DeliverEmailBatchRequest) GetEmail ¶
func (x *DeliverEmailBatchRequest) GetEmail() *EmailRequest
func (*DeliverEmailBatchRequest) GetTo ¶
func (x *DeliverEmailBatchRequest) GetTo() []string
func (*DeliverEmailBatchRequest) ProtoMessage ¶
func (*DeliverEmailBatchRequest) ProtoMessage()
func (*DeliverEmailBatchRequest) ProtoReflect ¶
func (x *DeliverEmailBatchRequest) ProtoReflect() protoreflect.Message
func (*DeliverEmailBatchRequest) Reset ¶
func (x *DeliverEmailBatchRequest) Reset()
func (*DeliverEmailBatchRequest) String ¶
func (x *DeliverEmailBatchRequest) String() string
type DeliverEmailRequest ¶
type DeliverEmailRequest struct { To string `protobuf:"bytes,1,opt,name=to,proto3" json:"to,omitempty"` Email *EmailRequest `protobuf:"bytes,2,opt,name=email,proto3" json:"email,omitempty"` // contains filtered or unexported fields }
func (*DeliverEmailRequest) Descriptor
deprecated
func (*DeliverEmailRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeliverEmailRequest.ProtoReflect.Descriptor instead.
func (*DeliverEmailRequest) GetEmail ¶
func (x *DeliverEmailRequest) GetEmail() *EmailRequest
func (*DeliverEmailRequest) GetTo ¶
func (x *DeliverEmailRequest) GetTo() string
func (*DeliverEmailRequest) ProtoMessage ¶
func (*DeliverEmailRequest) ProtoMessage()
func (*DeliverEmailRequest) ProtoReflect ¶
func (x *DeliverEmailRequest) ProtoReflect() protoreflect.Message
func (*DeliverEmailRequest) Reset ¶
func (x *DeliverEmailRequest) Reset()
func (*DeliverEmailRequest) String ¶
func (x *DeliverEmailRequest) String() string
type DeliverNotificationBatchRequest ¶
type DeliverNotificationBatchRequest struct { Providers []string `protobuf:"bytes,1,rep,name=providers,proto3" json:"providers,omitempty"` DeviceTokens []string `protobuf:"bytes,2,rep,name=device_tokens,json=deviceTokens,proto3" json:"device_tokens,omitempty"` Notify *NotifyRequest `protobuf:"bytes,3,opt,name=notify,proto3" json:"notify,omitempty"` // contains filtered or unexported fields }
func (*DeliverNotificationBatchRequest) Descriptor
deprecated
func (*DeliverNotificationBatchRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeliverNotificationBatchRequest.ProtoReflect.Descriptor instead.
func (*DeliverNotificationBatchRequest) GetDeviceTokens ¶
func (x *DeliverNotificationBatchRequest) GetDeviceTokens() []string
func (*DeliverNotificationBatchRequest) GetNotify ¶
func (x *DeliverNotificationBatchRequest) GetNotify() *NotifyRequest
func (*DeliverNotificationBatchRequest) GetProviders ¶
func (x *DeliverNotificationBatchRequest) GetProviders() []string
func (*DeliverNotificationBatchRequest) ProtoMessage ¶
func (*DeliverNotificationBatchRequest) ProtoMessage()
func (*DeliverNotificationBatchRequest) ProtoReflect ¶
func (x *DeliverNotificationBatchRequest) ProtoReflect() protoreflect.Message
func (*DeliverNotificationBatchRequest) Reset ¶
func (x *DeliverNotificationBatchRequest) Reset()
func (*DeliverNotificationBatchRequest) String ¶
func (x *DeliverNotificationBatchRequest) String() string
type DeliverNotificationRequest ¶
type DeliverNotificationRequest struct { Provider string `protobuf:"bytes,1,opt,name=provider,proto3" json:"provider,omitempty"` DeviceToken string `protobuf:"bytes,2,opt,name=device_token,json=deviceToken,proto3" json:"device_token,omitempty"` Notify *NotifyRequest `protobuf:"bytes,3,opt,name=notify,proto3" json:"notify,omitempty"` // contains filtered or unexported fields }
func (*DeliverNotificationRequest) Descriptor
deprecated
func (*DeliverNotificationRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeliverNotificationRequest.ProtoReflect.Descriptor instead.
func (*DeliverNotificationRequest) GetDeviceToken ¶
func (x *DeliverNotificationRequest) GetDeviceToken() string
func (*DeliverNotificationRequest) GetNotify ¶
func (x *DeliverNotificationRequest) GetNotify() *NotifyRequest
func (*DeliverNotificationRequest) GetProvider ¶
func (x *DeliverNotificationRequest) GetProvider() string
func (*DeliverNotificationRequest) ProtoMessage ¶
func (*DeliverNotificationRequest) ProtoMessage()
func (*DeliverNotificationRequest) ProtoReflect ¶
func (x *DeliverNotificationRequest) ProtoReflect() protoreflect.Message
func (*DeliverNotificationRequest) Reset ¶
func (x *DeliverNotificationRequest) Reset()
func (*DeliverNotificationRequest) String ¶
func (x *DeliverNotificationRequest) String() string
type DeliverResponse ¶
type DeliverResponse struct {
// contains filtered or unexported fields
}
func (*DeliverResponse) Descriptor
deprecated
func (*DeliverResponse) Descriptor() ([]byte, []int)
Deprecated: Use DeliverResponse.ProtoReflect.Descriptor instead.
func (*DeliverResponse) ProtoMessage ¶
func (*DeliverResponse) ProtoMessage()
func (*DeliverResponse) ProtoReflect ¶
func (x *DeliverResponse) ProtoReflect() protoreflect.Message
func (*DeliverResponse) Reset ¶
func (x *DeliverResponse) Reset()
func (*DeliverResponse) String ¶
func (x *DeliverResponse) String() string
type EmailRequest ¶
type EmailRequest struct { Subject string `protobuf:"bytes,1,opt,name=subject,proto3" json:"subject,omitempty"` TextBody *string `protobuf:"bytes,2,opt,name=text_body,json=textBody,proto3,oneof" json:"text_body,omitempty"` HtmlBody *string `protobuf:"bytes,3,opt,name=html_body,json=htmlBody,proto3,oneof" json:"html_body,omitempty"` // contains filtered or unexported fields }
func (*EmailRequest) Descriptor
deprecated
func (*EmailRequest) Descriptor() ([]byte, []int)
Deprecated: Use EmailRequest.ProtoReflect.Descriptor instead.
func (*EmailRequest) GetHtmlBody ¶
func (x *EmailRequest) GetHtmlBody() string
func (*EmailRequest) GetSubject ¶
func (x *EmailRequest) GetSubject() string
func (*EmailRequest) GetTextBody ¶
func (x *EmailRequest) GetTextBody() string
func (*EmailRequest) ProtoMessage ¶
func (*EmailRequest) ProtoMessage()
func (*EmailRequest) ProtoReflect ¶
func (x *EmailRequest) ProtoReflect() protoreflect.Message
func (*EmailRequest) Reset ¶
func (x *EmailRequest) Reset()
func (*EmailRequest) String ¶
func (x *EmailRequest) String() string
type EventRecorderClient ¶
type EventRecorderClient interface {
RecordEvent(ctx context.Context, in *RecordEventRequest, opts ...grpc.CallOption) (*RecordEventResponse, error)
}
EventRecorderClient is the client API for EventRecorder 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 NewEventRecorderClient ¶
func NewEventRecorderClient(cc grpc.ClientConnInterface) EventRecorderClient
type EventRecorderServer ¶
type EventRecorderServer interface { RecordEvent(context.Context, *RecordEventRequest) (*RecordEventResponse, error) // contains filtered or unexported methods }
EventRecorderServer is the server API for EventRecorder service. All implementations must embed UnimplementedEventRecorderServer for forward compatibility.
type GetServiceRequest ¶
type GetServiceRequest struct { Id *string `protobuf:"bytes,1,opt,name=id,proto3,oneof" json:"id,omitempty"` Type *string `protobuf:"bytes,2,opt,name=type,proto3,oneof" json:"type,omitempty"` // contains filtered or unexported fields }
func (*GetServiceRequest) Descriptor
deprecated
func (*GetServiceRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetServiceRequest.ProtoReflect.Descriptor instead.
func (*GetServiceRequest) GetId ¶
func (x *GetServiceRequest) GetId() string
func (*GetServiceRequest) GetType ¶
func (x *GetServiceRequest) GetType() string
func (*GetServiceRequest) ProtoMessage ¶
func (*GetServiceRequest) ProtoMessage()
func (*GetServiceRequest) ProtoReflect ¶
func (x *GetServiceRequest) ProtoReflect() protoreflect.Message
func (*GetServiceRequest) Reset ¶
func (x *GetServiceRequest) Reset()
func (*GetServiceRequest) String ¶
func (x *GetServiceRequest) String() string
type GetServiceResponse ¶
type GetServiceResponse struct { Data *ServiceInfo `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"` // contains filtered or unexported fields }
func (*GetServiceResponse) Descriptor
deprecated
func (*GetServiceResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetServiceResponse.ProtoReflect.Descriptor instead.
func (*GetServiceResponse) GetData ¶
func (x *GetServiceResponse) GetData() *ServiceInfo
func (*GetServiceResponse) ProtoMessage ¶
func (*GetServiceResponse) ProtoMessage()
func (*GetServiceResponse) ProtoReflect ¶
func (x *GetServiceResponse) ProtoReflect() protoreflect.Message
func (*GetServiceResponse) Reset ¶
func (x *GetServiceResponse) Reset()
func (*GetServiceResponse) String ¶
func (x *GetServiceResponse) String() string
type ListRealmMemberResponse ¶
type ListRealmMemberResponse struct { Data []*RealmMemberInfo `protobuf:"bytes,1,rep,name=data,proto3" json:"data,omitempty"` // contains filtered or unexported fields }
func (*ListRealmMemberResponse) Descriptor
deprecated
func (*ListRealmMemberResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListRealmMemberResponse.ProtoReflect.Descriptor instead.
func (*ListRealmMemberResponse) GetData ¶
func (x *ListRealmMemberResponse) GetData() []*RealmMemberInfo
func (*ListRealmMemberResponse) ProtoMessage ¶
func (*ListRealmMemberResponse) ProtoMessage()
func (*ListRealmMemberResponse) ProtoReflect ¶
func (x *ListRealmMemberResponse) ProtoReflect() protoreflect.Message
func (*ListRealmMemberResponse) Reset ¶
func (x *ListRealmMemberResponse) Reset()
func (*ListRealmMemberResponse) String ¶
func (x *ListRealmMemberResponse) String() string
type ListRealmRequest ¶
type ListRealmRequest struct {
// contains filtered or unexported fields
}
func (*ListRealmRequest) Descriptor
deprecated
func (*ListRealmRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListRealmRequest.ProtoReflect.Descriptor instead.
func (*ListRealmRequest) ProtoMessage ¶
func (*ListRealmRequest) ProtoMessage()
func (*ListRealmRequest) ProtoReflect ¶
func (x *ListRealmRequest) ProtoReflect() protoreflect.Message
func (*ListRealmRequest) Reset ¶
func (x *ListRealmRequest) Reset()
func (*ListRealmRequest) String ¶
func (x *ListRealmRequest) String() string
type ListRealmResponse ¶
type ListRealmResponse struct { Data []*RealmInfo `protobuf:"bytes,1,rep,name=data,proto3" json:"data,omitempty"` // contains filtered or unexported fields }
func (*ListRealmResponse) Descriptor
deprecated
func (*ListRealmResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListRealmResponse.ProtoReflect.Descriptor instead.
func (*ListRealmResponse) GetData ¶
func (x *ListRealmResponse) GetData() []*RealmInfo
func (*ListRealmResponse) ProtoMessage ¶
func (*ListRealmResponse) ProtoMessage()
func (*ListRealmResponse) ProtoReflect ¶
func (x *ListRealmResponse) ProtoReflect() protoreflect.Message
func (*ListRealmResponse) Reset ¶
func (x *ListRealmResponse) Reset()
func (*ListRealmResponse) String ¶
func (x *ListRealmResponse) String() string
type ListServiceRequest ¶
type ListServiceRequest struct { Type *string `protobuf:"bytes,1,opt,name=type,proto3,oneof" json:"type,omitempty"` // contains filtered or unexported fields }
func (*ListServiceRequest) Descriptor
deprecated
func (*ListServiceRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListServiceRequest.ProtoReflect.Descriptor instead.
func (*ListServiceRequest) GetType ¶
func (x *ListServiceRequest) GetType() string
func (*ListServiceRequest) ProtoMessage ¶
func (*ListServiceRequest) ProtoMessage()
func (*ListServiceRequest) ProtoReflect ¶
func (x *ListServiceRequest) ProtoReflect() protoreflect.Message
func (*ListServiceRequest) Reset ¶
func (x *ListServiceRequest) Reset()
func (*ListServiceRequest) String ¶
func (x *ListServiceRequest) String() string
type ListServiceResponse ¶
type ListServiceResponse struct { Data []*ServiceInfo `protobuf:"bytes,1,rep,name=data,proto3" json:"data,omitempty"` // contains filtered or unexported fields }
func (*ListServiceResponse) Descriptor
deprecated
func (*ListServiceResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListServiceResponse.ProtoReflect.Descriptor instead.
func (*ListServiceResponse) GetData ¶
func (x *ListServiceResponse) GetData() []*ServiceInfo
func (*ListServiceResponse) ProtoMessage ¶
func (*ListServiceResponse) ProtoMessage()
func (*ListServiceResponse) ProtoReflect ¶
func (x *ListServiceResponse) ProtoReflect() protoreflect.Message
func (*ListServiceResponse) Reset ¶
func (x *ListServiceResponse) Reset()
func (*ListServiceResponse) String ¶
func (x *ListServiceResponse) String() string
type ListUserRelativeRequest ¶
type ListUserRelativeRequest struct { UserId uint64 `protobuf:"varint,1,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"` IsRelated bool `protobuf:"varint,2,opt,name=is_related,json=isRelated,proto3" json:"is_related,omitempty"` // contains filtered or unexported fields }
func (*ListUserRelativeRequest) Descriptor
deprecated
func (*ListUserRelativeRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListUserRelativeRequest.ProtoReflect.Descriptor instead.
func (*ListUserRelativeRequest) GetIsRelated ¶
func (x *ListUserRelativeRequest) GetIsRelated() bool
func (*ListUserRelativeRequest) GetUserId ¶
func (x *ListUserRelativeRequest) GetUserId() uint64
func (*ListUserRelativeRequest) ProtoMessage ¶
func (*ListUserRelativeRequest) ProtoMessage()
func (*ListUserRelativeRequest) ProtoReflect ¶
func (x *ListUserRelativeRequest) ProtoReflect() protoreflect.Message
func (*ListUserRelativeRequest) Reset ¶
func (x *ListUserRelativeRequest) Reset()
func (*ListUserRelativeRequest) String ¶
func (x *ListUserRelativeRequest) String() string
type ListUserRelativeResponse ¶
type ListUserRelativeResponse struct { Data []*SimpleUserInfo `protobuf:"bytes,1,rep,name=data,proto3" json:"data,omitempty"` // contains filtered or unexported fields }
func (*ListUserRelativeResponse) Descriptor
deprecated
func (*ListUserRelativeResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListUserRelativeResponse.ProtoReflect.Descriptor instead.
func (*ListUserRelativeResponse) GetData ¶
func (x *ListUserRelativeResponse) GetData() []*SimpleUserInfo
func (*ListUserRelativeResponse) ProtoMessage ¶
func (*ListUserRelativeResponse) ProtoMessage()
func (*ListUserRelativeResponse) ProtoReflect ¶
func (x *ListUserRelativeResponse) ProtoReflect() protoreflect.Message
func (*ListUserRelativeResponse) Reset ¶
func (x *ListUserRelativeResponse) Reset()
func (*ListUserRelativeResponse) String ¶
func (x *ListUserRelativeResponse) String() string
type LookupRealmRequest ¶
type LookupRealmRequest struct { Id *uint64 `protobuf:"varint,1,opt,name=id,proto3,oneof" json:"id,omitempty"` Alias *string `protobuf:"bytes,2,opt,name=alias,proto3,oneof" json:"alias,omitempty"` IsPublic *bool `protobuf:"varint,3,opt,name=is_public,json=isPublic,proto3,oneof" json:"is_public,omitempty"` IsCommunity *bool `protobuf:"varint,4,opt,name=is_community,json=isCommunity,proto3,oneof" json:"is_community,omitempty"` // contains filtered or unexported fields }
func (*LookupRealmRequest) Descriptor
deprecated
func (*LookupRealmRequest) Descriptor() ([]byte, []int)
Deprecated: Use LookupRealmRequest.ProtoReflect.Descriptor instead.
func (*LookupRealmRequest) GetAlias ¶
func (x *LookupRealmRequest) GetAlias() string
func (*LookupRealmRequest) GetId ¶
func (x *LookupRealmRequest) GetId() uint64
func (*LookupRealmRequest) GetIsCommunity ¶
func (x *LookupRealmRequest) GetIsCommunity() bool
func (*LookupRealmRequest) GetIsPublic ¶
func (x *LookupRealmRequest) GetIsPublic() bool
func (*LookupRealmRequest) ProtoMessage ¶
func (*LookupRealmRequest) ProtoMessage()
func (*LookupRealmRequest) ProtoReflect ¶
func (x *LookupRealmRequest) ProtoReflect() protoreflect.Message
func (*LookupRealmRequest) Reset ¶
func (x *LookupRealmRequest) Reset()
func (*LookupRealmRequest) String ¶
func (x *LookupRealmRequest) String() string
type LookupUserRealmRequest ¶
type LookupUserRealmRequest struct { UserId uint64 `protobuf:"varint,1,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"` // contains filtered or unexported fields }
func (*LookupUserRealmRequest) Descriptor
deprecated
func (*LookupUserRealmRequest) Descriptor() ([]byte, []int)
Deprecated: Use LookupUserRealmRequest.ProtoReflect.Descriptor instead.
func (*LookupUserRealmRequest) GetUserId ¶
func (x *LookupUserRealmRequest) GetUserId() uint64
func (*LookupUserRealmRequest) ProtoMessage ¶
func (*LookupUserRealmRequest) ProtoMessage()
func (*LookupUserRealmRequest) ProtoReflect ¶
func (x *LookupUserRealmRequest) ProtoReflect() protoreflect.Message
func (*LookupUserRealmRequest) Reset ¶
func (x *LookupUserRealmRequest) Reset()
func (*LookupUserRealmRequest) String ¶
func (x *LookupUserRealmRequest) String() string
type NotifierClient ¶
type NotifierClient interface { NotifyUser(ctx context.Context, in *NotifyUserRequest, opts ...grpc.CallOption) (*NotifyResponse, error) NotifyUserBatch(ctx context.Context, in *NotifyUserBatchRequest, opts ...grpc.CallOption) (*NotifyResponse, error) NotifyAllUser(ctx context.Context, in *NotifyRequest, opts ...grpc.CallOption) (*NotifyResponse, error) }
NotifierClient is the client API for Notifier 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 NewNotifierClient ¶
func NewNotifierClient(cc grpc.ClientConnInterface) NotifierClient
type NotifierServer ¶
type NotifierServer interface { NotifyUser(context.Context, *NotifyUserRequest) (*NotifyResponse, error) NotifyUserBatch(context.Context, *NotifyUserBatchRequest) (*NotifyResponse, error) NotifyAllUser(context.Context, *NotifyRequest) (*NotifyResponse, error) // contains filtered or unexported methods }
NotifierServer is the server API for Notifier service. All implementations must embed UnimplementedNotifierServer for forward compatibility.
type NotifyRequest ¶
type NotifyRequest struct { Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"` Title string `protobuf:"bytes,2,opt,name=title,proto3" json:"title,omitempty"` Subtitle *string `protobuf:"bytes,3,opt,name=subtitle,proto3,oneof" json:"subtitle,omitempty"` Body string `protobuf:"bytes,4,opt,name=body,proto3" json:"body,omitempty"` Metadata []byte `protobuf:"bytes,5,opt,name=metadata,proto3" json:"metadata,omitempty"` Avatar *string `protobuf:"bytes,6,opt,name=avatar,proto3,oneof" json:"avatar,omitempty"` Picture *string `protobuf:"bytes,7,opt,name=picture,proto3,oneof" json:"picture,omitempty"` IsRealtime bool `protobuf:"varint,8,opt,name=is_realtime,json=isRealtime,proto3" json:"is_realtime,omitempty"` IsForcePush bool `protobuf:"varint,9,opt,name=is_force_push,json=isForcePush,proto3" json:"is_force_push,omitempty"` // contains filtered or unexported fields }
func (*NotifyRequest) Descriptor
deprecated
func (*NotifyRequest) Descriptor() ([]byte, []int)
Deprecated: Use NotifyRequest.ProtoReflect.Descriptor instead.
func (*NotifyRequest) GetAvatar ¶
func (x *NotifyRequest) GetAvatar() string
func (*NotifyRequest) GetBody ¶
func (x *NotifyRequest) GetBody() string
func (*NotifyRequest) GetIsForcePush ¶
func (x *NotifyRequest) GetIsForcePush() bool
func (*NotifyRequest) GetIsRealtime ¶
func (x *NotifyRequest) GetIsRealtime() bool
func (*NotifyRequest) GetMetadata ¶
func (x *NotifyRequest) GetMetadata() []byte
func (*NotifyRequest) GetPicture ¶
func (x *NotifyRequest) GetPicture() string
func (*NotifyRequest) GetSubtitle ¶
func (x *NotifyRequest) GetSubtitle() string
func (*NotifyRequest) GetTitle ¶
func (x *NotifyRequest) GetTitle() string
func (*NotifyRequest) GetTopic ¶
func (x *NotifyRequest) GetTopic() string
func (*NotifyRequest) ProtoMessage ¶
func (*NotifyRequest) ProtoMessage()
func (*NotifyRequest) ProtoReflect ¶
func (x *NotifyRequest) ProtoReflect() protoreflect.Message
func (*NotifyRequest) Reset ¶
func (x *NotifyRequest) Reset()
func (*NotifyRequest) String ¶
func (x *NotifyRequest) String() string
type NotifyResponse ¶
type NotifyResponse struct { IsSuccess bool `protobuf:"varint,1,opt,name=is_success,json=isSuccess,proto3" json:"is_success,omitempty"` AffectedCount int64 `protobuf:"varint,2,opt,name=affected_count,json=affectedCount,proto3" json:"affected_count,omitempty"` // contains filtered or unexported fields }
func (*NotifyResponse) Descriptor
deprecated
func (*NotifyResponse) Descriptor() ([]byte, []int)
Deprecated: Use NotifyResponse.ProtoReflect.Descriptor instead.
func (*NotifyResponse) GetAffectedCount ¶
func (x *NotifyResponse) GetAffectedCount() int64
func (*NotifyResponse) GetIsSuccess ¶
func (x *NotifyResponse) GetIsSuccess() bool
func (*NotifyResponse) ProtoMessage ¶
func (*NotifyResponse) ProtoMessage()
func (*NotifyResponse) ProtoReflect ¶
func (x *NotifyResponse) ProtoReflect() protoreflect.Message
func (*NotifyResponse) Reset ¶
func (x *NotifyResponse) Reset()
func (*NotifyResponse) String ¶
func (x *NotifyResponse) String() string
type NotifyUserBatchRequest ¶
type NotifyUserBatchRequest struct { UserId []uint64 `protobuf:"varint,1,rep,packed,name=user_id,json=userId,proto3" json:"user_id,omitempty"` Notify *NotifyRequest `protobuf:"bytes,2,opt,name=notify,proto3" json:"notify,omitempty"` // contains filtered or unexported fields }
func (*NotifyUserBatchRequest) Descriptor
deprecated
func (*NotifyUserBatchRequest) Descriptor() ([]byte, []int)
Deprecated: Use NotifyUserBatchRequest.ProtoReflect.Descriptor instead.
func (*NotifyUserBatchRequest) GetNotify ¶
func (x *NotifyUserBatchRequest) GetNotify() *NotifyRequest
func (*NotifyUserBatchRequest) GetUserId ¶
func (x *NotifyUserBatchRequest) GetUserId() []uint64
func (*NotifyUserBatchRequest) ProtoMessage ¶
func (*NotifyUserBatchRequest) ProtoMessage()
func (*NotifyUserBatchRequest) ProtoReflect ¶
func (x *NotifyUserBatchRequest) ProtoReflect() protoreflect.Message
func (*NotifyUserBatchRequest) Reset ¶
func (x *NotifyUserBatchRequest) Reset()
func (*NotifyUserBatchRequest) String ¶
func (x *NotifyUserBatchRequest) String() string
type NotifyUserRequest ¶
type NotifyUserRequest struct { UserId uint64 `protobuf:"varint,1,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"` Notify *NotifyRequest `protobuf:"bytes,2,opt,name=notify,proto3" json:"notify,omitempty"` // contains filtered or unexported fields }
func (*NotifyUserRequest) Descriptor
deprecated
func (*NotifyUserRequest) Descriptor() ([]byte, []int)
Deprecated: Use NotifyUserRequest.ProtoReflect.Descriptor instead.
func (*NotifyUserRequest) GetNotify ¶
func (x *NotifyUserRequest) GetNotify() *NotifyRequest
func (*NotifyUserRequest) GetUserId ¶
func (x *NotifyUserRequest) GetUserId() uint64
func (*NotifyUserRequest) ProtoMessage ¶
func (*NotifyUserRequest) ProtoMessage()
func (*NotifyUserRequest) ProtoReflect ¶
func (x *NotifyUserRequest) ProtoReflect() protoreflect.Message
func (*NotifyUserRequest) Reset ¶
func (x *NotifyUserRequest) Reset()
func (*NotifyUserRequest) String ¶
func (x *NotifyUserRequest) String() string
type PostmanClient ¶
type PostmanClient interface { DeliverNotification(ctx context.Context, in *DeliverNotificationRequest, opts ...grpc.CallOption) (*DeliverResponse, error) DeliverNotificationBatch(ctx context.Context, in *DeliverNotificationBatchRequest, opts ...grpc.CallOption) (*DeliverResponse, error) DeliverEmail(ctx context.Context, in *DeliverEmailRequest, opts ...grpc.CallOption) (*DeliverResponse, error) DeliverEmailBatch(ctx context.Context, in *DeliverEmailBatchRequest, opts ...grpc.CallOption) (*DeliverResponse, error) }
PostmanClient is the client API for Postman 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 NewPostmanClient ¶
func NewPostmanClient(cc grpc.ClientConnInterface) PostmanClient
type PostmanServer ¶
type PostmanServer interface { DeliverNotification(context.Context, *DeliverNotificationRequest) (*DeliverResponse, error) DeliverNotificationBatch(context.Context, *DeliverNotificationBatchRequest) (*DeliverResponse, error) DeliverEmail(context.Context, *DeliverEmailRequest) (*DeliverResponse, error) DeliverEmailBatch(context.Context, *DeliverEmailBatchRequest) (*DeliverResponse, error) // contains filtered or unexported methods }
PostmanServer is the server API for Postman service. All implementations must embed UnimplementedPostmanServer for forward compatibility.
type PushStreamBatchRequest ¶
type PushStreamBatchRequest struct { UserId []uint64 `protobuf:"varint,1,rep,packed,name=user_id,json=userId,proto3" json:"user_id,omitempty"` ClientId []uint64 `protobuf:"varint,2,rep,packed,name=client_id,json=clientId,proto3" json:"client_id,omitempty"` Body []byte `protobuf:"bytes,3,opt,name=body,proto3" json:"body,omitempty"` // contains filtered or unexported fields }
func (*PushStreamBatchRequest) Descriptor
deprecated
func (*PushStreamBatchRequest) Descriptor() ([]byte, []int)
Deprecated: Use PushStreamBatchRequest.ProtoReflect.Descriptor instead.
func (*PushStreamBatchRequest) GetBody ¶
func (x *PushStreamBatchRequest) GetBody() []byte
func (*PushStreamBatchRequest) GetClientId ¶
func (x *PushStreamBatchRequest) GetClientId() []uint64
func (*PushStreamBatchRequest) GetUserId ¶
func (x *PushStreamBatchRequest) GetUserId() []uint64
func (*PushStreamBatchRequest) ProtoMessage ¶
func (*PushStreamBatchRequest) ProtoMessage()
func (*PushStreamBatchRequest) ProtoReflect ¶
func (x *PushStreamBatchRequest) ProtoReflect() protoreflect.Message
func (*PushStreamBatchRequest) Reset ¶
func (x *PushStreamBatchRequest) Reset()
func (*PushStreamBatchRequest) String ¶
func (x *PushStreamBatchRequest) String() string
type PushStreamRequest ¶
type PushStreamRequest struct { UserId *uint64 `protobuf:"varint,1,opt,name=user_id,json=userId,proto3,oneof" json:"user_id,omitempty"` ClientId *uint64 `protobuf:"varint,2,opt,name=client_id,json=clientId,proto3,oneof" json:"client_id,omitempty"` Body []byte `protobuf:"bytes,3,opt,name=body,proto3" json:"body,omitempty"` // contains filtered or unexported fields }
func (*PushStreamRequest) Descriptor
deprecated
func (*PushStreamRequest) Descriptor() ([]byte, []int)
Deprecated: Use PushStreamRequest.ProtoReflect.Descriptor instead.
func (*PushStreamRequest) GetBody ¶
func (x *PushStreamRequest) GetBody() []byte
func (*PushStreamRequest) GetClientId ¶
func (x *PushStreamRequest) GetClientId() uint64
func (*PushStreamRequest) GetUserId ¶
func (x *PushStreamRequest) GetUserId() uint64
func (*PushStreamRequest) ProtoMessage ¶
func (*PushStreamRequest) ProtoMessage()
func (*PushStreamRequest) ProtoReflect ¶
func (x *PushStreamRequest) ProtoReflect() protoreflect.Message
func (*PushStreamRequest) Reset ¶
func (x *PushStreamRequest) Reset()
func (*PushStreamRequest) String ¶
func (x *PushStreamRequest) String() string
type PushStreamResponse ¶
type PushStreamResponse struct { IsAllSuccess bool `protobuf:"varint,1,opt,name=is_all_success,json=isAllSuccess,proto3" json:"is_all_success,omitempty"` AffectedCount int64 `protobuf:"varint,2,opt,name=affected_count,json=affectedCount,proto3" json:"affected_count,omitempty"` FailedCount int64 `protobuf:"varint,3,opt,name=failed_count,json=failedCount,proto3" json:"failed_count,omitempty"` // contains filtered or unexported fields }
func (*PushStreamResponse) Descriptor
deprecated
func (*PushStreamResponse) Descriptor() ([]byte, []int)
Deprecated: Use PushStreamResponse.ProtoReflect.Descriptor instead.
func (*PushStreamResponse) GetAffectedCount ¶
func (x *PushStreamResponse) GetAffectedCount() int64
func (*PushStreamResponse) GetFailedCount ¶
func (x *PushStreamResponse) GetFailedCount() int64
func (*PushStreamResponse) GetIsAllSuccess ¶
func (x *PushStreamResponse) GetIsAllSuccess() bool
func (*PushStreamResponse) ProtoMessage ¶
func (*PushStreamResponse) ProtoMessage()
func (*PushStreamResponse) ProtoReflect ¶
func (x *PushStreamResponse) ProtoReflect() protoreflect.Message
func (*PushStreamResponse) Reset ¶
func (x *PushStreamResponse) Reset()
func (*PushStreamResponse) String ¶
func (x *PushStreamResponse) String() string
type RealmClient ¶
type RealmClient interface { ListCommunityRealm(ctx context.Context, in *ListRealmRequest, opts ...grpc.CallOption) (*ListRealmResponse, error) ListAvailableRealm(ctx context.Context, in *LookupUserRealmRequest, opts ...grpc.CallOption) (*ListRealmResponse, error) ListOwnedRealm(ctx context.Context, in *LookupUserRealmRequest, opts ...grpc.CallOption) (*ListRealmResponse, error) GetRealm(ctx context.Context, in *LookupRealmRequest, opts ...grpc.CallOption) (*RealmInfo, error) ListRealmMember(ctx context.Context, in *RealmMemberLookupRequest, opts ...grpc.CallOption) (*ListRealmMemberResponse, error) GetRealmMember(ctx context.Context, in *RealmMemberLookupRequest, opts ...grpc.CallOption) (*RealmMemberInfo, error) CheckRealmMemberPerm(ctx context.Context, in *CheckRealmPermRequest, opts ...grpc.CallOption) (*CheckRealmPermResponse, error) }
RealmClient is the client API for Realm 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 NewRealmClient ¶
func NewRealmClient(cc grpc.ClientConnInterface) RealmClient
type RealmInfo ¶
type RealmInfo struct { Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` Alias string `protobuf:"bytes,2,opt,name=alias,proto3" json:"alias,omitempty"` Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"` Description string `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"` IsPublic bool `protobuf:"varint,5,opt,name=is_public,json=isPublic,proto3" json:"is_public,omitempty"` IsCommunity bool `protobuf:"varint,6,opt,name=is_community,json=isCommunity,proto3" json:"is_community,omitempty"` // contains filtered or unexported fields }
func (*RealmInfo) Descriptor
deprecated
func (*RealmInfo) GetDescription ¶
func (*RealmInfo) GetIsCommunity ¶
func (*RealmInfo) GetIsPublic ¶
func (*RealmInfo) ProtoMessage ¶
func (*RealmInfo) ProtoMessage()
func (*RealmInfo) ProtoReflect ¶
func (x *RealmInfo) ProtoReflect() protoreflect.Message
type RealmMemberInfo ¶
type RealmMemberInfo struct { RealmId uint64 `protobuf:"varint,1,opt,name=realm_id,json=realmId,proto3" json:"realm_id,omitempty"` UserId uint64 `protobuf:"varint,2,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"` PowerLevel int32 `protobuf:"varint,3,opt,name=power_level,json=powerLevel,proto3" json:"power_level,omitempty"` // contains filtered or unexported fields }
func (*RealmMemberInfo) Descriptor
deprecated
func (*RealmMemberInfo) Descriptor() ([]byte, []int)
Deprecated: Use RealmMemberInfo.ProtoReflect.Descriptor instead.
func (*RealmMemberInfo) GetPowerLevel ¶
func (x *RealmMemberInfo) GetPowerLevel() int32
func (*RealmMemberInfo) GetRealmId ¶
func (x *RealmMemberInfo) GetRealmId() uint64
func (*RealmMemberInfo) GetUserId ¶
func (x *RealmMemberInfo) GetUserId() uint64
func (*RealmMemberInfo) ProtoMessage ¶
func (*RealmMemberInfo) ProtoMessage()
func (*RealmMemberInfo) ProtoReflect ¶
func (x *RealmMemberInfo) ProtoReflect() protoreflect.Message
func (*RealmMemberInfo) Reset ¶
func (x *RealmMemberInfo) Reset()
func (*RealmMemberInfo) String ¶
func (x *RealmMemberInfo) String() string
type RealmMemberLookupRequest ¶
type RealmMemberLookupRequest struct { RealmId uint64 `protobuf:"varint,1,opt,name=realm_id,json=realmId,proto3" json:"realm_id,omitempty"` UserId *uint64 `protobuf:"varint,2,opt,name=user_id,json=userId,proto3,oneof" json:"user_id,omitempty"` // contains filtered or unexported fields }
func (*RealmMemberLookupRequest) Descriptor
deprecated
func (*RealmMemberLookupRequest) Descriptor() ([]byte, []int)
Deprecated: Use RealmMemberLookupRequest.ProtoReflect.Descriptor instead.
func (*RealmMemberLookupRequest) GetRealmId ¶
func (x *RealmMemberLookupRequest) GetRealmId() uint64
func (*RealmMemberLookupRequest) GetUserId ¶
func (x *RealmMemberLookupRequest) GetUserId() uint64
func (*RealmMemberLookupRequest) ProtoMessage ¶
func (*RealmMemberLookupRequest) ProtoMessage()
func (*RealmMemberLookupRequest) ProtoReflect ¶
func (x *RealmMemberLookupRequest) ProtoReflect() protoreflect.Message
func (*RealmMemberLookupRequest) Reset ¶
func (x *RealmMemberLookupRequest) Reset()
func (*RealmMemberLookupRequest) String ¶
func (x *RealmMemberLookupRequest) String() string
type RealmServer ¶
type RealmServer interface { ListCommunityRealm(context.Context, *ListRealmRequest) (*ListRealmResponse, error) ListAvailableRealm(context.Context, *LookupUserRealmRequest) (*ListRealmResponse, error) ListOwnedRealm(context.Context, *LookupUserRealmRequest) (*ListRealmResponse, error) GetRealm(context.Context, *LookupRealmRequest) (*RealmInfo, error) ListRealmMember(context.Context, *RealmMemberLookupRequest) (*ListRealmMemberResponse, error) GetRealmMember(context.Context, *RealmMemberLookupRequest) (*RealmMemberInfo, error) CheckRealmMemberPerm(context.Context, *CheckRealmPermRequest) (*CheckRealmPermResponse, error) // contains filtered or unexported methods }
RealmServer is the server API for Realm service. All implementations must embed UnimplementedRealmServer for forward compatibility.
type RecordEventRequest ¶
type RecordEventRequest struct { UserId uint64 `protobuf:"varint,1,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"` Action string `protobuf:"bytes,2,opt,name=action,proto3" json:"action,omitempty"` Target string `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"` Ip string `protobuf:"bytes,4,opt,name=ip,proto3" json:"ip,omitempty"` UserAgent string `protobuf:"bytes,5,opt,name=user_agent,json=userAgent,proto3" json:"user_agent,omitempty"` // contains filtered or unexported fields }
func (*RecordEventRequest) Descriptor
deprecated
func (*RecordEventRequest) Descriptor() ([]byte, []int)
Deprecated: Use RecordEventRequest.ProtoReflect.Descriptor instead.
func (*RecordEventRequest) GetAction ¶
func (x *RecordEventRequest) GetAction() string
func (*RecordEventRequest) GetIp ¶
func (x *RecordEventRequest) GetIp() string
func (*RecordEventRequest) GetTarget ¶
func (x *RecordEventRequest) GetTarget() string
func (*RecordEventRequest) GetUserAgent ¶
func (x *RecordEventRequest) GetUserAgent() string
func (*RecordEventRequest) GetUserId ¶
func (x *RecordEventRequest) GetUserId() uint64
func (*RecordEventRequest) ProtoMessage ¶
func (*RecordEventRequest) ProtoMessage()
func (*RecordEventRequest) ProtoReflect ¶
func (x *RecordEventRequest) ProtoReflect() protoreflect.Message
func (*RecordEventRequest) Reset ¶
func (x *RecordEventRequest) Reset()
func (*RecordEventRequest) String ¶
func (x *RecordEventRequest) String() string
type RecordEventResponse ¶
type RecordEventResponse struct { IsSuccess bool `protobuf:"varint,1,opt,name=is_success,json=isSuccess,proto3" json:"is_success,omitempty"` // contains filtered or unexported fields }
func (*RecordEventResponse) Descriptor
deprecated
func (*RecordEventResponse) Descriptor() ([]byte, []int)
Deprecated: Use RecordEventResponse.ProtoReflect.Descriptor instead.
func (*RecordEventResponse) GetIsSuccess ¶
func (x *RecordEventResponse) GetIsSuccess() bool
func (*RecordEventResponse) ProtoMessage ¶
func (*RecordEventResponse) ProtoMessage()
func (*RecordEventResponse) ProtoReflect ¶
func (x *RecordEventResponse) ProtoReflect() protoreflect.Message
func (*RecordEventResponse) Reset ¶
func (x *RecordEventResponse) Reset()
func (*RecordEventResponse) String ¶
func (x *RecordEventResponse) String() string
type RemoveServiceRequest ¶
type RemoveServiceRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
func (*RemoveServiceRequest) Descriptor
deprecated
func (*RemoveServiceRequest) Descriptor() ([]byte, []int)
Deprecated: Use RemoveServiceRequest.ProtoReflect.Descriptor instead.
func (*RemoveServiceRequest) GetId ¶
func (x *RemoveServiceRequest) GetId() string
func (*RemoveServiceRequest) ProtoMessage ¶
func (*RemoveServiceRequest) ProtoMessage()
func (*RemoveServiceRequest) ProtoReflect ¶
func (x *RemoveServiceRequest) ProtoReflect() protoreflect.Message
func (*RemoveServiceRequest) Reset ¶
func (x *RemoveServiceRequest) Reset()
func (*RemoveServiceRequest) String ¶
func (x *RemoveServiceRequest) String() string
type RemoveServiceResponse ¶
type RemoveServiceResponse struct { IsSuccess bool `protobuf:"varint,1,opt,name=is_success,json=isSuccess,proto3" json:"is_success,omitempty"` // contains filtered or unexported fields }
func (*RemoveServiceResponse) Descriptor
deprecated
func (*RemoveServiceResponse) Descriptor() ([]byte, []int)
Deprecated: Use RemoveServiceResponse.ProtoReflect.Descriptor instead.
func (*RemoveServiceResponse) GetIsSuccess ¶
func (x *RemoveServiceResponse) GetIsSuccess() bool
func (*RemoveServiceResponse) ProtoMessage ¶
func (*RemoveServiceResponse) ProtoMessage()
func (*RemoveServiceResponse) ProtoReflect ¶
func (x *RemoveServiceResponse) ProtoReflect() protoreflect.Message
func (*RemoveServiceResponse) Reset ¶
func (x *RemoveServiceResponse) Reset()
func (*RemoveServiceResponse) String ¶
func (x *RemoveServiceResponse) String() string
type ServiceDirectoryClient ¶
type ServiceDirectoryClient interface { GetService(ctx context.Context, in *GetServiceRequest, opts ...grpc.CallOption) (*GetServiceResponse, error) ListService(ctx context.Context, in *ListServiceRequest, opts ...grpc.CallOption) (*ListServiceResponse, error) AddService(ctx context.Context, in *ServiceInfo, opts ...grpc.CallOption) (*AddServiceResponse, error) RemoveService(ctx context.Context, in *RemoveServiceRequest, opts ...grpc.CallOption) (*RemoveServiceResponse, error) }
ServiceDirectoryClient is the client API for ServiceDirectory 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 NewServiceDirectoryClient ¶
func NewServiceDirectoryClient(cc grpc.ClientConnInterface) ServiceDirectoryClient
type ServiceDirectoryServer ¶
type ServiceDirectoryServer interface { GetService(context.Context, *GetServiceRequest) (*GetServiceResponse, error) ListService(context.Context, *ListServiceRequest) (*ListServiceResponse, error) AddService(context.Context, *ServiceInfo) (*AddServiceResponse, error) RemoveService(context.Context, *RemoveServiceRequest) (*RemoveServiceResponse, error) // contains filtered or unexported methods }
ServiceDirectoryServer is the server API for ServiceDirectory service. All implementations must embed UnimplementedServiceDirectoryServer for forward compatibility.
type ServiceInfo ¶
type ServiceInfo struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"` Label string `protobuf:"bytes,3,opt,name=label,proto3" json:"label,omitempty"` GrpcAddr string `protobuf:"bytes,4,opt,name=grpc_addr,json=grpcAddr,proto3" json:"grpc_addr,omitempty"` HttpAddr *string `protobuf:"bytes,5,opt,name=http_addr,json=httpAddr,proto3,oneof" json:"http_addr,omitempty"` // contains filtered or unexported fields }
func (*ServiceInfo) Descriptor
deprecated
func (*ServiceInfo) Descriptor() ([]byte, []int)
Deprecated: Use ServiceInfo.ProtoReflect.Descriptor instead.
func (*ServiceInfo) GetGrpcAddr ¶
func (x *ServiceInfo) GetGrpcAddr() string
func (*ServiceInfo) GetHttpAddr ¶
func (x *ServiceInfo) GetHttpAddr() string
func (*ServiceInfo) GetId ¶
func (x *ServiceInfo) GetId() string
func (*ServiceInfo) GetLabel ¶
func (x *ServiceInfo) GetLabel() string
func (*ServiceInfo) GetType ¶
func (x *ServiceInfo) GetType() string
func (*ServiceInfo) ProtoMessage ¶
func (*ServiceInfo) ProtoMessage()
func (*ServiceInfo) ProtoReflect ¶
func (x *ServiceInfo) ProtoReflect() protoreflect.Message
func (*ServiceInfo) Reset ¶
func (x *ServiceInfo) Reset()
func (*ServiceInfo) String ¶
func (x *ServiceInfo) String() string
type SimpleUserInfo ¶
type SimpleUserInfo struct { Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` Nick string `protobuf:"bytes,3,opt,name=nick,proto3" json:"nick,omitempty"` // contains filtered or unexported fields }
func (*SimpleUserInfo) Descriptor
deprecated
func (*SimpleUserInfo) Descriptor() ([]byte, []int)
Deprecated: Use SimpleUserInfo.ProtoReflect.Descriptor instead.
func (*SimpleUserInfo) GetId ¶
func (x *SimpleUserInfo) GetId() uint64
func (*SimpleUserInfo) GetName ¶
func (x *SimpleUserInfo) GetName() string
func (*SimpleUserInfo) GetNick ¶
func (x *SimpleUserInfo) GetNick() string
func (*SimpleUserInfo) ProtoMessage ¶
func (*SimpleUserInfo) ProtoMessage()
func (*SimpleUserInfo) ProtoReflect ¶
func (x *SimpleUserInfo) ProtoReflect() protoreflect.Message
func (*SimpleUserInfo) Reset ¶
func (x *SimpleUserInfo) Reset()
func (*SimpleUserInfo) String ¶
func (x *SimpleUserInfo) String() string
type StreamControllerClient ¶
type StreamControllerClient interface { CountStreamConnection(ctx context.Context, in *CountConnectionRequest, opts ...grpc.CallOption) (*CountConnectionResponse, error) PushStream(ctx context.Context, in *PushStreamRequest, opts ...grpc.CallOption) (*PushStreamResponse, error) PushStreamBatch(ctx context.Context, in *PushStreamBatchRequest, opts ...grpc.CallOption) (*PushStreamResponse, error) EmitStreamEvent(ctx context.Context, in *StreamEventRequest, opts ...grpc.CallOption) (*StreamEventResponse, error) }
StreamControllerClient is the client API for StreamController 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 NewStreamControllerClient ¶
func NewStreamControllerClient(cc grpc.ClientConnInterface) StreamControllerClient
type StreamControllerServer ¶
type StreamControllerServer interface { CountStreamConnection(context.Context, *CountConnectionRequest) (*CountConnectionResponse, error) PushStream(context.Context, *PushStreamRequest) (*PushStreamResponse, error) PushStreamBatch(context.Context, *PushStreamBatchRequest) (*PushStreamResponse, error) EmitStreamEvent(context.Context, *StreamEventRequest) (*StreamEventResponse, error) // contains filtered or unexported methods }
StreamControllerServer is the server API for StreamController service. All implementations must embed UnimplementedStreamControllerServer for forward compatibility.
type StreamEventRequest ¶
type StreamEventRequest struct { Event string `protobuf:"bytes,1,opt,name=event,proto3" json:"event,omitempty"` UserId uint64 `protobuf:"varint,2,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"` ClientId uint64 `protobuf:"varint,3,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"` Payload []byte `protobuf:"bytes,4,opt,name=payload,proto3" json:"payload,omitempty"` // contains filtered or unexported fields }
func (*StreamEventRequest) Descriptor
deprecated
func (*StreamEventRequest) Descriptor() ([]byte, []int)
Deprecated: Use StreamEventRequest.ProtoReflect.Descriptor instead.
func (*StreamEventRequest) GetClientId ¶
func (x *StreamEventRequest) GetClientId() uint64
func (*StreamEventRequest) GetEvent ¶
func (x *StreamEventRequest) GetEvent() string
func (*StreamEventRequest) GetPayload ¶
func (x *StreamEventRequest) GetPayload() []byte
func (*StreamEventRequest) GetUserId ¶
func (x *StreamEventRequest) GetUserId() uint64
func (*StreamEventRequest) ProtoMessage ¶
func (*StreamEventRequest) ProtoMessage()
func (*StreamEventRequest) ProtoReflect ¶
func (x *StreamEventRequest) ProtoReflect() protoreflect.Message
func (*StreamEventRequest) Reset ¶
func (x *StreamEventRequest) Reset()
func (*StreamEventRequest) String ¶
func (x *StreamEventRequest) String() string
type StreamEventResponse ¶
type StreamEventResponse struct {
// contains filtered or unexported fields
}
func (*StreamEventResponse) Descriptor
deprecated
func (*StreamEventResponse) Descriptor() ([]byte, []int)
Deprecated: Use StreamEventResponse.ProtoReflect.Descriptor instead.
func (*StreamEventResponse) ProtoMessage ¶
func (*StreamEventResponse) ProtoMessage()
func (*StreamEventResponse) ProtoReflect ¶
func (x *StreamEventResponse) ProtoReflect() protoreflect.Message
func (*StreamEventResponse) Reset ¶
func (x *StreamEventResponse) Reset()
func (*StreamEventResponse) String ¶
func (x *StreamEventResponse) String() string
type UnimplementedAuthServer ¶
type UnimplementedAuthServer struct{}
UnimplementedAuthServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedAuthServer) Authenticate ¶
func (UnimplementedAuthServer) Authenticate(context.Context, *AuthRequest) (*AuthReply, error)
func (UnimplementedAuthServer) EnsurePermGranted ¶
func (UnimplementedAuthServer) EnsurePermGranted(context.Context, *CheckPermRequest) (*CheckPermResponse, error)
func (UnimplementedAuthServer) EnsureUserPermGranted ¶
func (UnimplementedAuthServer) EnsureUserPermGranted(context.Context, *CheckUserPermRequest) (*CheckUserPermResponse, error)
func (UnimplementedAuthServer) ListUserBlocklist ¶
func (UnimplementedAuthServer) ListUserBlocklist(context.Context, *ListUserRelativeRequest) (*ListUserRelativeResponse, error)
func (UnimplementedAuthServer) ListUserFriends ¶
func (UnimplementedAuthServer) ListUserFriends(context.Context, *ListUserRelativeRequest) (*ListUserRelativeResponse, error)
type UnimplementedEventRecorderServer ¶
type UnimplementedEventRecorderServer struct{}
UnimplementedEventRecorderServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedEventRecorderServer) RecordEvent ¶
func (UnimplementedEventRecorderServer) RecordEvent(context.Context, *RecordEventRequest) (*RecordEventResponse, error)
type UnimplementedNotifierServer ¶
type UnimplementedNotifierServer struct{}
UnimplementedNotifierServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedNotifierServer) NotifyAllUser ¶
func (UnimplementedNotifierServer) NotifyAllUser(context.Context, *NotifyRequest) (*NotifyResponse, error)
func (UnimplementedNotifierServer) NotifyUser ¶
func (UnimplementedNotifierServer) NotifyUser(context.Context, *NotifyUserRequest) (*NotifyResponse, error)
func (UnimplementedNotifierServer) NotifyUserBatch ¶
func (UnimplementedNotifierServer) NotifyUserBatch(context.Context, *NotifyUserBatchRequest) (*NotifyResponse, error)
type UnimplementedPostmanServer ¶
type UnimplementedPostmanServer struct{}
UnimplementedPostmanServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedPostmanServer) DeliverEmail ¶
func (UnimplementedPostmanServer) DeliverEmail(context.Context, *DeliverEmailRequest) (*DeliverResponse, error)
func (UnimplementedPostmanServer) DeliverEmailBatch ¶
func (UnimplementedPostmanServer) DeliverEmailBatch(context.Context, *DeliverEmailBatchRequest) (*DeliverResponse, error)
func (UnimplementedPostmanServer) DeliverNotification ¶
func (UnimplementedPostmanServer) DeliverNotification(context.Context, *DeliverNotificationRequest) (*DeliverResponse, error)
func (UnimplementedPostmanServer) DeliverNotificationBatch ¶
func (UnimplementedPostmanServer) DeliverNotificationBatch(context.Context, *DeliverNotificationBatchRequest) (*DeliverResponse, error)
type UnimplementedRealmServer ¶
type UnimplementedRealmServer struct{}
UnimplementedRealmServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedRealmServer) CheckRealmMemberPerm ¶
func (UnimplementedRealmServer) CheckRealmMemberPerm(context.Context, *CheckRealmPermRequest) (*CheckRealmPermResponse, error)
func (UnimplementedRealmServer) GetRealm ¶
func (UnimplementedRealmServer) GetRealm(context.Context, *LookupRealmRequest) (*RealmInfo, error)
func (UnimplementedRealmServer) GetRealmMember ¶
func (UnimplementedRealmServer) GetRealmMember(context.Context, *RealmMemberLookupRequest) (*RealmMemberInfo, error)
func (UnimplementedRealmServer) ListAvailableRealm ¶
func (UnimplementedRealmServer) ListAvailableRealm(context.Context, *LookupUserRealmRequest) (*ListRealmResponse, error)
func (UnimplementedRealmServer) ListCommunityRealm ¶
func (UnimplementedRealmServer) ListCommunityRealm(context.Context, *ListRealmRequest) (*ListRealmResponse, error)
func (UnimplementedRealmServer) ListOwnedRealm ¶
func (UnimplementedRealmServer) ListOwnedRealm(context.Context, *LookupUserRealmRequest) (*ListRealmResponse, error)
func (UnimplementedRealmServer) ListRealmMember ¶
func (UnimplementedRealmServer) ListRealmMember(context.Context, *RealmMemberLookupRequest) (*ListRealmMemberResponse, error)
type UnimplementedServiceDirectoryServer ¶
type UnimplementedServiceDirectoryServer struct{}
UnimplementedServiceDirectoryServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedServiceDirectoryServer) AddService ¶
func (UnimplementedServiceDirectoryServer) AddService(context.Context, *ServiceInfo) (*AddServiceResponse, error)
func (UnimplementedServiceDirectoryServer) GetService ¶
func (UnimplementedServiceDirectoryServer) GetService(context.Context, *GetServiceRequest) (*GetServiceResponse, error)
func (UnimplementedServiceDirectoryServer) ListService ¶
func (UnimplementedServiceDirectoryServer) ListService(context.Context, *ListServiceRequest) (*ListServiceResponse, error)
func (UnimplementedServiceDirectoryServer) RemoveService ¶
func (UnimplementedServiceDirectoryServer) RemoveService(context.Context, *RemoveServiceRequest) (*RemoveServiceResponse, error)
type UnimplementedStreamControllerServer ¶
type UnimplementedStreamControllerServer struct{}
UnimplementedStreamControllerServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedStreamControllerServer) CountStreamConnection ¶
func (UnimplementedStreamControllerServer) CountStreamConnection(context.Context, *CountConnectionRequest) (*CountConnectionResponse, error)
func (UnimplementedStreamControllerServer) EmitStreamEvent ¶
func (UnimplementedStreamControllerServer) EmitStreamEvent(context.Context, *StreamEventRequest) (*StreamEventResponse, error)
func (UnimplementedStreamControllerServer) PushStream ¶
func (UnimplementedStreamControllerServer) PushStream(context.Context, *PushStreamRequest) (*PushStreamResponse, error)
func (UnimplementedStreamControllerServer) PushStreamBatch ¶
func (UnimplementedStreamControllerServer) PushStreamBatch(context.Context, *PushStreamBatchRequest) (*PushStreamResponse, error)
type UnsafeAuthServer ¶
type UnsafeAuthServer interface {
// contains filtered or unexported methods
}
UnsafeAuthServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to AuthServer will result in compilation errors.
type UnsafeEventRecorderServer ¶
type UnsafeEventRecorderServer interface {
// contains filtered or unexported methods
}
UnsafeEventRecorderServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to EventRecorderServer will result in compilation errors.
type UnsafeNotifierServer ¶
type UnsafeNotifierServer interface {
// contains filtered or unexported methods
}
UnsafeNotifierServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to NotifierServer will result in compilation errors.
type UnsafePostmanServer ¶
type UnsafePostmanServer interface {
// contains filtered or unexported methods
}
UnsafePostmanServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to PostmanServer will result in compilation errors.
type UnsafeRealmServer ¶
type UnsafeRealmServer interface {
// contains filtered or unexported methods
}
UnsafeRealmServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to RealmServer will result in compilation errors.
type UnsafeServiceDirectoryServer ¶
type UnsafeServiceDirectoryServer interface {
// contains filtered or unexported methods
}
UnsafeServiceDirectoryServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ServiceDirectoryServer will result in compilation errors.
type UnsafeStreamControllerServer ¶
type UnsafeStreamControllerServer interface {
// contains filtered or unexported methods
}
UnsafeStreamControllerServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to StreamControllerServer will result in compilation errors.
type UserInfo ¶
type UserInfo struct { Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` Nick string `protobuf:"bytes,3,opt,name=nick,proto3" json:"nick,omitempty"` Email string `protobuf:"bytes,4,opt,name=email,proto3" json:"email,omitempty"` Avatar string `protobuf:"bytes,5,opt,name=avatar,proto3" json:"avatar,omitempty"` Banner string `protobuf:"bytes,6,opt,name=banner,proto3" json:"banner,omitempty"` Description *string `protobuf:"bytes,7,opt,name=description,proto3,oneof" json:"description,omitempty"` // contains filtered or unexported fields }
func (*UserInfo) Descriptor
deprecated
func (*UserInfo) GetDescription ¶
func (*UserInfo) ProtoMessage ¶
func (*UserInfo) ProtoMessage()
func (*UserInfo) ProtoReflect ¶
func (x *UserInfo) ProtoReflect() protoreflect.Message