Documentation
¶
Index ¶
- Variables
- func RegisterGatewayManagerServer(s grpc.ServiceRegistrar, srv GatewayManagerServer)
- func RegisterMqttServerManagerServer(s grpc.ServiceRegistrar, srv MqttServerManagerServer)
- func RegisterServerManagerServer(s grpc.ServiceRegistrar, srv ServerManagerServer)
- func RegisterUserManagerServer(s grpc.ServiceRegistrar, srv UserManagerServer)
- type BytesValue
- type Empty
- type GatewayInfo
- func (*GatewayInfo) Descriptor() ([]byte, []int)deprecated
- func (x *GatewayInfo) GetHosts() []string
- func (x *GatewayInfo) GetName() string
- func (x *GatewayInfo) GetReadUserUuids() []string
- func (x *GatewayInfo) GetReadWriteUserUuids() []string
- func (x *GatewayInfo) GetServerUuid() []string
- func (x *GatewayInfo) GetStatus() bool
- func (x *GatewayInfo) GetSuperUserUuid() string
- func (x *GatewayInfo) GetUuid() string
- func (*GatewayInfo) ProtoMessage()
- func (x *GatewayInfo) ProtoReflect() protoreflect.Message
- func (x *GatewayInfo) Reset()
- func (x *GatewayInfo) String() string
- type GatewayManagerClient
- type GatewayManagerServer
- type MqttServerInfo
- func (*MqttServerInfo) Descriptor() ([]byte, []int)deprecated
- func (x *MqttServerInfo) GetClientId() string
- func (x *MqttServerInfo) GetHost() string
- func (x *MqttServerInfo) GetIsAnonymous() bool
- func (x *MqttServerInfo) GetPassword() string
- func (x *MqttServerInfo) GetPort() string
- func (x *MqttServerInfo) GetUsername() string
- func (*MqttServerInfo) ProtoMessage()
- func (x *MqttServerInfo) ProtoReflect() protoreflect.Message
- func (x *MqttServerInfo) Reset()
- func (x *MqttServerInfo) String() string
- type MqttServerManagerClient
- type MqttServerManagerServer
- type OperationResponse
- func (*OperationResponse) Descriptor() ([]byte, []int)deprecated
- func (x *OperationResponse) GetCode() int32
- func (x *OperationResponse) GetMessage() string
- func (*OperationResponse) ProtoMessage()
- func (x *OperationResponse) ProtoReflect() protoreflect.Message
- func (x *OperationResponse) Reset()
- func (x *OperationResponse) String() string
- type ServerInfo
- func (*ServerInfo) Descriptor() ([]byte, []int)deprecated
- func (x *ServerInfo) GetConnectionType() string
- func (x *ServerInfo) GetGrpcPort() int32
- func (x *ServerInfo) GetKcpApiPort() int32
- func (x *ServerInfo) GetKcpPort() int32
- func (x *ServerInfo) GetLoginKey() string
- func (x *ServerInfo) GetServerHost() string
- func (x *ServerInfo) GetTcpPort() int32
- func (x *ServerInfo) GetTlsPort() int32
- func (x *ServerInfo) GetUdpApiPort() int32
- func (x *ServerInfo) GetUuid() string
- func (*ServerInfo) ProtoMessage()
- func (x *ServerInfo) ProtoReflect() protoreflect.Message
- func (x *ServerInfo) Reset()
- func (x *ServerInfo) String() string
- type ServerInfoList
- type ServerManagerClient
- type ServerManagerServer
- type StringValue
- type UnimplementedGatewayManagerServer
- func (UnimplementedGatewayManagerServer) AddGateway(context.Context, *GatewayInfo) (*OperationResponse, error)
- func (UnimplementedGatewayManagerServer) DelGateway(context.Context, *GatewayInfo) (*OperationResponse, error)
- func (UnimplementedGatewayManagerServer) GetAllGateway(context.Context, *GatewayInfo) (*OperationResponse, error)
- func (UnimplementedGatewayManagerServer) UpdateGateway(context.Context, *GatewayInfo) (*OperationResponse, error)
- type UnimplementedMqttServerManagerServer
- func (UnimplementedMqttServerManagerServer) AddMqttServer(context.Context, *MqttServerInfo) (*OperationResponse, error)
- func (UnimplementedMqttServerManagerServer) DelMqttServer(context.Context, *MqttServerInfo) (*OperationResponse, error)
- func (UnimplementedMqttServerManagerServer) GetAllMqttServer(context.Context, *MqttServerInfo) (*OperationResponse, error)
- func (UnimplementedMqttServerManagerServer) UpdateMqttServer(context.Context, *MqttServerInfo) (*OperationResponse, error)
- type UnimplementedServerManagerServer
- func (UnimplementedServerManagerServer) AddServer(context.Context, *ServerInfo) (*OperationResponse, error)
- func (UnimplementedServerManagerServer) DelServer(context.Context, *ServerInfo) (*OperationResponse, error)
- func (UnimplementedServerManagerServer) GetAllServer(context.Context, *Empty) (*ServerInfoList, error)
- func (UnimplementedServerManagerServer) QueryServer(context.Context, *StringValue) (*ServerInfoList, error)
- func (UnimplementedServerManagerServer) UpdateServer(context.Context, *ServerInfo) (*OperationResponse, error)
- type UnimplementedUserManagerServer
- func (UnimplementedUserManagerServer) LoginWithUserLoginInfo(context.Context, *UserInfo) (*UserLoginResponse, error)
- func (UnimplementedUserManagerServer) RegisterUserWithUserInfo(context.Context, *UserInfo) (*OperationResponse, error)
- func (UnimplementedUserManagerServer) UpdateUserAvatar(context.Context, *UpdateAvatar) (*OperationResponse, error)
- func (UnimplementedUserManagerServer) UpdateUserEmail(context.Context, *UpdateInfo) (*OperationResponse, error)
- func (UnimplementedUserManagerServer) UpdateUserMobile(context.Context, *UpdateInfo) (*OperationResponse, error)
- func (UnimplementedUserManagerServer) UpdateUserNanme(context.Context, *UpdateInfo) (*OperationResponse, error)
- func (UnimplementedUserManagerServer) UpdateUserPassword(context.Context, *UpdateInfo) (*OperationResponse, error)
- type UnsafeGatewayManagerServer
- type UnsafeMqttServerManagerServer
- type UnsafeServerManagerServer
- type UnsafeUserManagerServer
- type UpdateAvatar
- func (*UpdateAvatar) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateAvatar) GetNewBytes() []byte
- func (x *UpdateAvatar) GetUUID() string
- func (*UpdateAvatar) ProtoMessage()
- func (x *UpdateAvatar) ProtoReflect() protoreflect.Message
- func (x *UpdateAvatar) Reset()
- func (x *UpdateAvatar) String() string
- type UpdateInfo
- type UserInfo
- type UserLoginResponse
- func (*UserLoginResponse) Descriptor() ([]byte, []int)deprecated
- func (x *UserLoginResponse) GetCode() int32
- func (x *UserLoginResponse) GetMsg() string
- func (x *UserLoginResponse) GetToken() string
- func (*UserLoginResponse) ProtoMessage()
- func (x *UserLoginResponse) ProtoReflect() protoreflect.Message
- func (x *UserLoginResponse) Reset()
- func (x *UserLoginResponse) String() string
- type UserManagerClient
- type UserManagerServer
Constants ¶
This section is empty.
Variables ¶
var File_common_proto protoreflect.FileDescriptor
var File_gatewayManager_proto protoreflect.FileDescriptor
var File_mqttServerManager_proto protoreflect.FileDescriptor
var File_serverManager_proto protoreflect.FileDescriptor
var File_userManager_proto protoreflect.FileDescriptor
Functions ¶
func RegisterGatewayManagerServer ¶
func RegisterGatewayManagerServer(s grpc.ServiceRegistrar, srv GatewayManagerServer)
func RegisterMqttServerManagerServer ¶ added in v0.0.3
func RegisterMqttServerManagerServer(s grpc.ServiceRegistrar, srv MqttServerManagerServer)
func RegisterServerManagerServer ¶
func RegisterServerManagerServer(s grpc.ServiceRegistrar, srv ServerManagerServer)
func RegisterUserManagerServer ¶
func RegisterUserManagerServer(s grpc.ServiceRegistrar, srv UserManagerServer)
Types ¶
type BytesValue ¶ added in v0.0.2
type BytesValue struct { Value []byte `protobuf:"bytes,1,opt,name=Value,proto3" json:"Value,omitempty"` // contains filtered or unexported fields }
func (*BytesValue) Descriptor
deprecated
added in
v0.0.2
func (*BytesValue) Descriptor() ([]byte, []int)
Deprecated: Use BytesValue.ProtoReflect.Descriptor instead.
func (*BytesValue) GetValue ¶ added in v0.0.2
func (x *BytesValue) GetValue() []byte
func (*BytesValue) ProtoMessage ¶ added in v0.0.2
func (*BytesValue) ProtoMessage()
func (*BytesValue) ProtoReflect ¶ added in v0.0.2
func (x *BytesValue) ProtoReflect() protoreflect.Message
func (*BytesValue) Reset ¶ added in v0.0.2
func (x *BytesValue) Reset()
func (*BytesValue) String ¶ added in v0.0.2
func (x *BytesValue) String() string
type Empty ¶
type Empty struct {
// contains filtered or unexported fields
}
func (*Empty) Descriptor
deprecated
func (*Empty) ProtoMessage ¶
func (*Empty) ProtoMessage()
func (*Empty) ProtoReflect ¶
func (x *Empty) ProtoReflect() protoreflect.Message
type GatewayInfo ¶
type GatewayInfo struct { Uuid string `protobuf:"bytes,1,opt,name=Uuid,proto3" json:"Uuid,omitempty"` Name string `protobuf:"bytes,2,opt,name=Name,proto3" json:"Name,omitempty"` ServerUuid []string `protobuf:"bytes,3,rep,name=ServerUuid,proto3" json:"ServerUuid,omitempty"` SuperUserUuid string `protobuf:"bytes,4,opt,name=SuperUserUuid,proto3" json:"SuperUserUuid,omitempty"` //读取权限的用户 ReadUserUuids []string `protobuf:"bytes,5,rep,name=ReadUserUuids,proto3" json:"ReadUserUuids,omitempty"` //增加删除操作的用户 ReadWriteUserUuids []string `protobuf:"bytes,6,rep,name=ReadWriteUserUuids,proto3" json:"ReadWriteUserUuids,omitempty"` Hosts []string `protobuf:"bytes,7,rep,name=Hosts,proto3" json:"Hosts,omitempty"` //在线状态 Status bool `protobuf:"varint,8,opt,name=Status,proto3" json:"Status,omitempty"` // contains filtered or unexported fields }
func (*GatewayInfo) Descriptor
deprecated
func (*GatewayInfo) Descriptor() ([]byte, []int)
Deprecated: Use GatewayInfo.ProtoReflect.Descriptor instead.
func (*GatewayInfo) GetHosts ¶ added in v0.0.2
func (x *GatewayInfo) GetHosts() []string
func (*GatewayInfo) GetName ¶ added in v0.0.2
func (x *GatewayInfo) GetName() string
func (*GatewayInfo) GetReadUserUuids ¶ added in v0.0.2
func (x *GatewayInfo) GetReadUserUuids() []string
func (*GatewayInfo) GetReadWriteUserUuids ¶ added in v0.0.2
func (x *GatewayInfo) GetReadWriteUserUuids() []string
func (*GatewayInfo) GetServerUuid ¶ added in v0.0.2
func (x *GatewayInfo) GetServerUuid() []string
func (*GatewayInfo) GetStatus ¶ added in v0.0.2
func (x *GatewayInfo) GetStatus() bool
func (*GatewayInfo) GetSuperUserUuid ¶ added in v0.0.2
func (x *GatewayInfo) GetSuperUserUuid() string
func (*GatewayInfo) GetUuid ¶ added in v0.0.2
func (x *GatewayInfo) GetUuid() string
func (*GatewayInfo) ProtoMessage ¶
func (*GatewayInfo) ProtoMessage()
func (*GatewayInfo) ProtoReflect ¶
func (x *GatewayInfo) ProtoReflect() protoreflect.Message
func (*GatewayInfo) Reset ¶
func (x *GatewayInfo) Reset()
func (*GatewayInfo) String ¶
func (x *GatewayInfo) String() string
type GatewayManagerClient ¶
type GatewayManagerClient interface { // 对网关的操作 AddGateway(ctx context.Context, in *GatewayInfo, opts ...grpc.CallOption) (*OperationResponse, error) DelGateway(ctx context.Context, in *GatewayInfo, opts ...grpc.CallOption) (*OperationResponse, error) UpdateGateway(ctx context.Context, in *GatewayInfo, opts ...grpc.CallOption) (*OperationResponse, error) // rpc QueryGateway (GatewayInfo) returns (OperationResponse) {} GetAllGateway(ctx context.Context, in *GatewayInfo, opts ...grpc.CallOption) (*OperationResponse, error) }
GatewayManagerClient is the client API for GatewayManager 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 NewGatewayManagerClient ¶
func NewGatewayManagerClient(cc grpc.ClientConnInterface) GatewayManagerClient
type GatewayManagerServer ¶
type GatewayManagerServer interface { // 对网关的操作 AddGateway(context.Context, *GatewayInfo) (*OperationResponse, error) DelGateway(context.Context, *GatewayInfo) (*OperationResponse, error) UpdateGateway(context.Context, *GatewayInfo) (*OperationResponse, error) // rpc QueryGateway (GatewayInfo) returns (OperationResponse) {} GetAllGateway(context.Context, *GatewayInfo) (*OperationResponse, error) // contains filtered or unexported methods }
GatewayManagerServer is the server API for GatewayManager service. All implementations must embed UnimplementedGatewayManagerServer for forward compatibility
type MqttServerInfo ¶ added in v0.0.3
type MqttServerInfo struct { // String host; Host string `protobuf:"bytes,1,opt,name=Host,proto3" json:"Host,omitempty"` // int port; Port string `protobuf:"bytes,2,opt,name=Port,proto3" json:"Port,omitempty"` // Client ID ClientId string `protobuf:"bytes,3,opt,name=ClientId,proto3" json:"ClientId,omitempty"` // String username; Username string `protobuf:"bytes,4,opt,name=Username,proto3" json:"Username,omitempty"` // String password; Password string `protobuf:"bytes,5,opt,name=Password,proto3" json:"Password,omitempty"` // 是否匿名 IsAnonymous bool `protobuf:"varint,6,opt,name=IsAnonymous,proto3" json:"IsAnonymous,omitempty"` // contains filtered or unexported fields }
func (*MqttServerInfo) Descriptor
deprecated
added in
v0.0.3
func (*MqttServerInfo) Descriptor() ([]byte, []int)
Deprecated: Use MqttServerInfo.ProtoReflect.Descriptor instead.
func (*MqttServerInfo) GetClientId ¶ added in v0.0.3
func (x *MqttServerInfo) GetClientId() string
func (*MqttServerInfo) GetHost ¶ added in v0.0.3
func (x *MqttServerInfo) GetHost() string
func (*MqttServerInfo) GetIsAnonymous ¶ added in v0.0.3
func (x *MqttServerInfo) GetIsAnonymous() bool
func (*MqttServerInfo) GetPassword ¶ added in v0.0.3
func (x *MqttServerInfo) GetPassword() string
func (*MqttServerInfo) GetPort ¶ added in v0.0.3
func (x *MqttServerInfo) GetPort() string
func (*MqttServerInfo) GetUsername ¶ added in v0.0.3
func (x *MqttServerInfo) GetUsername() string
func (*MqttServerInfo) ProtoMessage ¶ added in v0.0.3
func (*MqttServerInfo) ProtoMessage()
func (*MqttServerInfo) ProtoReflect ¶ added in v0.0.3
func (x *MqttServerInfo) ProtoReflect() protoreflect.Message
func (*MqttServerInfo) Reset ¶ added in v0.0.3
func (x *MqttServerInfo) Reset()
func (*MqttServerInfo) String ¶ added in v0.0.3
func (x *MqttServerInfo) String() string
type MqttServerManagerClient ¶ added in v0.0.3
type MqttServerManagerClient interface { // 对网关的操作 AddMqttServer(ctx context.Context, in *MqttServerInfo, opts ...grpc.CallOption) (*OperationResponse, error) DelMqttServer(ctx context.Context, in *MqttServerInfo, opts ...grpc.CallOption) (*OperationResponse, error) UpdateMqttServer(ctx context.Context, in *MqttServerInfo, opts ...grpc.CallOption) (*OperationResponse, error) // rpc QueryMqttServer (MqttServerInfo) returns (OperationResponse) {} GetAllMqttServer(ctx context.Context, in *MqttServerInfo, opts ...grpc.CallOption) (*OperationResponse, error) }
MqttServerManagerClient is the client API for MqttServerManager 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 NewMqttServerManagerClient ¶ added in v0.0.3
func NewMqttServerManagerClient(cc grpc.ClientConnInterface) MqttServerManagerClient
type MqttServerManagerServer ¶ added in v0.0.3
type MqttServerManagerServer interface { // 对网关的操作 AddMqttServer(context.Context, *MqttServerInfo) (*OperationResponse, error) DelMqttServer(context.Context, *MqttServerInfo) (*OperationResponse, error) UpdateMqttServer(context.Context, *MqttServerInfo) (*OperationResponse, error) // rpc QueryMqttServer (MqttServerInfo) returns (OperationResponse) {} GetAllMqttServer(context.Context, *MqttServerInfo) (*OperationResponse, error) // contains filtered or unexported methods }
MqttServerManagerServer is the server API for MqttServerManager service. All implementations must embed UnimplementedMqttServerManagerServer for forward compatibility
type OperationResponse ¶
type OperationResponse struct { Code int32 `protobuf:"varint,1,opt,name=Code,proto3" json:"Code,omitempty"` Message string `protobuf:"bytes,2,opt,name=Message,proto3" json:"Message,omitempty"` // contains filtered or unexported fields }
func (*OperationResponse) Descriptor
deprecated
func (*OperationResponse) Descriptor() ([]byte, []int)
Deprecated: Use OperationResponse.ProtoReflect.Descriptor instead.
func (*OperationResponse) GetCode ¶ added in v0.0.2
func (x *OperationResponse) GetCode() int32
func (*OperationResponse) GetMessage ¶ added in v0.0.2
func (x *OperationResponse) GetMessage() string
func (*OperationResponse) ProtoMessage ¶
func (*OperationResponse) ProtoMessage()
func (*OperationResponse) ProtoReflect ¶
func (x *OperationResponse) ProtoReflect() protoreflect.Message
func (*OperationResponse) Reset ¶
func (x *OperationResponse) Reset()
func (*OperationResponse) String ¶
func (x *OperationResponse) String() string
type ServerInfo ¶
type ServerInfo struct { Uuid string `protobuf:"bytes,1,opt,name=Uuid,proto3" json:"Uuid,omitempty"` ServerHost string `protobuf:"bytes,2,opt,name=ServerHost,proto3" json:"ServerHost,omitempty"` LoginKey string `protobuf:"bytes,3,opt,name=LoginKey,proto3" json:"LoginKey,omitempty"` ConnectionType string `protobuf:"bytes,4,opt,name=ConnectionType,proto3" json:"ConnectionType,omitempty"` TcpPort int32 `protobuf:"varint,5,opt,name=TcpPort,proto3" json:"TcpPort,omitempty"` KcpPort int32 `protobuf:"varint,6,opt,name=KcpPort,proto3" json:"KcpPort,omitempty"` UdpApiPort int32 `protobuf:"varint,7,opt,name=UdpApiPort,proto3" json:"UdpApiPort,omitempty"` KcpApiPort int32 `protobuf:"varint,8,opt,name=KcpApiPort,proto3" json:"KcpApiPort,omitempty"` TlsPort int32 `protobuf:"varint,9,opt,name=TlsPort,proto3" json:"TlsPort,omitempty"` GrpcPort int32 `protobuf:"varint,10,opt,name=GrpcPort,proto3" json:"GrpcPort,omitempty"` // contains filtered or unexported fields }
func (*ServerInfo) Descriptor
deprecated
func (*ServerInfo) Descriptor() ([]byte, []int)
Deprecated: Use ServerInfo.ProtoReflect.Descriptor instead.
func (*ServerInfo) GetConnectionType ¶
func (x *ServerInfo) GetConnectionType() string
func (*ServerInfo) GetGrpcPort ¶
func (x *ServerInfo) GetGrpcPort() int32
func (*ServerInfo) GetKcpApiPort ¶
func (x *ServerInfo) GetKcpApiPort() int32
func (*ServerInfo) GetKcpPort ¶
func (x *ServerInfo) GetKcpPort() int32
func (*ServerInfo) GetLoginKey ¶
func (x *ServerInfo) GetLoginKey() string
func (*ServerInfo) GetServerHost ¶
func (x *ServerInfo) GetServerHost() string
func (*ServerInfo) GetTcpPort ¶
func (x *ServerInfo) GetTcpPort() int32
func (*ServerInfo) GetTlsPort ¶
func (x *ServerInfo) GetTlsPort() int32
func (*ServerInfo) GetUdpApiPort ¶
func (x *ServerInfo) GetUdpApiPort() int32
func (*ServerInfo) GetUuid ¶ added in v0.0.2
func (x *ServerInfo) GetUuid() string
func (*ServerInfo) ProtoMessage ¶
func (*ServerInfo) ProtoMessage()
func (*ServerInfo) ProtoReflect ¶
func (x *ServerInfo) ProtoReflect() protoreflect.Message
func (*ServerInfo) Reset ¶
func (x *ServerInfo) Reset()
func (*ServerInfo) String ¶
func (x *ServerInfo) String() string
type ServerInfoList ¶ added in v0.0.2
type ServerInfoList struct { ServerInfoList []*ServerInfo `protobuf:"bytes,1,rep,name=ServerInfoList,proto3" json:"ServerInfoList,omitempty"` // contains filtered or unexported fields }
func (*ServerInfoList) Descriptor
deprecated
added in
v0.0.2
func (*ServerInfoList) Descriptor() ([]byte, []int)
Deprecated: Use ServerInfoList.ProtoReflect.Descriptor instead.
func (*ServerInfoList) GetServerInfoList ¶ added in v0.0.2
func (x *ServerInfoList) GetServerInfoList() []*ServerInfo
func (*ServerInfoList) ProtoMessage ¶ added in v0.0.2
func (*ServerInfoList) ProtoMessage()
func (*ServerInfoList) ProtoReflect ¶ added in v0.0.2
func (x *ServerInfoList) ProtoReflect() protoreflect.Message
func (*ServerInfoList) Reset ¶ added in v0.0.2
func (x *ServerInfoList) Reset()
func (*ServerInfoList) String ¶ added in v0.0.2
func (x *ServerInfoList) String() string
type ServerManagerClient ¶
type ServerManagerClient interface { // 对服务器的操作 AddServer(ctx context.Context, in *ServerInfo, opts ...grpc.CallOption) (*OperationResponse, error) DelServer(ctx context.Context, in *ServerInfo, opts ...grpc.CallOption) (*OperationResponse, error) UpdateServer(ctx context.Context, in *ServerInfo, opts ...grpc.CallOption) (*OperationResponse, error) QueryServer(ctx context.Context, in *StringValue, opts ...grpc.CallOption) (*ServerInfoList, error) GetAllServer(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ServerInfoList, error) }
ServerManagerClient is the client API for ServerManager 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 NewServerManagerClient ¶
func NewServerManagerClient(cc grpc.ClientConnInterface) ServerManagerClient
type ServerManagerServer ¶
type ServerManagerServer interface { // 对服务器的操作 AddServer(context.Context, *ServerInfo) (*OperationResponse, error) DelServer(context.Context, *ServerInfo) (*OperationResponse, error) UpdateServer(context.Context, *ServerInfo) (*OperationResponse, error) QueryServer(context.Context, *StringValue) (*ServerInfoList, error) GetAllServer(context.Context, *Empty) (*ServerInfoList, error) // contains filtered or unexported methods }
ServerManagerServer is the server API for ServerManager service. All implementations must embed UnimplementedServerManagerServer for forward compatibility
type StringValue ¶
type StringValue struct { Value string `protobuf:"bytes,1,opt,name=Value,proto3" json:"Value,omitempty"` // contains filtered or unexported fields }
func (*StringValue) Descriptor
deprecated
func (*StringValue) Descriptor() ([]byte, []int)
Deprecated: Use StringValue.ProtoReflect.Descriptor instead.
func (*StringValue) GetValue ¶
func (x *StringValue) GetValue() string
func (*StringValue) ProtoMessage ¶
func (*StringValue) ProtoMessage()
func (*StringValue) ProtoReflect ¶
func (x *StringValue) ProtoReflect() protoreflect.Message
func (*StringValue) Reset ¶
func (x *StringValue) Reset()
func (*StringValue) String ¶
func (x *StringValue) String() string
type UnimplementedGatewayManagerServer ¶
type UnimplementedGatewayManagerServer struct { }
UnimplementedGatewayManagerServer must be embedded to have forward compatible implementations.
func (UnimplementedGatewayManagerServer) AddGateway ¶
func (UnimplementedGatewayManagerServer) AddGateway(context.Context, *GatewayInfo) (*OperationResponse, error)
func (UnimplementedGatewayManagerServer) DelGateway ¶ added in v0.0.2
func (UnimplementedGatewayManagerServer) DelGateway(context.Context, *GatewayInfo) (*OperationResponse, error)
func (UnimplementedGatewayManagerServer) GetAllGateway ¶ added in v0.0.2
func (UnimplementedGatewayManagerServer) GetAllGateway(context.Context, *GatewayInfo) (*OperationResponse, error)
func (UnimplementedGatewayManagerServer) UpdateGateway ¶ added in v0.0.2
func (UnimplementedGatewayManagerServer) UpdateGateway(context.Context, *GatewayInfo) (*OperationResponse, error)
type UnimplementedMqttServerManagerServer ¶ added in v0.0.3
type UnimplementedMqttServerManagerServer struct { }
UnimplementedMqttServerManagerServer must be embedded to have forward compatible implementations.
func (UnimplementedMqttServerManagerServer) AddMqttServer ¶ added in v0.0.3
func (UnimplementedMqttServerManagerServer) AddMqttServer(context.Context, *MqttServerInfo) (*OperationResponse, error)
func (UnimplementedMqttServerManagerServer) DelMqttServer ¶ added in v0.0.3
func (UnimplementedMqttServerManagerServer) DelMqttServer(context.Context, *MqttServerInfo) (*OperationResponse, error)
func (UnimplementedMqttServerManagerServer) GetAllMqttServer ¶ added in v0.0.3
func (UnimplementedMqttServerManagerServer) GetAllMqttServer(context.Context, *MqttServerInfo) (*OperationResponse, error)
func (UnimplementedMqttServerManagerServer) UpdateMqttServer ¶ added in v0.0.3
func (UnimplementedMqttServerManagerServer) UpdateMqttServer(context.Context, *MqttServerInfo) (*OperationResponse, error)
type UnimplementedServerManagerServer ¶
type UnimplementedServerManagerServer struct { }
UnimplementedServerManagerServer must be embedded to have forward compatible implementations.
func (UnimplementedServerManagerServer) AddServer ¶
func (UnimplementedServerManagerServer) AddServer(context.Context, *ServerInfo) (*OperationResponse, error)
func (UnimplementedServerManagerServer) DelServer ¶ added in v0.0.2
func (UnimplementedServerManagerServer) DelServer(context.Context, *ServerInfo) (*OperationResponse, error)
func (UnimplementedServerManagerServer) GetAllServer ¶ added in v0.0.2
func (UnimplementedServerManagerServer) GetAllServer(context.Context, *Empty) (*ServerInfoList, error)
func (UnimplementedServerManagerServer) QueryServer ¶ added in v0.0.2
func (UnimplementedServerManagerServer) QueryServer(context.Context, *StringValue) (*ServerInfoList, error)
func (UnimplementedServerManagerServer) UpdateServer ¶ added in v0.0.2
func (UnimplementedServerManagerServer) UpdateServer(context.Context, *ServerInfo) (*OperationResponse, error)
type UnimplementedUserManagerServer ¶
type UnimplementedUserManagerServer struct { }
UnimplementedUserManagerServer must be embedded to have forward compatible implementations.
func (UnimplementedUserManagerServer) LoginWithUserLoginInfo ¶
func (UnimplementedUserManagerServer) LoginWithUserLoginInfo(context.Context, *UserInfo) (*UserLoginResponse, error)
func (UnimplementedUserManagerServer) RegisterUserWithUserInfo ¶ added in v0.0.2
func (UnimplementedUserManagerServer) RegisterUserWithUserInfo(context.Context, *UserInfo) (*OperationResponse, error)
func (UnimplementedUserManagerServer) UpdateUserAvatar ¶ added in v0.0.2
func (UnimplementedUserManagerServer) UpdateUserAvatar(context.Context, *UpdateAvatar) (*OperationResponse, error)
func (UnimplementedUserManagerServer) UpdateUserEmail ¶ added in v0.0.2
func (UnimplementedUserManagerServer) UpdateUserEmail(context.Context, *UpdateInfo) (*OperationResponse, error)
func (UnimplementedUserManagerServer) UpdateUserMobile ¶ added in v0.0.2
func (UnimplementedUserManagerServer) UpdateUserMobile(context.Context, *UpdateInfo) (*OperationResponse, error)
func (UnimplementedUserManagerServer) UpdateUserNanme ¶ added in v0.0.2
func (UnimplementedUserManagerServer) UpdateUserNanme(context.Context, *UpdateInfo) (*OperationResponse, error)
func (UnimplementedUserManagerServer) UpdateUserPassword ¶ added in v0.0.2
func (UnimplementedUserManagerServer) UpdateUserPassword(context.Context, *UpdateInfo) (*OperationResponse, error)
type UnsafeGatewayManagerServer ¶
type UnsafeGatewayManagerServer interface {
// contains filtered or unexported methods
}
UnsafeGatewayManagerServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to GatewayManagerServer will result in compilation errors.
type UnsafeMqttServerManagerServer ¶ added in v0.0.3
type UnsafeMqttServerManagerServer interface {
// contains filtered or unexported methods
}
UnsafeMqttServerManagerServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to MqttServerManagerServer will result in compilation errors.
type UnsafeServerManagerServer ¶
type UnsafeServerManagerServer interface {
// contains filtered or unexported methods
}
UnsafeServerManagerServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ServerManagerServer will result in compilation errors.
type UnsafeUserManagerServer ¶
type UnsafeUserManagerServer interface {
// contains filtered or unexported methods
}
UnsafeUserManagerServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to UserManagerServer will result in compilation errors.
type UpdateAvatar ¶ added in v0.0.3
type UpdateAvatar struct { UUID string `protobuf:"bytes,1,opt,name=UUID,proto3" json:"UUID,omitempty"` NewBytes []byte `protobuf:"bytes,2,opt,name=NewBytes,proto3" json:"NewBytes,omitempty"` // contains filtered or unexported fields }
func (*UpdateAvatar) Descriptor
deprecated
added in
v0.0.3
func (*UpdateAvatar) Descriptor() ([]byte, []int)
Deprecated: Use UpdateAvatar.ProtoReflect.Descriptor instead.
func (*UpdateAvatar) GetNewBytes ¶ added in v0.0.3
func (x *UpdateAvatar) GetNewBytes() []byte
func (*UpdateAvatar) GetUUID ¶ added in v0.0.3
func (x *UpdateAvatar) GetUUID() string
func (*UpdateAvatar) ProtoMessage ¶ added in v0.0.3
func (*UpdateAvatar) ProtoMessage()
func (*UpdateAvatar) ProtoReflect ¶ added in v0.0.3
func (x *UpdateAvatar) ProtoReflect() protoreflect.Message
func (*UpdateAvatar) Reset ¶ added in v0.0.3
func (x *UpdateAvatar) Reset()
func (*UpdateAvatar) String ¶ added in v0.0.3
func (x *UpdateAvatar) String() string
type UpdateInfo ¶ added in v0.0.3
type UpdateInfo struct { UUID string `protobuf:"bytes,1,opt,name=UUID,proto3" json:"UUID,omitempty"` NewString string `protobuf:"bytes,2,opt,name=NewString,proto3" json:"NewString,omitempty"` // contains filtered or unexported fields }
func (*UpdateInfo) Descriptor
deprecated
added in
v0.0.3
func (*UpdateInfo) Descriptor() ([]byte, []int)
Deprecated: Use UpdateInfo.ProtoReflect.Descriptor instead.
func (*UpdateInfo) GetNewString ¶ added in v0.0.3
func (x *UpdateInfo) GetNewString() string
func (*UpdateInfo) GetUUID ¶ added in v0.0.3
func (x *UpdateInfo) GetUUID() string
func (*UpdateInfo) ProtoMessage ¶ added in v0.0.3
func (*UpdateInfo) ProtoMessage()
func (*UpdateInfo) ProtoReflect ¶ added in v0.0.3
func (x *UpdateInfo) ProtoReflect() protoreflect.Message
func (*UpdateInfo) Reset ¶ added in v0.0.3
func (x *UpdateInfo) Reset()
func (*UpdateInfo) String ¶ added in v0.0.3
func (x *UpdateInfo) String() string
type UserInfo ¶ added in v0.0.2
type UserInfo struct { UserEmailMobile string `protobuf:"bytes,1,opt,name=UserEmailMobile,proto3" json:"UserEmailMobile,omitempty"` Password string `protobuf:"bytes,2,opt,name=Password,proto3" json:"Password,omitempty"` // contains filtered or unexported fields }
func (*UserInfo) Descriptor
deprecated
added in
v0.0.2
func (*UserInfo) GetPassword ¶ added in v0.0.2
func (*UserInfo) GetUserEmailMobile ¶ added in v0.0.3
func (*UserInfo) ProtoMessage ¶ added in v0.0.2
func (*UserInfo) ProtoMessage()
func (*UserInfo) ProtoReflect ¶ added in v0.0.2
func (x *UserInfo) ProtoReflect() protoreflect.Message
type UserLoginResponse ¶ added in v0.0.2
type UserLoginResponse struct { Code int32 `protobuf:"varint,1,opt,name=Code,proto3" json:"Code,omitempty"` Msg string `protobuf:"bytes,2,opt,name=Msg,proto3" json:"Msg,omitempty"` Token string `protobuf:"bytes,3,opt,name=Token,proto3" json:"Token,omitempty"` // contains filtered or unexported fields }
func (*UserLoginResponse) Descriptor
deprecated
added in
v0.0.2
func (*UserLoginResponse) Descriptor() ([]byte, []int)
Deprecated: Use UserLoginResponse.ProtoReflect.Descriptor instead.
func (*UserLoginResponse) GetCode ¶ added in v0.0.2
func (x *UserLoginResponse) GetCode() int32
func (*UserLoginResponse) GetMsg ¶ added in v0.0.2
func (x *UserLoginResponse) GetMsg() string
func (*UserLoginResponse) GetToken ¶ added in v0.0.2
func (x *UserLoginResponse) GetToken() string
func (*UserLoginResponse) ProtoMessage ¶ added in v0.0.2
func (*UserLoginResponse) ProtoMessage()
func (*UserLoginResponse) ProtoReflect ¶ added in v0.0.2
func (x *UserLoginResponse) ProtoReflect() protoreflect.Message
func (*UserLoginResponse) Reset ¶ added in v0.0.2
func (x *UserLoginResponse) Reset()
func (*UserLoginResponse) String ¶ added in v0.0.2
func (x *UserLoginResponse) String() string
type UserManagerClient ¶
type UserManagerClient interface { // 注册用户 RegisterUserWithUserInfo(ctx context.Context, in *UserInfo, opts ...grpc.CallOption) (*OperationResponse, error) // 登录 获取Token LoginWithUserLoginInfo(ctx context.Context, in *UserInfo, opts ...grpc.CallOption) (*UserLoginResponse, error) // 更新用户信息 UpdateUserNanme(ctx context.Context, in *UpdateInfo, opts ...grpc.CallOption) (*OperationResponse, error) UpdateUserEmail(ctx context.Context, in *UpdateInfo, opts ...grpc.CallOption) (*OperationResponse, error) UpdateUserMobile(ctx context.Context, in *UpdateInfo, opts ...grpc.CallOption) (*OperationResponse, error) UpdateUserPassword(ctx context.Context, in *UpdateInfo, opts ...grpc.CallOption) (*OperationResponse, error) UpdateUserAvatar(ctx context.Context, in *UpdateAvatar, opts ...grpc.CallOption) (*OperationResponse, error) }
UserManagerClient is the client API for UserManager 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 NewUserManagerClient ¶
func NewUserManagerClient(cc grpc.ClientConnInterface) UserManagerClient
type UserManagerServer ¶
type UserManagerServer interface { // 注册用户 RegisterUserWithUserInfo(context.Context, *UserInfo) (*OperationResponse, error) // 登录 获取Token LoginWithUserLoginInfo(context.Context, *UserInfo) (*UserLoginResponse, error) // 更新用户信息 UpdateUserNanme(context.Context, *UpdateInfo) (*OperationResponse, error) UpdateUserEmail(context.Context, *UpdateInfo) (*OperationResponse, error) UpdateUserMobile(context.Context, *UpdateInfo) (*OperationResponse, error) UpdateUserPassword(context.Context, *UpdateInfo) (*OperationResponse, error) UpdateUserAvatar(context.Context, *UpdateAvatar) (*OperationResponse, error) // contains filtered or unexported methods }
UserManagerServer is the server API for UserManager service. All implementations must embed UnimplementedUserManagerServer for forward compatibility