pb

package
v1.1.8 Latest Latest
Warning

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

 Go to latest Published: Jul 20, 2024 License: MIT Imports: 10 Imported by: 2

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_publicApi_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,
		},
		{
			MethodName: "GetOpenIoTHubJwtByGatewayUuid",
			Handler:    _GatewayManager_GetOpenIoTHubJwtByGatewayUuid_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 PublicApi_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "pb.PublicApi",
	HandlerType: (*PublicApiServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GenerateJwtQRCodePair",
			Handler:    _PublicApi_GenerateJwtQRCodePair_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "publicApi.proto",
}

PublicApi_ServiceDesc is the grpc.ServiceDesc for PublicApi 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,
		},
		{
			MethodName: "DeleteMyAccount",
			Handler:    _UserManager_DeleteMyAccount_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 

func RegisterAdminManagerServer(s grpc.ServiceRegistrar, srv AdminManagerServer)

func RegisterCnameManagerServer 

func RegisterCnameManagerServer(s grpc.ServiceRegistrar, srv CnameManagerServer)

func RegisterConfigManagerServer 

func RegisterConfigManagerServer(s grpc.ServiceRegistrar, srv ConfigManagerServer)

func RegisterGatewayManagerServer 

func RegisterGatewayManagerServer(s grpc.ServiceRegistrar, srv GatewayManagerServer)

func RegisterHostManagerServer 

func RegisterHostManagerServer(s grpc.ServiceRegistrar, srv HostManagerServer)

func RegisterMqttDeviceManagerServer 

func RegisterMqttDeviceManagerServer(s grpc.ServiceRegistrar, srv MqttDeviceManagerServer)

func RegisterPortManagerServer 

func RegisterPortManagerServer(s grpc.ServiceRegistrar, srv PortManagerServer)

func RegisterPublicApiServer added in v1.1.2 

func RegisterPublicApiServer(s grpc.ServiceRegistrar, srv PublicApiServer)

func RegisterServerManagerServer 

func RegisterServerManagerServer(s grpc.ServiceRegistrar, srv ServerManagerServer)

func RegisterUserManagerServer 

func RegisterUserManagerServer(s grpc.ServiceRegistrar, srv UserManagerServer)

Types

type AdminManagerClient 

type AdminManagerClient interface {
	//	管理员权限，管理用户
	//
	// 获取所有用户
	GetAllUser(ctx context.Context, in *emptypb.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 

func NewAdminManagerClient(cc grpc.ClientConnInterface) AdminManagerClient

type AdminManagerServer 

type AdminManagerServer interface {
	//	管理员权限，管理用户
	//
	// 获取所有用户
	GetAllUser(context.Context, *emptypb.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 CnameManagerClient 

type CnameManagerClient interface {
	// 用户别名
	// 普通配置一次性操作多个
	GetCnameByKey(ctx context.Context, in *wrapperspb.StringValue, opts ...grpc.CallOption) (*wrapperspb.StringValue, error)
	GetAllCname(ctx context.Context, in *emptypb.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 *wrapperspb.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 

func NewCnameManagerClient(cc grpc.ClientConnInterface) CnameManagerClient

type CnameManagerServer 

type CnameManagerServer interface {
	// 用户别名
	// 普通配置一次性操作多个
	GetCnameByKey(context.Context, *wrapperspb.StringValue) (*wrapperspb.StringValue, error)
	GetAllCname(context.Context, *emptypb.Empty) (*CnameMap, error)
	// 创建或者更新
	SetCnameByKey(context.Context, *CnameMap) (*OperationResponse, error)
	// 删除
	DelAllCname(context.Context, *CnameMap) (*OperationResponse, error)
	DelCnameByKey(context.Context, *wrapperspb.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 

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

func (*CnameMap) Descriptor deprecated 

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

Deprecated: Use CnameMap.ProtoReflect.Descriptor instead.

func (*CnameMap) GetConfig 

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

func (*CnameMap) ProtoMessage 

func (*CnameMap) ProtoMessage()

func (*CnameMap) ProtoReflect 

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

func (*CnameMap) Reset 

func (x *CnameMap) Reset()

func (*CnameMap) String 

func (x *CnameMap) String() string

type ConfigManagerClient 

type ConfigManagerClient interface {
	// 用户配置
	// 普通配置一次性操作多个
	GetUserConfigByKey(ctx context.Context, in *wrapperspb.StringValue, opts ...grpc.CallOption) (*wrapperspb.StringValue, error)
	GetAllUserConfig(ctx context.Context, in *emptypb.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 *wrapperspb.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 

func NewConfigManagerClient(cc grpc.ClientConnInterface) ConfigManagerClient

type ConfigManagerServer 

type ConfigManagerServer interface {
	// 用户配置
	// 普通配置一次性操作多个
	GetUserConfigByKey(context.Context, *wrapperspb.StringValue) (*wrapperspb.StringValue, error)
	GetAllUserConfig(context.Context, *emptypb.Empty) (*UserConfigMap, error)
	// 创建或者更新
	SetUserConfigByKey(context.Context, *UserConfigMap) (*OperationResponse, error)
	// 删除
	DelAllUserConfig(context.Context, *UserConfigMap) (*OperationResponse, error)
	DelUserConfigByKey(context.Context, *wrapperspb.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 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 

func (x *GatewayInfo) GetDescription() string

func (*GatewayInfo) GetGatewayJwt 

func (x *GatewayInfo) GetGatewayJwt() string

func (*GatewayInfo) GetGatewayUuid 

func (x *GatewayInfo) GetGatewayUuid() string

func (*GatewayInfo) GetName 

func (x *GatewayInfo) GetName() string

func (*GatewayInfo) GetOpenIoTHubJwt 

func (x *GatewayInfo) GetOpenIoTHubJwt() string

func (*GatewayInfo) GetServerUuid 

func (x *GatewayInfo) GetServerUuid() string

func (*GatewayInfo) GetStatus 

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 

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

func (*GatewayInfoList) Descriptor deprecated 

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

Deprecated: Use GatewayInfoList.ProtoReflect.Descriptor instead.

func (*GatewayInfoList) GetGatewayInfoList 

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

func (*GatewayInfoList) ProtoMessage 

func (*GatewayInfoList) ProtoMessage()

func (*GatewayInfoList) ProtoReflect 

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

func (*GatewayInfoList) Reset 

func (x *GatewayInfoList) Reset()

func (*GatewayInfoList) String 

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 *emptypb.Empty, opts ...grpc.CallOption) (*GatewayInfoList, error)
	UpdateGatewayNameAndDescription(ctx context.Context, in *GatewayInfo, opts ...grpc.CallOption) (*OperationResponse, error)
	GenerateOneGatewayWithDefaultServer(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*GatewayInfo, error)
	GenerateOneGatewayWithServerUuid(ctx context.Context, in *wrapperspb.StringValue, opts ...grpc.CallOption) (*GatewayInfo, error)
	GetGatewayJwtByGatewayUuid(ctx context.Context, in *wrapperspb.StringValue, opts ...grpc.CallOption) (*wrapperspb.StringValue, error)
	GetOpenIoTHubJwtByGatewayUuid(ctx context.Context, in *wrapperspb.StringValue, opts ...grpc.CallOption) (*wrapperspb.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, *emptypb.Empty) (*GatewayInfoList, error)
	UpdateGatewayNameAndDescription(context.Context, *GatewayInfo) (*OperationResponse, error)
	GenerateOneGatewayWithDefaultServer(context.Context, *emptypb.Empty) (*GatewayInfo, error)
	GenerateOneGatewayWithServerUuid(context.Context, *wrapperspb.StringValue) (*GatewayInfo, error)
	GetGatewayJwtByGatewayUuid(context.Context, *wrapperspb.StringValue) (*wrapperspb.StringValue, error)
	GetOpenIoTHubJwtByGatewayUuid(context.Context, *wrapperspb.StringValue) (*wrapperspb.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 

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 

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

Deprecated: Use HostInfo.ProtoReflect.Descriptor instead.

func (*HostInfo) GetDescription 

func (x *HostInfo) GetDescription() string

func (*HostInfo) GetGatewayUUID 

func (x *HostInfo) GetGatewayUUID() string

func (*HostInfo) GetHostAddr 

func (x *HostInfo) GetHostAddr() string

func (*HostInfo) GetMac 

func (x *HostInfo) GetMac() string

func (*HostInfo) GetName 

func (x *HostInfo) GetName() string

func (*HostInfo) GetUUID 

func (x *HostInfo) GetUUID() string

func (*HostInfo) ProtoMessage 

func (*HostInfo) ProtoMessage()

func (*HostInfo) ProtoReflect 

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

func (*HostInfo) Reset 

func (x *HostInfo) Reset()

func (*HostInfo) String 

func (x *HostInfo) String() string

type HostInfoList 

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

手动添加的局域网主机

func (*HostInfoList) Descriptor deprecated 

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

Deprecated: Use HostInfoList.ProtoReflect.Descriptor instead.

func (*HostInfoList) GetHostInfoList 

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

func (*HostInfoList) ProtoMessage 

func (*HostInfoList) ProtoMessage()

func (*HostInfoList) ProtoReflect 

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

func (*HostInfoList) Reset 

func (x *HostInfoList) Reset()

func (*HostInfoList) String 

func (x *HostInfoList) String() string

type HostManagerClient 

type HostManagerClient interface {
	// Host
	GetAllHosts(ctx context.Context, in *emptypb.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 

func NewHostManagerClient(cc grpc.ClientConnInterface) HostManagerClient

type HostManagerServer 

type HostManagerServer interface {
	// Host
	GetAllHosts(context.Context, *emptypb.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 

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 

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

Deprecated: Use HttpInfo.ProtoReflect.Descriptor instead.

func (*HttpInfo) GetApplicationProtocol 

func (x *HttpInfo) GetApplicationProtocol() string

func (*HttpInfo) GetDescription 

func (x *HttpInfo) GetDescription() string

func (*HttpInfo) GetDomain 

func (x *HttpInfo) GetDomain() string

func (*HttpInfo) GetGatewayUuid 

func (x *HttpInfo) GetGatewayUuid() string

func (*HttpInfo) GetName 

func (x *HttpInfo) GetName() string

func (*HttpInfo) GetNetworkProtocol 

func (x *HttpInfo) GetNetworkProtocol() string

func (*HttpInfo) GetPassword 

func (x *HttpInfo) GetPassword() string

func (*HttpInfo) GetRemoteAddr 

func (x *HttpInfo) GetRemoteAddr() string

func (*HttpInfo) GetRemotePort 

func (x *HttpInfo) GetRemotePort() int32

func (*HttpInfo) GetUUID 

func (x *HttpInfo) GetUUID() string

func (*HttpInfo) GetUsername 

func (x *HttpInfo) GetUsername() string

func (*HttpInfo) ProtoMessage 

func (*HttpInfo) ProtoMessage()

func (*HttpInfo) ProtoReflect 

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

func (*HttpInfo) Reset 

func (x *HttpInfo) Reset()

func (*HttpInfo) String 

func (x *HttpInfo) String() string

type HttpInfoList 

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

func (*HttpInfoList) Descriptor deprecated 

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

Deprecated: Use HttpInfoList.ProtoReflect.Descriptor instead.

func (*HttpInfoList) GetHttpInfoList 

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

func (*HttpInfoList) ProtoMessage 

func (*HttpInfoList) ProtoMessage()

func (*HttpInfoList) ProtoReflect 

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

func (*HttpInfoList) Reset 

func (x *HttpInfoList) Reset()

func (*HttpInfoList) String 

func (x *HttpInfoList) String() string

type JwtQRCodePair added in v1.1.2 

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

func (*JwtQRCodePair) Descriptor deprecated added in v1.1.2 

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

Deprecated: Use JwtQRCodePair.ProtoReflect.Descriptor instead.

func (*JwtQRCodePair) GetGatewayJwt added in v1.1.2 

func (x *JwtQRCodePair) GetGatewayJwt() string

func (*JwtQRCodePair) GetQRCodeForMobileAdd added in v1.1.2 

func (x *JwtQRCodePair) GetQRCodeForMobileAdd() string

func (*JwtQRCodePair) ProtoMessage added in v1.1.2 

func (*JwtQRCodePair) ProtoMessage()

func (*JwtQRCodePair) ProtoReflect added in v1.1.2 

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

func (*JwtQRCodePair) Reset added in v1.1.2 

func (x *JwtQRCodePair) Reset()

func (*JwtQRCodePair) String added in v1.1.2 

func (x *JwtQRCodePair) String() string

type LoginInfo 

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 

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

Deprecated: Use LoginInfo.ProtoReflect.Descriptor instead.

func (*LoginInfo) GetPassword 

func (x *LoginInfo) GetPassword() string

func (*LoginInfo) GetUserMobile 

func (x *LoginInfo) GetUserMobile() string

func (*LoginInfo) ProtoMessage 

func (*LoginInfo) ProtoMessage()

func (*LoginInfo) ProtoReflect 

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

func (*LoginInfo) Reset 

func (x *LoginInfo) Reset()

func (*LoginInfo) String 

func (x *LoginInfo) String() string

type MqttBroker 

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 

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

Deprecated: Use MqttBroker.ProtoReflect.Descriptor instead.

func (*MqttBroker) GetCountry 

func (x *MqttBroker) GetCountry() string

func (*MqttBroker) GetDescription 

func (x *MqttBroker) GetDescription() string

func (*MqttBroker) GetHost 

func (x *MqttBroker) GetHost() string

func (*MqttBroker) GetName 

func (x *MqttBroker) GetName() string

func (*MqttBroker) GetPort 

func (x *MqttBroker) GetPort() int32

func (*MqttBroker) GetSSLorTLS 

func (x *MqttBroker) GetSSLorTLS() bool

func (*MqttBroker) GetZone 

func (x *MqttBroker) GetZone() string

func (*MqttBroker) ProtoMessage 

func (*MqttBroker) ProtoMessage()

func (*MqttBroker) ProtoReflect 

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

func (*MqttBroker) Reset 

func (x *MqttBroker) Reset()

func (*MqttBroker) String 

func (x *MqttBroker) String() string

type MqttBrokerList 

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

func (*MqttBrokerList) Descriptor deprecated 

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

Deprecated: Use MqttBrokerList.ProtoReflect.Descriptor instead.

func (*MqttBrokerList) GetMqttBrokerList 

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

func (*MqttBrokerList) ProtoMessage 

func (*MqttBrokerList) ProtoMessage()

func (*MqttBrokerList) ProtoReflect 

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

func (*MqttBrokerList) Reset 

func (x *MqttBrokerList) Reset()

func (*MqttBrokerList) String 

func (x *MqttBrokerList) String() string

type MqttDeviceInfo 

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 

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

Deprecated: Use MqttDeviceInfo.ProtoReflect.Descriptor instead.

func (*MqttDeviceInfo) GetDeviceDefaultName 

func (x *MqttDeviceInfo) GetDeviceDefaultName() string

func (*MqttDeviceInfo) GetDeviceId 

func (x *MqttDeviceInfo) GetDeviceId() string

func (*MqttDeviceInfo) GetDeviceModel 

func (x *MqttDeviceInfo) GetDeviceModel() string

func (*MqttDeviceInfo) GetMqttInfo 

func (x *MqttDeviceInfo) GetMqttInfo() *MqttInfo

func (*MqttDeviceInfo) ProtoMessage 

func (*MqttDeviceInfo) ProtoMessage()

func (*MqttDeviceInfo) ProtoReflect 

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

func (*MqttDeviceInfo) Reset 

func (x *MqttDeviceInfo) Reset()

func (*MqttDeviceInfo) String 

func (x *MqttDeviceInfo) String() string

type MqttDeviceInfoList 

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

func (*MqttDeviceInfoList) Descriptor deprecated 

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

Deprecated: Use MqttDeviceInfoList.ProtoReflect.Descriptor instead.

func (*MqttDeviceInfoList) GetMqttDeviceInfoList 

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

func (*MqttDeviceInfoList) ProtoMessage 

func (*MqttDeviceInfoList) ProtoMessage()

func (*MqttDeviceInfoList) ProtoReflect 

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

func (*MqttDeviceInfoList) Reset 

func (x *MqttDeviceInfoList) Reset()

func (*MqttDeviceInfoList) String 

func (x *MqttDeviceInfoList) String() string

type MqttDeviceManagerClient 

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 *emptypb.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 *emptypb.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 

func NewMqttDeviceManagerClient(cc grpc.ClientConnInterface) MqttDeviceManagerClient

type MqttDeviceManagerServer 

type MqttDeviceManagerServer interface {
	// 对MQTT类型设备的操作
	AddMqttDevice(context.Context, *MqttDeviceInfo) (*OperationResponse, error)
	DelMqttDevice(context.Context, *MqttDeviceInfo) (*OperationResponse, error)
	GetAllMqttDevice(context.Context, *emptypb.Empty) (*MqttDeviceInfoList, error)
	// 设备生成mqtt登录信息
	GenerateMqttUsernamePassword(context.Context, *MqttDeviceInfo) (*MqttInfo, error)
	// 获取所有的mqtt Broker
	GetAllMqttBrokers(context.Context, *emptypb.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 

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 

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

Deprecated: Use MqttInfo.ProtoReflect.Descriptor instead.

func (*MqttInfo) GetMqttClientId 

func (x *MqttInfo) GetMqttClientId() string

func (*MqttInfo) GetMqttClientUserName 

func (x *MqttInfo) GetMqttClientUserName() string

func (*MqttInfo) GetMqttClientUserPassword 

func (x *MqttInfo) GetMqttClientUserPassword() string

func (*MqttInfo) GetMqttServerHost 

func (x *MqttInfo) GetMqttServerHost() string

func (*MqttInfo) GetMqttServerPort 

func (x *MqttInfo) GetMqttServerPort() int32

func (*MqttInfo) GetSSLorTLS 

func (x *MqttInfo) GetSSLorTLS() bool

func (*MqttInfo) ProtoMessage 

func (*MqttInfo) ProtoMessage()

func (*MqttInfo) ProtoReflect 

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

func (*MqttInfo) Reset 

func (x *MqttInfo) Reset()

func (*MqttInfo) String 

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 

func (x *OperationResponse) GetCode() int32

func (*OperationResponse) GetMsg 

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 

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 

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

Deprecated: Use PortInfo.ProtoReflect.Descriptor instead.

func (*PortInfo) GetApplicationProtocol 

func (x *PortInfo) GetApplicationProtocol() string

func (*PortInfo) GetBindAllAddr 

func (x *PortInfo) GetBindAllAddr() bool

func (*PortInfo) GetDescription 

func (x *PortInfo) GetDescription() string

func (*PortInfo) GetDomain 

func (x *PortInfo) GetDomain() string

func (*PortInfo) GetHostUUID 

func (x *PortInfo) GetHostUUID() string

func (*PortInfo) GetLocalPort 

func (x *PortInfo) GetLocalPort() int32

func (*PortInfo) GetName 

func (x *PortInfo) GetName() string

func (*PortInfo) GetNetworkProtocol 

func (x *PortInfo) GetNetworkProtocol() string

func (*PortInfo) GetPassword 

func (x *PortInfo) GetPassword() string

func (*PortInfo) GetPort 

func (x *PortInfo) GetPort() int32

func (*PortInfo) GetUUID 

func (x *PortInfo) GetUUID() string

func (*PortInfo) GetUsername 

func (x *PortInfo) GetUsername() string

func (*PortInfo) ProtoMessage 

func (*PortInfo) ProtoMessage()

func (*PortInfo) ProtoReflect 

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

func (*PortInfo) Reset 

func (x *PortInfo) Reset()

func (*PortInfo) String 

func (x *PortInfo) String() string

type PortInfoList 

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

手动添加的局域网主机

func (*PortInfoList) Descriptor deprecated 

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

Deprecated: Use PortInfoList.ProtoReflect.Descriptor instead.

func (*PortInfoList) GetPortInfoList 

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

func (*PortInfoList) ProtoMessage 

func (*PortInfoList) ProtoMessage()

func (*PortInfoList) ProtoReflect 

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

func (*PortInfoList) Reset 

func (x *PortInfoList) Reset()

func (*PortInfoList) String 

func (x *PortInfoList) String() string

type PortManagerClient 

type PortManagerClient interface {
	// Port
	GetAllPorts(ctx context.Context, in *emptypb.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 *emptypb.Empty, opts ...grpc.CallOption) (*PortInfoList, error)
	GetAllHttpInfoListByServerUuid(ctx context.Context, in *emptypb.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 

func NewPortManagerClient(cc grpc.ClientConnInterface) PortManagerClient

type PortManagerServer 

type PortManagerServer interface {
	// Port
	GetAllPorts(context.Context, *emptypb.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, *emptypb.Empty) (*PortInfoList, error)
	GetAllHttpInfoListByServerUuid(context.Context, *emptypb.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 PublicApiClient added in v1.1.2 

type PublicApiClient interface {
	// 获取网关链接服务器的jwt和手机添加网关的二维码
	GenerateJwtQRCodePair(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*JwtQRCodePair, error)
}

PublicApiClient is the client API for PublicApi 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 NewPublicApiClient added in v1.1.2 

func NewPublicApiClient(cc grpc.ClientConnInterface) PublicApiClient

type PublicApiServer added in v1.1.2 

type PublicApiServer interface {
	// 获取网关链接服务器的jwt和手机添加网关的二维码
	GenerateJwtQRCodePair(context.Context, *emptypb.Empty) (*JwtQRCodePair, error)
	// contains filtered or unexported methods
}

PublicApiServer is the server API for PublicApi service. All implementations must embed UnimplementedPublicApiServer 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 

func (x *ServerInfo) GetDescription() string

func (*ServerInfo) GetGrpcPort 

func (x *ServerInfo) GetGrpcPort() int32

func (*ServerInfo) GetIsPublic 

func (x *ServerInfo) GetIsPublic() bool

func (*ServerInfo) GetIsSharedServer 

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 

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 

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 

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

func (*ServerInfoList) Descriptor deprecated 

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

Deprecated: Use ServerInfoList.ProtoReflect.Descriptor instead.

func (*ServerInfoList) GetServerInfoList 

func (x *ServerInfoList) GetServerInfoList() []*ServerInfo

func (*ServerInfoList) ProtoMessage 

func (*ServerInfoList) ProtoMessage()

func (*ServerInfoList) ProtoReflect 

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

func (*ServerInfoList) Reset 

func (x *ServerInfoList) Reset()

func (*ServerInfoList) String 

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 *wrapperspb.StringValue, opts ...grpc.CallOption) (*ServerInfoList, error)
	// 获取所有我可以使用的服务器(公共服务器、自己添加的服务器、别人分享给我的服务器)
	GetAllServer(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ServerInfoList, error)
	// 获取自己作为管理员的所有服务器
	GetAllMyServers(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ServerInfoList, error)
	// 获取别人分享给自己的所有服务器
	GetAllMySharedServers(ctx context.Context, in *emptypb.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, *wrapperspb.StringValue) (*ServerInfoList, error)
	// 获取所有我可以使用的服务器(公共服务器、自己添加的服务器、别人分享给我的服务器)
	GetAllServer(context.Context, *emptypb.Empty) (*ServerInfoList, error)
	// 获取自己作为管理员的所有服务器
	GetAllMyServers(context.Context, *emptypb.Empty) (*ServerInfoList, error)
	// 获取别人分享给自己的所有服务器
	GetAllMySharedServers(context.Context, *emptypb.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 UnimplementedAdminManagerServer 

type UnimplementedAdminManagerServer struct {
}

UnimplementedAdminManagerServer must be embedded to have forward compatible implementations.

func (UnimplementedAdminManagerServer) BanUser 

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

func (UnimplementedAdminManagerServer) GetAllUser 

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

type UnimplementedCnameManagerServer 

type UnimplementedCnameManagerServer struct {
}

UnimplementedCnameManagerServer must be embedded to have forward compatible implementations.

func (UnimplementedCnameManagerServer) DelAllCname 

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

func (UnimplementedCnameManagerServer) DelCnameByKey 

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

func (UnimplementedCnameManagerServer) GetAllCname 

func (UnimplementedCnameManagerServer) GetAllCname(context.Context, *emptypb.Empty) (*CnameMap, error)

func (UnimplementedCnameManagerServer) GetCnameByKey 

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

func (UnimplementedCnameManagerServer) SetCnameByKey 

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

type UnimplementedConfigManagerServer 

type UnimplementedConfigManagerServer struct {
}

UnimplementedConfigManagerServer must be embedded to have forward compatible implementations.

func (UnimplementedConfigManagerServer) DelAllUserConfig 

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

func (UnimplementedConfigManagerServer) DelUserConfigByKey 

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

func (UnimplementedConfigManagerServer) GetAllUserConfig 

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

func (UnimplementedConfigManagerServer) GetUserConfigByKey 

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

func (UnimplementedConfigManagerServer) SetUserConfigByKey 

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 

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

func (UnimplementedGatewayManagerServer) GenerateOneGatewayWithDefaultServer 

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

func (UnimplementedGatewayManagerServer) GenerateOneGatewayWithServerUuid 

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

func (UnimplementedGatewayManagerServer) GetAllGateway 

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

func (UnimplementedGatewayManagerServer) GetGatewayJwtByGatewayUuid 

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

func (UnimplementedGatewayManagerServer) GetOpenIoTHubJwtByGatewayUuid added in v1.1.5 

func (UnimplementedGatewayManagerServer) GetOpenIoTHubJwtByGatewayUuid(context.Context, *wrapperspb.StringValue) (*wrapperspb.StringValue, error)

func (UnimplementedGatewayManagerServer) QueryGateway 

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

func (UnimplementedGatewayManagerServer) UpdateGateway 

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

func (UnimplementedGatewayManagerServer) UpdateGatewayNameAndDescription 

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

type UnimplementedHostManagerServer 

type UnimplementedHostManagerServer struct {
}

UnimplementedHostManagerServer must be embedded to have forward compatible implementations.

func (UnimplementedHostManagerServer) AddHost 

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

func (UnimplementedHostManagerServer) DelHost 

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

func (UnimplementedHostManagerServer) GetAllHosts 

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

func (UnimplementedHostManagerServer) SetDeviceMac 

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

func (UnimplementedHostManagerServer) UpdateHost 

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

type UnimplementedMqttDeviceManagerServer 

type UnimplementedMqttDeviceManagerServer struct {
}

UnimplementedMqttDeviceManagerServer must be embedded to have forward compatible implementations.

func (UnimplementedMqttDeviceManagerServer) AddMqttDevice 

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

func (UnimplementedMqttDeviceManagerServer) DelMqttDevice 

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

func (UnimplementedMqttDeviceManagerServer) GenerateMqttUsernamePassword 

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

func (UnimplementedMqttDeviceManagerServer) GetAllMqttBrokers 

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

func (UnimplementedMqttDeviceManagerServer) GetAllMqttDevice 

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

type UnimplementedPortManagerServer 

type UnimplementedPortManagerServer struct {
}

UnimplementedPortManagerServer must be embedded to have forward compatible implementations.

func (UnimplementedPortManagerServer) AddPort 

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

func (UnimplementedPortManagerServer) DelPort 

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

func (UnimplementedPortManagerServer) GetAllHttpInfoListByServerUuid 

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

func (UnimplementedPortManagerServer) GetAllPortInfoListByServerUuid 

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

func (UnimplementedPortManagerServer) GetAllPorts 

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

func (UnimplementedPortManagerServer) UpdatePort 

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

type UnimplementedPublicApiServer added in v1.1.2 

type UnimplementedPublicApiServer struct {
}

UnimplementedPublicApiServer must be embedded to have forward compatible implementations.

func (UnimplementedPublicApiServer) GenerateJwtQRCodePair added in v1.1.2 

func (UnimplementedPublicApiServer) GenerateJwtQRCodePair(context.Context, *emptypb.Empty) (*JwtQRCodePair, 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 

func (UnimplementedServerManagerServer) DelServer(context.Context, *ServerInfo) (*OperationResponse, error)

func (UnimplementedServerManagerServer) GetAllMyServers 

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

func (UnimplementedServerManagerServer) GetAllMySharedServers 

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

func (UnimplementedServerManagerServer) GetAllServer 

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

func (UnimplementedServerManagerServer) QueryServer 

func (UnimplementedServerManagerServer) QueryServer(context.Context, *wrapperspb.StringValue) (*ServerInfoList, error)

func (UnimplementedServerManagerServer) UpdateServer 

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 

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

func (UnimplementedUserManagerServer) DeleteMyAccount added in v1.1.6 

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

func (UnimplementedUserManagerServer) GetAllConfig 

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

func (UnimplementedUserManagerServer) GetUserInfo 

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

func (UnimplementedUserManagerServer) GetUserWechatInfoByCode 

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

func (UnimplementedUserManagerServer) LoginWithUserLoginInfo 

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

func (UnimplementedUserManagerServer) LoginWithWechatCode 

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

func (UnimplementedUserManagerServer) RegisterUserWithLoginInfo 

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

func (UnimplementedUserManagerServer) UnbindWechat 

func (UnimplementedUserManagerServer) UnbindWechat(context.Context, *emptypb.Empty) (*OperationResponse, error)

func (UnimplementedUserManagerServer) UpdateUserAvatar 

func (UnimplementedUserManagerServer) UpdateUserAvatar(context.Context, *UpdateAvatar) (*OperationResponse, error)

func (UnimplementedUserManagerServer) UpdateUserEmail 

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

func (UnimplementedUserManagerServer) UpdateUserMobile 

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

func (UnimplementedUserManagerServer) UpdateUserName 

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

func (UnimplementedUserManagerServer) UpdateUserPassword 

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

type UnsafeAdminManagerServer 

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 

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 

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 

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 

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 

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 UnsafePublicApiServer added in v1.1.2 

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

UnsafePublicApiServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to PublicApiServer 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 

type UpdateAvatar struct {
	NewBytes []byte `protobuf:"bytes,1,opt,name=NewBytes,proto3" json:"NewBytes,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateAvatar) Descriptor deprecated 

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

Deprecated: Use UpdateAvatar.ProtoReflect.Descriptor instead.

func (*UpdateAvatar) GetNewBytes 

func (x *UpdateAvatar) GetNewBytes() []byte

func (*UpdateAvatar) ProtoMessage 

func (*UpdateAvatar) ProtoMessage()

func (*UpdateAvatar) ProtoReflect 

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

func (*UpdateAvatar) Reset 

func (x *UpdateAvatar) Reset()

func (*UpdateAvatar) String 

func (x *UpdateAvatar) String() string

type UserConfigMap 

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

func (*UserConfigMap) Descriptor deprecated 

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

Deprecated: Use UserConfigMap.ProtoReflect.Descriptor instead.

func (*UserConfigMap) GetConfig 

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

func (*UserConfigMap) ProtoMessage 

func (*UserConfigMap) ProtoMessage()

func (*UserConfigMap) ProtoReflect 

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

func (*UserConfigMap) Reset 

func (x *UserConfigMap) Reset()

func (*UserConfigMap) String 

func (x *UserConfigMap) String() string

type UserInfo 

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 

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

Deprecated: Use UserInfo.ProtoReflect.Descriptor instead.

func (*UserInfo) GetAvatar 

func (x *UserInfo) GetAvatar() string

func (*UserInfo) GetEmail 

func (x *UserInfo) GetEmail() string

func (*UserInfo) GetMobile 

func (x *UserInfo) GetMobile() string

func (*UserInfo) GetName 

func (x *UserInfo) GetName() string

func (*UserInfo) GetUuid 

func (x *UserInfo) GetUuid() string

func (*UserInfo) ProtoMessage 

func (*UserInfo) ProtoMessage()

func (*UserInfo) ProtoReflect 

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

func (*UserInfo) Reset 

func (x *UserInfo) Reset()

func (*UserInfo) String 

func (x *UserInfo) String() string

type UserInfoList 

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

func (*UserInfoList) Descriptor deprecated 

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

Deprecated: Use UserInfoList.ProtoReflect.Descriptor instead.

func (*UserInfoList) GetUserInfoList 

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

func (*UserInfoList) ProtoMessage 

func (*UserInfoList) ProtoMessage()

func (*UserInfoList) ProtoReflect 

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

func (*UserInfoList) Reset 

func (x *UserInfoList) Reset()

func (*UserInfoList) String 

func (x *UserInfoList) String() string

type UserLoginResponse 

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 

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

Deprecated: Use UserLoginResponse.ProtoReflect.Descriptor instead.

func (*UserLoginResponse) GetCode 

func (x *UserLoginResponse) GetCode() int32

func (*UserLoginResponse) GetMsg 

func (x *UserLoginResponse) GetMsg() string

func (*UserLoginResponse) GetToken 

func (x *UserLoginResponse) GetToken() string

func (*UserLoginResponse) GetUserInfo 

func (x *UserLoginResponse) GetUserInfo() *UserInfo

func (*UserLoginResponse) ProtoMessage 

func (*UserLoginResponse) ProtoMessage()

func (*UserLoginResponse) ProtoReflect 

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

func (*UserLoginResponse) Reset 

func (x *UserLoginResponse) Reset()

func (*UserLoginResponse) String 

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

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

type WechatUserInfo 

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 

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

Deprecated: Use WechatUserInfo.ProtoReflect.Descriptor instead.

func (*WechatUserInfo) GetAccessToken 

func (x *WechatUserInfo) GetAccessToken() string

func (*WechatUserInfo) GetExpiresIn 

func (x *WechatUserInfo) GetExpiresIn() int32

func (*WechatUserInfo) GetOpenid 

func (x *WechatUserInfo) GetOpenid() string

func (*WechatUserInfo) GetRefreshToken 

func (x *WechatUserInfo) GetRefreshToken() string

func (*WechatUserInfo) GetScope 

func (x *WechatUserInfo) GetScope() string

func (*WechatUserInfo) GetUnionid 

func (x *WechatUserInfo) GetUnionid() string

func (*WechatUserInfo) ProtoMessage 

func (*WechatUserInfo) ProtoMessage()

func (*WechatUserInfo) ProtoReflect 

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

func (*WechatUserInfo) Reset 

func (x *WechatUserInfo) Reset()

func (*WechatUserInfo) String 

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.