pb

package
v1.0.1 Latest Latest
Warning

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

 Go to latest Published: Nov 11, 2023 License: MIT Imports: 8 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var AdminManager_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "pb.AdminManager",
	HandlerType: (*AdminManagerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetAllUser",
			Handler:    _AdminManager_GetAllUser_Handler,
		},
		{
			MethodName: "BanUser",
			Handler:    _AdminManager_BanUser_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "adminManager.proto",
}

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

View Source 
var CnameManager_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "pb.CnameManager",
	HandlerType: (*CnameManagerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetCnameByKey",
			Handler:    _CnameManager_GetCnameByKey_Handler,
		},
		{
			MethodName: "GetAllCname",
			Handler:    _CnameManager_GetAllCname_Handler,
		},
		{
			MethodName: "SetCnameByKey",
			Handler:    _CnameManager_SetCnameByKey_Handler,
		},
		{
			MethodName: "DelAllCname",
			Handler:    _CnameManager_DelAllCname_Handler,
		},
		{
			MethodName: "DelCnameByKey",
			Handler:    _CnameManager_DelCnameByKey_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "cnameManager.proto",
}

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

View Source 
var ConfigManager_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "pb.ConfigManager",
	HandlerType: (*ConfigManagerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetUserConfigByKey",
			Handler:    _ConfigManager_GetUserConfigByKey_Handler,
		},
		{
			MethodName: "GetAllUserConfig",
			Handler:    _ConfigManager_GetAllUserConfig_Handler,
		},
		{
			MethodName: "SetUserConfigByKey",
			Handler:    _ConfigManager_SetUserConfigByKey_Handler,
		},
		{
			MethodName: "DelAllUserConfig",
			Handler:    _ConfigManager_DelAllUserConfig_Handler,
		},
		{
			MethodName: "DelUserConfigByKey",
			Handler:    _ConfigManager_DelUserConfigByKey_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "configManager.proto",
}

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

View Source 
var File_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_mqttDeviceManager_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
View Source 
var GatewayManager_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "pb.GatewayManager",
	HandlerType: (*GatewayManagerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "AddGateway",
			Handler:    _GatewayManager_AddGateway_Handler,
		},
		{
			MethodName: "DelGateway",
			Handler:    _GatewayManager_DelGateway_Handler,
		},
		{
			MethodName: "UpdateGateway",
			Handler:    _GatewayManager_UpdateGateway_Handler,
		},
		{
			MethodName: "QueryGateway",
			Handler:    _GatewayManager_QueryGateway_Handler,
		},
		{
			MethodName: "GetAllGateway",
			Handler:    _GatewayManager_GetAllGateway_Handler,
		},
		{
			MethodName: "UpdateGatewayNameAndDescription",
			Handler:    _GatewayManager_UpdateGatewayNameAndDescription_Handler,
		},
		{
			MethodName: "GenerateOneGatewayWithDefaultServer",
			Handler:    _GatewayManager_GenerateOneGatewayWithDefaultServer_Handler,
		},
		{
			MethodName: "GenerateOneGatewayWithServerUuid",
			Handler:    _GatewayManager_GenerateOneGatewayWithServerUuid_Handler,
		},
		{
			MethodName: "GetGatewayJwtByGatewayUuid",
			Handler:    _GatewayManager_GetGatewayJwtByGatewayUuid_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "gatewayManager.proto",
}

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

View Source 
var HostManager_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "pb.HostManager",
	HandlerType: (*HostManagerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetAllHosts",
			Handler:    _HostManager_GetAllHosts_Handler,
		},
		{
			MethodName: "AddHost",
			Handler:    _HostManager_AddHost_Handler,
		},
		{
			MethodName: "UpdateHost",
			Handler:    _HostManager_UpdateHost_Handler,
		},
		{
			MethodName: "DelHost",
			Handler:    _HostManager_DelHost_Handler,
		},
		{
			MethodName: "SetDeviceMac",
			Handler:    _HostManager_SetDeviceMac_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "hostManager.proto",
}

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

View Source 
var MqttDeviceManager_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "pb.MqttDeviceManager",
	HandlerType: (*MqttDeviceManagerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "AddMqttDevice",
			Handler:    _MqttDeviceManager_AddMqttDevice_Handler,
		},
		{
			MethodName: "DelMqttDevice",
			Handler:    _MqttDeviceManager_DelMqttDevice_Handler,
		},
		{
			MethodName: "GetAllMqttDevice",
			Handler:    _MqttDeviceManager_GetAllMqttDevice_Handler,
		},
		{
			MethodName: "GenerateMqttUsernamePassword",
			Handler:    _MqttDeviceManager_GenerateMqttUsernamePassword_Handler,
		},
		{
			MethodName: "GetAllMqttBrokers",
			Handler:    _MqttDeviceManager_GetAllMqttBrokers_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "mqttDeviceManager.proto",
}

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

View Source 
var PortManager_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "pb.PortManager",
	HandlerType: (*PortManagerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetAllPorts",
			Handler:    _PortManager_GetAllPorts_Handler,
		},
		{
			MethodName: "AddPort",
			Handler:    _PortManager_AddPort_Handler,
		},
		{
			MethodName: "UpdatePort",
			Handler:    _PortManager_UpdatePort_Handler,
		},
		{
			MethodName: "DelPort",
			Handler:    _PortManager_DelPort_Handler,
		},
		{
			MethodName: "GetAllPortInfoListByServerUuid",
			Handler:    _PortManager_GetAllPortInfoListByServerUuid_Handler,
		},
		{
			MethodName: "GetAllHttpInfoListByServerUuid",
			Handler:    _PortManager_GetAllHttpInfoListByServerUuid_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "portManager.proto",
}

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

View Source 
var ServerManager_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "pb.ServerManager",
	HandlerType: (*ServerManagerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "AddServer",
			Handler:    _ServerManager_AddServer_Handler,
		},
		{
			MethodName: "DelServer",
			Handler:    _ServerManager_DelServer_Handler,
		},
		{
			MethodName: "UpdateServer",
			Handler:    _ServerManager_UpdateServer_Handler,
		},
		{
			MethodName: "QueryServer",
			Handler:    _ServerManager_QueryServer_Handler,
		},
		{
			MethodName: "GetAllServer",
			Handler:    _ServerManager_GetAllServer_Handler,
		},
		{
			MethodName: "GetAllMyServers",
			Handler:    _ServerManager_GetAllMyServers_Handler,
		},
		{
			MethodName: "GetAllMySharedServers",
			Handler:    _ServerManager_GetAllMySharedServers_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "serverManager.proto",
}

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

View Source 
var UserManager_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "pb.UserManager",
	HandlerType: (*UserManagerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "RegisterUserWithLoginInfo",
			Handler:    _UserManager_RegisterUserWithLoginInfo_Handler,
		},
		{
			MethodName: "LoginWithUserLoginInfo",
			Handler:    _UserManager_LoginWithUserLoginInfo_Handler,
		},
		{
			MethodName: "LoginWithWechatCode",
			Handler:    _UserManager_LoginWithWechatCode_Handler,
		},
		{
			MethodName: "BindWithWechatCode",
			Handler:    _UserManager_BindWithWechatCode_Handler,
		},
		{
			MethodName: "UnbindWechat",
			Handler:    _UserManager_UnbindWechat_Handler,
		},
		{
			MethodName: "GetUserInfo",
			Handler:    _UserManager_GetUserInfo_Handler,
		},
		{
			MethodName: "GetUserWechatInfoByCode",
			Handler:    _UserManager_GetUserWechatInfoByCode_Handler,
		},
		{
			MethodName: "UpdateUserName",
			Handler:    _UserManager_UpdateUserName_Handler,
		},
		{
			MethodName: "UpdateUserEmail",
			Handler:    _UserManager_UpdateUserEmail_Handler,
		},
		{
			MethodName: "UpdateUserMobile",
			Handler:    _UserManager_UpdateUserMobile_Handler,
		},
		{
			MethodName: "UpdateUserPassword",
			Handler:    _UserManager_UpdateUserPassword_Handler,
		},
		{
			MethodName: "UpdateUserAvatar",
			Handler:    _UserManager_UpdateUserAvatar_Handler,
		},
		{
			MethodName: "GetAllConfig",
			Handler:    _UserManager_GetAllConfig_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "userManager.proto",
}

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

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 RegisterMqttDeviceManagerServer added in v0.0.18 

func RegisterMqttDeviceManagerServer(s grpc.ServiceRegistrar, srv MqttDeviceManagerServer)

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 {
	// 用户别名
	// 普通配置一次性操作多个
	GetCnameByKey(ctx context.Context, in *StringValue, opts ...grpc.CallOption) (*StringValue, error)
	GetAllCname(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*CnameMap, error)
	// 创建或者更新
	SetCnameByKey(ctx context.Context, in *CnameMap, opts ...grpc.CallOption) (*OperationResponse, error)
	// 删除
	DelAllCname(ctx context.Context, in *CnameMap, 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 {
	// 用户别名
	// 普通配置一次性操作多个
	GetCnameByKey(context.Context, *StringValue) (*StringValue, error)
	GetAllCname(context.Context, *Empty) (*CnameMap, error)
	// 创建或者更新
	SetCnameByKey(context.Context, *CnameMap) (*OperationResponse, error)
	// 删除
	DelAllCname(context.Context, *CnameMap) (*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 CnameMap added in v0.0.32 

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

func (*CnameMap) Descriptor deprecated added in v0.0.32 

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

Deprecated: Use CnameMap.ProtoReflect.Descriptor instead.

func (*CnameMap) GetConfig added in v0.0.32 

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

func (*CnameMap) ProtoMessage added in v0.0.32 

func (*CnameMap) ProtoMessage()

func (*CnameMap) ProtoReflect added in v0.0.32 

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

func (*CnameMap) Reset added in v0.0.32 

func (x *CnameMap) Reset()

func (*CnameMap) String added in v0.0.32 

func (x *CnameMap) String() string

type ConfigManagerClient added in v0.0.14 

type ConfigManagerClient interface {
	// 用户配置
	// 普通配置一次性操作多个
	GetUserConfigByKey(ctx context.Context, in *StringValue, opts ...grpc.CallOption) (*StringValue, error)
	GetAllUserConfig(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*UserConfigMap, error)
	// 创建或者更新
	SetUserConfigByKey(ctx context.Context, in *UserConfigMap, opts ...grpc.CallOption) (*OperationResponse, error)
	// 删除
	DelAllUserConfig(ctx context.Context, in *UserConfigMap, 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 {
	// 用户配置
	// 普通配置一次性操作多个
	GetUserConfigByKey(context.Context, *StringValue) (*StringValue, error)
	GetAllUserConfig(context.Context, *Empty) (*UserConfigMap, error)
	// 创建或者更新
	SetUserConfigByKey(context.Context, *UserConfigMap) (*OperationResponse, error)
	// 删除
	DelAllUserConfig(context.Context, *UserConfigMap) (*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 {
	GatewayUuid string `protobuf:"bytes,1,opt,name=GatewayUuid,proto3" json:"GatewayUuid,omitempty"`
	ServerUuid  string `protobuf:"bytes,2,opt,name=ServerUuid,proto3" json:"ServerUuid,omitempty"`
	Name        string `protobuf:"bytes,3,opt,name=Name,proto3" json:"Name,omitempty"`
	Description string `protobuf:"bytes,4,opt,name=Description,proto3" json:"Description,omitempty"`
	// 在线状态
	Status        bool   `protobuf:"varint,5,opt,name=Status,proto3" json:"Status,omitempty"`
	GatewayJwt    string `protobuf:"bytes,6,opt,name=GatewayJwt,proto3" json:"GatewayJwt,omitempty"`
	OpenIoTHubJwt string `protobuf:"bytes,7,opt,name=OpenIoTHubJwt,proto3" json:"OpenIoTHubJwt,omitempty"`
	// contains filtered or unexported fields
}

func (*GatewayInfo) Descriptor deprecated 

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

Deprecated: Use GatewayInfo.ProtoReflect.Descriptor instead.

func (*GatewayInfo) GetDescription added in v0.0.6 

func (x *GatewayInfo) GetDescription() string

func (*GatewayInfo) GetGatewayJwt added in v0.0.30 

func (x *GatewayInfo) GetGatewayJwt() string

func (*GatewayInfo) GetGatewayUuid added in v0.0.30 

func (x *GatewayInfo) GetGatewayUuid() string

func (*GatewayInfo) GetName added in v0.0.2 

func (x *GatewayInfo) GetName() string

func (*GatewayInfo) GetOpenIoTHubJwt added in v0.0.30 

func (x *GatewayInfo) GetOpenIoTHubJwt() 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) 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)
	QueryGateway(ctx context.Context, in *GatewayInfo, opts ...grpc.CallOption) (*GatewayInfo, error)
	GetAllGateway(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*GatewayInfoList, error)
	UpdateGatewayNameAndDescription(ctx context.Context, in *GatewayInfo, opts ...grpc.CallOption) (*OperationResponse, error)
	GenerateOneGatewayWithDefaultServer(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*GatewayInfo, error)
	GenerateOneGatewayWithServerUuid(ctx context.Context, in *StringValue, opts ...grpc.CallOption) (*GatewayInfo, error)
	GetGatewayJwtByGatewayUuid(ctx context.Context, in *StringValue, opts ...grpc.CallOption) (*StringValue, 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)
	QueryGateway(context.Context, *GatewayInfo) (*GatewayInfo, error)
	GetAllGateway(context.Context, *Empty) (*GatewayInfoList, error)
	UpdateGatewayNameAndDescription(context.Context, *GatewayInfo) (*OperationResponse, error)
	GenerateOneGatewayWithDefaultServer(context.Context, *Empty) (*GatewayInfo, error)
	GenerateOneGatewayWithServerUuid(context.Context, *StringValue) (*GatewayInfo, error)
	GetGatewayJwtByGatewayUuid(context.Context, *StringValue) (*StringValue, 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"`
	Mac         string `protobuf:"bytes,6,opt,name=Mac,proto3" json:"Mac,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) GetMac added in v0.0.35 

func (x *HostInfo) GetMac() 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)
	AddHost(ctx context.Context, in *HostInfo, opts ...grpc.CallOption) (*OperationResponse, error)
	UpdateHost(ctx context.Context, in *HostInfo, opts ...grpc.CallOption) (*OperationResponse, error)
	DelHost(ctx context.Context, in *HostInfo, opts ...grpc.CallOption) (*OperationResponse, error)
	// 设置主机的MAC物理地址(用于WoL远程唤醒)
	SetDeviceMac(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)
	AddHost(context.Context, *HostInfo) (*OperationResponse, error)
	UpdateHost(context.Context, *HostInfo) (*OperationResponse, error)
	DelHost(context.Context, *HostInfo) (*OperationResponse, error)
	// 设置主机的MAC物理地址(用于WoL远程唤醒)
	SetDeviceMac(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"`
	Domain              string `protobuf:"bytes,4,opt,name=Domain,proto3" json:"Domain,omitempty"`
	Username            string `protobuf:"bytes,5,opt,name=Username,proto3" json:"Username,omitempty"`
	Password            string `protobuf:"bytes,6,opt,name=Password,proto3" json:"Password,omitempty"`
	RemoteAddr          string `protobuf:"bytes,7,opt,name=RemoteAddr,proto3" json:"RemoteAddr,omitempty"`
	RemotePort          int32  `protobuf:"varint,8,opt,name=RemotePort,proto3" json:"RemotePort,omitempty"`
	NetworkProtocol     string `protobuf:"bytes,9,opt,name=NetworkProtocol,proto3" json:"NetworkProtocol,omitempty"`
	ApplicationProtocol string `protobuf:"bytes,10,opt,name=ApplicationProtocol,proto3" json:"ApplicationProtocol,omitempty"`
	GatewayUuid         string `protobuf:"bytes,11,opt,name=GatewayUuid,proto3" json:"GatewayUuid,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) GetApplicationProtocol added in v0.0.44 

func (x *HttpInfo) GetApplicationProtocol() string

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) GetGatewayUuid added in v0.0.45 

func (x *HttpInfo) GetGatewayUuid() string

func (*HttpInfo) GetName added in v0.0.14 

func (x *HttpInfo) GetName() string

func (*HttpInfo) GetNetworkProtocol added in v0.0.44 

func (x *HttpInfo) GetNetworkProtocol() string

func (*HttpInfo) GetPassword added in v0.0.44 

func (x *HttpInfo) GetPassword() string

func (*HttpInfo) GetRemoteAddr added in v0.0.44 

func (x *HttpInfo) GetRemoteAddr() string

func (*HttpInfo) GetRemotePort added in v0.0.44 

func (x *HttpInfo) GetRemotePort() int32

func (*HttpInfo) GetUUID added in v0.0.14 

func (x *HttpInfo) GetUUID() string

func (*HttpInfo) GetUsername added in v0.0.44 

func (x *HttpInfo) GetUsername() 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 LoginInfo added in v0.0.13 

type LoginInfo struct {
	UserMobile string `protobuf:"bytes,1,opt,name=UserMobile,proto3" json:"UserMobile,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) GetUserMobile added in v0.0.17 

func (x *LoginInfo) GetUserMobile() 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 MqttBroker added in v0.0.24 

type MqttBroker struct {
	Name        string `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"`
	Description string `protobuf:"bytes,2,opt,name=Description,proto3" json:"Description,omitempty"`
	Country     string `protobuf:"bytes,3,opt,name=Country,proto3" json:"Country,omitempty"`
	Zone        string `protobuf:"bytes,4,opt,name=Zone,proto3" json:"Zone,omitempty"`
	Host        string `protobuf:"bytes,5,opt,name=Host,proto3" json:"Host,omitempty"`
	Port        int32  `protobuf:"varint,6,opt,name=Port,proto3" json:"Port,omitempty"`
	SSLorTLS    bool   `protobuf:"varint,7,opt,name=SSLorTLS,proto3" json:"SSLorTLS,omitempty"`
	// contains filtered or unexported fields
}

func (*MqttBroker) Descriptor deprecated added in v0.0.24 

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

Deprecated: Use MqttBroker.ProtoReflect.Descriptor instead.

func (*MqttBroker) GetCountry added in v0.0.24 

func (x *MqttBroker) GetCountry() string

func (*MqttBroker) GetDescription added in v0.0.24 

func (x *MqttBroker) GetDescription() string

func (*MqttBroker) GetHost added in v0.0.24 

func (x *MqttBroker) GetHost() string

func (*MqttBroker) GetName added in v0.0.24 

func (x *MqttBroker) GetName() string

func (*MqttBroker) GetPort added in v0.0.24 

func (x *MqttBroker) GetPort() int32

func (*MqttBroker) GetSSLorTLS added in v0.0.24 

func (x *MqttBroker) GetSSLorTLS() bool

func (*MqttBroker) GetZone added in v0.0.24 

func (x *MqttBroker) GetZone() string

func (*MqttBroker) ProtoMessage added in v0.0.24 

func (*MqttBroker) ProtoMessage()

func (*MqttBroker) ProtoReflect added in v0.0.24 

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

func (*MqttBroker) Reset added in v0.0.24 

func (x *MqttBroker) Reset()

func (*MqttBroker) String added in v0.0.24 

func (x *MqttBroker) String() string

type MqttBrokerList added in v0.0.24 

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

func (*MqttBrokerList) Descriptor deprecated added in v0.0.24 

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

Deprecated: Use MqttBrokerList.ProtoReflect.Descriptor instead.

func (*MqttBrokerList) GetMqttBrokerList added in v0.0.24 

func (x *MqttBrokerList) GetMqttBrokerList() []*MqttBroker

func (*MqttBrokerList) ProtoMessage added in v0.0.24 

func (*MqttBrokerList) ProtoMessage()

func (*MqttBrokerList) ProtoReflect added in v0.0.24 

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

func (*MqttBrokerList) Reset added in v0.0.24 

func (x *MqttBrokerList) Reset()

func (*MqttBrokerList) String added in v0.0.24 

func (x *MqttBrokerList) String() string

type MqttDeviceInfo added in v0.0.18 

type MqttDeviceInfo struct {

	// String ip;
	DeviceId string `protobuf:"bytes,1,opt,name=DeviceId,proto3" json:"DeviceId,omitempty"`
	// int port;
	DeviceModel       string    `protobuf:"bytes,2,opt,name=DeviceModel,proto3" json:"DeviceModel,omitempty"`
	DeviceDefaultName string    `protobuf:"bytes,3,opt,name=DeviceDefaultName,proto3" json:"DeviceDefaultName,omitempty"`
	MqttInfo          *MqttInfo `protobuf:"bytes,4,opt,name=MqttInfo,proto3" json:"MqttInfo,omitempty"`
	// contains filtered or unexported fields
}

func (*MqttDeviceInfo) Descriptor deprecated added in v0.0.18 

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

Deprecated: Use MqttDeviceInfo.ProtoReflect.Descriptor instead.

func (*MqttDeviceInfo) GetDeviceDefaultName added in v0.0.25 

func (x *MqttDeviceInfo) GetDeviceDefaultName() string

func (*MqttDeviceInfo) GetDeviceId added in v0.0.18 

func (x *MqttDeviceInfo) GetDeviceId() string

func (*MqttDeviceInfo) GetDeviceModel added in v0.0.18 

func (x *MqttDeviceInfo) GetDeviceModel() string

func (*MqttDeviceInfo) GetMqttInfo added in v0.0.23 

func (x *MqttDeviceInfo) GetMqttInfo() *MqttInfo

func (*MqttDeviceInfo) ProtoMessage added in v0.0.18 

func (*MqttDeviceInfo) ProtoMessage()

func (*MqttDeviceInfo) ProtoReflect added in v0.0.18 

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

func (*MqttDeviceInfo) Reset added in v0.0.18 

func (x *MqttDeviceInfo) Reset()

func (*MqttDeviceInfo) String added in v0.0.18 

func (x *MqttDeviceInfo) String() string

type MqttDeviceInfoList added in v0.0.18 

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

func (*MqttDeviceInfoList) Descriptor deprecated added in v0.0.18 

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

Deprecated: Use MqttDeviceInfoList.ProtoReflect.Descriptor instead.

func (*MqttDeviceInfoList) GetMqttDeviceInfoList added in v0.0.18 

func (x *MqttDeviceInfoList) GetMqttDeviceInfoList() []*MqttDeviceInfo

func (*MqttDeviceInfoList) ProtoMessage added in v0.0.18 

func (*MqttDeviceInfoList) ProtoMessage()

func (*MqttDeviceInfoList) ProtoReflect added in v0.0.18 

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

func (*MqttDeviceInfoList) Reset added in v0.0.18 

func (x *MqttDeviceInfoList) Reset()

func (*MqttDeviceInfoList) String added in v0.0.18 

func (x *MqttDeviceInfoList) String() string

type MqttDeviceManagerClient added in v0.0.18 

type MqttDeviceManagerClient interface {
	// 对MQTT类型设备的操作
	AddMqttDevice(ctx context.Context, in *MqttDeviceInfo, opts ...grpc.CallOption) (*OperationResponse, error)
	DelMqttDevice(ctx context.Context, in *MqttDeviceInfo, opts ...grpc.CallOption) (*OperationResponse, error)
	GetAllMqttDevice(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*MqttDeviceInfoList, error)
	// 设备生成mqtt登录信息
	GenerateMqttUsernamePassword(ctx context.Context, in *MqttDeviceInfo, opts ...grpc.CallOption) (*MqttInfo, error)
	// 获取所有的mqtt Broker
	GetAllMqttBrokers(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*MqttBrokerList, error)
}

MqttDeviceManagerClient is the client API for MqttDeviceManager 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 NewMqttDeviceManagerClient added in v0.0.18 

func NewMqttDeviceManagerClient(cc grpc.ClientConnInterface) MqttDeviceManagerClient

type MqttDeviceManagerServer added in v0.0.18 

type MqttDeviceManagerServer interface {
	// 对MQTT类型设备的操作
	AddMqttDevice(context.Context, *MqttDeviceInfo) (*OperationResponse, error)
	DelMqttDevice(context.Context, *MqttDeviceInfo) (*OperationResponse, error)
	GetAllMqttDevice(context.Context, *Empty) (*MqttDeviceInfoList, error)
	// 设备生成mqtt登录信息
	GenerateMqttUsernamePassword(context.Context, *MqttDeviceInfo) (*MqttInfo, error)
	// 获取所有的mqtt Broker
	GetAllMqttBrokers(context.Context, *Empty) (*MqttBrokerList, error)
	// contains filtered or unexported methods
}

MqttDeviceManagerServer is the server API for MqttDeviceManager service. All implementations must embed UnimplementedMqttDeviceManagerServer for forward compatibility

type MqttInfo added in v0.0.21 

type MqttInfo struct {

	// String ip;
	MqttServerHost string `protobuf:"bytes,1,opt,name=MqttServerHost,proto3" json:"MqttServerHost,omitempty"`
	// int port;
	MqttServerPort         int32  `protobuf:"varint,2,opt,name=MqttServerPort,proto3" json:"MqttServerPort,omitempty"`
	MqttClientUserName     string `protobuf:"bytes,3,opt,name=MqttClientUserName,proto3" json:"MqttClientUserName,omitempty"`
	MqttClientUserPassword string `protobuf:"bytes,4,opt,name=MqttClientUserPassword,proto3" json:"MqttClientUserPassword,omitempty"`
	MqttClientId           string `protobuf:"bytes,5,opt,name=MqttClientId,proto3" json:"MqttClientId,omitempty"`
	SSLorTLS               bool   `protobuf:"varint,6,opt,name=SSLorTLS,proto3" json:"SSLorTLS,omitempty"`
	// contains filtered or unexported fields
}

func (*MqttInfo) Descriptor deprecated added in v0.0.21 

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

Deprecated: Use MqttInfo.ProtoReflect.Descriptor instead.

func (*MqttInfo) GetMqttClientId added in v0.0.21 

func (x *MqttInfo) GetMqttClientId() string

func (*MqttInfo) GetMqttClientUserName added in v0.0.21 

func (x *MqttInfo) GetMqttClientUserName() string

func (*MqttInfo) GetMqttClientUserPassword added in v0.0.21 

func (x *MqttInfo) GetMqttClientUserPassword() string

func (*MqttInfo) GetMqttServerHost added in v0.0.21 

func (x *MqttInfo) GetMqttServerHost() string

func (*MqttInfo) GetMqttServerPort added in v0.0.21 

func (x *MqttInfo) GetMqttServerPort() int32

func (*MqttInfo) GetSSLorTLS added in v0.0.21 

func (x *MqttInfo) GetSSLorTLS() bool

func (*MqttInfo) ProtoMessage added in v0.0.21 

func (*MqttInfo) ProtoMessage()

func (*MqttInfo) ProtoReflect added in v0.0.21 

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

func (*MqttInfo) Reset added in v0.0.21 

func (x *MqttInfo) Reset()

func (*MqttInfo) String added in v0.0.21 

func (x *MqttInfo) String() string

type OperationResponse 

type OperationResponse 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"`
	// 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) GetMsg added in v0.0.16 

func (x *OperationResponse) GetMsg() 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"`
	Domain              string `protobuf:"bytes,4,opt,name=Domain,proto3" json:"Domain,omitempty"`
	Username            string `protobuf:"bytes,5,opt,name=Username,proto3" json:"Username,omitempty"`
	Password            string `protobuf:"bytes,6,opt,name=Password,proto3" json:"Password,omitempty"`
	Port                int32  `protobuf:"varint,7,opt,name=Port,proto3" json:"Port,omitempty"`
	LocalPort           int32  `protobuf:"varint,8,opt,name=LocalPort,proto3" json:"LocalPort,omitempty"`
	BindAllAddr         bool   `protobuf:"varint,9,opt,name=BindAllAddr,proto3" json:"BindAllAddr,omitempty"`
	NetworkProtocol     string `protobuf:"bytes,10,opt,name=NetworkProtocol,proto3" json:"NetworkProtocol,omitempty"`
	ApplicationProtocol string `protobuf:"bytes,11,opt,name=ApplicationProtocol,proto3" json:"ApplicationProtocol,omitempty"`
	HostUUID            string `protobuf:"bytes,12,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) GetBindAllAddr added in v0.0.32 

func (x *PortInfo) GetBindAllAddr() bool

func (*PortInfo) GetDescription added in v0.0.14 

func (x *PortInfo) GetDescription() string

func (*PortInfo) GetDomain added in v0.0.32 

func (x *PortInfo) GetDomain() string

func (*PortInfo) GetHostUUID added in v0.0.14 

func (x *PortInfo) GetHostUUID() string

func (*PortInfo) GetLocalPort added in v0.0.32 

func (x *PortInfo) GetLocalPort() int32

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) GetPassword added in v0.0.44 

func (x *PortInfo) GetPassword() 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) GetUsername added in v0.0.44 

func (x *PortInfo) GetUsername() 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)
	AddPort(ctx context.Context, in *PortInfo, opts ...grpc.CallOption) (*OperationResponse, error)
	UpdatePort(ctx context.Context, in *PortInfo, opts ...grpc.CallOption) (*OperationResponse, error)
	DelPort(ctx context.Context, in *PortInfo, opts ...grpc.CallOption) (*OperationResponse, error)
	// server-go服务器查询本服务器所有端口配置的接口
	GetAllPortInfoListByServerUuid(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*PortInfoList, error)
	GetAllHttpInfoListByServerUuid(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*HttpInfoList, 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)
	AddPort(context.Context, *PortInfo) (*OperationResponse, error)
	UpdatePort(context.Context, *PortInfo) (*OperationResponse, error)
	DelPort(context.Context, *PortInfo) (*OperationResponse, error)
	// server-go服务器查询本服务器所有端口配置的接口
	GetAllPortInfoListByServerUuid(context.Context, *Empty) (*PortInfoList, error)
	GetAllHttpInfoListByServerUuid(context.Context, *Empty) (*HttpInfoList, 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"`
	IsSharedServer bool   `protobuf:"varint,13,opt,name=IsSharedServer,proto3" json:"IsSharedServer,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) GetIsSharedServer added in v0.0.38 

func (x *ServerInfo) GetIsSharedServer() 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)
	// 获取自己作为管理员的所有服务器
	GetAllMyServers(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ServerInfoList, error)
	// 获取别人分享给自己的所有服务器
	GetAllMySharedServers(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)
	// 获取自己作为管理员的所有服务器
	GetAllMyServers(context.Context, *Empty) (*ServerInfoList, error)
	// 获取别人分享给自己的所有服务器
	GetAllMySharedServers(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) DelAllCname added in v0.0.32 

func (UnimplementedCnameManagerServer) DelAllCname(context.Context, *CnameMap) (*OperationResponse, error)

func (UnimplementedCnameManagerServer) DelCnameByKey added in v0.0.14 

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

func (UnimplementedCnameManagerServer) GetAllCname added in v0.0.32 

func (UnimplementedCnameManagerServer) GetAllCname(context.Context, *Empty) (*CnameMap, 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, *CnameMap) (*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) SetUserConfigByKey added in v0.0.14 

func (UnimplementedConfigManagerServer) SetUserConfigByKey(context.Context, *UserConfigMap) (*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) GenerateOneGatewayWithDefaultServer added in v0.0.30 

func (UnimplementedGatewayManagerServer) GenerateOneGatewayWithDefaultServer(context.Context, *Empty) (*GatewayInfo, error)

func (UnimplementedGatewayManagerServer) GenerateOneGatewayWithServerUuid added in v0.0.46 

func (UnimplementedGatewayManagerServer) GenerateOneGatewayWithServerUuid(context.Context, *StringValue) (*GatewayInfo, error)

func (UnimplementedGatewayManagerServer) GetAllGateway added in v0.0.2 

func (UnimplementedGatewayManagerServer) GetAllGateway(context.Context, *Empty) (*GatewayInfoList, error)

func (UnimplementedGatewayManagerServer) GetGatewayJwtByGatewayUuid added in v0.0.41 

func (UnimplementedGatewayManagerServer) GetGatewayJwtByGatewayUuid(context.Context, *StringValue) (*StringValue, error)

func (UnimplementedGatewayManagerServer) QueryGateway added in v0.0.30 

func (UnimplementedGatewayManagerServer) QueryGateway(context.Context, *GatewayInfo) (*GatewayInfo, error)

func (UnimplementedGatewayManagerServer) UpdateGateway added in v0.0.2 

func (UnimplementedGatewayManagerServer) UpdateGateway(context.Context, *GatewayInfo) (*OperationResponse, error)

func (UnimplementedGatewayManagerServer) UpdateGatewayNameAndDescription added in v0.0.48 

func (UnimplementedGatewayManagerServer) UpdateGatewayNameAndDescription(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) AddHost added in v0.0.34 

func (UnimplementedHostManagerServer) AddHost(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)

func (UnimplementedHostManagerServer) SetDeviceMac added in v0.0.40 

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

func (UnimplementedHostManagerServer) UpdateHost added in v0.0.34 

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

type UnimplementedMqttDeviceManagerServer added in v0.0.18 

type UnimplementedMqttDeviceManagerServer struct {
}

UnimplementedMqttDeviceManagerServer must be embedded to have forward compatible implementations.

func (UnimplementedMqttDeviceManagerServer) AddMqttDevice added in v0.0.18 

func (UnimplementedMqttDeviceManagerServer) AddMqttDevice(context.Context, *MqttDeviceInfo) (*OperationResponse, error)

func (UnimplementedMqttDeviceManagerServer) DelMqttDevice added in v0.0.18 

func (UnimplementedMqttDeviceManagerServer) DelMqttDevice(context.Context, *MqttDeviceInfo) (*OperationResponse, error)

func (UnimplementedMqttDeviceManagerServer) GenerateMqttUsernamePassword added in v0.0.21 

func (UnimplementedMqttDeviceManagerServer) GenerateMqttUsernamePassword(context.Context, *MqttDeviceInfo) (*MqttInfo, error)

func (UnimplementedMqttDeviceManagerServer) GetAllMqttBrokers added in v0.0.24 

func (UnimplementedMqttDeviceManagerServer) GetAllMqttBrokers(context.Context, *Empty) (*MqttBrokerList, error)

func (UnimplementedMqttDeviceManagerServer) GetAllMqttDevice added in v0.0.18 

func (UnimplementedMqttDeviceManagerServer) GetAllMqttDevice(context.Context, *Empty) (*MqttDeviceInfoList, error)

type UnimplementedPortManagerServer added in v0.0.14 

type UnimplementedPortManagerServer struct {
}

UnimplementedPortManagerServer must be embedded to have forward compatible implementations.

func (UnimplementedPortManagerServer) AddPort added in v0.0.36 

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

func (UnimplementedPortManagerServer) DelPort added in v0.0.14 

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

func (UnimplementedPortManagerServer) GetAllHttpInfoListByServerUuid added in v0.0.44 

func (UnimplementedPortManagerServer) GetAllHttpInfoListByServerUuid(context.Context, *Empty) (*HttpInfoList, error)

func (UnimplementedPortManagerServer) GetAllPortInfoListByServerUuid added in v0.0.44 

func (UnimplementedPortManagerServer) GetAllPortInfoListByServerUuid(context.Context, *Empty) (*PortInfoList, error)

func (UnimplementedPortManagerServer) GetAllPorts added in v0.0.14 

func (UnimplementedPortManagerServer) GetAllPorts(context.Context, *Empty) (*PortInfoList, error)

func (UnimplementedPortManagerServer) UpdatePort added in v0.0.36 

func (UnimplementedPortManagerServer) UpdatePort(context.Context, *PortInfo) (*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) GetAllMyServers added in v0.0.47 

func (UnimplementedServerManagerServer) GetAllMyServers(context.Context, *Empty) (*ServerInfoList, error)

func (UnimplementedServerManagerServer) GetAllMySharedServers added in v0.0.47 

func (UnimplementedServerManagerServer) GetAllMySharedServers(context.Context, *Empty) (*ServerInfoList, 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) BindWithWechatCode added in v0.0.26 

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

func (UnimplementedUserManagerServer) GetAllConfig added in v0.0.31 

func (UnimplementedUserManagerServer) GetAllConfig(context.Context, *Empty) (*StringValue, error)

func (UnimplementedUserManagerServer) GetUserInfo added in v0.0.13 

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

func (UnimplementedUserManagerServer) GetUserWechatInfoByCode added in v0.0.26 

func (UnimplementedUserManagerServer) GetUserWechatInfoByCode(context.Context, *StringValue) (*WechatUserInfo, error)

func (UnimplementedUserManagerServer) LoginWithUserLoginInfo 

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

func (UnimplementedUserManagerServer) LoginWithWechatCode added in v0.0.26 

func (UnimplementedUserManagerServer) LoginWithWechatCode(context.Context, *StringValue) (*UserLoginResponse, error)

func (UnimplementedUserManagerServer) RegisterUserWithLoginInfo added in v0.0.17 

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

func (UnimplementedUserManagerServer) UnbindWechat added in v0.0.28 

func (UnimplementedUserManagerServer) UnbindWechat(context.Context, *Empty) (*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) UpdateUserName added in v0.0.29 

func (UnimplementedUserManagerServer) UpdateUserName(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 UnsafeMqttDeviceManagerServer added in v0.0.18 

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

UnsafeMqttDeviceManagerServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to MqttDeviceManagerServer 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 {
	Uuid   string `protobuf:"bytes,1,opt,name=Uuid,proto3" json:"Uuid,omitempty"`
	Name   string `protobuf:"bytes,2,opt,name=Name,proto3" json:"Name,omitempty"`
	Email  string `protobuf:"bytes,3,opt,name=Email,proto3" json:"Email,omitempty"`
	Mobile string `protobuf:"bytes,4,opt,name=Mobile,proto3" json:"Mobile,omitempty"`
	Avatar string `protobuf:"bytes,5,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) GetName added in v0.0.16 

func (x *UserInfo) GetName() string

func (*UserInfo) GetUuid added in v0.0.39 

func (x *UserInfo) GetUuid() 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 {
	// 注册用户
	RegisterUserWithLoginInfo(ctx context.Context, in *LoginInfo, opts ...grpc.CallOption) (*OperationResponse, error)
	// 登录 获取Token
	LoginWithUserLoginInfo(ctx context.Context, in *LoginInfo, opts ...grpc.CallOption) (*UserLoginResponse, error)
	// 使用微信登录账号获取jwt
	LoginWithWechatCode(ctx context.Context, in *StringValue, opts ...grpc.CallOption) (*UserLoginResponse, error)
	// 账号绑定微信
	BindWithWechatCode(ctx context.Context, in *StringValue, opts ...grpc.CallOption) (*OperationResponse, error)
	// 账号解绑微信
	UnbindWechat(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*OperationResponse, error)
	// 获取用户信息
	GetUserInfo(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*UserInfo, error)
	// 获取用户的微信信息
	GetUserWechatInfoByCode(ctx context.Context, in *StringValue, opts ...grpc.CallOption) (*WechatUserInfo, error)
	// 更新用户信息
	UpdateUserName(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)
	// 业务相关操作
	// 获取所有配置(网关、设备、配置等)用于APP的初始化
	GetAllConfig(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*StringValue, 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 {
	// 注册用户
	RegisterUserWithLoginInfo(context.Context, *LoginInfo) (*OperationResponse, error)
	// 登录 获取Token
	LoginWithUserLoginInfo(context.Context, *LoginInfo) (*UserLoginResponse, error)
	// 使用微信登录账号获取jwt
	LoginWithWechatCode(context.Context, *StringValue) (*UserLoginResponse, error)
	// 账号绑定微信
	BindWithWechatCode(context.Context, *StringValue) (*OperationResponse, error)
	// 账号解绑微信
	UnbindWechat(context.Context, *Empty) (*OperationResponse, error)
	// 获取用户信息
	GetUserInfo(context.Context, *Empty) (*UserInfo, error)
	// 获取用户的微信信息
	GetUserWechatInfoByCode(context.Context, *StringValue) (*WechatUserInfo, error)
	// 更新用户信息
	UpdateUserName(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)
	// 业务相关操作
	// 获取所有配置(网关、设备、配置等)用于APP的初始化
	GetAllConfig(context.Context, *Empty) (*StringValue, error)
	// contains filtered or unexported methods
}

UserManagerServer is the server API for UserManager service. All implementations must embed UnimplementedUserManagerServer for forward compatibility

type WechatUserInfo added in v0.0.26 

type WechatUserInfo struct {
	AccessToken  string `protobuf:"bytes,1,opt,name=access_token,json=accessToken,proto3" json:"access_token,omitempty"`
	ExpiresIn    int32  `protobuf:"varint,2,opt,name=expires_in,json=expiresIn,proto3" json:"expires_in,omitempty"`
	RefreshToken string `protobuf:"bytes,3,opt,name=refresh_token,json=refreshToken,proto3" json:"refresh_token,omitempty"`
	Openid       string `protobuf:"bytes,4,opt,name=openid,proto3" json:"openid,omitempty"`
	Scope        string `protobuf:"bytes,5,opt,name=scope,proto3" json:"scope,omitempty"`
	Unionid      string `protobuf:"bytes,6,opt,name=unionid,proto3" json:"unionid,omitempty"`
	// contains filtered or unexported fields
}

func (*WechatUserInfo) Descriptor deprecated added in v0.0.26 

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

Deprecated: Use WechatUserInfo.ProtoReflect.Descriptor instead.

func (*WechatUserInfo) GetAccessToken added in v0.0.26 

func (x *WechatUserInfo) GetAccessToken() string

func (*WechatUserInfo) GetExpiresIn added in v0.0.26 

func (x *WechatUserInfo) GetExpiresIn() int32

func (*WechatUserInfo) GetOpenid added in v0.0.26 

func (x *WechatUserInfo) GetOpenid() string

func (*WechatUserInfo) GetRefreshToken added in v0.0.26 

func (x *WechatUserInfo) GetRefreshToken() string

func (*WechatUserInfo) GetScope added in v0.0.26 

func (x *WechatUserInfo) GetScope() string

func (*WechatUserInfo) GetUnionid added in v0.0.26 

func (x *WechatUserInfo) GetUnionid() string

func (*WechatUserInfo) ProtoMessage added in v0.0.26 

func (*WechatUserInfo) ProtoMessage()

func (*WechatUserInfo) ProtoReflect added in v0.0.26 

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

func (*WechatUserInfo) Reset added in v0.0.26 

func (x *WechatUserInfo) Reset()

func (*WechatUserInfo) String added in v0.0.26 

func (x *WechatUserInfo) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

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