proto

package
v0.0.0-...-208da7e Latest Latest
Warning

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

 Go to latest Published: Aug 23, 2024 License: AGPL-3.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

View Source 
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"
)
View Source 
const (
	Notifier_NotifyUser_FullMethodName      = "/proto.Notifier/NotifyUser"
	Notifier_NotifyUserBatch_FullMethodName = "/proto.Notifier/NotifyUserBatch"
	Notifier_NotifyAllUser_FullMethodName   = "/proto.Notifier/NotifyAllUser"
)
View Source 
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"
)
View Source 
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"
)
View Source 
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"
)
View Source 
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"
)
View Source 
const (
	EventRecorder_RecordEvent_FullMethodName = "/proto.EventRecorder/RecordEvent"
)

Variables

View Source 
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)

View Source 
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)

View Source 
var File_auth_proto protoreflect.FileDescriptor
View Source 
var File_notify_proto protoreflect.FileDescriptor
View Source 
var File_postman_proto protoreflect.FileDescriptor
View Source 
var File_realm_proto protoreflect.FileDescriptor
View Source 
var File_record_proto protoreflect.FileDescriptor
View Source 
var File_services_proto protoreflect.FileDescriptor
View Source 
var File_stream_proto protoreflect.FileDescriptor
View Source 
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)

View Source 
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)

View Source 
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)

View Source 
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)

View Source 
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) Descriptor() ([]byte, []int)

Deprecated: Use AuthInfo.ProtoReflect.Descriptor instead.

func (*AuthInfo) GetInfo 

func (x *AuthInfo) GetInfo() *UserInfo

func (*AuthInfo) GetNewAccessToken 

func (x *AuthInfo) GetNewAccessToken() string

func (*AuthInfo) GetNewRefreshToken 

func (x *AuthInfo) GetNewRefreshToken() string

func (*AuthInfo) GetPermissions 

func (x *AuthInfo) GetPermissions() []byte

func (*AuthInfo) GetTicketId 

func (x *AuthInfo) GetTicketId() uint64

func (*AuthInfo) ProtoMessage 

func (*AuthInfo) ProtoMessage()

func (*AuthInfo) ProtoReflect 

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

func (*AuthInfo) Reset 

func (x *AuthInfo) Reset()

func (*AuthInfo) String 

func (x *AuthInfo) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use AuthReply.ProtoReflect.Descriptor instead.

func (*AuthReply) GetInfo 

func (x *AuthReply) GetInfo() *AuthInfo

func (*AuthReply) GetIsValid 

func (x *AuthReply) GetIsValid() bool

func (*AuthReply) ProtoMessage 

func (*AuthReply) ProtoMessage()

func (*AuthReply) ProtoReflect 

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

func (*AuthReply) Reset 

func (x *AuthReply) Reset()

func (*AuthReply) String 

func (x *AuthReply) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use RealmInfo.ProtoReflect.Descriptor instead.

func (*RealmInfo) GetAlias 

func (x *RealmInfo) GetAlias() string

func (*RealmInfo) GetDescription 

func (x *RealmInfo) GetDescription() string

func (*RealmInfo) GetId 

func (x *RealmInfo) GetId() uint64

func (*RealmInfo) GetIsCommunity 

func (x *RealmInfo) GetIsCommunity() bool

func (*RealmInfo) GetIsPublic 

func (x *RealmInfo) GetIsPublic() bool

func (*RealmInfo) GetName 

func (x *RealmInfo) GetName() string

func (*RealmInfo) ProtoMessage 

func (*RealmInfo) ProtoMessage()

func (*RealmInfo) ProtoReflect 

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

func (*RealmInfo) Reset 

func (x *RealmInfo) Reset()

func (*RealmInfo) String 

func (x *RealmInfo) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use UserInfo.ProtoReflect.Descriptor instead.

func (*UserInfo) GetAvatar 

func (x *UserInfo) GetAvatar() string

func (*UserInfo) GetBanner 

func (x *UserInfo) GetBanner() string

func (*UserInfo) GetDescription 

func (x *UserInfo) GetDescription() string

func (*UserInfo) GetEmail 

func (x *UserInfo) GetEmail() string

func (*UserInfo) GetId 

func (x *UserInfo) GetId() uint64

func (*UserInfo) GetName 

func (x *UserInfo) GetName() string

func (*UserInfo) GetNick 

func (x *UserInfo) GetNick() string

func (*UserInfo) ProtoMessage 

func (*UserInfo) ProtoMessage()

func (*UserInfo) ProtoReflect 

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

func (*UserInfo) Reset 

func (x *UserInfo) Reset()

func (*UserInfo) String 

func (x *UserInfo) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

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