pb

package
v0.0.15 Latest Latest
Warning

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

 Go to latest Published: Apr 15, 2021 License: MIT Imports: 9 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_adminManager_proto protoreflect.FileDescriptor
View Source 
var File_cnameManager_proto protoreflect.FileDescriptor
View Source 
var File_common_proto protoreflect.FileDescriptor
View Source 
var File_configManager_proto protoreflect.FileDescriptor
View Source 
var File_gatewayManager_proto protoreflect.FileDescriptor
View Source 
var File_hostManager_proto protoreflect.FileDescriptor
View Source 
var File_httpManager_proto protoreflect.FileDescriptor
View Source 
var File_mqttServerManager_proto protoreflect.FileDescriptor
View Source 
var File_portManager_proto protoreflect.FileDescriptor
View Source 
var File_serverManager_proto protoreflect.FileDescriptor
View Source 
var File_userManager_proto protoreflect.FileDescriptor

Functions

func RegisterAdminManagerServer added in v0.0.14 

func RegisterAdminManagerServer(s grpc.ServiceRegistrar, srv AdminManagerServer)

func RegisterCnameManagerServer added in v0.0.14 

func RegisterCnameManagerServer(s grpc.ServiceRegistrar, srv CnameManagerServer)

func RegisterConfigManagerServer added in v0.0.14 

func RegisterConfigManagerServer(s grpc.ServiceRegistrar, srv ConfigManagerServer)

func RegisterGatewayManagerServer 

func RegisterGatewayManagerServer(s grpc.ServiceRegistrar, srv GatewayManagerServer)

func RegisterHostManagerServer added in v0.0.14 

func RegisterHostManagerServer(s grpc.ServiceRegistrar, srv HostManagerServer)

func RegisterHttpManagerServer added in v0.0.14 

func RegisterHttpManagerServer(s grpc.ServiceRegistrar, srv HttpManagerServer)

func RegisterMqttServerManagerServer added in v0.0.3 

func RegisterMqttServerManagerServer(s grpc.ServiceRegistrar, srv MqttServerManagerServer)

func RegisterPortManagerServer added in v0.0.14 

func RegisterPortManagerServer(s grpc.ServiceRegistrar, srv PortManagerServer)

func RegisterServerManagerServer 

func RegisterServerManagerServer(s grpc.ServiceRegistrar, srv ServerManagerServer)

func RegisterUserManagerServer 

func RegisterUserManagerServer(s grpc.ServiceRegistrar, srv UserManagerServer)

Types

type AdminManagerClient added in v0.0.14 

type AdminManagerClient interface {
	//    管理员权限，管理用户
	//获取所有用户
	GetAllUser(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*UserInfoList, error)
	//禁用一个用户(不可以禁用管理员)
	BanUser(ctx context.Context, in *UserInfo, opts ...grpc.CallOption) (*OperationResponse, error)
}

AdminManagerClient is the client API for AdminManager 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 NewAdminManagerClient added in v0.0.14 

func NewAdminManagerClient(cc grpc.ClientConnInterface) AdminManagerClient

type AdminManagerServer added in v0.0.14 

type AdminManagerServer interface {
	//    管理员权限，管理用户
	//获取所有用户
	GetAllUser(context.Context, *Empty) (*UserInfoList, error)
	//禁用一个用户(不可以禁用管理员)
	BanUser(context.Context, *UserInfo) (*OperationResponse, error)
	// contains filtered or unexported methods
}

AdminManagerServer is the server API for AdminManager service. All implementations must embed UnimplementedAdminManagerServer for forward compatibility

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 CnameManagerClient added in v0.0.14 

type CnameManagerClient interface {
	//    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)
}

CnameManagerClient is the client API for CnameManager 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 NewCnameManagerClient added in v0.0.14 

func NewCnameManagerClient(cc grpc.ClientConnInterface) CnameManagerClient

type CnameManagerServer added in v0.0.14 

type CnameManagerServer interface {
	//    Cname
	GetCnameByKey(context.Context, *StringValue) (*StringValue, error)
	SetCnameByKey(context.Context, *StringValue) (*OperationResponse, error)
	DelCnameByKey(context.Context, *StringValue) (*OperationResponse, error)
	// contains filtered or unexported methods
}

CnameManagerServer is the server API for CnameManager service. All implementations must embed UnimplementedCnameManagerServer for forward compatibility

type ConfigManagerClient added in v0.0.14 

type ConfigManagerClient interface {
	//    用户配置
	//    普通配置一次性操作多个
	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)
}

ConfigManagerClient is the client API for ConfigManager 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 NewConfigManagerClient added in v0.0.14 

func NewConfigManagerClient(cc grpc.ClientConnInterface) ConfigManagerClient

type ConfigManagerServer added in v0.0.14 

type ConfigManagerServer interface {
	//    用户配置
	//    普通配置一次性操作多个
	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)
	// contains filtered or unexported methods
}

ConfigManagerServer is the server API for ConfigManager service. All implementations must embed UnimplementedConfigManagerServer for forward compatibility

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 {
	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"`
	HostAddr    string `protobuf:"bytes,4,opt,name=HostAddr,proto3" json:"HostAddr,omitempty"`
	GatewayUUID string `protobuf:"bytes,5,opt,name=GatewayUUID,proto3" json:"GatewayUUID,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) GetDescription added in v0.0.14 

func (x *HostInfo) GetDescription() string

func (*HostInfo) GetGatewayUUID added in v0.0.13 

func (x *HostInfo) GetGatewayUUID() string

func (*HostInfo) GetHostAddr added in v0.0.14 

func (x *HostInfo) GetHostAddr() string

func (*HostInfo) GetName added in v0.0.13 

func (x *HostInfo) GetName() string

func (*HostInfo) GetUUID added in v0.0.14 

func (x *HostInfo) GetUUID() string

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 HostManagerClient added in v0.0.14 

type HostManagerClient interface {
	//    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)
}

HostManagerClient is the client API for HostManager 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 NewHostManagerClient added in v0.0.14 

func NewHostManagerClient(cc grpc.ClientConnInterface) HostManagerClient

type HostManagerServer added in v0.0.14 

type HostManagerServer interface {
	//    Host
	GetAllHosts(context.Context, *Empty) (*HostInfoList, error)
	AddOrUpdateHost(context.Context, *HostInfo) (*OperationResponse, error)
	DelHost(context.Context, *HostInfo) (*OperationResponse, error)
	// contains filtered or unexported methods
}

HostManagerServer is the server API for HostManager service. All implementations must embed UnimplementedHostManagerServer for forward compatibility

type HttpInfo added in v0.0.14 

type HttpInfo 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"`
	Port        int32  `protobuf:"varint,4,opt,name=Port,proto3" json:"Port,omitempty"`
	Domain      string `protobuf:"bytes,5,opt,name=Domain,proto3" json:"Domain,omitempty"`
	HostUUID    int64  `protobuf:"varint,6,opt,name=HostUUID,proto3" json:"HostUUID,omitempty"`
	// contains filtered or unexported fields
}

func (*HttpInfo) Descriptor deprecated added in v0.0.14 

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

Deprecated: Use HttpInfo.ProtoReflect.Descriptor instead.

func (*HttpInfo) GetDescription added in v0.0.14 

func (x *HttpInfo) GetDescription() string

func (*HttpInfo) GetDomain added in v0.0.14 

func (x *HttpInfo) GetDomain() string

func (*HttpInfo) GetHostUUID added in v0.0.14 

func (x *HttpInfo) GetHostUUID() int64

func (*HttpInfo) GetName added in v0.0.14 

func (x *HttpInfo) GetName() string

func (*HttpInfo) GetPort added in v0.0.14 

func (x *HttpInfo) GetPort() int32

func (*HttpInfo) GetUUID added in v0.0.14 

func (x *HttpInfo) GetUUID() string

func (*HttpInfo) ProtoMessage added in v0.0.14 

func (*HttpInfo) ProtoMessage()

func (*HttpInfo) ProtoReflect added in v0.0.14 

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

func (*HttpInfo) Reset added in v0.0.14 

func (x *HttpInfo) Reset()

func (*HttpInfo) String added in v0.0.14 

func (x *HttpInfo) String() string

type HttpInfoList added in v0.0.14 

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

手动添加的局域网主机

func (*HttpInfoList) Descriptor deprecated added in v0.0.14 

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

Deprecated: Use HttpInfoList.ProtoReflect.Descriptor instead.

func (*HttpInfoList) GetHttpInfoList added in v0.0.14 

func (x *HttpInfoList) GetHttpInfoList() []*HttpInfo

func (*HttpInfoList) ProtoMessage added in v0.0.14 

func (*HttpInfoList) ProtoMessage()

func (*HttpInfoList) ProtoReflect added in v0.0.14 

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

func (*HttpInfoList) Reset added in v0.0.14 

func (x *HttpInfoList) Reset()

func (*HttpInfoList) String added in v0.0.14 

func (x *HttpInfoList) String() string

type HttpManagerClient added in v0.0.14 

type HttpManagerClient interface {
	//    Http
	GetAllHttps(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*HttpInfoList, error)
	AddOrUpdateHttp(ctx context.Context, in *HttpInfo, opts ...grpc.CallOption) (*OperationResponse, error)
	DelHttp(ctx context.Context, in *HttpInfo, opts ...grpc.CallOption) (*OperationResponse, error)
}

HttpManagerClient is the client API for HttpManager 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 NewHttpManagerClient added in v0.0.14 

func NewHttpManagerClient(cc grpc.ClientConnInterface) HttpManagerClient

type HttpManagerServer added in v0.0.14 

type HttpManagerServer interface {
	//    Http
	GetAllHttps(context.Context, *Empty) (*HttpInfoList, error)
	AddOrUpdateHttp(context.Context, *HttpInfo) (*OperationResponse, error)
	DelHttp(context.Context, *HttpInfo) (*OperationResponse, error)
	// contains filtered or unexported methods
}

HttpManagerServer is the server API for HttpManager service. All implementations must embed UnimplementedHttpManagerServer for forward compatibility

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 {
	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"`
	Port                int32  `protobuf:"varint,4,opt,name=Port,proto3" json:"Port,omitempty"`
	NetworkProtocol     string `protobuf:"bytes,5,opt,name=NetworkProtocol,proto3" json:"NetworkProtocol,omitempty"`
	ApplicationProtocol string `protobuf:"bytes,6,opt,name=ApplicationProtocol,proto3" json:"ApplicationProtocol,omitempty"`
	HostUUID            int64  `protobuf:"varint,7,opt,name=HostUUID,proto3" json:"HostUUID,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) GetApplicationProtocol added in v0.0.14 

func (x *PortInfo) GetApplicationProtocol() string

func (*PortInfo) GetDescription added in v0.0.14 

func (x *PortInfo) GetDescription() string

func (*PortInfo) GetHostUUID added in v0.0.14 

func (x *PortInfo) GetHostUUID() int64

func (*PortInfo) GetName added in v0.0.13 

func (x *PortInfo) GetName() string

func (*PortInfo) GetNetworkProtocol added in v0.0.14 

func (x *PortInfo) GetNetworkProtocol() string

func (*PortInfo) GetPort added in v0.0.13 

func (x *PortInfo) GetPort() int32

func (*PortInfo) GetUUID added in v0.0.14 

func (x *PortInfo) GetUUID() string

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 PortInfoList added in v0.0.14 

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

手动添加的局域网主机

func (*PortInfoList) Descriptor deprecated added in v0.0.14 

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

Deprecated: Use PortInfoList.ProtoReflect.Descriptor instead.

func (*PortInfoList) GetPortInfoList added in v0.0.14 

func (x *PortInfoList) GetPortInfoList() []*PortInfo

func (*PortInfoList) ProtoMessage added in v0.0.14 

func (*PortInfoList) ProtoMessage()

func (*PortInfoList) ProtoReflect added in v0.0.14 

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

func (*PortInfoList) Reset added in v0.0.14 

func (x *PortInfoList) Reset()

func (*PortInfoList) String added in v0.0.14 

func (x *PortInfoList) String() string

type PortManagerClient added in v0.0.14 

type PortManagerClient interface {
	//    Port
	GetAllPorts(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*PortInfoList, error)
	AddOrUpdatePort(ctx context.Context, in *PortInfo, opts ...grpc.CallOption) (*OperationResponse, error)
	DelPort(ctx context.Context, in *PortInfo, opts ...grpc.CallOption) (*OperationResponse, error)
}

PortManagerClient is the client API for PortManager 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 NewPortManagerClient added in v0.0.14 

func NewPortManagerClient(cc grpc.ClientConnInterface) PortManagerClient

type PortManagerServer added in v0.0.14 

type PortManagerServer interface {
	//    Port
	GetAllPorts(context.Context, *Empty) (*PortInfoList, error)
	AddOrUpdatePort(context.Context, *PortInfo) (*OperationResponse, error)
	DelPort(context.Context, *PortInfo) (*OperationResponse, error)
	// contains filtered or unexported methods
}

PortManagerServer is the server API for PortManager service. All implementations must embed UnimplementedPortManagerServer for forward compatibility

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 UnimplementedAdminManagerServer added in v0.0.14 

type UnimplementedAdminManagerServer struct {
}

UnimplementedAdminManagerServer must be embedded to have forward compatible implementations.

func (UnimplementedAdminManagerServer) BanUser added in v0.0.14 

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

func (UnimplementedAdminManagerServer) GetAllUser added in v0.0.14 

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

type UnimplementedCnameManagerServer added in v0.0.14 

type UnimplementedCnameManagerServer struct {
}

UnimplementedCnameManagerServer must be embedded to have forward compatible implementations.

func (UnimplementedCnameManagerServer) DelCnameByKey added in v0.0.14 

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

func (UnimplementedCnameManagerServer) GetCnameByKey added in v0.0.14 

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

func (UnimplementedCnameManagerServer) SetCnameByKey added in v0.0.14 

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

type UnimplementedConfigManagerServer added in v0.0.14 

type UnimplementedConfigManagerServer struct {
}

UnimplementedConfigManagerServer must be embedded to have forward compatible implementations.

func (UnimplementedConfigManagerServer) DelAllUserConfig added in v0.0.14 

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

func (UnimplementedConfigManagerServer) DelUserConfigByKey added in v0.0.14 

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

func (UnimplementedConfigManagerServer) GetAllUserConfig added in v0.0.14 

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

func (UnimplementedConfigManagerServer) GetUserConfigByKey added in v0.0.14 

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

func (UnimplementedConfigManagerServer) SetAllUserConfig added in v0.0.14 

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

func (UnimplementedConfigManagerServer) SetUserConfigByKey added in v0.0.14 

func (UnimplementedConfigManagerServer) SetUserConfigByKey(context.Context, *StringValue) (*OperationResponse, error)

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 UnimplementedHostManagerServer added in v0.0.14 

type UnimplementedHostManagerServer struct {
}

UnimplementedHostManagerServer must be embedded to have forward compatible implementations.

func (UnimplementedHostManagerServer) AddOrUpdateHost added in v0.0.14 

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

func (UnimplementedHostManagerServer) DelHost added in v0.0.14 

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

func (UnimplementedHostManagerServer) GetAllHosts added in v0.0.14 

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

type UnimplementedHttpManagerServer added in v0.0.14 

type UnimplementedHttpManagerServer struct {
}

UnimplementedHttpManagerServer must be embedded to have forward compatible implementations.

func (UnimplementedHttpManagerServer) AddOrUpdateHttp added in v0.0.14 

func (UnimplementedHttpManagerServer) AddOrUpdateHttp(context.Context, *HttpInfo) (*OperationResponse, error)

func (UnimplementedHttpManagerServer) DelHttp added in v0.0.14 

func (UnimplementedHttpManagerServer) DelHttp(context.Context, *HttpInfo) (*OperationResponse, error)

func (UnimplementedHttpManagerServer) GetAllHttps added in v0.0.14 

func (UnimplementedHttpManagerServer) GetAllHttps(context.Context, *Empty) (*HttpInfoList, 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 UnimplementedPortManagerServer added in v0.0.14 

type UnimplementedPortManagerServer struct {
}

UnimplementedPortManagerServer must be embedded to have forward compatible implementations.

func (UnimplementedPortManagerServer) AddOrUpdatePort added in v0.0.14 

func (UnimplementedPortManagerServer) AddOrUpdatePort(context.Context, *PortInfo) (*OperationResponse, error)

func (UnimplementedPortManagerServer) DelPort added in v0.0.14 

func (UnimplementedPortManagerServer) DelPort(context.Context, *PortInfo) (*OperationResponse, error)

func (UnimplementedPortManagerServer) GetAllPorts added in v0.0.14 

func (UnimplementedPortManagerServer) GetAllPorts(context.Context, *Empty) (*PortInfoList, 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) GetUserInfo added in v0.0.13 

func (UnimplementedUserManagerServer) GetUserInfo(context.Context, *Empty) (*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) 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, *StringValue) (*OperationResponse, error)

func (UnimplementedUserManagerServer) UpdateUserMobile added in v0.0.2 

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

func (UnimplementedUserManagerServer) UpdateUserNanme added in v0.0.2 

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

func (UnimplementedUserManagerServer) UpdateUserPassword added in v0.0.2 

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

type UnsafeAdminManagerServer added in v0.0.14 

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

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

type UnsafeCnameManagerServer added in v0.0.14 

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

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

type UnsafeConfigManagerServer added in v0.0.14 

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

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

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 UnsafeHostManagerServer added in v0.0.14 

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

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

type UnsafeHttpManagerServer added in v0.0.14 

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

UnsafeHttpManagerServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to HttpManagerServer 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 UnsafePortManagerServer added in v0.0.14 

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

UnsafePortManagerServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to PortManagerServer 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 {
	NewBytes []byte `protobuf:"bytes,1,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) 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 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 string `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() string

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 *Empty, opts ...grpc.CallOption) (*UserInfo, error)
	//    更新用户信息
	UpdateUserNanme(ctx context.Context, in *StringValue, opts ...grpc.CallOption) (*OperationResponse, error)
	UpdateUserEmail(ctx context.Context, in *StringValue, opts ...grpc.CallOption) (*OperationResponse, error)
	UpdateUserMobile(ctx context.Context, in *StringValue, opts ...grpc.CallOption) (*OperationResponse, error)
	UpdateUserPassword(ctx context.Context, in *StringValue, 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, *LoginInfo) (*OperationResponse, error)
	//    登录 获取Token
	LoginWithUserLoginInfo(context.Context, *LoginInfo) (*UserLoginResponse, error)
	GetUserInfo(context.Context, *Empty) (*UserInfo, error)
	//    更新用户信息
	UpdateUserNanme(context.Context, *StringValue) (*OperationResponse, error)
	UpdateUserEmail(context.Context, *StringValue) (*OperationResponse, error)
	UpdateUserMobile(context.Context, *StringValue) (*OperationResponse, error)
	UpdateUserPassword(context.Context, *StringValue) (*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

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.