pb

package
v0.0.0-...-1173702 Latest Latest
Warning

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

 Go to latest Published: Apr 27, 2020 License: MIT Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterCommonDeviceManagerServer 

func RegisterCommonDeviceManagerServer(s *grpc.Server, srv CommonDeviceManagerServer)

func RegisterHttpManagerServer 

func RegisterHttpManagerServer(s *grpc.Server, srv HttpManagerServer)

func RegisterSessionManagerServer 

func RegisterSessionManagerServer(s *grpc.Server, srv SessionManagerServer)

func RegisterUtilsServer 

func RegisterUtilsServer(s *grpc.Server, srv UtilsServer)

Types

type Color 

type Color struct {
	R                    int32    `protobuf:"varint,1,opt,name=R,proto3" json:"R,omitempty"`
	G                    int32    `protobuf:"varint,2,opt,name=G,proto3" json:"G,omitempty"`
	B                    int32    `protobuf:"varint,3,opt,name=B,proto3" json:"B,omitempty"`
	A                    int32    `protobuf:"varint,4,opt,name=A,proto3" json:"A,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Color) Descriptor 

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

func (*Color) GetA 

func (m *Color) GetA() int32

func (*Color) GetB 

func (m *Color) GetB() int32

func (*Color) GetG 

func (m *Color) GetG() int32

func (*Color) GetR 

func (m *Color) GetR() int32

func (*Color) ProtoMessage 

func (*Color) ProtoMessage()

func (*Color) Reset 

func (m *Color) Reset()

func (*Color) String 

func (m *Color) String() string

func (*Color) XXX_DiscardUnknown 

func (m *Color) XXX_DiscardUnknown()

func (*Color) XXX_Marshal 

func (m *Color) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Color) XXX_Merge 

func (m *Color) XXX_Merge(src proto.Message)

func (*Color) XXX_Size 

func (m *Color) XXX_Size() int

func (*Color) XXX_Unmarshal 

func (m *Color) XXX_Unmarshal(b []byte) error

type CommonDeviceManagerClient 

type CommonDeviceManagerClient interface {
	//设备的操作:增删
	AddDevice(ctx context.Context, in *Device, opts ...grpc.CallOption) (*Empty, error)
	DelDevice(ctx context.Context, in *Device, opts ...grpc.CallOption) (*Empty, error)
	GetAllDevice(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*DeviceList, error)
	//网络唤醒
	SetDeviceMac(ctx context.Context, in *Device, opts ...grpc.CallOption) (*Empty, error)
	WakeOnLAN(ctx context.Context, in *Device, opts ...grpc.CallOption) (*Empty, error)
	// TCP
	CreateOneTCP(ctx context.Context, in *PortConfig, opts ...grpc.CallOption) (*PortConfig, error)
	DeleteOneTCP(ctx context.Context, in *PortConfig, opts ...grpc.CallOption) (*Empty, 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) (*Empty, 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) (*Empty, 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://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewCommonDeviceManagerClient 

func NewCommonDeviceManagerClient(cc *grpc.ClientConn) CommonDeviceManagerClient

type CommonDeviceManagerServer 

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

CommonDeviceManagerServer is the server API for CommonDeviceManager service.

type Device 

type Device struct {
	RunId                string   `protobuf:"bytes,1,opt,name=RunId,proto3" json:"RunId,omitempty"`
	Addr                 string   `protobuf:"bytes,2,opt,name=Addr,proto3" json:"Addr,omitempty"`
	Mac                  string   `protobuf:"bytes,3,opt,name=Mac,proto3" json:"Mac,omitempty"`
	Description          string   `protobuf:"bytes,4,opt,name=Description,proto3" json:"Description,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Device) Descriptor 

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

func (*Device) GetAddr 

func (m *Device) GetAddr() string

func (*Device) GetDescription 

func (m *Device) GetDescription() string

func (*Device) GetMac 

func (m *Device) GetMac() string

func (*Device) GetRunId 

func (m *Device) GetRunId() string

func (*Device) ProtoMessage 

func (*Device) ProtoMessage()

func (*Device) Reset 

func (m *Device) Reset()

func (*Device) String 

func (m *Device) String() string

func (*Device) XXX_DiscardUnknown 

func (m *Device) XXX_DiscardUnknown()

func (*Device) XXX_Marshal 

func (m *Device) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Device) XXX_Merge 

func (m *Device) XXX_Merge(src proto.Message)

func (*Device) XXX_Size 

func (m *Device) XXX_Size() int

func (*Device) XXX_Unmarshal 

func (m *Device) XXX_Unmarshal(b []byte) error

type DeviceList 

type DeviceList struct {
	Devices              []*Device `protobuf:"bytes,1,rep,name=Devices,proto3" json:"Devices,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*DeviceList) Descriptor 

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

func (*DeviceList) GetDevices 

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

func (*DeviceList) ProtoMessage 

func (*DeviceList) ProtoMessage()

func (*DeviceList) Reset 

func (m *DeviceList) Reset()

func (*DeviceList) String 

func (m *DeviceList) String() string

func (*DeviceList) XXX_DiscardUnknown 

func (m *DeviceList) XXX_DiscardUnknown()

func (*DeviceList) XXX_Marshal 

func (m *DeviceList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeviceList) XXX_Merge 

func (m *DeviceList) XXX_Merge(src proto.Message)

func (*DeviceList) XXX_Size 

func (m *DeviceList) XXX_Size() int

func (*DeviceList) XXX_Unmarshal 

func (m *DeviceList) XXX_Unmarshal(b []byte) error

type Empty 

type Empty struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

小米网关设备

func (*Empty) Descriptor 

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

func (*Empty) ProtoMessage 

func (*Empty) ProtoMessage()

func (*Empty) Reset 

func (m *Empty) Reset()

func (*Empty) String 

func (m *Empty) String() string

func (*Empty) XXX_DiscardUnknown 

func (m *Empty) XXX_DiscardUnknown()

func (*Empty) XXX_Marshal 

func (m *Empty) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Empty) XXX_Merge 

func (m *Empty) XXX_Merge(src proto.Message)

func (*Empty) XXX_Size 

func (m *Empty) XXX_Size() int

func (*Empty) XXX_Unmarshal 

func (m *Empty) XXX_Unmarshal(b []byte) error

type GatewayState 

type GatewayState struct {
	On                   bool     `protobuf:"varint,1,opt,name=On,proto3" json:"On,omitempty"`
	Color                *Color   `protobuf:"bytes,2,opt,name=Color,proto3" json:"Color,omitempty"`
	Brightness           uint32   `protobuf:"varint,3,opt,name=Brightness,proto3" json:"Brightness,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GatewayState) Descriptor 

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

func (*GatewayState) GetBrightness 

func (m *GatewayState) GetBrightness() uint32

func (*GatewayState) GetColor 

func (m *GatewayState) GetColor() *Color

func (*GatewayState) GetOn 

func (m *GatewayState) GetOn() bool

func (*GatewayState) ProtoMessage 

func (*GatewayState) ProtoMessage()

func (*GatewayState) Reset 

func (m *GatewayState) Reset()

func (*GatewayState) String 

func (m *GatewayState) String() string

func (*GatewayState) XXX_DiscardUnknown 

func (m *GatewayState) XXX_DiscardUnknown()

func (*GatewayState) XXX_Marshal 

func (m *GatewayState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GatewayState) XXX_Merge 

func (m *GatewayState) XXX_Merge(src proto.Message)

func (*GatewayState) XXX_Size 

func (m *GatewayState) XXX_Size() int

func (*GatewayState) XXX_Unmarshal 

func (m *GatewayState) XXX_Unmarshal(b []byte) error

type GatewayUpdateMessage 

type GatewayUpdateMessage struct {
	ID                   string        `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	State                *GatewayState `protobuf:"bytes,2,opt,name=State,proto3" json:"State,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*GatewayUpdateMessage) Descriptor 

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

func (*GatewayUpdateMessage) GetID 

func (m *GatewayUpdateMessage) GetID() string

func (*GatewayUpdateMessage) GetState 

func (m *GatewayUpdateMessage) GetState() *GatewayState

func (*GatewayUpdateMessage) ProtoMessage 

func (*GatewayUpdateMessage) ProtoMessage()

func (*GatewayUpdateMessage) Reset 

func (m *GatewayUpdateMessage) Reset()

func (*GatewayUpdateMessage) String 

func (m *GatewayUpdateMessage) String() string

func (*GatewayUpdateMessage) XXX_DiscardUnknown 

func (m *GatewayUpdateMessage) XXX_DiscardUnknown()

func (*GatewayUpdateMessage) XXX_Marshal 

func (m *GatewayUpdateMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GatewayUpdateMessage) XXX_Merge 

func (m *GatewayUpdateMessage) XXX_Merge(src proto.Message)

func (*GatewayUpdateMessage) XXX_Size 

func (m *GatewayUpdateMessage) XXX_Size() int

func (*GatewayUpdateMessage) XXX_Unmarshal 

func (m *GatewayUpdateMessage) XXX_Unmarshal(b []byte) error

type HTTPConfig 

type HTTPConfig struct {
	RunId                string   `protobuf:"bytes,1,opt,name=RunId,proto3" json:"RunId,omitempty"`
	Domain               string   `protobuf:"bytes,2,opt,name=Domain,proto3" json:"Domain,omitempty"`
	RemoteIP             string   `protobuf:"bytes,3,opt,name=RemoteIP,proto3" json:"RemoteIP,omitempty"`
	RemotePort           int32    `protobuf:"varint,4,opt,name=RemotePort,proto3" json:"RemotePort,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"`
	IfHttps              bool     `protobuf:"varint,7,opt,name=IfHttps,proto3" json:"IfHttps,omitempty"`
	Description          string   `protobuf:"bytes,8,opt,name=Description,proto3" json:"Description,omitempty"`
	RemotePortStatus     bool     `protobuf:"varint,9,opt,name=RemotePortStatus,proto3" json:"RemotePortStatus,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*HTTPConfig) Descriptor 

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

func (*HTTPConfig) GetDescription 

func (m *HTTPConfig) GetDescription() string

func (*HTTPConfig) GetDomain 

func (m *HTTPConfig) GetDomain() string

func (*HTTPConfig) GetIfHttps 

func (m *HTTPConfig) GetIfHttps() bool

func (*HTTPConfig) GetPassword 

func (m *HTTPConfig) GetPassword() string

func (*HTTPConfig) GetRemoteIP 

func (m *HTTPConfig) GetRemoteIP() string

func (*HTTPConfig) GetRemotePort 

func (m *HTTPConfig) GetRemotePort() int32

func (*HTTPConfig) GetRemotePortStatus 

func (m *HTTPConfig) GetRemotePortStatus() bool

func (*HTTPConfig) GetRunId 

func (m *HTTPConfig) GetRunId() string

func (*HTTPConfig) GetUserName 

func (m *HTTPConfig) GetUserName() string

func (*HTTPConfig) ProtoMessage 

func (*HTTPConfig) ProtoMessage()

func (*HTTPConfig) Reset 

func (m *HTTPConfig) Reset()

func (*HTTPConfig) String 

func (m *HTTPConfig) String() string

func (*HTTPConfig) XXX_DiscardUnknown 

func (m *HTTPConfig) XXX_DiscardUnknown()

func (*HTTPConfig) XXX_Marshal 

func (m *HTTPConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HTTPConfig) XXX_Merge 

func (m *HTTPConfig) XXX_Merge(src proto.Message)

func (*HTTPConfig) XXX_Size 

func (m *HTTPConfig) XXX_Size() int

func (*HTTPConfig) XXX_Unmarshal 

func (m *HTTPConfig) XXX_Unmarshal(b []byte) error

type HTTPList 

type HTTPList struct {
	HTTPConfigs          []*HTTPConfig `protobuf:"bytes,1,rep,name=HTTPConfigs,proto3" json:"HTTPConfigs,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*HTTPList) Descriptor 

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

func (*HTTPList) GetHTTPConfigs 

func (m *HTTPList) GetHTTPConfigs() []*HTTPConfig

func (*HTTPList) ProtoMessage 

func (*HTTPList) ProtoMessage()

func (*HTTPList) Reset 

func (m *HTTPList) Reset()

func (*HTTPList) String 

func (m *HTTPList) String() string

func (*HTTPList) XXX_DiscardUnknown 

func (m *HTTPList) XXX_DiscardUnknown()

func (*HTTPList) XXX_Marshal 

func (m *HTTPList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HTTPList) XXX_Merge 

func (m *HTTPList) XXX_Merge(src proto.Message)

func (*HTTPList) XXX_Size 

func (m *HTTPList) XXX_Size() int

func (*HTTPList) XXX_Unmarshal 

func (m *HTTPList) XXX_Unmarshal(b []byte) error

type HttpManagerClient 

type HttpManagerClient interface {
	CreateOneHTTP(ctx context.Context, in *HTTPConfig, opts ...grpc.CallOption) (*HTTPConfig, error)
	DeleteOneHTTP(ctx context.Context, in *HTTPConfig, opts ...grpc.CallOption) (*Empty, error)
	GetOneHTTP(ctx context.Context, in *HTTPConfig, opts ...grpc.CallOption) (*HTTPConfig, error)
	GetAllHTTP(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*HTTPList, error)
}

HttpManagerClient is the client API for HttpManager service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewHttpManagerClient 

func NewHttpManagerClient(cc *grpc.ClientConn) HttpManagerClient

type HttpManagerServer 

type HttpManagerServer interface {
	CreateOneHTTP(context.Context, *HTTPConfig) (*HTTPConfig, error)
	DeleteOneHTTP(context.Context, *HTTPConfig) (*Empty, error)
	GetOneHTTP(context.Context, *HTTPConfig) (*HTTPConfig, error)
	GetAllHTTP(context.Context, *Empty) (*HTTPList, error)
}

HttpManagerServer is the server API for HttpManager service.

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MDNSService) Descriptor 

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

func (*MDNSService) GetIP 

func (m *MDNSService) GetIP() string

func (*MDNSService) GetInstance 

func (m *MDNSService) GetInstance() string

func (*MDNSService) GetMDNSInfo 

func (m *MDNSService) GetMDNSInfo() string

func (*MDNSService) GetPort 

func (m *MDNSService) GetPort() int32

func (*MDNSService) ProtoMessage 

func (*MDNSService) ProtoMessage()

func (*MDNSService) Reset 

func (m *MDNSService) Reset()

func (*MDNSService) String 

func (m *MDNSService) String() string

func (*MDNSService) XXX_DiscardUnknown 

func (m *MDNSService) XXX_DiscardUnknown()

func (*MDNSService) XXX_Marshal 

func (m *MDNSService) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MDNSService) XXX_Merge 

func (m *MDNSService) XXX_Merge(src proto.Message)

func (*MDNSService) XXX_Size 

func (m *MDNSService) XXX_Size() int

func (*MDNSService) XXX_Unmarshal 

func (m *MDNSService) XXX_Unmarshal(b []byte) error

type MDNSServiceList 

type MDNSServiceList struct {
	MDNSServices         []*MDNSService `protobuf:"bytes,1,rep,name=MDNSServices,proto3" json:"MDNSServices,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*MDNSServiceList) Descriptor 

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

func (*MDNSServiceList) GetMDNSServices 

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

func (*MDNSServiceList) ProtoMessage 

func (*MDNSServiceList) ProtoMessage()

func (*MDNSServiceList) Reset 

func (m *MDNSServiceList) Reset()

func (*MDNSServiceList) String 

func (m *MDNSServiceList) String() string

func (*MDNSServiceList) XXX_DiscardUnknown 

func (m *MDNSServiceList) XXX_DiscardUnknown()

func (*MDNSServiceList) XXX_Marshal 

func (m *MDNSServiceList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MDNSServiceList) XXX_Merge 

func (m *MDNSServiceList) XXX_Merge(src proto.Message)

func (*MDNSServiceList) XXX_Size 

func (m *MDNSServiceList) XXX_Size() int

func (*MDNSServiceList) XXX_Unmarshal 

func (m *MDNSServiceList) XXX_Unmarshal(b []byte) error

type PortConfig 

type PortConfig struct {
	Device               *Device  `protobuf:"bytes,1,opt,name=Device,proto3" json:"Device,omitempty"`
	LocalProt            int32    `protobuf:"varint,2,opt,name=LocalProt,proto3" json:"LocalProt,omitempty"`
	RemotePort           int32    `protobuf:"varint,3,opt,name=RemotePort,proto3" json:"RemotePort,omitempty"`
	Description          string   `protobuf:"bytes,4,opt,name=Description,proto3" json:"Description,omitempty"`
	RemotePortStatus     bool     `protobuf:"varint,5,opt,name=RemotePortStatus,proto3" json:"RemotePortStatus,omitempty"`
	MDNSInfo             string   `protobuf:"bytes,6,opt,name=MDNSInfo,proto3" json:"MDNSInfo,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PortConfig) Descriptor 

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

func (*PortConfig) GetDescription 

func (m *PortConfig) GetDescription() string

func (*PortConfig) GetDevice 

func (m *PortConfig) GetDevice() *Device

func (*PortConfig) GetLocalProt 

func (m *PortConfig) GetLocalProt() int32

func (*PortConfig) GetMDNSInfo 

func (m *PortConfig) GetMDNSInfo() string

func (*PortConfig) GetRemotePort 

func (m *PortConfig) GetRemotePort() int32

func (*PortConfig) GetRemotePortStatus 

func (m *PortConfig) GetRemotePortStatus() bool

func (*PortConfig) ProtoMessage 

func (*PortConfig) ProtoMessage()

func (*PortConfig) Reset 

func (m *PortConfig) Reset()

func (*PortConfig) String 

func (m *PortConfig) String() string

func (*PortConfig) XXX_DiscardUnknown 

func (m *PortConfig) XXX_DiscardUnknown()

func (*PortConfig) XXX_Marshal 

func (m *PortConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PortConfig) XXX_Merge 

func (m *PortConfig) XXX_Merge(src proto.Message)

func (*PortConfig) XXX_Size 

func (m *PortConfig) XXX_Size() int

func (*PortConfig) XXX_Unmarshal 

func (m *PortConfig) XXX_Unmarshal(b []byte) error

type PortList 

type PortList struct {
	PortConfigs          []*PortConfig `protobuf:"bytes,1,rep,name=PortConfigs,proto3" json:"PortConfigs,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*PortList) Descriptor 

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

func (*PortList) GetPortConfigs 

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

func (*PortList) ProtoMessage 

func (*PortList) ProtoMessage()

func (*PortList) Reset 

func (m *PortList) Reset()

func (*PortList) String 

func (m *PortList) String() string

func (*PortList) XXX_DiscardUnknown 

func (m *PortList) XXX_DiscardUnknown()

func (*PortList) XXX_Marshal 

func (m *PortList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PortList) XXX_Merge 

func (m *PortList) XXX_Merge(src proto.Message)

func (*PortList) XXX_Size 

func (m *PortList) XXX_Size() int

func (*PortList) XXX_Unmarshal 

func (m *PortList) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SOCKS5Config) Descriptor 

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

func (*SOCKS5Config) GetDescription 

func (m *SOCKS5Config) GetDescription() string

func (*SOCKS5Config) GetEncType 

func (m *SOCKS5Config) GetEncType() string

func (*SOCKS5Config) GetPassword 

func (m *SOCKS5Config) GetPassword() string

func (*SOCKS5Config) GetPort 

func (m *SOCKS5Config) GetPort() int32

func (*SOCKS5Config) GetRunId 

func (m *SOCKS5Config) GetRunId() string

func (*SOCKS5Config) ProtoMessage 

func (*SOCKS5Config) ProtoMessage()

func (*SOCKS5Config) Reset 

func (m *SOCKS5Config) Reset()

func (*SOCKS5Config) String 

func (m *SOCKS5Config) String() string

func (*SOCKS5Config) XXX_DiscardUnknown 

func (m *SOCKS5Config) XXX_DiscardUnknown()

func (*SOCKS5Config) XXX_Marshal 

func (m *SOCKS5Config) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SOCKS5Config) XXX_Merge 

func (m *SOCKS5Config) XXX_Merge(src proto.Message)

func (*SOCKS5Config) XXX_Size 

func (m *SOCKS5Config) XXX_Size() int

func (*SOCKS5Config) XXX_Unmarshal 

func (m *SOCKS5Config) XXX_Unmarshal(b []byte) error

type SOCKS5List 

type SOCKS5List struct {
	SOCKS5Configs        []*SOCKS5Config `protobuf:"bytes,1,rep,name=SOCKS5Configs,proto3" json:"SOCKS5Configs,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*SOCKS5List) Descriptor 

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

func (*SOCKS5List) GetSOCKS5Configs 

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

func (*SOCKS5List) ProtoMessage 

func (*SOCKS5List) ProtoMessage()

func (*SOCKS5List) Reset 

func (m *SOCKS5List) Reset()

func (*SOCKS5List) String 

func (m *SOCKS5List) String() string

func (*SOCKS5List) XXX_DiscardUnknown 

func (m *SOCKS5List) XXX_DiscardUnknown()

func (*SOCKS5List) XXX_Marshal 

func (m *SOCKS5List) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SOCKS5List) XXX_Merge 

func (m *SOCKS5List) XXX_Merge(src proto.Message)

func (*SOCKS5List) XXX_Size 

func (m *SOCKS5List) XXX_Size() int

func (*SOCKS5List) XXX_Unmarshal 

func (m *SOCKS5List) XXX_Unmarshal(b []byte) error

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"`
	Description          string   `protobuf:"bytes,3,opt,name=Description,proto3" json:"Description,omitempty"`
	StatusToClient       bool     `protobuf:"varint,4,opt,name=StatusToClient,proto3" json:"StatusToClient,omitempty"`
	StatusP2PAsClient    bool     `protobuf:"varint,5,opt,name=StatusP2PAsClient,proto3" json:"StatusP2PAsClient,omitempty"`
	StatusP2PAsServer    bool     `protobuf:"varint,6,opt,name=StatusP2PAsServer,proto3" json:"StatusP2PAsServer,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

几种代理类型

func (*SessionConfig) Descriptor 

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

func (*SessionConfig) GetDescription 

func (m *SessionConfig) GetDescription() string

func (*SessionConfig) GetRunId 

func (m *SessionConfig) GetRunId() string

func (*SessionConfig) GetStatusP2PAsClient 

func (m *SessionConfig) GetStatusP2PAsClient() bool

func (*SessionConfig) GetStatusP2PAsServer 

func (m *SessionConfig) GetStatusP2PAsServer() bool

func (*SessionConfig) GetStatusToClient 

func (m *SessionConfig) GetStatusToClient() bool

func (*SessionConfig) GetToken 

func (m *SessionConfig) GetToken() string

func (*SessionConfig) ProtoMessage 

func (*SessionConfig) ProtoMessage()

func (*SessionConfig) Reset 

func (m *SessionConfig) Reset()

func (*SessionConfig) String 

func (m *SessionConfig) String() string

func (*SessionConfig) XXX_DiscardUnknown 

func (m *SessionConfig) XXX_DiscardUnknown()

func (*SessionConfig) XXX_Marshal 

func (m *SessionConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SessionConfig) XXX_Merge 

func (m *SessionConfig) XXX_Merge(src proto.Message)

func (*SessionConfig) XXX_Size 

func (m *SessionConfig) XXX_Size() int

func (*SessionConfig) XXX_Unmarshal 

func (m *SessionConfig) XXX_Unmarshal(b []byte) error

type SessionList 

type SessionList struct {
	SessionConfigs       []*SessionConfig `protobuf:"bytes,1,rep,name=SessionConfigs,proto3" json:"SessionConfigs,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*SessionList) Descriptor 

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

func (*SessionList) GetSessionConfigs 

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

func (*SessionList) ProtoMessage 

func (*SessionList) ProtoMessage()

func (*SessionList) Reset 

func (m *SessionList) Reset()

func (*SessionList) String 

func (m *SessionList) String() string

func (*SessionList) XXX_DiscardUnknown 

func (m *SessionList) XXX_DiscardUnknown()

func (*SessionList) XXX_Marshal 

func (m *SessionList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SessionList) XXX_Merge 

func (m *SessionList) XXX_Merge(src proto.Message)

func (*SessionList) XXX_Size 

func (m *SessionList) XXX_Size() int

func (*SessionList) XXX_Unmarshal 

func (m *SessionList) XXX_Unmarshal(b []byte) error

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) (*Empty, error)
	GetOneSession(ctx context.Context, in *SessionConfig, opts ...grpc.CallOption) (*SessionConfig, error)
	GetAllSession(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*SessionList, error)
	// Socks5
	CreateOneSOCKS5(ctx context.Context, in *SOCKS5Config, opts ...grpc.CallOption) (*SOCKS5Config, error)
	DeleteOneSOCKS5(ctx context.Context, in *SOCKS5Config, opts ...grpc.CallOption) (*Empty, error)
	GetOneSOCKS5(ctx context.Context, in *SOCKS5Config, opts ...grpc.CallOption) (*SOCKS5Config, error)
	//:TODO  获取所有的设备列表
	// mDNS刷新列表
	RefreshmDNSProxyList(ctx context.Context, in *SessionConfig, opts ...grpc.CallOption) (*Empty, error)
	// 获取通过mDNS自动映射的TCP端口列表，然后可以查看页面
	GetAllTCP(ctx context.Context, in *SessionConfig, opts ...grpc.CallOption) (*PortList, error)
}

SessionManagerClient is the client API for SessionManager service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewSessionManagerClient 

func NewSessionManagerClient(cc *grpc.ClientConn) SessionManagerClient

type SessionManagerServer 

type SessionManagerServer interface {
	// Sends a greeting
	CreateOneSession(context.Context, *SessionConfig) (*SessionConfig, error)
	DeleteOneSession(context.Context, *SessionConfig) (*Empty, error)
	GetOneSession(context.Context, *SessionConfig) (*SessionConfig, error)
	GetAllSession(context.Context, *Empty) (*SessionList, error)
	// Socks5
	CreateOneSOCKS5(context.Context, *SOCKS5Config) (*SOCKS5Config, error)
	DeleteOneSOCKS5(context.Context, *SOCKS5Config) (*Empty, error)
	GetOneSOCKS5(context.Context, *SOCKS5Config) (*SOCKS5Config, error)
	//:TODO  获取所有的设备列表
	// mDNS刷新列表
	RefreshmDNSProxyList(context.Context, *SessionConfig) (*Empty, error)
	// 获取通过mDNS自动映射的TCP端口列表，然后可以查看页面
	GetAllTCP(context.Context, *SessionConfig) (*PortList, error)
}

SessionManagerServer is the server API for SessionManager service.

type StringValue 

type StringValue struct {
	Value                string   `protobuf:"bytes,1,opt,name=Value,proto3" json:"Value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StringValue) Descriptor 

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

func (*StringValue) GetValue 

func (m *StringValue) GetValue() string

func (*StringValue) ProtoMessage 

func (*StringValue) ProtoMessage()

func (*StringValue) Reset 

func (m *StringValue) Reset()

func (*StringValue) String 

func (m *StringValue) String() string

func (*StringValue) XXX_DiscardUnknown 

func (m *StringValue) XXX_DiscardUnknown()

func (*StringValue) XXX_Marshal 

func (m *StringValue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StringValue) XXX_Merge 

func (m *StringValue) XXX_Merge(src proto.Message)

func (*StringValue) XXX_Size 

func (m *StringValue) XXX_Size() int

func (*StringValue) XXX_Unmarshal 

func (m *StringValue) XXX_Unmarshal(b []byte) error

type UnimplementedCommonDeviceManagerServer 

type UnimplementedCommonDeviceManagerServer struct {
}

UnimplementedCommonDeviceManagerServer can be embedded to have forward compatible implementations.

func (*UnimplementedCommonDeviceManagerServer) AddDevice 

func (*UnimplementedCommonDeviceManagerServer) AddDevice(ctx context.Context, req *Device) (*Empty, error)

func (*UnimplementedCommonDeviceManagerServer) CreateOneFTP 

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

func (*UnimplementedCommonDeviceManagerServer) CreateOneTCP 

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

func (*UnimplementedCommonDeviceManagerServer) CreateOneUDP 

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

func (*UnimplementedCommonDeviceManagerServer) DelDevice 

func (*UnimplementedCommonDeviceManagerServer) DelDevice(ctx context.Context, req *Device) (*Empty, error)

func (*UnimplementedCommonDeviceManagerServer) DeleteOneFTP 

func (*UnimplementedCommonDeviceManagerServer) DeleteOneFTP(ctx context.Context, req *PortConfig) (*Empty, error)

func (*UnimplementedCommonDeviceManagerServer) DeleteOneTCP 

func (*UnimplementedCommonDeviceManagerServer) DeleteOneTCP(ctx context.Context, req *PortConfig) (*Empty, error)

func (*UnimplementedCommonDeviceManagerServer) DeleteOneUDP 

func (*UnimplementedCommonDeviceManagerServer) DeleteOneUDP(ctx context.Context, req *PortConfig) (*Empty, error)

func (*UnimplementedCommonDeviceManagerServer) GetAllDevice 

func (*UnimplementedCommonDeviceManagerServer) GetAllDevice(ctx context.Context, req *Empty) (*DeviceList, error)

func (*UnimplementedCommonDeviceManagerServer) GetAllFTP 

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

func (*UnimplementedCommonDeviceManagerServer) GetAllTCP 

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

func (*UnimplementedCommonDeviceManagerServer) GetAllUDP 

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

func (*UnimplementedCommonDeviceManagerServer) GetOneFTP 

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

func (*UnimplementedCommonDeviceManagerServer) GetOneTCP 

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

func (*UnimplementedCommonDeviceManagerServer) GetOneUDP 

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

func (*UnimplementedCommonDeviceManagerServer) SetDeviceMac 

func (*UnimplementedCommonDeviceManagerServer) SetDeviceMac(ctx context.Context, req *Device) (*Empty, error)

func (*UnimplementedCommonDeviceManagerServer) WakeOnLAN 

func (*UnimplementedCommonDeviceManagerServer) WakeOnLAN(ctx context.Context, req *Device) (*Empty, error)

type UnimplementedHttpManagerServer 

type UnimplementedHttpManagerServer struct {
}

UnimplementedHttpManagerServer can be embedded to have forward compatible implementations.

func (*UnimplementedHttpManagerServer) CreateOneHTTP 

func (*UnimplementedHttpManagerServer) CreateOneHTTP(ctx context.Context, req *HTTPConfig) (*HTTPConfig, error)

func (*UnimplementedHttpManagerServer) DeleteOneHTTP 

func (*UnimplementedHttpManagerServer) DeleteOneHTTP(ctx context.Context, req *HTTPConfig) (*Empty, error)

func (*UnimplementedHttpManagerServer) GetAllHTTP 

func (*UnimplementedHttpManagerServer) GetAllHTTP(ctx context.Context, req *Empty) (*HTTPList, error)

func (*UnimplementedHttpManagerServer) GetOneHTTP 

func (*UnimplementedHttpManagerServer) GetOneHTTP(ctx context.Context, req *HTTPConfig) (*HTTPConfig, error)

type UnimplementedSessionManagerServer 

type UnimplementedSessionManagerServer struct {
}

UnimplementedSessionManagerServer can be embedded to have forward compatible implementations.

func (*UnimplementedSessionManagerServer) CreateOneSOCKS5 

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

func (*UnimplementedSessionManagerServer) CreateOneSession 

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

func (*UnimplementedSessionManagerServer) DeleteOneSOCKS5 

func (*UnimplementedSessionManagerServer) DeleteOneSOCKS5(ctx context.Context, req *SOCKS5Config) (*Empty, error)

func (*UnimplementedSessionManagerServer) DeleteOneSession 

func (*UnimplementedSessionManagerServer) DeleteOneSession(ctx context.Context, req *SessionConfig) (*Empty, error)

func (*UnimplementedSessionManagerServer) GetAllSession 

func (*UnimplementedSessionManagerServer) GetAllSession(ctx context.Context, req *Empty) (*SessionList, error)

func (*UnimplementedSessionManagerServer) GetAllTCP 

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

func (*UnimplementedSessionManagerServer) GetOneSOCKS5 

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

func (*UnimplementedSessionManagerServer) GetOneSession 

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

func (*UnimplementedSessionManagerServer) RefreshmDNSProxyList 

func (*UnimplementedSessionManagerServer) RefreshmDNSProxyList(ctx context.Context, req *SessionConfig) (*Empty, error)

type UnimplementedUtilsServer 

type UnimplementedUtilsServer struct {
}

UnimplementedUtilsServer can be embedded to have forward compatible implementations.

func (*UnimplementedUtilsServer) ConvertOctonaryUtf8 

func (*UnimplementedUtilsServer) ConvertOctonaryUtf8(ctx context.Context, req *StringValue) (*StringValue, error)

func (*UnimplementedUtilsServer) GetAllmDNSServiceList 

func (*UnimplementedUtilsServer) GetAllmDNSServiceList(ctx context.Context, req *Empty) (*MDNSServiceList, error)

func (*UnimplementedUtilsServer) GetmDNSServiceListByType 

func (*UnimplementedUtilsServer) GetmDNSServiceListByType(ctx context.Context, req *StringValue) (*MDNSServiceList, error)

type UtilsClient 

type UtilsClient interface {
	GetAllmDNSServiceList(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*MDNSServiceList, error)
	GetmDNSServiceListByType(ctx context.Context, in *StringValue, opts ...grpc.CallOption) (*MDNSServiceList, error)
	ConvertOctonaryUtf8(ctx context.Context, in *StringValue, opts ...grpc.CallOption) (*StringValue, error)
}

UtilsClient is the client API for Utils service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewUtilsClient 

func NewUtilsClient(cc *grpc.ClientConn) UtilsClient

type UtilsServer 

type UtilsServer interface {
	GetAllmDNSServiceList(context.Context, *Empty) (*MDNSServiceList, error)
	GetmDNSServiceListByType(context.Context, *StringValue) (*MDNSServiceList, error)
	ConvertOctonaryUtf8(context.Context, *StringValue) (*StringValue, error)
}

UtilsServer is the server API for Utils service.

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.