pb

package
v1.0.22 Latest Latest
Warning

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

 Go to latest Published: Jul 29, 2021 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_service_proto protoreflect.FileDescriptor

Functions

func RegisterCommonDeviceManagerServer 

func RegisterCommonDeviceManagerServer(s grpc.ServiceRegistrar, srv CommonDeviceManagerServer)

func RegisterSessionManagerServer 

func RegisterSessionManagerServer(s grpc.ServiceRegistrar, srv SessionManagerServer)

func RegisterUtilsServer 

func RegisterUtilsServer(s grpc.ServiceRegistrar, srv UtilsServer)

Types

type CommonDeviceManagerClient 

type CommonDeviceManagerClient interface {
	//设备的操作:增删
	AddDevice(ctx context.Context, in *Device, opts ...grpc.CallOption) (*OpenIoTHubEmpty, error)
	DelDevice(ctx context.Context, in *Device, opts ...grpc.CallOption) (*OpenIoTHubEmpty, error)
	GetAllDevice(ctx context.Context, in *OpenIoTHubEmpty, opts ...grpc.CallOption) (*DeviceList, error)
	//网络唤醒
	SetDeviceMac(ctx context.Context, in *Device, opts ...grpc.CallOption) (*OpenIoTHubEmpty, error)
	WakeOnLAN(ctx context.Context, in *Device, opts ...grpc.CallOption) (*OpenIoTHubEmpty, error)
	// TCP
	CreateOneTCP(ctx context.Context, in *PortConfig, opts ...grpc.CallOption) (*PortConfig, error)
	DeleteOneTCP(ctx context.Context, in *PortConfig, opts ...grpc.CallOption) (*OpenIoTHubEmpty, error)
	GetOneTCP(ctx context.Context, in *PortConfig, opts ...grpc.CallOption) (*PortConfig, error)
	GetAllTCP(ctx context.Context, in *Device, opts ...grpc.CallOption) (*PortList, error)
	// UDP
	CreateOneUDP(ctx context.Context, in *PortConfig, opts ...grpc.CallOption) (*PortConfig, error)
	DeleteOneUDP(ctx context.Context, in *PortConfig, opts ...grpc.CallOption) (*OpenIoTHubEmpty, error)
	GetOneUDP(ctx context.Context, in *PortConfig, opts ...grpc.CallOption) (*PortConfig, error)
	GetAllUDP(ctx context.Context, in *Device, opts ...grpc.CallOption) (*PortList, error)
	// FTP
	CreateOneFTP(ctx context.Context, in *PortConfig, opts ...grpc.CallOption) (*PortConfig, error)
	DeleteOneFTP(ctx context.Context, in *PortConfig, opts ...grpc.CallOption) (*OpenIoTHubEmpty, error)
	GetOneFTP(ctx context.Context, in *PortConfig, opts ...grpc.CallOption) (*PortConfig, error)
	GetAllFTP(ctx context.Context, in *Device, opts ...grpc.CallOption) (*PortList, error)
}

CommonDeviceManagerClient is the client API for CommonDeviceManager 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 NewCommonDeviceManagerClient 

func NewCommonDeviceManagerClient(cc grpc.ClientConnInterface) CommonDeviceManagerClient

type CommonDeviceManagerServer 

type CommonDeviceManagerServer interface {
	//设备的操作:增删
	AddDevice(context.Context, *Device) (*OpenIoTHubEmpty, error)
	DelDevice(context.Context, *Device) (*OpenIoTHubEmpty, error)
	GetAllDevice(context.Context, *OpenIoTHubEmpty) (*DeviceList, error)
	//网络唤醒
	SetDeviceMac(context.Context, *Device) (*OpenIoTHubEmpty, error)
	WakeOnLAN(context.Context, *Device) (*OpenIoTHubEmpty, error)
	// TCP
	CreateOneTCP(context.Context, *PortConfig) (*PortConfig, error)
	DeleteOneTCP(context.Context, *PortConfig) (*OpenIoTHubEmpty, error)
	GetOneTCP(context.Context, *PortConfig) (*PortConfig, error)
	GetAllTCP(context.Context, *Device) (*PortList, error)
	// UDP
	CreateOneUDP(context.Context, *PortConfig) (*PortConfig, error)
	DeleteOneUDP(context.Context, *PortConfig) (*OpenIoTHubEmpty, error)
	GetOneUDP(context.Context, *PortConfig) (*PortConfig, error)
	GetAllUDP(context.Context, *Device) (*PortList, error)
	// FTP
	CreateOneFTP(context.Context, *PortConfig) (*PortConfig, error)
	DeleteOneFTP(context.Context, *PortConfig) (*OpenIoTHubEmpty, error)
	GetOneFTP(context.Context, *PortConfig) (*PortConfig, error)
	GetAllFTP(context.Context, *Device) (*PortList, error)
	// contains filtered or unexported methods
}

CommonDeviceManagerServer is the server API for CommonDeviceManager service. All implementations must embed UnimplementedCommonDeviceManagerServer for forward compatibility

type Device 

type Device struct {
	Uuid        string `protobuf:"bytes,1,opt,name=Uuid,proto3" json:"Uuid,omitempty"`
	RunId       string `protobuf:"bytes,2,opt,name=RunId,proto3" json:"RunId,omitempty"`
	Addr        string `protobuf:"bytes,3,opt,name=Addr,proto3" json:"Addr,omitempty"`
	Mac         string `protobuf:"bytes,4,opt,name=Mac,proto3" json:"Mac,omitempty"`
	Name        string `protobuf:"bytes,5,opt,name=Name,proto3" json:"Name,omitempty"`
	Description string `protobuf:"bytes,6,opt,name=Description,proto3" json:"Description,omitempty"`
	// contains filtered or unexported fields
}

func (*Device) Descriptor deprecated 

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

Deprecated: Use Device.ProtoReflect.Descriptor instead.

func (*Device) GetAddr 

func (x *Device) GetAddr() string

func (*Device) GetDescription 

func (x *Device) GetDescription() string

func (*Device) GetMac 

func (x *Device) GetMac() string

func (*Device) GetName 

func (x *Device) GetName() string

func (*Device) GetRunId 

func (x *Device) GetRunId() string

func (*Device) GetUuid 

func (x *Device) GetUuid() string

func (*Device) ProtoMessage 

func (*Device) ProtoMessage()

func (*Device) ProtoReflect 

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

func (*Device) Reset 

func (x *Device) Reset()

func (*Device) String 

func (x *Device) String() string

type DeviceList 

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

func (*DeviceList) Descriptor deprecated 

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

Deprecated: Use DeviceList.ProtoReflect.Descriptor instead.

func (*DeviceList) GetDevices 

func (x *DeviceList) GetDevices() []*Device

func (*DeviceList) ProtoMessage 

func (*DeviceList) ProtoMessage()

func (*DeviceList) ProtoReflect 

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

func (*DeviceList) Reset 

func (x *DeviceList) Reset()

func (*DeviceList) String 

func (x *DeviceList) String() string

type IoTManagerServerAndToken 

type IoTManagerServerAndToken struct {
	Host  string `protobuf:"bytes,1,opt,name=Host,proto3" json:"Host,omitempty"`
	Port  int32  `protobuf:"varint,2,opt,name=Port,proto3" json:"Port,omitempty"`
	Token string `protobuf:"bytes,3,opt,name=Token,proto3" json:"Token,omitempty"`
	// contains filtered or unexported fields
}

func (*IoTManagerServerAndToken) Descriptor deprecated 

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

Deprecated: Use IoTManagerServerAndToken.ProtoReflect.Descriptor instead.

func (*IoTManagerServerAndToken) GetHost 

func (x *IoTManagerServerAndToken) GetHost() string

func (*IoTManagerServerAndToken) GetPort 

func (x *IoTManagerServerAndToken) GetPort() int32

func (*IoTManagerServerAndToken) GetToken 

func (x *IoTManagerServerAndToken) GetToken() string

func (*IoTManagerServerAndToken) ProtoMessage 

func (*IoTManagerServerAndToken) ProtoMessage()

func (*IoTManagerServerAndToken) ProtoReflect 

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

func (*IoTManagerServerAndToken) Reset 

func (x *IoTManagerServerAndToken) Reset()

func (*IoTManagerServerAndToken) String 

func (x *IoTManagerServerAndToken) String() string

type MDNSService 

type MDNSService struct {
	Instance string `protobuf:"bytes,1,opt,name=Instance,proto3" json:"Instance,omitempty"`
	IP       string `protobuf:"bytes,2,opt,name=IP,proto3" json:"IP,omitempty"`
	Port     int32  `protobuf:"varint,3,opt,name=Port,proto3" json:"Port,omitempty"`
	MDNSInfo string `protobuf:"bytes,4,opt,name=MDNSInfo,proto3" json:"MDNSInfo,omitempty"`
	// contains filtered or unexported fields
}

func (*MDNSService) Descriptor deprecated 

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

Deprecated: Use MDNSService.ProtoReflect.Descriptor instead.

func (*MDNSService) GetIP 

func (x *MDNSService) GetIP() string

func (*MDNSService) GetInstance 

func (x *MDNSService) GetInstance() string

func (*MDNSService) GetMDNSInfo 

func (x *MDNSService) GetMDNSInfo() string

func (*MDNSService) GetPort 

func (x *MDNSService) GetPort() int32

func (*MDNSService) ProtoMessage 

func (*MDNSService) ProtoMessage()

func (*MDNSService) ProtoReflect 

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

func (*MDNSService) Reset 

func (x *MDNSService) Reset()

func (*MDNSService) String 

func (x *MDNSService) String() string

type MDNSServiceList 

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

func (*MDNSServiceList) Descriptor deprecated 

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

Deprecated: Use MDNSServiceList.ProtoReflect.Descriptor instead.

func (*MDNSServiceList) GetMDNSServices 

func (x *MDNSServiceList) GetMDNSServices() []*MDNSService

func (*MDNSServiceList) ProtoMessage 

func (*MDNSServiceList) ProtoMessage()

func (*MDNSServiceList) ProtoReflect 

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

func (*MDNSServiceList) Reset 

func (x *MDNSServiceList) Reset()

func (*MDNSServiceList) String 

func (x *MDNSServiceList) String() string

type OpenIoTHubEmpty 

type OpenIoTHubEmpty struct {
	// contains filtered or unexported fields
}

小米网关设备

func (*OpenIoTHubEmpty) Descriptor deprecated 

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

Deprecated: Use OpenIoTHubEmpty.ProtoReflect.Descriptor instead.

func (*OpenIoTHubEmpty) ProtoMessage 

func (*OpenIoTHubEmpty) ProtoMessage()

func (*OpenIoTHubEmpty) ProtoReflect 

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

func (*OpenIoTHubEmpty) Reset 

func (x *OpenIoTHubEmpty) Reset()

func (*OpenIoTHubEmpty) String 

func (x *OpenIoTHubEmpty) String() string

type OpenIoTHubOperationResponse 

type OpenIoTHubOperationResponse 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 (*OpenIoTHubOperationResponse) Descriptor deprecated 

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

Deprecated: Use OpenIoTHubOperationResponse.ProtoReflect.Descriptor instead.

func (*OpenIoTHubOperationResponse) GetCode 

func (x *OpenIoTHubOperationResponse) GetCode() int32

func (*OpenIoTHubOperationResponse) GetMsg 

func (x *OpenIoTHubOperationResponse) GetMsg() string

func (*OpenIoTHubOperationResponse) ProtoMessage 

func (*OpenIoTHubOperationResponse) ProtoMessage()

func (*OpenIoTHubOperationResponse) ProtoReflect 

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

func (*OpenIoTHubOperationResponse) Reset 

func (x *OpenIoTHubOperationResponse) Reset()

func (*OpenIoTHubOperationResponse) String 

func (x *OpenIoTHubOperationResponse) String() string

type OpenIoTHubStringValue 

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

func (*OpenIoTHubStringValue) Descriptor deprecated 

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

Deprecated: Use OpenIoTHubStringValue.ProtoReflect.Descriptor instead.

func (*OpenIoTHubStringValue) GetValue 

func (x *OpenIoTHubStringValue) GetValue() string

func (*OpenIoTHubStringValue) ProtoMessage 

func (*OpenIoTHubStringValue) ProtoMessage()

func (*OpenIoTHubStringValue) ProtoReflect 

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

func (*OpenIoTHubStringValue) Reset 

func (x *OpenIoTHubStringValue) Reset()

func (*OpenIoTHubStringValue) String 

func (x *OpenIoTHubStringValue) String() string

type PortConfig 

type PortConfig struct {
	Device              *Device      `protobuf:"bytes,1,opt,name=Device,proto3" json:"Device,omitempty"`
	Uuid                string       `protobuf:"bytes,2,opt,name=Uuid,proto3" json:"Uuid,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"`
	LocalProt           int32        `protobuf:"varint,5,opt,name=LocalProt,proto3" json:"LocalProt,omitempty"`
	RemotePort          int32        `protobuf:"varint,6,opt,name=RemotePort,proto3" json:"RemotePort,omitempty"`
	BindAllAddr         bool         `protobuf:"varint,7,opt,name=BindAllAddr,proto3" json:"BindAllAddr,omitempty"`
	Domain              string       `protobuf:"bytes,8,opt,name=Domain,proto3" json:"Domain,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"`
	RemotePortStatus    bool         `protobuf:"varint,11,opt,name=RemotePortStatus,proto3" json:"RemotePortStatus,omitempty"`
	MDNSInfo            *PortService `protobuf:"bytes,12,opt,name=MDNSInfo,proto3" json:"MDNSInfo,omitempty"`
	// contains filtered or unexported fields
}

func (*PortConfig) Descriptor deprecated 

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

Deprecated: Use PortConfig.ProtoReflect.Descriptor instead.

func (*PortConfig) GetApplicationProtocol 

func (x *PortConfig) GetApplicationProtocol() string

func (*PortConfig) GetBindAllAddr 

func (x *PortConfig) GetBindAllAddr() bool

func (*PortConfig) GetDescription 

func (x *PortConfig) GetDescription() string

func (*PortConfig) GetDevice 

func (x *PortConfig) GetDevice() *Device

func (*PortConfig) GetDomain 

func (x *PortConfig) GetDomain() string

func (*PortConfig) GetLocalProt 

func (x *PortConfig) GetLocalProt() int32

func (*PortConfig) GetMDNSInfo 

func (x *PortConfig) GetMDNSInfo() *PortService

func (*PortConfig) GetName 

func (x *PortConfig) GetName() string

func (*PortConfig) GetNetworkProtocol 

func (x *PortConfig) GetNetworkProtocol() string

func (*PortConfig) GetRemotePort 

func (x *PortConfig) GetRemotePort() int32

func (*PortConfig) GetRemotePortStatus 

func (x *PortConfig) GetRemotePortStatus() bool

func (*PortConfig) GetUuid 

func (x *PortConfig) GetUuid() string

func (*PortConfig) ProtoMessage 

func (*PortConfig) ProtoMessage()

func (*PortConfig) ProtoReflect 

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

func (*PortConfig) Reset 

func (x *PortConfig) Reset()

func (*PortConfig) String 

func (x *PortConfig) String() string

type PortList 

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

func (*PortList) Descriptor deprecated 

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

Deprecated: Use PortList.ProtoReflect.Descriptor instead.

func (*PortList) GetPortConfigs 

func (x *PortList) GetPortConfigs() []*PortConfig

func (*PortList) ProtoMessage 

func (*PortList) ProtoMessage()

func (*PortList) ProtoReflect 

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

func (*PortList) Reset 

func (x *PortList) Reset()

func (*PortList) String 

func (x *PortList) String() string

type PortService 

type PortService struct {

	//    String ip;
	Ip string `protobuf:"bytes,1,opt,name=Ip,proto3" json:"Ip,omitempty"`
	//    int port;
	Port int32 `protobuf:"varint,2,opt,name=Port,proto3" json:"Port,omitempty"`
	//    bool isLocal = false;
	IsLocal bool `protobuf:"varint,3,opt,name=IsLocal,proto3" json:"IsLocal,omitempty"`
	//  设备的注册信息
	//  Map<String, dynamic> info = Map<String, dynamic>();
	Info map[string]string `` /* 149-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*PortService) Descriptor deprecated 

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

Deprecated: Use PortService.ProtoReflect.Descriptor instead.

func (*PortService) GetInfo 

func (x *PortService) GetInfo() map[string]string

func (*PortService) GetIp 

func (x *PortService) GetIp() string

func (*PortService) GetIsLocal 

func (x *PortService) GetIsLocal() bool

func (*PortService) GetPort 

func (x *PortService) GetPort() int32

func (*PortService) ProtoMessage 

func (*PortService) ProtoMessage()

func (*PortService) ProtoReflect 

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

func (*PortService) Reset 

func (x *PortService) Reset()

func (*PortService) String 

func (x *PortService) String() string

type SOCKS5Config 

type SOCKS5Config struct {
	RunId       string `protobuf:"bytes,1,opt,name=RunId,proto3" json:"RunId,omitempty"`
	Port        int32  `protobuf:"varint,2,opt,name=Port,proto3" json:"Port,omitempty"`
	Password    string `protobuf:"bytes,3,opt,name=Password,proto3" json:"Password,omitempty"`
	EncType     string `protobuf:"bytes,4,opt,name=EncType,proto3" json:"EncType,omitempty"`
	Description string `protobuf:"bytes,5,opt,name=Description,proto3" json:"Description,omitempty"`
	// contains filtered or unexported fields
}

func (*SOCKS5Config) Descriptor deprecated 

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

Deprecated: Use SOCKS5Config.ProtoReflect.Descriptor instead.

func (*SOCKS5Config) GetDescription 

func (x *SOCKS5Config) GetDescription() string

func (*SOCKS5Config) GetEncType 

func (x *SOCKS5Config) GetEncType() string

func (*SOCKS5Config) GetPassword 

func (x *SOCKS5Config) GetPassword() string

func (*SOCKS5Config) GetPort 

func (x *SOCKS5Config) GetPort() int32

func (*SOCKS5Config) GetRunId 

func (x *SOCKS5Config) GetRunId() string

func (*SOCKS5Config) ProtoMessage 

func (*SOCKS5Config) ProtoMessage()

func (*SOCKS5Config) ProtoReflect 

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

func (*SOCKS5Config) Reset 

func (x *SOCKS5Config) Reset()

func (*SOCKS5Config) String 

func (x *SOCKS5Config) String() string

type SOCKS5List 

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

func (*SOCKS5List) Descriptor deprecated 

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

Deprecated: Use SOCKS5List.ProtoReflect.Descriptor instead.

func (*SOCKS5List) GetSOCKS5Configs 

func (x *SOCKS5List) GetSOCKS5Configs() []*SOCKS5Config

func (*SOCKS5List) ProtoMessage 

func (*SOCKS5List) ProtoMessage()

func (*SOCKS5List) ProtoReflect 

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

func (*SOCKS5List) Reset 

func (x *SOCKS5List) Reset()

func (*SOCKS5List) String 

func (x *SOCKS5List) String() string

type SessionConfig 

type SessionConfig struct {
	RunId             string `protobuf:"bytes,1,opt,name=RunId,proto3" json:"RunId,omitempty"`
	Token             string `protobuf:"bytes,2,opt,name=Token,proto3" json:"Token,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"`
	StatusToClient    bool   `protobuf:"varint,5,opt,name=StatusToClient,proto3" json:"StatusToClient,omitempty"`
	StatusP2PAsClient bool   `protobuf:"varint,6,opt,name=StatusP2PAsClient,proto3" json:"StatusP2PAsClient,omitempty"`
	StatusP2PAsServer bool   `protobuf:"varint,7,opt,name=StatusP2PAsServer,proto3" json:"StatusP2PAsServer,omitempty"`
	// contains filtered or unexported fields
}

几种代理类型

func (*SessionConfig) Descriptor deprecated 

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

Deprecated: Use SessionConfig.ProtoReflect.Descriptor instead.

func (*SessionConfig) GetDescription 

func (x *SessionConfig) GetDescription() string

func (*SessionConfig) GetName 

func (x *SessionConfig) GetName() string

func (*SessionConfig) GetRunId 

func (x *SessionConfig) GetRunId() string

func (*SessionConfig) GetStatusP2PAsClient 

func (x *SessionConfig) GetStatusP2PAsClient() bool

func (*SessionConfig) GetStatusP2PAsServer 

func (x *SessionConfig) GetStatusP2PAsServer() bool

func (*SessionConfig) GetStatusToClient 

func (x *SessionConfig) GetStatusToClient() bool

func (*SessionConfig) GetToken 

func (x *SessionConfig) GetToken() string

func (*SessionConfig) ProtoMessage 

func (*SessionConfig) ProtoMessage()

func (*SessionConfig) ProtoReflect 

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

func (*SessionConfig) Reset 

func (x *SessionConfig) Reset()

func (*SessionConfig) String 

func (x *SessionConfig) String() string

type SessionList 

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

func (*SessionList) Descriptor deprecated 

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

Deprecated: Use SessionList.ProtoReflect.Descriptor instead.

func (*SessionList) GetSessionConfigs 

func (x *SessionList) GetSessionConfigs() []*SessionConfig

func (*SessionList) ProtoMessage 

func (*SessionList) ProtoMessage()

func (*SessionList) ProtoReflect 

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

func (*SessionList) Reset 

func (x *SessionList) Reset()

func (*SessionList) String 

func (x *SessionList) String() string

type SessionManagerClient 

type SessionManagerClient interface {
	// Sends a greeting
	CreateOneSession(ctx context.Context, in *SessionConfig, opts ...grpc.CallOption) (*SessionConfig, error)
	DeleteOneSession(ctx context.Context, in *SessionConfig, opts ...grpc.CallOption) (*OpenIoTHubEmpty, error)
	GetOneSession(ctx context.Context, in *SessionConfig, opts ...grpc.CallOption) (*SessionConfig, error)
	GetAllSession(ctx context.Context, in *OpenIoTHubEmpty, opts ...grpc.CallOption) (*SessionList, error)
	UpdateSessionNameDescription(ctx context.Context, in *SessionConfig, opts ...grpc.CallOption) (*SessionConfig, error)
	// Socks5
	CreateOneSOCKS5(ctx context.Context, in *SOCKS5Config, opts ...grpc.CallOption) (*SOCKS5Config, error)
	DeleteOneSOCKS5(ctx context.Context, in *SOCKS5Config, opts ...grpc.CallOption) (*OpenIoTHubEmpty, error)
	GetOneSOCKS5(ctx context.Context, in *SOCKS5Config, opts ...grpc.CallOption) (*SOCKS5Config, error)
	//:TODO  获取所有的设备列表
	// mDNS刷新列表
	RefreshmDNSProxyList(ctx context.Context, in *SessionConfig, opts ...grpc.CallOption) (*OpenIoTHubEmpty, error)
	// 获取通过mDNS自动映射的TCP端口列表，然后可以查看页面
	GetAllTCP(ctx context.Context, in *SessionConfig, opts ...grpc.CallOption) (*PortList, error)
	//:TODO VPN接口
	// 通知这个网关删除配置文件中的token
	DeleteRemoteGatewayConfig(ctx context.Context, in *SessionConfig, opts ...grpc.CallOption) (*OpenIoTHubOperationResponse, error)
}

SessionManagerClient is the client API for SessionManager 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 NewSessionManagerClient 

func NewSessionManagerClient(cc grpc.ClientConnInterface) SessionManagerClient

type SessionManagerServer 

type SessionManagerServer interface {
	// Sends a greeting
	CreateOneSession(context.Context, *SessionConfig) (*SessionConfig, error)
	DeleteOneSession(context.Context, *SessionConfig) (*OpenIoTHubEmpty, error)
	GetOneSession(context.Context, *SessionConfig) (*SessionConfig, error)
	GetAllSession(context.Context, *OpenIoTHubEmpty) (*SessionList, error)
	UpdateSessionNameDescription(context.Context, *SessionConfig) (*SessionConfig, error)
	// Socks5
	CreateOneSOCKS5(context.Context, *SOCKS5Config) (*SOCKS5Config, error)
	DeleteOneSOCKS5(context.Context, *SOCKS5Config) (*OpenIoTHubEmpty, error)
	GetOneSOCKS5(context.Context, *SOCKS5Config) (*SOCKS5Config, error)
	//:TODO  获取所有的设备列表
	// mDNS刷新列表
	RefreshmDNSProxyList(context.Context, *SessionConfig) (*OpenIoTHubEmpty, error)
	// 获取通过mDNS自动映射的TCP端口列表，然后可以查看页面
	GetAllTCP(context.Context, *SessionConfig) (*PortList, error)
	//:TODO VPN接口
	// 通知这个网关删除配置文件中的token
	DeleteRemoteGatewayConfig(context.Context, *SessionConfig) (*OpenIoTHubOperationResponse, error)
	// contains filtered or unexported methods
}

SessionManagerServer is the server API for SessionManager service. All implementations must embed UnimplementedSessionManagerServer for forward compatibility

type TokenModel 

type TokenModel struct {
	RunId      string   `protobuf:"bytes,1,opt,name=RunId,proto3" json:"RunId,omitempty"`
	Host       string   `protobuf:"bytes,2,opt,name=Host,proto3" json:"Host,omitempty"`
	TcpPort    int32    `protobuf:"varint,3,opt,name=TcpPort,proto3" json:"TcpPort,omitempty"`
	KcpPort    int32    `protobuf:"varint,4,opt,name=KcpPort,proto3" json:"KcpPort,omitempty"`
	TlsPort    int32    `protobuf:"varint,5,opt,name=TlsPort,proto3" json:"TlsPort,omitempty"`
	GrpcPort   int32    `protobuf:"varint,6,opt,name=GrpcPort,proto3" json:"GrpcPort,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"`
	Permission []string `protobuf:"bytes,9,rep,name=Permission,proto3" json:"Permission,omitempty"`
	// contains filtered or unexported fields
}

func (*TokenModel) Descriptor deprecated 

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

Deprecated: Use TokenModel.ProtoReflect.Descriptor instead.

func (*TokenModel) GetGrpcPort 

func (x *TokenModel) GetGrpcPort() int32

func (*TokenModel) GetHost 

func (x *TokenModel) GetHost() string

func (*TokenModel) GetKCPApiPort 

func (x *TokenModel) GetKCPApiPort() int32

func (*TokenModel) GetKcpPort 

func (x *TokenModel) GetKcpPort() int32

func (*TokenModel) GetPermission 

func (x *TokenModel) GetPermission() []string

func (*TokenModel) GetRunId 

func (x *TokenModel) GetRunId() string

func (*TokenModel) GetTcpPort 

func (x *TokenModel) GetTcpPort() int32

func (*TokenModel) GetTlsPort 

func (x *TokenModel) GetTlsPort() int32

func (*TokenModel) GetUDPApiPort 

func (x *TokenModel) GetUDPApiPort() int32

func (*TokenModel) ProtoMessage 

func (*TokenModel) ProtoMessage()

func (*TokenModel) ProtoReflect 

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

func (*TokenModel) Reset 

func (x *TokenModel) Reset()

func (*TokenModel) String 

func (x *TokenModel) String() string

type UnimplementedCommonDeviceManagerServer 

type UnimplementedCommonDeviceManagerServer struct {
}

UnimplementedCommonDeviceManagerServer must be embedded to have forward compatible implementations.

func (UnimplementedCommonDeviceManagerServer) AddDevice 

func (UnimplementedCommonDeviceManagerServer) AddDevice(context.Context, *Device) (*OpenIoTHubEmpty, error)

func (UnimplementedCommonDeviceManagerServer) CreateOneFTP 

func (UnimplementedCommonDeviceManagerServer) CreateOneFTP(context.Context, *PortConfig) (*PortConfig, error)

func (UnimplementedCommonDeviceManagerServer) CreateOneTCP 

func (UnimplementedCommonDeviceManagerServer) CreateOneTCP(context.Context, *PortConfig) (*PortConfig, error)

func (UnimplementedCommonDeviceManagerServer) CreateOneUDP 

func (UnimplementedCommonDeviceManagerServer) CreateOneUDP(context.Context, *PortConfig) (*PortConfig, error)

func (UnimplementedCommonDeviceManagerServer) DelDevice 

func (UnimplementedCommonDeviceManagerServer) DelDevice(context.Context, *Device) (*OpenIoTHubEmpty, error)

func (UnimplementedCommonDeviceManagerServer) DeleteOneFTP 

func (UnimplementedCommonDeviceManagerServer) DeleteOneFTP(context.Context, *PortConfig) (*OpenIoTHubEmpty, error)

func (UnimplementedCommonDeviceManagerServer) DeleteOneTCP 

func (UnimplementedCommonDeviceManagerServer) DeleteOneTCP(context.Context, *PortConfig) (*OpenIoTHubEmpty, error)

func (UnimplementedCommonDeviceManagerServer) DeleteOneUDP 

func (UnimplementedCommonDeviceManagerServer) DeleteOneUDP(context.Context, *PortConfig) (*OpenIoTHubEmpty, error)

func (UnimplementedCommonDeviceManagerServer) GetAllDevice 

func (UnimplementedCommonDeviceManagerServer) GetAllDevice(context.Context, *OpenIoTHubEmpty) (*DeviceList, error)

func (UnimplementedCommonDeviceManagerServer) GetAllFTP 

func (UnimplementedCommonDeviceManagerServer) GetAllFTP(context.Context, *Device) (*PortList, error)

func (UnimplementedCommonDeviceManagerServer) GetAllTCP 

func (UnimplementedCommonDeviceManagerServer) GetAllTCP(context.Context, *Device) (*PortList, error)

func (UnimplementedCommonDeviceManagerServer) GetAllUDP 

func (UnimplementedCommonDeviceManagerServer) GetAllUDP(context.Context, *Device) (*PortList, error)

func (UnimplementedCommonDeviceManagerServer) GetOneFTP 

func (UnimplementedCommonDeviceManagerServer) GetOneFTP(context.Context, *PortConfig) (*PortConfig, error)

func (UnimplementedCommonDeviceManagerServer) GetOneTCP 

func (UnimplementedCommonDeviceManagerServer) GetOneTCP(context.Context, *PortConfig) (*PortConfig, error)

func (UnimplementedCommonDeviceManagerServer) GetOneUDP 

func (UnimplementedCommonDeviceManagerServer) GetOneUDP(context.Context, *PortConfig) (*PortConfig, error)

func (UnimplementedCommonDeviceManagerServer) SetDeviceMac 

func (UnimplementedCommonDeviceManagerServer) SetDeviceMac(context.Context, *Device) (*OpenIoTHubEmpty, error)

func (UnimplementedCommonDeviceManagerServer) WakeOnLAN 

func (UnimplementedCommonDeviceManagerServer) WakeOnLAN(context.Context, *Device) (*OpenIoTHubEmpty, error)

type UnimplementedSessionManagerServer 

type UnimplementedSessionManagerServer struct {
}

UnimplementedSessionManagerServer must be embedded to have forward compatible implementations.

func (UnimplementedSessionManagerServer) CreateOneSOCKS5 

func (UnimplementedSessionManagerServer) CreateOneSOCKS5(context.Context, *SOCKS5Config) (*SOCKS5Config, error)

func (UnimplementedSessionManagerServer) CreateOneSession 

func (UnimplementedSessionManagerServer) CreateOneSession(context.Context, *SessionConfig) (*SessionConfig, error)

func (UnimplementedSessionManagerServer) DeleteOneSOCKS5 

func (UnimplementedSessionManagerServer) DeleteOneSOCKS5(context.Context, *SOCKS5Config) (*OpenIoTHubEmpty, error)

func (UnimplementedSessionManagerServer) DeleteOneSession 

func (UnimplementedSessionManagerServer) DeleteOneSession(context.Context, *SessionConfig) (*OpenIoTHubEmpty, error)

func (UnimplementedSessionManagerServer) DeleteRemoteGatewayConfig 

func (UnimplementedSessionManagerServer) DeleteRemoteGatewayConfig(context.Context, *SessionConfig) (*OpenIoTHubOperationResponse, error)

func (UnimplementedSessionManagerServer) GetAllSession 

func (UnimplementedSessionManagerServer) GetAllSession(context.Context, *OpenIoTHubEmpty) (*SessionList, error)

func (UnimplementedSessionManagerServer) GetAllTCP 

func (UnimplementedSessionManagerServer) GetAllTCP(context.Context, *SessionConfig) (*PortList, error)

func (UnimplementedSessionManagerServer) GetOneSOCKS5 

func (UnimplementedSessionManagerServer) GetOneSOCKS5(context.Context, *SOCKS5Config) (*SOCKS5Config, error)

func (UnimplementedSessionManagerServer) GetOneSession 

func (UnimplementedSessionManagerServer) GetOneSession(context.Context, *SessionConfig) (*SessionConfig, error)

func (UnimplementedSessionManagerServer) RefreshmDNSProxyList 

func (UnimplementedSessionManagerServer) RefreshmDNSProxyList(context.Context, *SessionConfig) (*OpenIoTHubEmpty, error)

func (UnimplementedSessionManagerServer) UpdateSessionNameDescription 

func (UnimplementedSessionManagerServer) UpdateSessionNameDescription(context.Context, *SessionConfig) (*SessionConfig, error)

type UnimplementedUtilsServer 

type UnimplementedUtilsServer struct {
}

UnimplementedUtilsServer must be embedded to have forward compatible implementations.

func (UnimplementedUtilsServer) ConvertOctonaryUtf8 

func (UnimplementedUtilsServer) ConvertOctonaryUtf8(context.Context, *OpenIoTHubStringValue) (*OpenIoTHubStringValue, error)

func (UnimplementedUtilsServer) GetAllConfig 

func (UnimplementedUtilsServer) GetAllConfig(context.Context, *OpenIoTHubEmpty) (*OpenIoTHubStringValue, error)

func (UnimplementedUtilsServer) GetAllmDNSServiceList 

func (UnimplementedUtilsServer) GetAllmDNSServiceList(context.Context, *OpenIoTHubEmpty) (*MDNSServiceList, error)

func (UnimplementedUtilsServer) GetTokenModel 

func (UnimplementedUtilsServer) GetTokenModel(context.Context, *OpenIoTHubStringValue) (*TokenModel, error)

func (UnimplementedUtilsServer) GetmDNSServiceListByType 

func (UnimplementedUtilsServer) GetmDNSServiceListByType(context.Context, *OpenIoTHubStringValue) (*MDNSServiceList, error)

func (UnimplementedUtilsServer) LoadAllConfig 

func (UnimplementedUtilsServer) LoadAllConfig(context.Context, *OpenIoTHubStringValue) (*OpenIoTHubEmpty, error)

func (UnimplementedUtilsServer) SyncConfigWithToken 

func (UnimplementedUtilsServer) SyncConfigWithToken(context.Context, *IoTManagerServerAndToken) (*OpenIoTHubOperationResponse, error)

type UnsafeCommonDeviceManagerServer 

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

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

type UnsafeSessionManagerServer 

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

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

type UnsafeUtilsServer 

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

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

type UtilsClient 

type UtilsClient interface {
	//    让后台服务登录服务器并同步配置
	SyncConfigWithToken(ctx context.Context, in *IoTManagerServerAndToken, opts ...grpc.CallOption) (*OpenIoTHubOperationResponse, error)
	GetAllConfig(ctx context.Context, in *OpenIoTHubEmpty, opts ...grpc.CallOption) (*OpenIoTHubStringValue, error)
	LoadAllConfig(ctx context.Context, in *OpenIoTHubStringValue, opts ...grpc.CallOption) (*OpenIoTHubEmpty, error)
	GetAllmDNSServiceList(ctx context.Context, in *OpenIoTHubEmpty, opts ...grpc.CallOption) (*MDNSServiceList, error)
	GetmDNSServiceListByType(ctx context.Context, in *OpenIoTHubStringValue, opts ...grpc.CallOption) (*MDNSServiceList, error)
	ConvertOctonaryUtf8(ctx context.Context, in *OpenIoTHubStringValue, opts ...grpc.CallOption) (*OpenIoTHubStringValue, error)
	GetTokenModel(ctx context.Context, in *OpenIoTHubStringValue, opts ...grpc.CallOption) (*TokenModel, error)
}

UtilsClient is the client API for Utils 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 NewUtilsClient 

func NewUtilsClient(cc grpc.ClientConnInterface) UtilsClient

type UtilsServer 

type UtilsServer interface {
	//    让后台服务登录服务器并同步配置
	SyncConfigWithToken(context.Context, *IoTManagerServerAndToken) (*OpenIoTHubOperationResponse, error)
	GetAllConfig(context.Context, *OpenIoTHubEmpty) (*OpenIoTHubStringValue, error)
	LoadAllConfig(context.Context, *OpenIoTHubStringValue) (*OpenIoTHubEmpty, error)
	GetAllmDNSServiceList(context.Context, *OpenIoTHubEmpty) (*MDNSServiceList, error)
	GetmDNSServiceListByType(context.Context, *OpenIoTHubStringValue) (*MDNSServiceList, error)
	ConvertOctonaryUtf8(context.Context, *OpenIoTHubStringValue) (*OpenIoTHubStringValue, error)
	GetTokenModel(context.Context, *OpenIoTHubStringValue) (*TokenModel, error)
	// contains filtered or unexported methods
}

UtilsServer is the server API for Utils service. All implementations must embed UnimplementedUtilsServer for forward compatibility

Source Files

View all Source files

Jump to

Keyboard shortcuts

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