pb

package
v0.0.13 Latest Latest
Warning

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

 Go to latest Published: Mar 17, 2021 License: MIT Imports: 9 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_common_proto protoreflect.FileDescriptor
View Source 
var File_gatewayManager_proto protoreflect.FileDescriptor
View Source 
var File_mqttServerManager_proto protoreflect.FileDescriptor
View Source 
var File_serverManager_proto protoreflect.FileDescriptor
View Source 
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) Descriptor() ([]byte, []int)

Deprecated: Use Empty.ProtoReflect.Descriptor instead.

func (*Empty) ProtoMessage 

func (*Empty) ProtoMessage()

func (*Empty) ProtoReflect 

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

func (*Empty) Reset 

func (x *Empty) Reset()

func (*Empty) String 

func (x *Empty) String() string

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"`
	Description string   `protobuf:"bytes,3,opt,name=Description,proto3" json:"Description,omitempty"`
	ServerUuid  []string `protobuf:"bytes,4,rep,name=ServerUuid,proto3" json:"ServerUuid,omitempty"`
	//在线状态
	Status bool `protobuf:"varint,5,opt,name=Status,proto3" json:"Status,omitempty"`
	//    额外的配置
	ConfigMap map[string]string `` /* 159-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*GatewayInfo) Descriptor deprecated 

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

Deprecated: Use GatewayInfo.ProtoReflect.Descriptor instead.

func (*GatewayInfo) GetConfigMap added in v0.0.7 

func (x *GatewayInfo) GetConfigMap() map[string]string

func (*GatewayInfo) GetDescription added in v0.0.6 

func (x *GatewayInfo) GetDescription() string

func (*GatewayInfo) GetName added in v0.0.2 

func (x *GatewayInfo) GetName() 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) 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 GatewayInfoList added in v0.0.10 

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

func (*GatewayInfoList) Descriptor deprecated added in v0.0.10 

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

Deprecated: Use GatewayInfoList.ProtoReflect.Descriptor instead.

func (*GatewayInfoList) GetGatewayInfoList added in v0.0.10 

func (x *GatewayInfoList) GetGatewayInfoList() []*GatewayInfo

func (*GatewayInfoList) ProtoMessage added in v0.0.10 

func (*GatewayInfoList) ProtoMessage()

func (*GatewayInfoList) ProtoReflect added in v0.0.10 

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

func (*GatewayInfoList) Reset added in v0.0.10 

func (x *GatewayInfoList) Reset()

func (*GatewayInfoList) String added in v0.0.10 

func (x *GatewayInfoList) 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 *Empty, opts ...grpc.CallOption) (*GatewayInfoList, 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, *Empty) (*GatewayInfoList, error)
	// contains filtered or unexported methods
}

GatewayManagerServer is the server API for GatewayManager service. All implementations must embed UnimplementedGatewayManagerServer for forward compatibility

type HostInfo added in v0.0.13 

type HostInfo struct {
	Name        string      `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"`
	GatewayUUID string      `protobuf:"bytes,2,opt,name=GatewayUUID,proto3" json:"GatewayUUID,omitempty"`
	Addr        string      `protobuf:"bytes,3,opt,name=Addr,proto3" json:"Addr,omitempty"`
	TCPPort     []*PortInfo `protobuf:"bytes,4,rep,name=TCPPort,proto3" json:"TCPPort,omitempty"`
	UDPPort     []*PortInfo `protobuf:"bytes,5,rep,name=UDPPort,proto3" json:"UDPPort,omitempty"`
	FTPPort     []*PortInfo `protobuf:"bytes,6,rep,name=FTPPort,proto3" json:"FTPPort,omitempty"`
	// contains filtered or unexported fields
}

func (*HostInfo) Descriptor deprecated added in v0.0.13 

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

Deprecated: Use HostInfo.ProtoReflect.Descriptor instead.

func (*HostInfo) GetAddr added in v0.0.13 

func (x *HostInfo) GetAddr() string

func (*HostInfo) GetFTPPort added in v0.0.13 

func (x *HostInfo) GetFTPPort() []*PortInfo

func (*HostInfo) GetGatewayUUID added in v0.0.13 

func (x *HostInfo) GetGatewayUUID() string

func (*HostInfo) GetName added in v0.0.13 

func (x *HostInfo) GetName() string

func (*HostInfo) GetTCPPort added in v0.0.13 

func (x *HostInfo) GetTCPPort() []*PortInfo

func (*HostInfo) GetUDPPort added in v0.0.13 

func (x *HostInfo) GetUDPPort() []*PortInfo

func (*HostInfo) ProtoMessage added in v0.0.13 

func (*HostInfo) ProtoMessage()

func (*HostInfo) ProtoReflect added in v0.0.13 

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

func (*HostInfo) Reset added in v0.0.13 

func (x *HostInfo) Reset()

func (*HostInfo) String added in v0.0.13 

func (x *HostInfo) String() string

type HostInfoList added in v0.0.13 

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

手动添加的局域网主机

func (*HostInfoList) Descriptor deprecated added in v0.0.13 

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

Deprecated: Use HostInfoList.ProtoReflect.Descriptor instead.

func (*HostInfoList) GetHostInfoList added in v0.0.13 

func (x *HostInfoList) GetHostInfoList() []*HostInfo

func (*HostInfoList) ProtoMessage added in v0.0.13 

func (*HostInfoList) ProtoMessage()

func (*HostInfoList) ProtoReflect added in v0.0.13 

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

func (*HostInfoList) Reset added in v0.0.13 

func (x *HostInfoList) Reset()

func (*HostInfoList) String added in v0.0.13 

func (x *HostInfoList) String() string

type LoginInfo added in v0.0.13 

type LoginInfo 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 (*LoginInfo) Descriptor deprecated added in v0.0.13 

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

Deprecated: Use LoginInfo.ProtoReflect.Descriptor instead.

func (*LoginInfo) GetPassword added in v0.0.13 

func (x *LoginInfo) GetPassword() string

func (*LoginInfo) GetUserEmailMobile added in v0.0.13 

func (x *LoginInfo) GetUserEmailMobile() string

func (*LoginInfo) ProtoMessage added in v0.0.13 

func (*LoginInfo) ProtoMessage()

func (*LoginInfo) ProtoReflect added in v0.0.13 

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

func (*LoginInfo) Reset added in v0.0.13 

func (x *LoginInfo) Reset()

func (*LoginInfo) String added in v0.0.13 

func (x *LoginInfo) String() string

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"`
	//    额外的配置
	ConfigMap map[string]string `` /* 159-byte string literal not displayed */
	// 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) GetConfigMap added in v0.0.7 

func (x *MqttServerInfo) GetConfigMap() map[string]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 PortInfo added in v0.0.13 

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

func (*PortInfo) Descriptor deprecated added in v0.0.13 

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

Deprecated: Use PortInfo.ProtoReflect.Descriptor instead.

func (*PortInfo) GetName added in v0.0.13 

func (x *PortInfo) GetName() string

func (*PortInfo) GetPort added in v0.0.13 

func (x *PortInfo) GetPort() uint32

func (*PortInfo) ProtoMessage added in v0.0.13 

func (*PortInfo) ProtoMessage()

func (*PortInfo) ProtoReflect added in v0.0.13 

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

func (*PortInfo) Reset added in v0.0.13 

func (x *PortInfo) Reset()

func (*PortInfo) String added in v0.0.13 

func (x *PortInfo) String() string

type ServerInfo 

type ServerInfo 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"`
	ServerHost  string `protobuf:"bytes,3,opt,name=ServerHost,proto3" json:"ServerHost,omitempty"`
	LoginKey    string `protobuf:"bytes,4,opt,name=LoginKey,proto3" json:"LoginKey,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"`
	Description string `protobuf:"bytes,11,opt,name=Description,proto3" json:"Description,omitempty"`
	IsPublic    bool   `protobuf:"varint,12,opt,name=IsPublic,proto3" json:"IsPublic,omitempty"`
	// contains filtered or unexported fields
}

func (*ServerInfo) Descriptor deprecated 

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

Deprecated: Use ServerInfo.ProtoReflect.Descriptor instead.

func (*ServerInfo) GetDescription added in v0.0.6 

func (x *ServerInfo) GetDescription() string

func (*ServerInfo) GetGrpcPort 

func (x *ServerInfo) GetGrpcPort() int32

func (*ServerInfo) GetIsPublic added in v0.0.9 

func (x *ServerInfo) GetIsPublic() bool

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) GetName added in v0.0.8 

func (x *ServerInfo) GetName() 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, *Empty) (*GatewayInfoList, 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) AddOrUpdateHost added in v0.0.13 

func (UnimplementedUserManagerServer) AddOrUpdateHost(context.Context, *HostInfo) (*OperationResponse, error)

func (UnimplementedUserManagerServer) BanUser added in v0.0.13 

func (UnimplementedUserManagerServer) BanUser(context.Context, *UserInfo) (*OperationResponse, error)

func (UnimplementedUserManagerServer) DelAllUserConfig added in v0.0.13 

func (UnimplementedUserManagerServer) DelAllUserConfig(context.Context, *UserConfigMap) (*OperationResponse, error)

func (UnimplementedUserManagerServer) DelCnameByKey added in v0.0.13 

func (UnimplementedUserManagerServer) DelCnameByKey(context.Context, *StringValue) (*OperationResponse, error)

func (UnimplementedUserManagerServer) DelHost added in v0.0.13 

func (UnimplementedUserManagerServer) DelHost(context.Context, *HostInfo) (*OperationResponse, error)

func (UnimplementedUserManagerServer) DelUserConfigByKey added in v0.0.13 

func (UnimplementedUserManagerServer) DelUserConfigByKey(context.Context, *StringValue) (*OperationResponse, error)

func (UnimplementedUserManagerServer) GetAllHosts added in v0.0.13 

func (UnimplementedUserManagerServer) GetAllHosts(context.Context, *Empty) (*HostInfoList, error)

func (UnimplementedUserManagerServer) GetAllUser added in v0.0.13 

func (UnimplementedUserManagerServer) GetAllUser(context.Context, *Empty) (*UserInfoList, error)

func (UnimplementedUserManagerServer) GetAllUserConfig added in v0.0.7 

func (UnimplementedUserManagerServer) GetAllUserConfig(context.Context, *Empty) (*UserConfigMap, error)

func (UnimplementedUserManagerServer) GetCnameByKey added in v0.0.13 

func (UnimplementedUserManagerServer) GetCnameByKey(context.Context, *StringValue) (*StringValue, error)

func (UnimplementedUserManagerServer) GetUserConfigByKey added in v0.0.7 

func (UnimplementedUserManagerServer) GetUserConfigByKey(context.Context, *StringValue) (*StringValue, error)

func (UnimplementedUserManagerServer) GetUserInfo added in v0.0.13 

func (UnimplementedUserManagerServer) GetUserInfo(context.Context, *LoginInfo) (*UserInfo, error)

func (UnimplementedUserManagerServer) LoginWithUserLoginInfo 

func (UnimplementedUserManagerServer) LoginWithUserLoginInfo(context.Context, *LoginInfo) (*UserLoginResponse, error)

func (UnimplementedUserManagerServer) RegisterUserWithUserInfo added in v0.0.2 

func (UnimplementedUserManagerServer) RegisterUserWithUserInfo(context.Context, *LoginInfo) (*OperationResponse, error)

func (UnimplementedUserManagerServer) SetAllUserConfig added in v0.0.7 

func (UnimplementedUserManagerServer) SetAllUserConfig(context.Context, *UserConfigMap) (*OperationResponse, error)

func (UnimplementedUserManagerServer) SetCnameByKey added in v0.0.13 

func (UnimplementedUserManagerServer) SetCnameByKey(context.Context, *StringValue) (*OperationResponse, error)

func (UnimplementedUserManagerServer) SetUserConfigByKey added in v0.0.7 

func (UnimplementedUserManagerServer) SetUserConfigByKey(context.Context, *StringValue) (*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 UserConfigMap added in v0.0.13 

type UserConfigMap struct {
	Config map[string]string `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*UserConfigMap) Descriptor deprecated added in v0.0.13 

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

Deprecated: Use UserConfigMap.ProtoReflect.Descriptor instead.

func (*UserConfigMap) GetConfig added in v0.0.13 

func (x *UserConfigMap) GetConfig() map[string]string

func (*UserConfigMap) ProtoMessage added in v0.0.13 

func (*UserConfigMap) ProtoMessage()

func (*UserConfigMap) ProtoReflect added in v0.0.13 

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

func (*UserConfigMap) Reset added in v0.0.13 

func (x *UserConfigMap) Reset()

func (*UserConfigMap) String added in v0.0.13 

func (x *UserConfigMap) String() string

type UserInfo added in v0.0.2 

type UserInfo struct {
	Nanme  string `protobuf:"bytes,1,opt,name=Nanme,proto3" json:"Nanme,omitempty"`
	Email  string `protobuf:"bytes,2,opt,name=Email,proto3" json:"Email,omitempty"`
	Mobile string `protobuf:"bytes,3,opt,name=Mobile,proto3" json:"Mobile,omitempty"`
	Avatar []byte `protobuf:"bytes,4,opt,name=Avatar,proto3" json:"Avatar,omitempty"`
	// contains filtered or unexported fields
}

func (*UserInfo) Descriptor deprecated added in v0.0.2 

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

Deprecated: Use UserInfo.ProtoReflect.Descriptor instead.

func (*UserInfo) GetAvatar added in v0.0.13 

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

func (*UserInfo) GetEmail added in v0.0.13 

func (x *UserInfo) GetEmail() string

func (*UserInfo) GetMobile added in v0.0.13 

func (x *UserInfo) GetMobile() string

func (*UserInfo) GetNanme added in v0.0.13 

func (x *UserInfo) GetNanme() string

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

func (*UserInfo) Reset added in v0.0.2 

func (x *UserInfo) Reset()

func (*UserInfo) String added in v0.0.2 

func (x *UserInfo) String() string

type UserInfoList added in v0.0.13 

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

func (*UserInfoList) Descriptor deprecated added in v0.0.13 

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

Deprecated: Use UserInfoList.ProtoReflect.Descriptor instead.

func (*UserInfoList) GetUserInfoList added in v0.0.13 

func (x *UserInfoList) GetUserInfoList() []*UserInfo

func (*UserInfoList) ProtoMessage added in v0.0.13 

func (*UserInfoList) ProtoMessage()

func (*UserInfoList) ProtoReflect added in v0.0.13 

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

func (*UserInfoList) Reset added in v0.0.13 

func (x *UserInfoList) Reset()

func (*UserInfoList) String added in v0.0.13 

func (x *UserInfoList) String() string

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"`
	//    UserInfo
	UserInfo *UserInfo `protobuf:"bytes,4,opt,name=UserInfo,proto3" json:"UserInfo,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) GetUserInfo added in v0.0.13 

func (x *UserLoginResponse) GetUserInfo() *UserInfo

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 *LoginInfo, opts ...grpc.CallOption) (*OperationResponse, error)
	//    登录 获取Token
	LoginWithUserLoginInfo(ctx context.Context, in *LoginInfo, opts ...grpc.CallOption) (*UserLoginResponse, error)
	GetUserInfo(ctx context.Context, in *LoginInfo, opts ...grpc.CallOption) (*UserInfo, 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)
	//    用户配置
	//    Host
	GetAllHosts(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*HostInfoList, error)
	AddOrUpdateHost(ctx context.Context, in *HostInfo, opts ...grpc.CallOption) (*OperationResponse, error)
	DelHost(ctx context.Context, in *HostInfo, opts ...grpc.CallOption) (*OperationResponse, error)
	//    Cname
	GetCnameByKey(ctx context.Context, in *StringValue, opts ...grpc.CallOption) (*StringValue, error)
	SetCnameByKey(ctx context.Context, in *StringValue, opts ...grpc.CallOption) (*OperationResponse, error)
	DelCnameByKey(ctx context.Context, in *StringValue, opts ...grpc.CallOption) (*OperationResponse, error)
	//    普通配置一次性操作多个
	GetAllUserConfig(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*UserConfigMap, error)
	SetAllUserConfig(ctx context.Context, in *UserConfigMap, opts ...grpc.CallOption) (*OperationResponse, error)
	DelAllUserConfig(ctx context.Context, in *UserConfigMap, opts ...grpc.CallOption) (*OperationResponse, error)
	//    StringValue一次性操作一个
	GetUserConfigByKey(ctx context.Context, in *StringValue, opts ...grpc.CallOption) (*StringValue, error)
	SetUserConfigByKey(ctx context.Context, in *StringValue, opts ...grpc.CallOption) (*OperationResponse, error)
	DelUserConfigByKey(ctx context.Context, in *StringValue, opts ...grpc.CallOption) (*OperationResponse, error)
	//    管理员权限，管理用户
	//获取所有用户
	GetAllUser(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*UserInfoList, error)
	//禁用一个用户(不可以禁用管理员)
	BanUser(ctx context.Context, in *UserInfo, 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, *LoginInfo) (*OperationResponse, error)
	//    登录 获取Token
	LoginWithUserLoginInfo(context.Context, *LoginInfo) (*UserLoginResponse, error)
	GetUserInfo(context.Context, *LoginInfo) (*UserInfo, 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)
	//    用户配置
	//    Host
	GetAllHosts(context.Context, *Empty) (*HostInfoList, error)
	AddOrUpdateHost(context.Context, *HostInfo) (*OperationResponse, error)
	DelHost(context.Context, *HostInfo) (*OperationResponse, error)
	//    Cname
	GetCnameByKey(context.Context, *StringValue) (*StringValue, error)
	SetCnameByKey(context.Context, *StringValue) (*OperationResponse, error)
	DelCnameByKey(context.Context, *StringValue) (*OperationResponse, error)
	//    普通配置一次性操作多个
	GetAllUserConfig(context.Context, *Empty) (*UserConfigMap, error)
	SetAllUserConfig(context.Context, *UserConfigMap) (*OperationResponse, error)
	DelAllUserConfig(context.Context, *UserConfigMap) (*OperationResponse, error)
	//    StringValue一次性操作一个
	GetUserConfigByKey(context.Context, *StringValue) (*StringValue, error)
	SetUserConfigByKey(context.Context, *StringValue) (*OperationResponse, error)
	DelUserConfigByKey(context.Context, *StringValue) (*OperationResponse, error)
	//    管理员权限，管理用户
	//获取所有用户
	GetAllUser(context.Context, *Empty) (*UserInfoList, error)
	//禁用一个用户(不可以禁用管理员)
	BanUser(context.Context, *UserInfo) (*OperationResponse, error)
	// contains filtered or unexported methods
}

UserManagerServer is the server API for UserManager service. All implementations must embed UnimplementedUserManagerServer 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.