proto

package
v0.0.0-...-cd58e7a Latest Latest
Warning

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

 Go to latest Published: Dec 3, 2024 License: AGPL-3.0 Imports: 8 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var AllocatorService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "proto.AllocatorService",
	HandlerType: (*AllocatorServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "AllocMessageQueue",
			Handler:    _AllocatorService_AllocMessageQueue_Handler,
		},
		{
			MethodName: "AllocKv",
			Handler:    _AllocatorService_AllocKv_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "allocator.proto",
}

AllocatorService_ServiceDesc is the grpc.ServiceDesc for AllocatorService 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 AuthService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "proto.AuthService",
	HandlerType: (*AuthServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Authenticate",
			Handler:    _AuthService_Authenticate_Handler,
		},
		{
			MethodName: "EnsurePermGranted",
			Handler:    _AuthService_EnsurePermGranted_Handler,
		},
		{
			MethodName: "EnsureUserPermGranted",
			Handler:    _AuthService_EnsureUserPermGranted_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "authenticate.proto",
}

AuthService_ServiceDesc is the grpc.ServiceDesc for AuthService 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 CommandProvider_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "proto.CommandProvider",
	HandlerType: (*CommandProviderServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "AddCommand",
			Handler:    _CommandProvider_AddCommand_Handler,
		},
		{
			MethodName: "RemoveCommand",
			Handler:    _CommandProvider_RemoveCommand_Handler,
		},
		{
			MethodName: "SendCommand",
			Handler:    _CommandProvider_SendCommand_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "SendStreamCommand",
			Handler:       _CommandProvider_SendStreamCommand_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "command.proto",
}

CommandProvider_ServiceDesc is the grpc.ServiceDesc for CommandProvider 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 DatabaseService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "proto.DatabaseService",
	HandlerType: (*DatabaseServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "AllocDatabase",
			Handler:    _DatabaseService_AllocDatabase_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "database.proto",
}

DatabaseService_ServiceDesc is the grpc.ServiceDesc for DatabaseService 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 DirectoryService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "proto.DirectoryService",
	HandlerType: (*DirectoryServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetService",
			Handler:    _DirectoryService_GetService_Handler,
		},
		{
			MethodName: "ListService",
			Handler:    _DirectoryService_ListService_Handler,
		},
		{
			MethodName: "AddService",
			Handler:    _DirectoryService_AddService_Handler,
		},
		{
			MethodName: "RemoveService",
			Handler:    _DirectoryService_RemoveService_Handler,
		},
		{
			MethodName: "BroadcastEvent",
			Handler:    _DirectoryService_BroadcastEvent_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "services.proto",
}

DirectoryService_ServiceDesc is the grpc.ServiceDesc for DirectoryService 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_allocator_proto protoreflect.FileDescriptor
View Source 
var File_authenticate_proto protoreflect.FileDescriptor
View Source 
var File_command_proto protoreflect.FileDescriptor
View Source 
var File_database_proto protoreflect.FileDescriptor
View Source 
var File_services_proto protoreflect.FileDescriptor
View Source 
var File_stream_proto protoreflect.FileDescriptor
View Source 
var File_user_proto protoreflect.FileDescriptor
View Source 
var StreamService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "proto.StreamService",
	HandlerType: (*StreamServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CountStreamConnection",
			Handler:    _StreamService_CountStreamConnection_Handler,
		},
		{
			MethodName: "PushStream",
			Handler:    _StreamService_PushStream_Handler,
		},
		{
			MethodName: "PushStreamBatch",
			Handler:    _StreamService_PushStreamBatch_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "stream.proto",
}

StreamService_ServiceDesc is the grpc.ServiceDesc for StreamService 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 UserService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "proto.UserService",
	HandlerType: (*UserServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetUser",
			Handler:    _UserService_GetUser_Handler,
		},
		{
			MethodName: "ListUser",
			Handler:    _UserService_ListUser_Handler,
		},
		{
			MethodName: "ListUserRelative",
			Handler:    _UserService_ListUserRelative_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "user.proto",
}

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

Functions

func RegisterAllocatorServiceServer 

func RegisterAllocatorServiceServer(s grpc.ServiceRegistrar, srv AllocatorServiceServer)

func RegisterAuthServiceServer 

func RegisterAuthServiceServer(s grpc.ServiceRegistrar, srv AuthServiceServer)

func RegisterCommandProviderServer 

func RegisterCommandProviderServer(s grpc.ServiceRegistrar, srv CommandProviderServer)

func RegisterDatabaseServiceServer 

func RegisterDatabaseServiceServer(s grpc.ServiceRegistrar, srv DatabaseServiceServer)

func RegisterDirectoryServiceServer 

func RegisterDirectoryServiceServer(s grpc.ServiceRegistrar, srv DirectoryServiceServer)

func RegisterStreamServiceServer 

func RegisterStreamServiceServer(s grpc.ServiceRegistrar, srv StreamServiceServer)

func RegisterUserServiceServer 

func RegisterUserServiceServer(s grpc.ServiceRegistrar, srv UserServiceServer)

Types

type AddCommandResponse 

type AddCommandResponse struct {
	IsSuccess bool `protobuf:"varint,1,opt,name=is_success,json=isSuccess,proto3" json:"is_success,omitempty"`
	// contains filtered or unexported fields
}

func (*AddCommandResponse) Descriptor deprecated 

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

Deprecated: Use AddCommandResponse.ProtoReflect.Descriptor instead.

func (*AddCommandResponse) GetIsSuccess 

func (x *AddCommandResponse) GetIsSuccess() bool

func (*AddCommandResponse) ProtoMessage 

func (*AddCommandResponse) ProtoMessage()

func (*AddCommandResponse) ProtoReflect 

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

func (*AddCommandResponse) Reset 

func (x *AddCommandResponse) Reset()

func (*AddCommandResponse) String 

func (x *AddCommandResponse) String() string

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 AllocDatabaseRequest 

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

func (*AllocDatabaseRequest) Descriptor deprecated 

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

Deprecated: Use AllocDatabaseRequest.ProtoReflect.Descriptor instead.

func (*AllocDatabaseRequest) GetName 

func (x *AllocDatabaseRequest) GetName() string

func (*AllocDatabaseRequest) ProtoMessage 

func (*AllocDatabaseRequest) ProtoMessage()

func (*AllocDatabaseRequest) ProtoReflect 

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

func (*AllocDatabaseRequest) Reset 

func (x *AllocDatabaseRequest) Reset()

func (*AllocDatabaseRequest) String 

func (x *AllocDatabaseRequest) String() string

type AllocDatabaseResponse 

type AllocDatabaseResponse struct {
	IsSuccess bool   `protobuf:"varint,1,opt,name=is_success,json=isSuccess,proto3" json:"is_success,omitempty"`
	Dsn       string `protobuf:"bytes,2,opt,name=dsn,proto3" json:"dsn,omitempty"`
	// contains filtered or unexported fields
}

func (*AllocDatabaseResponse) Descriptor deprecated 

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

Deprecated: Use AllocDatabaseResponse.ProtoReflect.Descriptor instead.

func (*AllocDatabaseResponse) GetDsn 

func (x *AllocDatabaseResponse) GetDsn() string

func (*AllocDatabaseResponse) GetIsSuccess 

func (x *AllocDatabaseResponse) GetIsSuccess() bool

func (*AllocDatabaseResponse) ProtoMessage 

func (*AllocDatabaseResponse) ProtoMessage()

func (*AllocDatabaseResponse) ProtoReflect 

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

func (*AllocDatabaseResponse) Reset 

func (x *AllocDatabaseResponse) Reset()

func (*AllocDatabaseResponse) String 

func (x *AllocDatabaseResponse) String() string

type AllocKvRequest 

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

func (*AllocKvRequest) Descriptor deprecated 

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

Deprecated: Use AllocKvRequest.ProtoReflect.Descriptor instead.

func (*AllocKvRequest) ProtoMessage 

func (*AllocKvRequest) ProtoMessage()

func (*AllocKvRequest) ProtoReflect 

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

func (*AllocKvRequest) Reset 

func (x *AllocKvRequest) Reset()

func (*AllocKvRequest) String 

func (x *AllocKvRequest) String() string

type AllocKvResponse 

type AllocKvResponse struct {
	IsSuccess bool     `protobuf:"varint,1,opt,name=is_success,json=isSuccess,proto3" json:"is_success,omitempty"`
	Endpoints []string `protobuf:"bytes,2,rep,name=endpoints,proto3" json:"endpoints,omitempty"`
	// contains filtered or unexported fields
}

func (*AllocKvResponse) Descriptor deprecated 

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

Deprecated: Use AllocKvResponse.ProtoReflect.Descriptor instead.

func (*AllocKvResponse) GetEndpoints 

func (x *AllocKvResponse) GetEndpoints() []string

func (*AllocKvResponse) GetIsSuccess 

func (x *AllocKvResponse) GetIsSuccess() bool

func (*AllocKvResponse) ProtoMessage 

func (*AllocKvResponse) ProtoMessage()

func (*AllocKvResponse) ProtoReflect 

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

func (*AllocKvResponse) Reset 

func (x *AllocKvResponse) Reset()

func (*AllocKvResponse) String 

func (x *AllocKvResponse) String() string

type AllocMqRequest 

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

func (*AllocMqRequest) Descriptor deprecated 

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

Deprecated: Use AllocMqRequest.ProtoReflect.Descriptor instead.

func (*AllocMqRequest) ProtoMessage 

func (*AllocMqRequest) ProtoMessage()

func (*AllocMqRequest) ProtoReflect 

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

func (*AllocMqRequest) Reset 

func (x *AllocMqRequest) Reset()

func (*AllocMqRequest) String 

func (x *AllocMqRequest) String() string

type AllocMqResponse 

type AllocMqResponse struct {
	IsSuccess bool   `protobuf:"varint,1,opt,name=is_success,json=isSuccess,proto3" json:"is_success,omitempty"`
	Addr      string `protobuf:"bytes,2,opt,name=addr,proto3" json:"addr,omitempty"`
	// contains filtered or unexported fields
}

func (*AllocMqResponse) Descriptor deprecated 

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

Deprecated: Use AllocMqResponse.ProtoReflect.Descriptor instead.

func (*AllocMqResponse) GetAddr 

func (x *AllocMqResponse) GetAddr() string

func (*AllocMqResponse) GetIsSuccess 

func (x *AllocMqResponse) GetIsSuccess() bool

func (*AllocMqResponse) ProtoMessage 

func (*AllocMqResponse) ProtoMessage()

func (*AllocMqResponse) ProtoReflect 

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

func (*AllocMqResponse) Reset 

func (x *AllocMqResponse) Reset()

func (*AllocMqResponse) String 

func (x *AllocMqResponse) String() string

type AllocatorServiceClient 

type AllocatorServiceClient interface {
	AllocMessageQueue(ctx context.Context, in *AllocMqRequest, opts ...grpc.CallOption) (*AllocMqResponse, error)
	AllocKv(ctx context.Context, in *AllocKvRequest, opts ...grpc.CallOption) (*AllocKvResponse, error)
}

AllocatorServiceClient is the client API for AllocatorService 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 NewAllocatorServiceClient 

func NewAllocatorServiceClient(cc grpc.ClientConnInterface) AllocatorServiceClient

type AllocatorServiceServer 

type AllocatorServiceServer interface {
	AllocMessageQueue(context.Context, *AllocMqRequest) (*AllocMqResponse, error)
	AllocKv(context.Context, *AllocKvRequest) (*AllocKvResponse, error)
	// contains filtered or unexported methods
}

AllocatorServiceServer is the server API for AllocatorService service. All implementations must embed UnimplementedAllocatorServiceServer for forward compatibility

type AuthInfo 

type AuthInfo struct {
	Info      *UserInfo `protobuf:"bytes,1,opt,name=info,proto3" json:"info,omitempty"`
	SessionId uint64    `protobuf:"varint,3,opt,name=session_id,json=sessionId,proto3" json:"session_id,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) GetSessionId 

func (x *AuthInfo) GetSessionId() 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 {
	SessionId uint64 `protobuf:"varint,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	// contains filtered or unexported fields
}

func (*AuthRequest) Descriptor deprecated 

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

Deprecated: Use AuthRequest.ProtoReflect.Descriptor instead.

func (*AuthRequest) GetSessionId 

func (x *AuthRequest) GetSessionId() uint64

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 AuthServiceClient 

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

AuthServiceClient is the client API for AuthService 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 NewAuthServiceClient 

func NewAuthServiceClient(cc grpc.ClientConnInterface) AuthServiceClient

type AuthServiceServer 

type AuthServiceServer interface {
	Authenticate(context.Context, *AuthRequest) (*AuthReply, error)
	EnsurePermGranted(context.Context, *CheckPermRequest) (*CheckPermResponse, error)
	EnsureUserPermGranted(context.Context, *CheckUserPermRequest) (*CheckUserPermResponse, error)
	// contains filtered or unexported methods
}

AuthServiceServer is the server API for AuthService service. All implementations must embed UnimplementedAuthServiceServer for forward compatibility

type CheckPermRequest 

type CheckPermRequest struct {
	SessionId uint64 `protobuf:"varint,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,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) GetSessionId 

func (x *CheckPermRequest) GetSessionId() uint64

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 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 CommandArgument 

type CommandArgument struct {
	Command string `protobuf:"bytes,1,opt,name=command,proto3" json:"command,omitempty"`
	Method  string `protobuf:"bytes,2,opt,name=method,proto3" json:"method,omitempty"`
	Payload []byte `protobuf:"bytes,3,opt,name=payload,proto3,oneof" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

func (*CommandArgument) Descriptor deprecated 

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

Deprecated: Use CommandArgument.ProtoReflect.Descriptor instead.

func (*CommandArgument) GetCommand 

func (x *CommandArgument) GetCommand() string

func (*CommandArgument) GetMethod 

func (x *CommandArgument) GetMethod() string

func (*CommandArgument) GetPayload 

func (x *CommandArgument) GetPayload() []byte

func (*CommandArgument) ProtoMessage 

func (*CommandArgument) ProtoMessage()

func (*CommandArgument) ProtoReflect 

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

func (*CommandArgument) Reset 

func (x *CommandArgument) Reset()

func (*CommandArgument) String 

func (x *CommandArgument) String() string

type CommandInfo 

type CommandInfo struct {
	Id     string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Method string   `protobuf:"bytes,2,opt,name=method,proto3" json:"method,omitempty"`
	Tags   []string `protobuf:"bytes,3,rep,name=tags,proto3" json:"tags,omitempty"`
	// contains filtered or unexported fields
}

func (*CommandInfo) Descriptor deprecated 

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

Deprecated: Use CommandInfo.ProtoReflect.Descriptor instead.

func (*CommandInfo) GetId 

func (x *CommandInfo) GetId() string

func (*CommandInfo) GetMethod 

func (x *CommandInfo) GetMethod() string

func (*CommandInfo) GetTags 

func (x *CommandInfo) GetTags() []string

func (*CommandInfo) ProtoMessage 

func (*CommandInfo) ProtoMessage()

func (*CommandInfo) ProtoReflect 

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

func (*CommandInfo) Reset 

func (x *CommandInfo) Reset()

func (*CommandInfo) String 

func (x *CommandInfo) String() string

type CommandLookupRequest 

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

func (*CommandLookupRequest) Descriptor deprecated 

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

Deprecated: Use CommandLookupRequest.ProtoReflect.Descriptor instead.

func (*CommandLookupRequest) GetId 

func (x *CommandLookupRequest) GetId() string

func (*CommandLookupRequest) GetMethod 

func (x *CommandLookupRequest) GetMethod() string

func (*CommandLookupRequest) ProtoMessage 

func (*CommandLookupRequest) ProtoMessage()

func (*CommandLookupRequest) ProtoReflect 

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

func (*CommandLookupRequest) Reset 

func (x *CommandLookupRequest) Reset()

func (*CommandLookupRequest) String 

func (x *CommandLookupRequest) String() string

type CommandProviderClient 

type CommandProviderClient interface {
	AddCommand(ctx context.Context, in *CommandInfo, opts ...grpc.CallOption) (*AddCommandResponse, error)
	RemoveCommand(ctx context.Context, in *CommandLookupRequest, opts ...grpc.CallOption) (*RemoveCommandResponse, error)
	SendCommand(ctx context.Context, in *CommandArgument, opts ...grpc.CallOption) (*CommandReturn, error)
	SendStreamCommand(ctx context.Context, opts ...grpc.CallOption) (CommandProvider_SendStreamCommandClient, error)
}

CommandProviderClient is the client API for CommandProvider 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 NewCommandProviderClient 

func NewCommandProviderClient(cc grpc.ClientConnInterface) CommandProviderClient

type CommandProviderServer 

type CommandProviderServer interface {
	AddCommand(context.Context, *CommandInfo) (*AddCommandResponse, error)
	RemoveCommand(context.Context, *CommandLookupRequest) (*RemoveCommandResponse, error)
	SendCommand(context.Context, *CommandArgument) (*CommandReturn, error)
	SendStreamCommand(CommandProvider_SendStreamCommandServer) error
	// contains filtered or unexported methods
}

CommandProviderServer is the server API for CommandProvider service. All implementations must embed UnimplementedCommandProviderServer for forward compatibility

type CommandProvider_SendStreamCommandClient 

type CommandProvider_SendStreamCommandClient interface {
	Send(*CommandArgument) error
	Recv() (*CommandReturn, error)
	grpc.ClientStream
}

type CommandProvider_SendStreamCommandServer 

type CommandProvider_SendStreamCommandServer interface {
	Send(*CommandReturn) error
	Recv() (*CommandArgument, error)
	grpc.ServerStream
}

type CommandReturn 

type CommandReturn struct {
	IsDelivered bool   `protobuf:"varint,1,opt,name=is_delivered,json=isDelivered,proto3" json:"is_delivered,omitempty"`
	Status      int32  `protobuf:"varint,2,opt,name=status,proto3" json:"status,omitempty"`
	ContentType string `protobuf:"bytes,3,opt,name=content_type,json=contentType,proto3" json:"content_type,omitempty"`
	Payload     []byte `protobuf:"bytes,4,opt,name=payload,proto3,oneof" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

func (*CommandReturn) Descriptor deprecated 

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

Deprecated: Use CommandReturn.ProtoReflect.Descriptor instead.

func (*CommandReturn) GetContentType 

func (x *CommandReturn) GetContentType() string

func (*CommandReturn) GetIsDelivered 

func (x *CommandReturn) GetIsDelivered() bool

func (*CommandReturn) GetPayload 

func (x *CommandReturn) GetPayload() []byte

func (*CommandReturn) GetStatus 

func (x *CommandReturn) GetStatus() int32

func (*CommandReturn) ProtoMessage 

func (*CommandReturn) ProtoMessage()

func (*CommandReturn) ProtoReflect 

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

func (*CommandReturn) Reset 

func (x *CommandReturn) Reset()

func (*CommandReturn) String 

func (x *CommandReturn) 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 DatabaseServiceClient 

type DatabaseServiceClient interface {
	AllocDatabase(ctx context.Context, in *AllocDatabaseRequest, opts ...grpc.CallOption) (*AllocDatabaseResponse, error)
}

DatabaseServiceClient is the client API for DatabaseService 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 NewDatabaseServiceClient 

func NewDatabaseServiceClient(cc grpc.ClientConnInterface) DatabaseServiceClient

type DatabaseServiceServer 

type DatabaseServiceServer interface {
	AllocDatabase(context.Context, *AllocDatabaseRequest) (*AllocDatabaseResponse, error)
	// contains filtered or unexported methods
}

DatabaseServiceServer is the server API for DatabaseService service. All implementations must embed UnimplementedDatabaseServiceServer for forward compatibility

type DirectoryServiceClient 

type DirectoryServiceClient 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)
	BroadcastEvent(ctx context.Context, in *EventInfo, opts ...grpc.CallOption) (*EventResponse, error)
}

DirectoryServiceClient is the client API for DirectoryService 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 NewDirectoryServiceClient 

func NewDirectoryServiceClient(cc grpc.ClientConnInterface) DirectoryServiceClient

type DirectoryServiceServer 

type DirectoryServiceServer 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)
	BroadcastEvent(context.Context, *EventInfo) (*EventResponse, error)
	// contains filtered or unexported methods
}

DirectoryServiceServer is the server API for DirectoryService service. All implementations must embed UnimplementedDirectoryServiceServer for forward compatibility

type EventInfo 

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

func (*EventInfo) Descriptor deprecated 

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

Deprecated: Use EventInfo.ProtoReflect.Descriptor instead.

func (*EventInfo) GetData 

func (x *EventInfo) GetData() []byte

func (*EventInfo) GetEvent 

func (x *EventInfo) GetEvent() string

func (*EventInfo) ProtoMessage 

func (*EventInfo) ProtoMessage()

func (*EventInfo) ProtoReflect 

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

func (*EventInfo) Reset 

func (x *EventInfo) Reset()

func (*EventInfo) String 

func (x *EventInfo) String() string

type EventResponse 

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

func (*EventResponse) Descriptor deprecated 

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

Deprecated: Use EventResponse.ProtoReflect.Descriptor instead.

func (*EventResponse) ProtoMessage 

func (*EventResponse) ProtoMessage()

func (*EventResponse) ProtoReflect 

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

func (*EventResponse) Reset 

func (x *EventResponse) Reset()

func (*EventResponse) String 

func (x *EventResponse) String() string

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 GetUserRequest 

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

func (*GetUserRequest) Descriptor deprecated 

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

Deprecated: Use GetUserRequest.ProtoReflect.Descriptor instead.

func (*GetUserRequest) GetName 

func (x *GetUserRequest) GetName() string

func (*GetUserRequest) GetUserId 

func (x *GetUserRequest) GetUserId() uint64

func (*GetUserRequest) ProtoMessage 

func (*GetUserRequest) ProtoMessage()

func (*GetUserRequest) ProtoReflect 

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

func (*GetUserRequest) Reset 

func (x *GetUserRequest) Reset()

func (*GetUserRequest) String 

func (x *GetUserRequest) 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"`
	Status    int32  `protobuf:"varint,2,opt,name=status,proto3" json:"status,omitempty"`
	IsRelated bool   `protobuf:"varint,3,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) GetStatus 

func (x *ListUserRelativeRequest) GetStatus() int32

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 []*UserInfo `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() []*UserInfo

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 ListUserRequest 

type ListUserRequest struct {
	UserId []uint64 `protobuf:"varint,1,rep,packed,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ListUserRequest) Descriptor deprecated 

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

Deprecated: Use ListUserRequest.ProtoReflect.Descriptor instead.

func (*ListUserRequest) GetUserId 

func (x *ListUserRequest) GetUserId() []uint64

func (*ListUserRequest) ProtoMessage 

func (*ListUserRequest) ProtoMessage()

func (*ListUserRequest) ProtoReflect 

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

func (*ListUserRequest) Reset 

func (x *ListUserRequest) Reset()

func (*ListUserRequest) String 

func (x *ListUserRequest) String() string

type MultipleUserInfo 

type MultipleUserInfo struct {
	Data []*UserInfo `protobuf:"bytes,1,rep,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*MultipleUserInfo) Descriptor deprecated 

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

Deprecated: Use MultipleUserInfo.ProtoReflect.Descriptor instead.

func (*MultipleUserInfo) GetData 

func (x *MultipleUserInfo) GetData() []*UserInfo

func (*MultipleUserInfo) ProtoMessage 

func (*MultipleUserInfo) ProtoMessage()

func (*MultipleUserInfo) ProtoReflect 

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

func (*MultipleUserInfo) Reset 

func (x *MultipleUserInfo) Reset()

func (*MultipleUserInfo) String 

func (x *MultipleUserInfo) String() string

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 RemoveCommandResponse 

type RemoveCommandResponse struct {
	IsSuccess bool `protobuf:"varint,1,opt,name=is_success,json=isSuccess,proto3" json:"is_success,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveCommandResponse) Descriptor deprecated 

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

Deprecated: Use RemoveCommandResponse.ProtoReflect.Descriptor instead.

func (*RemoveCommandResponse) GetIsSuccess 

func (x *RemoveCommandResponse) GetIsSuccess() bool

func (*RemoveCommandResponse) ProtoMessage 

func (*RemoveCommandResponse) ProtoMessage()

func (*RemoveCommandResponse) ProtoReflect 

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

func (*RemoveCommandResponse) Reset 

func (x *RemoveCommandResponse) Reset()

func (*RemoveCommandResponse) String 

func (x *RemoveCommandResponse) 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 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 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 StreamServiceClient 

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

StreamServiceClient is the client API for StreamService 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 NewStreamServiceClient 

func NewStreamServiceClient(cc grpc.ClientConnInterface) StreamServiceClient

type StreamServiceServer 

type StreamServiceServer interface {
	CountStreamConnection(context.Context, *CountConnectionRequest) (*CountConnectionResponse, error)
	PushStream(context.Context, *PushStreamRequest) (*PushStreamResponse, error)
	PushStreamBatch(context.Context, *PushStreamBatchRequest) (*PushStreamResponse, error)
	// contains filtered or unexported methods
}

StreamServiceServer is the server API for StreamService service. All implementations must embed UnimplementedStreamServiceServer for forward compatibility

type UnimplementedAllocatorServiceServer 

type UnimplementedAllocatorServiceServer struct {
}

UnimplementedAllocatorServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedAllocatorServiceServer) AllocKv 

func (UnimplementedAllocatorServiceServer) AllocKv(context.Context, *AllocKvRequest) (*AllocKvResponse, error)

func (UnimplementedAllocatorServiceServer) AllocMessageQueue 

func (UnimplementedAllocatorServiceServer) AllocMessageQueue(context.Context, *AllocMqRequest) (*AllocMqResponse, error)

type UnimplementedAuthServiceServer 

type UnimplementedAuthServiceServer struct {
}

UnimplementedAuthServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedAuthServiceServer) Authenticate 

func (UnimplementedAuthServiceServer) Authenticate(context.Context, *AuthRequest) (*AuthReply, error)

func (UnimplementedAuthServiceServer) EnsurePermGranted 

func (UnimplementedAuthServiceServer) EnsurePermGranted(context.Context, *CheckPermRequest) (*CheckPermResponse, error)

func (UnimplementedAuthServiceServer) EnsureUserPermGranted 

func (UnimplementedAuthServiceServer) EnsureUserPermGranted(context.Context, *CheckUserPermRequest) (*CheckUserPermResponse, error)

type UnimplementedCommandProviderServer 

type UnimplementedCommandProviderServer struct {
}

UnimplementedCommandProviderServer must be embedded to have forward compatible implementations.

func (UnimplementedCommandProviderServer) AddCommand 

func (UnimplementedCommandProviderServer) AddCommand(context.Context, *CommandInfo) (*AddCommandResponse, error)

func (UnimplementedCommandProviderServer) RemoveCommand 

func (UnimplementedCommandProviderServer) RemoveCommand(context.Context, *CommandLookupRequest) (*RemoveCommandResponse, error)

func (UnimplementedCommandProviderServer) SendCommand 

func (UnimplementedCommandProviderServer) SendCommand(context.Context, *CommandArgument) (*CommandReturn, error)

func (UnimplementedCommandProviderServer) SendStreamCommand 

func (UnimplementedCommandProviderServer) SendStreamCommand(CommandProvider_SendStreamCommandServer) error

type UnimplementedDatabaseServiceServer 

type UnimplementedDatabaseServiceServer struct {
}

UnimplementedDatabaseServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedDatabaseServiceServer) AllocDatabase 

func (UnimplementedDatabaseServiceServer) AllocDatabase(context.Context, *AllocDatabaseRequest) (*AllocDatabaseResponse, error)

type UnimplementedDirectoryServiceServer 

type UnimplementedDirectoryServiceServer struct {
}

UnimplementedDirectoryServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedDirectoryServiceServer) AddService 

func (UnimplementedDirectoryServiceServer) AddService(context.Context, *ServiceInfo) (*AddServiceResponse, error)

func (UnimplementedDirectoryServiceServer) BroadcastEvent 

func (UnimplementedDirectoryServiceServer) BroadcastEvent(context.Context, *EventInfo) (*EventResponse, error)

func (UnimplementedDirectoryServiceServer) GetService 

func (UnimplementedDirectoryServiceServer) GetService(context.Context, *GetServiceRequest) (*GetServiceResponse, error)

func (UnimplementedDirectoryServiceServer) ListService 

func (UnimplementedDirectoryServiceServer) ListService(context.Context, *ListServiceRequest) (*ListServiceResponse, error)

func (UnimplementedDirectoryServiceServer) RemoveService 

func (UnimplementedDirectoryServiceServer) RemoveService(context.Context, *RemoveServiceRequest) (*RemoveServiceResponse, error)

type UnimplementedStreamServiceServer 

type UnimplementedStreamServiceServer struct {
}

UnimplementedStreamServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedStreamServiceServer) CountStreamConnection 

func (UnimplementedStreamServiceServer) CountStreamConnection(context.Context, *CountConnectionRequest) (*CountConnectionResponse, error)

func (UnimplementedStreamServiceServer) PushStream 

func (UnimplementedStreamServiceServer) PushStream(context.Context, *PushStreamRequest) (*PushStreamResponse, error)

func (UnimplementedStreamServiceServer) PushStreamBatch 

func (UnimplementedStreamServiceServer) PushStreamBatch(context.Context, *PushStreamBatchRequest) (*PushStreamResponse, error)

type UnimplementedUserServiceServer 

type UnimplementedUserServiceServer struct {
}

UnimplementedUserServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedUserServiceServer) GetUser 

func (UnimplementedUserServiceServer) GetUser(context.Context, *GetUserRequest) (*UserInfo, error)

func (UnimplementedUserServiceServer) ListUser 

func (UnimplementedUserServiceServer) ListUser(context.Context, *ListUserRequest) (*MultipleUserInfo, error)

func (UnimplementedUserServiceServer) ListUserRelative 

func (UnimplementedUserServiceServer) ListUserRelative(context.Context, *ListUserRelativeRequest) (*ListUserRelativeResponse, error)

type UnsafeAllocatorServiceServer 

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

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

type UnsafeAuthServiceServer 

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

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

type UnsafeCommandProviderServer 

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

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

type UnsafeDatabaseServiceServer 

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

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

type UnsafeDirectoryServiceServer 

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

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

type UnsafeStreamServiceServer 

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

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

type UnsafeUserServiceServer 

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

UnsafeUserServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to UserServiceServer 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"`
	PermNodes []byte `protobuf:"bytes,3,opt,name=perm_nodes,json=permNodes,proto3,oneof" json:"perm_nodes,omitempty"`
	Metadata  []byte `protobuf:"bytes,4,opt,name=metadata,proto3,oneof" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

func (*UserInfo) Descriptor deprecated 

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

Deprecated: Use UserInfo.ProtoReflect.Descriptor instead.

func (*UserInfo) GetId 

func (x *UserInfo) GetId() uint64

func (*UserInfo) GetMetadata 

func (x *UserInfo) GetMetadata() []byte

func (*UserInfo) GetName 

func (x *UserInfo) GetName() string

func (*UserInfo) GetPermNodes 

func (x *UserInfo) GetPermNodes() []byte

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

type UserServiceClient 

type UserServiceClient interface {
	GetUser(ctx context.Context, in *GetUserRequest, opts ...grpc.CallOption) (*UserInfo, error)
	ListUser(ctx context.Context, in *ListUserRequest, opts ...grpc.CallOption) (*MultipleUserInfo, error)
	ListUserRelative(ctx context.Context, in *ListUserRelativeRequest, opts ...grpc.CallOption) (*ListUserRelativeResponse, error)
}

UserServiceClient is the client API for UserService 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 NewUserServiceClient 

func NewUserServiceClient(cc grpc.ClientConnInterface) UserServiceClient

type UserServiceServer 

type UserServiceServer interface {
	GetUser(context.Context, *GetUserRequest) (*UserInfo, error)
	ListUser(context.Context, *ListUserRequest) (*MultipleUserInfo, error)
	ListUserRelative(context.Context, *ListUserRelativeRequest) (*ListUserRelativeResponse, error)
	// contains filtered or unexported methods
}

UserServiceServer is the server API for UserService service. All implementations must embed UnimplementedUserServiceServer for forward compatibility

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.