Documentation ¶
Index ¶
- Constants
- Variables
- func RegisterDaemonServer(s grpc.ServiceRegistrar, srv DaemonServer)
- type Clone
- func (*Clone) Descriptor() ([]byte, []int)deprecated
- func (x *Clone) GetCluster() string
- func (x *Clone) GetClusterID() string
- func (x *Clone) GetKubeconfig() string
- func (x *Clone) GetNamespace() string
- func (x *Clone) GetRuleList() []*CloneRule
- func (x *Clone) GetSyncthingGUIAddr() string
- func (x *Clone) GetWorkload() string
- func (*Clone) ProtoMessage()
- func (x *Clone) ProtoReflect() protoreflect.Message
- func (x *Clone) Reset()
- func (x *Clone) String() string
- type CloneRequest
- func (*CloneRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CloneRequest) GetEngine() string
- func (x *CloneRequest) GetExtraRoute() *ExtraRoute
- func (x *CloneRequest) GetHeaders() map[string]string
- func (x *CloneRequest) GetImage() string
- func (x *CloneRequest) GetIsChangeTargetRegistry() bool
- func (x *CloneRequest) GetKubeconfigBytes() string
- func (x *CloneRequest) GetLevel() int32
- func (x *CloneRequest) GetLocalDir() string
- func (x *CloneRequest) GetNamespace() string
- func (x *CloneRequest) GetOriginKubeconfigPath() string
- func (x *CloneRequest) GetRemoteDir() string
- func (x *CloneRequest) GetSshJump() *SshJump
- func (x *CloneRequest) GetTargetContainer() string
- func (x *CloneRequest) GetTargetImage() string
- func (x *CloneRequest) GetTargetKubeconfig() string
- func (x *CloneRequest) GetTargetNamespace() string
- func (x *CloneRequest) GetTargetRegistry() string
- func (x *CloneRequest) GetTransferImage() bool
- func (x *CloneRequest) GetWorkloads() []string
- func (*CloneRequest) ProtoMessage()
- func (x *CloneRequest) ProtoReflect() protoreflect.Message
- func (x *CloneRequest) Reset()
- func (x *CloneRequest) String() string
- type CloneResponse
- type CloneRule
- func (*CloneRule) Descriptor() ([]byte, []int)deprecated
- func (x *CloneRule) GetDstCluster() string
- func (x *CloneRule) GetDstClusterID() string
- func (x *CloneRule) GetDstKubeconfig() string
- func (x *CloneRule) GetDstNamespace() string
- func (x *CloneRule) GetDstWorkload() string
- func (x *CloneRule) GetHeaders() map[string]string
- func (*CloneRule) ProtoMessage()
- func (x *CloneRule) ProtoReflect() protoreflect.Message
- func (x *CloneRule) Reset()
- func (x *CloneRule) String() string
- type ConfigAddRequest
- func (*ConfigAddRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ConfigAddRequest) GetKubeconfigBytes() string
- func (x *ConfigAddRequest) GetNamespace() string
- func (x *ConfigAddRequest) GetSshJump() *SshJump
- func (*ConfigAddRequest) ProtoMessage()
- func (x *ConfigAddRequest) ProtoReflect() protoreflect.Message
- func (x *ConfigAddRequest) Reset()
- func (x *ConfigAddRequest) String() string
- type ConfigAddResponse
- type ConfigRemoveRequest
- func (*ConfigRemoveRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ConfigRemoveRequest) GetClusterID() string
- func (*ConfigRemoveRequest) ProtoMessage()
- func (x *ConfigRemoveRequest) ProtoReflect() protoreflect.Message
- func (x *ConfigRemoveRequest) Reset()
- func (x *ConfigRemoveRequest) String() string
- type ConfigRemoveResponse
- type ConnectRequest
- func (*ConnectRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ConnectRequest) GetEngine() string
- func (x *ConnectRequest) GetExtraRoute() *ExtraRoute
- func (x *ConnectRequest) GetForeground() bool
- func (x *ConnectRequest) GetHeaders() map[string]string
- func (x *ConnectRequest) GetImage() string
- func (x *ConnectRequest) GetKubeconfigBytes() string
- func (x *ConnectRequest) GetLevel() int32
- func (x *ConnectRequest) GetNamespace() string
- func (x *ConnectRequest) GetOriginKubeconfigPath() string
- func (x *ConnectRequest) GetPortMap() []string
- func (x *ConnectRequest) GetSshJump() *SshJump
- func (x *ConnectRequest) GetTransferImage() bool
- func (x *ConnectRequest) GetWorkloads() []string
- func (*ConnectRequest) ProtoMessage()
- func (x *ConnectRequest) ProtoReflect() protoreflect.Message
- func (x *ConnectRequest) Reset()
- func (x *ConnectRequest) String() string
- type ConnectResponse
- type DaemonClient
- type DaemonServer
- type Daemon_CloneClient
- type Daemon_CloneServer
- type Daemon_ConnectClient
- type Daemon_ConnectForkClient
- type Daemon_ConnectForkServer
- type Daemon_ConnectServer
- type Daemon_DisconnectClient
- type Daemon_DisconnectServer
- type Daemon_LeaveClient
- type Daemon_LeaveServer
- type Daemon_LogsClient
- type Daemon_LogsServer
- type Daemon_ProxyClient
- type Daemon_ProxyServer
- type Daemon_QuitClient
- type Daemon_QuitServer
- type Daemon_RemoveClient
- type Daemon_RemoveServer
- type Daemon_ResetClient
- type Daemon_ResetServer
- type Daemon_SshConnectClient
- type Daemon_SshConnectServer
- type DisconnectRequest
- func (*DisconnectRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DisconnectRequest) GetAll() bool
- func (x *DisconnectRequest) GetClusterIDs() []string
- func (x *DisconnectRequest) GetID() int32
- func (x *DisconnectRequest) GetKubeconfigBytes() string
- func (x *DisconnectRequest) GetNamespace() string
- func (x *DisconnectRequest) GetSshJump() *SshJump
- func (*DisconnectRequest) ProtoMessage()
- func (x *DisconnectRequest) ProtoReflect() protoreflect.Message
- func (x *DisconnectRequest) Reset()
- func (x *DisconnectRequest) String() string
- type DisconnectResponse
- func (*DisconnectResponse) Descriptor() ([]byte, []int)deprecated
- func (x *DisconnectResponse) GetMessage() string
- func (*DisconnectResponse) ProtoMessage()
- func (x *DisconnectResponse) ProtoReflect() protoreflect.Message
- func (x *DisconnectResponse) Reset()
- func (x *DisconnectResponse) String() string
- type ExtraRoute
- func (*ExtraRoute) Descriptor() ([]byte, []int)deprecated
- func (x *ExtraRoute) GetExtraCIDR() []string
- func (x *ExtraRoute) GetExtraDomain() []string
- func (x *ExtraRoute) GetExtraNodeIP() bool
- func (*ExtraRoute) ProtoMessage()
- func (x *ExtraRoute) ProtoReflect() protoreflect.Message
- func (x *ExtraRoute) Reset()
- func (x *ExtraRoute) String() string
- type GetRequest
- type GetResponse
- type IdentifyRequest
- type IdentifyResponse
- type LeaveRequest
- type LeaveResponse
- type ListRequest
- type ListResponse
- type LogRequest
- type LogResponse
- type Proxy
- func (*Proxy) Descriptor() ([]byte, []int)deprecated
- func (x *Proxy) GetCluster() string
- func (x *Proxy) GetClusterID() string
- func (x *Proxy) GetKubeconfig() string
- func (x *Proxy) GetNamespace() string
- func (x *Proxy) GetRuleList() []*ProxyRule
- func (x *Proxy) GetWorkload() string
- func (*Proxy) ProtoMessage()
- func (x *Proxy) ProtoReflect() protoreflect.Message
- func (x *Proxy) Reset()
- func (x *Proxy) String() string
- type ProxyRule
- func (*ProxyRule) Descriptor() ([]byte, []int)deprecated
- func (x *ProxyRule) GetCurrentDevice() bool
- func (x *ProxyRule) GetHeaders() map[string]string
- func (x *ProxyRule) GetLocalTunIPv4() string
- func (x *ProxyRule) GetLocalTunIPv6() string
- func (x *ProxyRule) GetPortMap() map[int32]int32
- func (*ProxyRule) ProtoMessage()
- func (x *ProxyRule) ProtoReflect() protoreflect.Message
- func (x *ProxyRule) Reset()
- func (x *ProxyRule) String() string
- type QuitRequest
- type QuitResponse
- type RemoveRequest
- type RemoveResponse
- type ResetRequest
- func (*ResetRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ResetRequest) GetKubeconfigBytes() string
- func (x *ResetRequest) GetNamespace() string
- func (x *ResetRequest) GetSshJump() *SshJump
- func (*ResetRequest) ProtoMessage()
- func (x *ResetRequest) ProtoReflect() protoreflect.Message
- func (x *ResetRequest) Reset()
- func (x *ResetRequest) String() string
- type ResetResponse
- type SshConnectRequest
- func (*SshConnectRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SshConnectRequest) GetSshJump() *SshJump
- func (x *SshConnectRequest) GetStdin() string
- func (*SshConnectRequest) ProtoMessage()
- func (x *SshConnectRequest) ProtoReflect() protoreflect.Message
- func (x *SshConnectRequest) Reset()
- func (x *SshConnectRequest) String() string
- type SshConnectResponse
- func (*SshConnectResponse) Descriptor() ([]byte, []int)deprecated
- func (x *SshConnectResponse) GetStderr() string
- func (x *SshConnectResponse) GetStdout() string
- func (*SshConnectResponse) ProtoMessage()
- func (x *SshConnectResponse) ProtoReflect() protoreflect.Message
- func (x *SshConnectResponse) Reset()
- func (x *SshConnectResponse) String() string
- type SshJump
- func (*SshJump) Descriptor() ([]byte, []int)deprecated
- func (x *SshJump) GetAddr() string
- func (x *SshJump) GetConfigAlias() string
- func (x *SshJump) GetGSSAPICacheFile() string
- func (x *SshJump) GetGSSAPIKeytabConf() string
- func (x *SshJump) GetGSSAPIPassword() string
- func (x *SshJump) GetJump() string
- func (x *SshJump) GetKeyfile() string
- func (x *SshJump) GetPassword() string
- func (x *SshJump) GetRemoteKubeconfig() string
- func (x *SshJump) GetUser() string
- func (*SshJump) ProtoMessage()
- func (x *SshJump) ProtoReflect() protoreflect.Message
- func (x *SshJump) Reset()
- func (x *SshJump) String() string
- type SshStartRequest
- type SshStartResponse
- type SshStopRequest
- type SshStopResponse
- type Status
- func (*Status) Descriptor() ([]byte, []int)deprecated
- func (x *Status) GetCloneList() []*Clone
- func (x *Status) GetCluster() string
- func (x *Status) GetClusterID() string
- func (x *Status) GetID() int32
- func (x *Status) GetKubeconfig() string
- func (x *Status) GetMode() string
- func (x *Status) GetNamespace() string
- func (x *Status) GetNetif() string
- func (x *Status) GetProxyList() []*Proxy
- func (x *Status) GetStatus() string
- func (*Status) ProtoMessage()
- func (x *Status) ProtoReflect() protoreflect.Message
- func (x *Status) Reset()
- func (x *Status) String() string
- type StatusRequest
- type StatusResponse
- type UnimplementedDaemonServer
- func (UnimplementedDaemonServer) Clone(*CloneRequest, Daemon_CloneServer) error
- func (UnimplementedDaemonServer) ConfigAdd(context.Context, *ConfigAddRequest) (*ConfigAddResponse, error)
- func (UnimplementedDaemonServer) ConfigRemove(context.Context, *ConfigRemoveRequest) (*ConfigRemoveResponse, error)
- func (UnimplementedDaemonServer) Connect(*ConnectRequest, Daemon_ConnectServer) error
- func (UnimplementedDaemonServer) ConnectFork(*ConnectRequest, Daemon_ConnectForkServer) error
- func (UnimplementedDaemonServer) Disconnect(*DisconnectRequest, Daemon_DisconnectServer) error
- func (UnimplementedDaemonServer) Get(context.Context, *GetRequest) (*GetResponse, error)
- func (UnimplementedDaemonServer) Identify(context.Context, *IdentifyRequest) (*IdentifyResponse, error)
- func (UnimplementedDaemonServer) Leave(*LeaveRequest, Daemon_LeaveServer) error
- func (UnimplementedDaemonServer) List(context.Context, *ListRequest) (*ListResponse, error)
- func (UnimplementedDaemonServer) Logs(*LogRequest, Daemon_LogsServer) error
- func (UnimplementedDaemonServer) Proxy(*ConnectRequest, Daemon_ProxyServer) error
- func (UnimplementedDaemonServer) Quit(*QuitRequest, Daemon_QuitServer) error
- func (UnimplementedDaemonServer) Remove(*RemoveRequest, Daemon_RemoveServer) error
- func (UnimplementedDaemonServer) Reset(*ResetRequest, Daemon_ResetServer) error
- func (UnimplementedDaemonServer) SshConnect(Daemon_SshConnectServer) error
- func (UnimplementedDaemonServer) SshStart(context.Context, *SshStartRequest) (*SshStartResponse, error)
- func (UnimplementedDaemonServer) SshStop(context.Context, *SshStopRequest) (*SshStopResponse, error)
- func (UnimplementedDaemonServer) Status(context.Context, *StatusRequest) (*StatusResponse, error)
- func (UnimplementedDaemonServer) Upgrade(context.Context, *UpgradeRequest) (*UpgradeResponse, error)
- func (UnimplementedDaemonServer) Version(context.Context, *VersionRequest) (*VersionResponse, error)
- type UnsafeDaemonServer
- type UpgradeRequest
- type UpgradeResponse
- type VersionRequest
- type VersionResponse
Constants ¶
const ( Daemon_Connect_FullMethodName = "/rpc.Daemon/Connect" Daemon_ConnectFork_FullMethodName = "/rpc.Daemon/ConnectFork" Daemon_Disconnect_FullMethodName = "/rpc.Daemon/Disconnect" Daemon_Proxy_FullMethodName = "/rpc.Daemon/Proxy" Daemon_Leave_FullMethodName = "/rpc.Daemon/Leave" Daemon_Clone_FullMethodName = "/rpc.Daemon/Clone" Daemon_Remove_FullMethodName = "/rpc.Daemon/Remove" Daemon_ConfigAdd_FullMethodName = "/rpc.Daemon/ConfigAdd" Daemon_ConfigRemove_FullMethodName = "/rpc.Daemon/ConfigRemove" Daemon_SshStart_FullMethodName = "/rpc.Daemon/SshStart" Daemon_SshStop_FullMethodName = "/rpc.Daemon/SshStop" Daemon_SshConnect_FullMethodName = "/rpc.Daemon/SshConnect" Daemon_Logs_FullMethodName = "/rpc.Daemon/Logs" Daemon_List_FullMethodName = "/rpc.Daemon/List" Daemon_Get_FullMethodName = "/rpc.Daemon/Get" Daemon_Upgrade_FullMethodName = "/rpc.Daemon/Upgrade" Daemon_Status_FullMethodName = "/rpc.Daemon/Status" Daemon_Version_FullMethodName = "/rpc.Daemon/Version" Daemon_Reset_FullMethodName = "/rpc.Daemon/Reset" Daemon_Quit_FullMethodName = "/rpc.Daemon/Quit" Daemon_Identify_FullMethodName = "/rpc.Daemon/Identify" )
Variables ¶
var Daemon_ServiceDesc = grpc.ServiceDesc{ ServiceName: "rpc.Daemon", HandlerType: (*DaemonServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "ConfigAdd", Handler: _Daemon_ConfigAdd_Handler, }, { MethodName: "ConfigRemove", Handler: _Daemon_ConfigRemove_Handler, }, { MethodName: "SshStart", Handler: _Daemon_SshStart_Handler, }, { MethodName: "SshStop", Handler: _Daemon_SshStop_Handler, }, { MethodName: "List", Handler: _Daemon_List_Handler, }, { MethodName: "Get", Handler: _Daemon_Get_Handler, }, { MethodName: "Upgrade", Handler: _Daemon_Upgrade_Handler, }, { MethodName: "Status", Handler: _Daemon_Status_Handler, }, { MethodName: "Version", Handler: _Daemon_Version_Handler, }, { MethodName: "Identify", Handler: _Daemon_Identify_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "Connect", Handler: _Daemon_Connect_Handler, ServerStreams: true, }, { StreamName: "ConnectFork", Handler: _Daemon_ConnectFork_Handler, ServerStreams: true, }, { StreamName: "Disconnect", Handler: _Daemon_Disconnect_Handler, ServerStreams: true, }, { StreamName: "Proxy", Handler: _Daemon_Proxy_Handler, ServerStreams: true, }, { StreamName: "Leave", Handler: _Daemon_Leave_Handler, ServerStreams: true, }, { StreamName: "Clone", Handler: _Daemon_Clone_Handler, ServerStreams: true, }, { StreamName: "Remove", Handler: _Daemon_Remove_Handler, ServerStreams: true, }, { StreamName: "SshConnect", Handler: _Daemon_SshConnect_Handler, ServerStreams: true, ClientStreams: true, }, { StreamName: "Logs", Handler: _Daemon_Logs_Handler, ServerStreams: true, }, { StreamName: "Reset", Handler: _Daemon_Reset_Handler, ServerStreams: true, }, { StreamName: "Quit", Handler: _Daemon_Quit_Handler, ServerStreams: true, }, }, Metadata: "daemon.proto", }
Daemon_ServiceDesc is the grpc.ServiceDesc for Daemon service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_daemon_proto protoreflect.FileDescriptor
Functions ¶
func RegisterDaemonServer ¶
func RegisterDaemonServer(s grpc.ServiceRegistrar, srv DaemonServer)
Types ¶
type Clone ¶ added in v2.2.8
type Clone struct { ClusterID string `protobuf:"bytes,1,opt,name=ClusterID,proto3" json:"ClusterID,omitempty"` Cluster string `protobuf:"bytes,2,opt,name=Cluster,proto3" json:"Cluster,omitempty"` Kubeconfig string `protobuf:"bytes,3,opt,name=Kubeconfig,proto3" json:"Kubeconfig,omitempty"` Namespace string `protobuf:"bytes,4,opt,name=Namespace,proto3" json:"Namespace,omitempty"` Workload string `protobuf:"bytes,5,opt,name=Workload,proto3" json:"Workload,omitempty"` SyncthingGUIAddr string `protobuf:"bytes,6,opt,name=SyncthingGUIAddr,proto3" json:"SyncthingGUIAddr,omitempty"` RuleList []*CloneRule `protobuf:"bytes,7,rep,name=RuleList,proto3" json:"RuleList,omitempty"` // contains filtered or unexported fields }
func (*Clone) Descriptor
deprecated
added in
v2.2.8
func (*Clone) GetCluster ¶ added in v2.2.8
func (*Clone) GetClusterID ¶ added in v2.2.8
func (*Clone) GetKubeconfig ¶ added in v2.2.8
func (*Clone) GetNamespace ¶ added in v2.2.8
func (*Clone) GetRuleList ¶ added in v2.2.8
func (*Clone) GetSyncthingGUIAddr ¶ added in v2.2.11
func (*Clone) GetWorkload ¶ added in v2.2.8
func (*Clone) ProtoMessage ¶ added in v2.2.8
func (*Clone) ProtoMessage()
func (*Clone) ProtoReflect ¶ added in v2.2.8
func (x *Clone) ProtoReflect() protoreflect.Message
type CloneRequest ¶
type CloneRequest struct { KubeconfigBytes string `protobuf:"bytes,1,opt,name=KubeconfigBytes,proto3" json:"KubeconfigBytes,omitempty"` Namespace string `protobuf:"bytes,2,opt,name=Namespace,proto3" json:"Namespace,omitempty"` Headers map[string]string `` /* 155-byte string literal not displayed */ Workloads []string `protobuf:"bytes,4,rep,name=Workloads,proto3" json:"Workloads,omitempty"` Engine string `protobuf:"bytes,6,opt,name=Engine,proto3" json:"Engine,omitempty"` // extra route table info ExtraRoute *ExtraRoute `protobuf:"bytes,7,opt,name=ExtraRoute,proto3" json:"ExtraRoute,omitempty"` // ssh jump SshJump *SshJump `protobuf:"bytes,8,opt,name=SshJump,proto3" json:"SshJump,omitempty"` // target cluster info TargetKubeconfig string `protobuf:"bytes,9,opt,name=TargetKubeconfig,proto3" json:"TargetKubeconfig,omitempty"` TargetNamespace string `protobuf:"bytes,10,opt,name=TargetNamespace,proto3" json:"TargetNamespace,omitempty"` TargetContainer string `protobuf:"bytes,11,opt,name=TargetContainer,proto3" json:"TargetContainer,omitempty"` TargetImage string `protobuf:"bytes,12,opt,name=TargetImage,proto3" json:"TargetImage,omitempty"` TargetRegistry string `protobuf:"bytes,13,opt,name=TargetRegistry,proto3" json:"TargetRegistry,omitempty"` IsChangeTargetRegistry bool `protobuf:"varint,14,opt,name=IsChangeTargetRegistry,proto3" json:"IsChangeTargetRegistry,omitempty"` // transfer image TransferImage bool `protobuf:"varint,15,opt,name=TransferImage,proto3" json:"TransferImage,omitempty"` Image string `protobuf:"bytes,16,opt,name=Image,proto3" json:"Image,omitempty"` // log level Level int32 `protobuf:"varint,17,opt,name=Level,proto3" json:"Level,omitempty"` OriginKubeconfigPath string `protobuf:"bytes,18,opt,name=OriginKubeconfigPath,proto3" json:"OriginKubeconfigPath,omitempty"` LocalDir string `protobuf:"bytes,19,opt,name=LocalDir,proto3" json:"LocalDir,omitempty"` RemoteDir string `protobuf:"bytes,20,opt,name=RemoteDir,proto3" json:"RemoteDir,omitempty"` // contains filtered or unexported fields }
func (*CloneRequest) Descriptor
deprecated
func (*CloneRequest) Descriptor() ([]byte, []int)
Deprecated: Use CloneRequest.ProtoReflect.Descriptor instead.
func (*CloneRequest) GetEngine ¶
func (x *CloneRequest) GetEngine() string
func (*CloneRequest) GetExtraRoute ¶ added in v2.2.3
func (x *CloneRequest) GetExtraRoute() *ExtraRoute
func (*CloneRequest) GetHeaders ¶
func (x *CloneRequest) GetHeaders() map[string]string
func (*CloneRequest) GetImage ¶
func (x *CloneRequest) GetImage() string
func (*CloneRequest) GetIsChangeTargetRegistry ¶
func (x *CloneRequest) GetIsChangeTargetRegistry() bool
func (*CloneRequest) GetKubeconfigBytes ¶
func (x *CloneRequest) GetKubeconfigBytes() string
func (*CloneRequest) GetLevel ¶
func (x *CloneRequest) GetLevel() int32
func (*CloneRequest) GetLocalDir ¶ added in v2.2.11
func (x *CloneRequest) GetLocalDir() string
func (*CloneRequest) GetNamespace ¶
func (x *CloneRequest) GetNamespace() string
func (*CloneRequest) GetOriginKubeconfigPath ¶
func (x *CloneRequest) GetOriginKubeconfigPath() string
func (*CloneRequest) GetRemoteDir ¶ added in v2.2.11
func (x *CloneRequest) GetRemoteDir() string
func (*CloneRequest) GetSshJump ¶
func (x *CloneRequest) GetSshJump() *SshJump
func (*CloneRequest) GetTargetContainer ¶
func (x *CloneRequest) GetTargetContainer() string
func (*CloneRequest) GetTargetImage ¶
func (x *CloneRequest) GetTargetImage() string
func (*CloneRequest) GetTargetKubeconfig ¶
func (x *CloneRequest) GetTargetKubeconfig() string
func (*CloneRequest) GetTargetNamespace ¶
func (x *CloneRequest) GetTargetNamespace() string
func (*CloneRequest) GetTargetRegistry ¶
func (x *CloneRequest) GetTargetRegistry() string
func (*CloneRequest) GetTransferImage ¶
func (x *CloneRequest) GetTransferImage() bool
func (*CloneRequest) GetWorkloads ¶
func (x *CloneRequest) GetWorkloads() []string
func (*CloneRequest) ProtoMessage ¶
func (*CloneRequest) ProtoMessage()
func (*CloneRequest) ProtoReflect ¶
func (x *CloneRequest) ProtoReflect() protoreflect.Message
func (*CloneRequest) Reset ¶
func (x *CloneRequest) Reset()
func (*CloneRequest) String ¶
func (x *CloneRequest) String() string
type CloneResponse ¶
type CloneResponse struct { Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"` // contains filtered or unexported fields }
func (*CloneResponse) Descriptor
deprecated
func (*CloneResponse) Descriptor() ([]byte, []int)
Deprecated: Use CloneResponse.ProtoReflect.Descriptor instead.
func (*CloneResponse) GetMessage ¶
func (x *CloneResponse) GetMessage() string
func (*CloneResponse) ProtoMessage ¶
func (*CloneResponse) ProtoMessage()
func (*CloneResponse) ProtoReflect ¶
func (x *CloneResponse) ProtoReflect() protoreflect.Message
func (*CloneResponse) Reset ¶
func (x *CloneResponse) Reset()
func (*CloneResponse) String ¶
func (x *CloneResponse) String() string
type CloneRule ¶ added in v2.2.8
type CloneRule struct { Headers map[string]string `` /* 155-byte string literal not displayed */ DstClusterID string `protobuf:"bytes,9,opt,name=DstClusterID,proto3" json:"DstClusterID,omitempty"` DstCluster string `protobuf:"bytes,10,opt,name=DstCluster,proto3" json:"DstCluster,omitempty"` DstKubeconfig string `protobuf:"bytes,11,opt,name=DstKubeconfig,proto3" json:"DstKubeconfig,omitempty"` DstNamespace string `protobuf:"bytes,12,opt,name=DstNamespace,proto3" json:"DstNamespace,omitempty"` DstWorkload string `protobuf:"bytes,13,opt,name=DstWorkload,proto3" json:"DstWorkload,omitempty"` // contains filtered or unexported fields }
func (*CloneRule) Descriptor
deprecated
added in
v2.2.8
func (*CloneRule) GetDstCluster ¶ added in v2.2.8
func (*CloneRule) GetDstClusterID ¶ added in v2.2.8
func (*CloneRule) GetDstKubeconfig ¶ added in v2.2.8
func (*CloneRule) GetDstNamespace ¶ added in v2.2.8
func (*CloneRule) GetDstWorkload ¶ added in v2.2.8
func (*CloneRule) GetHeaders ¶ added in v2.2.8
func (*CloneRule) ProtoMessage ¶ added in v2.2.8
func (*CloneRule) ProtoMessage()
func (*CloneRule) ProtoReflect ¶ added in v2.2.8
func (x *CloneRule) ProtoReflect() protoreflect.Message
type ConfigAddRequest ¶
type ConfigAddRequest struct { KubeconfigBytes string `protobuf:"bytes,1,opt,name=KubeconfigBytes,proto3" json:"KubeconfigBytes,omitempty"` Namespace string `protobuf:"bytes,2,opt,name=Namespace,proto3" json:"Namespace,omitempty"` // ssh jump SshJump *SshJump `protobuf:"bytes,3,opt,name=SshJump,proto3" json:"SshJump,omitempty"` // contains filtered or unexported fields }
func (*ConfigAddRequest) Descriptor
deprecated
func (*ConfigAddRequest) Descriptor() ([]byte, []int)
Deprecated: Use ConfigAddRequest.ProtoReflect.Descriptor instead.
func (*ConfigAddRequest) GetKubeconfigBytes ¶
func (x *ConfigAddRequest) GetKubeconfigBytes() string
func (*ConfigAddRequest) GetNamespace ¶
func (x *ConfigAddRequest) GetNamespace() string
func (*ConfigAddRequest) GetSshJump ¶
func (x *ConfigAddRequest) GetSshJump() *SshJump
func (*ConfigAddRequest) ProtoMessage ¶
func (*ConfigAddRequest) ProtoMessage()
func (*ConfigAddRequest) ProtoReflect ¶
func (x *ConfigAddRequest) ProtoReflect() protoreflect.Message
func (*ConfigAddRequest) Reset ¶
func (x *ConfigAddRequest) Reset()
func (*ConfigAddRequest) String ¶
func (x *ConfigAddRequest) String() string
type ConfigAddResponse ¶
type ConfigAddResponse struct { ClusterID string `protobuf:"bytes,1,opt,name=ClusterID,proto3" json:"ClusterID,omitempty"` // contains filtered or unexported fields }
func (*ConfigAddResponse) Descriptor
deprecated
func (*ConfigAddResponse) Descriptor() ([]byte, []int)
Deprecated: Use ConfigAddResponse.ProtoReflect.Descriptor instead.
func (*ConfigAddResponse) GetClusterID ¶
func (x *ConfigAddResponse) GetClusterID() string
func (*ConfigAddResponse) ProtoMessage ¶
func (*ConfigAddResponse) ProtoMessage()
func (*ConfigAddResponse) ProtoReflect ¶
func (x *ConfigAddResponse) ProtoReflect() protoreflect.Message
func (*ConfigAddResponse) Reset ¶
func (x *ConfigAddResponse) Reset()
func (*ConfigAddResponse) String ¶
func (x *ConfigAddResponse) String() string
type ConfigRemoveRequest ¶
type ConfigRemoveRequest struct { ClusterID string `protobuf:"bytes,1,opt,name=ClusterID,proto3" json:"ClusterID,omitempty"` // contains filtered or unexported fields }
func (*ConfigRemoveRequest) Descriptor
deprecated
func (*ConfigRemoveRequest) Descriptor() ([]byte, []int)
Deprecated: Use ConfigRemoveRequest.ProtoReflect.Descriptor instead.
func (*ConfigRemoveRequest) GetClusterID ¶
func (x *ConfigRemoveRequest) GetClusterID() string
func (*ConfigRemoveRequest) ProtoMessage ¶
func (*ConfigRemoveRequest) ProtoMessage()
func (*ConfigRemoveRequest) ProtoReflect ¶
func (x *ConfigRemoveRequest) ProtoReflect() protoreflect.Message
func (*ConfigRemoveRequest) Reset ¶
func (x *ConfigRemoveRequest) Reset()
func (*ConfigRemoveRequest) String ¶
func (x *ConfigRemoveRequest) String() string
type ConfigRemoveResponse ¶
type ConfigRemoveResponse struct {
// contains filtered or unexported fields
}
func (*ConfigRemoveResponse) Descriptor
deprecated
func (*ConfigRemoveResponse) Descriptor() ([]byte, []int)
Deprecated: Use ConfigRemoveResponse.ProtoReflect.Descriptor instead.
func (*ConfigRemoveResponse) ProtoMessage ¶
func (*ConfigRemoveResponse) ProtoMessage()
func (*ConfigRemoveResponse) ProtoReflect ¶
func (x *ConfigRemoveResponse) ProtoReflect() protoreflect.Message
func (*ConfigRemoveResponse) Reset ¶
func (x *ConfigRemoveResponse) Reset()
func (*ConfigRemoveResponse) String ¶
func (x *ConfigRemoveResponse) String() string
type ConnectRequest ¶
type ConnectRequest struct { KubeconfigBytes string `protobuf:"bytes,1,opt,name=KubeconfigBytes,proto3" json:"KubeconfigBytes,omitempty"` Namespace string `protobuf:"bytes,2,opt,name=Namespace,proto3" json:"Namespace,omitempty"` Headers map[string]string `` /* 155-byte string literal not displayed */ PortMap []string `protobuf:"bytes,4,rep,name=PortMap,proto3" json:"PortMap,omitempty"` Workloads []string `protobuf:"bytes,5,rep,name=Workloads,proto3" json:"Workloads,omitempty"` Engine string `protobuf:"bytes,7,opt,name=Engine,proto3" json:"Engine,omitempty"` // extra route table info ExtraRoute *ExtraRoute `protobuf:"bytes,8,opt,name=ExtraRoute,proto3" json:"ExtraRoute,omitempty"` // ssh jump SshJump *SshJump `protobuf:"bytes,9,opt,name=SshJump,proto3" json:"SshJump,omitempty"` // transfer image TransferImage bool `protobuf:"varint,10,opt,name=TransferImage,proto3" json:"TransferImage,omitempty"` Image string `protobuf:"bytes,11,opt,name=Image,proto3" json:"Image,omitempty"` // foreground Foreground bool `protobuf:"varint,12,opt,name=Foreground,proto3" json:"Foreground,omitempty"` // log level Level int32 `protobuf:"varint,13,opt,name=Level,proto3" json:"Level,omitempty"` OriginKubeconfigPath string `protobuf:"bytes,14,opt,name=OriginKubeconfigPath,proto3" json:"OriginKubeconfigPath,omitempty"` // contains filtered or unexported fields }
func (*ConnectRequest) Descriptor
deprecated
func (*ConnectRequest) Descriptor() ([]byte, []int)
Deprecated: Use ConnectRequest.ProtoReflect.Descriptor instead.
func (*ConnectRequest) GetEngine ¶
func (x *ConnectRequest) GetEngine() string
func (*ConnectRequest) GetExtraRoute ¶ added in v2.2.3
func (x *ConnectRequest) GetExtraRoute() *ExtraRoute
func (*ConnectRequest) GetForeground ¶
func (x *ConnectRequest) GetForeground() bool
func (*ConnectRequest) GetHeaders ¶
func (x *ConnectRequest) GetHeaders() map[string]string
func (*ConnectRequest) GetImage ¶
func (x *ConnectRequest) GetImage() string
func (*ConnectRequest) GetKubeconfigBytes ¶
func (x *ConnectRequest) GetKubeconfigBytes() string
func (*ConnectRequest) GetLevel ¶
func (x *ConnectRequest) GetLevel() int32
func (*ConnectRequest) GetNamespace ¶
func (x *ConnectRequest) GetNamespace() string
func (*ConnectRequest) GetOriginKubeconfigPath ¶
func (x *ConnectRequest) GetOriginKubeconfigPath() string
func (*ConnectRequest) GetPortMap ¶ added in v2.2.3
func (x *ConnectRequest) GetPortMap() []string
func (*ConnectRequest) GetSshJump ¶
func (x *ConnectRequest) GetSshJump() *SshJump
func (*ConnectRequest) GetTransferImage ¶
func (x *ConnectRequest) GetTransferImage() bool
func (*ConnectRequest) GetWorkloads ¶
func (x *ConnectRequest) GetWorkloads() []string
func (*ConnectRequest) ProtoMessage ¶
func (*ConnectRequest) ProtoMessage()
func (*ConnectRequest) ProtoReflect ¶
func (x *ConnectRequest) ProtoReflect() protoreflect.Message
func (*ConnectRequest) Reset ¶
func (x *ConnectRequest) Reset()
func (*ConnectRequest) String ¶
func (x *ConnectRequest) String() string
type ConnectResponse ¶
type ConnectResponse struct { Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"` // contains filtered or unexported fields }
func (*ConnectResponse) Descriptor
deprecated
func (*ConnectResponse) Descriptor() ([]byte, []int)
Deprecated: Use ConnectResponse.ProtoReflect.Descriptor instead.
func (*ConnectResponse) GetMessage ¶
func (x *ConnectResponse) GetMessage() string
func (*ConnectResponse) ProtoMessage ¶
func (*ConnectResponse) ProtoMessage()
func (*ConnectResponse) ProtoReflect ¶
func (x *ConnectResponse) ProtoReflect() protoreflect.Message
func (*ConnectResponse) Reset ¶
func (x *ConnectResponse) Reset()
func (*ConnectResponse) String ¶
func (x *ConnectResponse) String() string
type DaemonClient ¶
type DaemonClient interface { Connect(ctx context.Context, in *ConnectRequest, opts ...grpc.CallOption) (Daemon_ConnectClient, error) ConnectFork(ctx context.Context, in *ConnectRequest, opts ...grpc.CallOption) (Daemon_ConnectForkClient, error) Disconnect(ctx context.Context, in *DisconnectRequest, opts ...grpc.CallOption) (Daemon_DisconnectClient, error) Proxy(ctx context.Context, in *ConnectRequest, opts ...grpc.CallOption) (Daemon_ProxyClient, error) Leave(ctx context.Context, in *LeaveRequest, opts ...grpc.CallOption) (Daemon_LeaveClient, error) Clone(ctx context.Context, in *CloneRequest, opts ...grpc.CallOption) (Daemon_CloneClient, error) Remove(ctx context.Context, in *RemoveRequest, opts ...grpc.CallOption) (Daemon_RemoveClient, error) ConfigAdd(ctx context.Context, in *ConfigAddRequest, opts ...grpc.CallOption) (*ConfigAddResponse, error) ConfigRemove(ctx context.Context, in *ConfigRemoveRequest, opts ...grpc.CallOption) (*ConfigRemoveResponse, error) SshStart(ctx context.Context, in *SshStartRequest, opts ...grpc.CallOption) (*SshStartResponse, error) SshStop(ctx context.Context, in *SshStopRequest, opts ...grpc.CallOption) (*SshStopResponse, error) SshConnect(ctx context.Context, opts ...grpc.CallOption) (Daemon_SshConnectClient, error) Logs(ctx context.Context, in *LogRequest, opts ...grpc.CallOption) (Daemon_LogsClient, error) List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListResponse, error) Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error) Upgrade(ctx context.Context, in *UpgradeRequest, opts ...grpc.CallOption) (*UpgradeResponse, error) Status(ctx context.Context, in *StatusRequest, opts ...grpc.CallOption) (*StatusResponse, error) Version(ctx context.Context, in *VersionRequest, opts ...grpc.CallOption) (*VersionResponse, error) Reset(ctx context.Context, in *ResetRequest, opts ...grpc.CallOption) (Daemon_ResetClient, error) Quit(ctx context.Context, in *QuitRequest, opts ...grpc.CallOption) (Daemon_QuitClient, error) Identify(ctx context.Context, in *IdentifyRequest, opts ...grpc.CallOption) (*IdentifyResponse, error) }
DaemonClient is the client API for Daemon 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 NewDaemonClient ¶
func NewDaemonClient(cc grpc.ClientConnInterface) DaemonClient
type DaemonServer ¶
type DaemonServer interface { Connect(*ConnectRequest, Daemon_ConnectServer) error ConnectFork(*ConnectRequest, Daemon_ConnectForkServer) error Disconnect(*DisconnectRequest, Daemon_DisconnectServer) error Proxy(*ConnectRequest, Daemon_ProxyServer) error Leave(*LeaveRequest, Daemon_LeaveServer) error Clone(*CloneRequest, Daemon_CloneServer) error Remove(*RemoveRequest, Daemon_RemoveServer) error ConfigAdd(context.Context, *ConfigAddRequest) (*ConfigAddResponse, error) ConfigRemove(context.Context, *ConfigRemoveRequest) (*ConfigRemoveResponse, error) SshStart(context.Context, *SshStartRequest) (*SshStartResponse, error) SshStop(context.Context, *SshStopRequest) (*SshStopResponse, error) SshConnect(Daemon_SshConnectServer) error Logs(*LogRequest, Daemon_LogsServer) error List(context.Context, *ListRequest) (*ListResponse, error) Get(context.Context, *GetRequest) (*GetResponse, error) Upgrade(context.Context, *UpgradeRequest) (*UpgradeResponse, error) Status(context.Context, *StatusRequest) (*StatusResponse, error) Version(context.Context, *VersionRequest) (*VersionResponse, error) Reset(*ResetRequest, Daemon_ResetServer) error Quit(*QuitRequest, Daemon_QuitServer) error Identify(context.Context, *IdentifyRequest) (*IdentifyResponse, error) // contains filtered or unexported methods }
DaemonServer is the server API for Daemon service. All implementations must embed UnimplementedDaemonServer for forward compatibility
type Daemon_CloneClient ¶
type Daemon_CloneClient interface { Recv() (*CloneResponse, error) grpc.ClientStream }
type Daemon_CloneServer ¶
type Daemon_CloneServer interface { Send(*CloneResponse) error grpc.ServerStream }
type Daemon_ConnectClient ¶
type Daemon_ConnectClient interface { Recv() (*ConnectResponse, error) grpc.ClientStream }
type Daemon_ConnectForkClient ¶
type Daemon_ConnectForkClient interface { Recv() (*ConnectResponse, error) grpc.ClientStream }
type Daemon_ConnectForkServer ¶
type Daemon_ConnectForkServer interface { Send(*ConnectResponse) error grpc.ServerStream }
type Daemon_ConnectServer ¶
type Daemon_ConnectServer interface { Send(*ConnectResponse) error grpc.ServerStream }
type Daemon_DisconnectClient ¶
type Daemon_DisconnectClient interface { Recv() (*DisconnectResponse, error) grpc.ClientStream }
type Daemon_DisconnectServer ¶
type Daemon_DisconnectServer interface { Send(*DisconnectResponse) error grpc.ServerStream }
type Daemon_LeaveClient ¶
type Daemon_LeaveClient interface { Recv() (*LeaveResponse, error) grpc.ClientStream }
type Daemon_LeaveServer ¶
type Daemon_LeaveServer interface { Send(*LeaveResponse) error grpc.ServerStream }
type Daemon_LogsClient ¶
type Daemon_LogsClient interface { Recv() (*LogResponse, error) grpc.ClientStream }
type Daemon_LogsServer ¶
type Daemon_LogsServer interface { Send(*LogResponse) error grpc.ServerStream }
type Daemon_ProxyClient ¶
type Daemon_ProxyClient interface { Recv() (*ConnectResponse, error) grpc.ClientStream }
type Daemon_ProxyServer ¶
type Daemon_ProxyServer interface { Send(*ConnectResponse) error grpc.ServerStream }
type Daemon_QuitClient ¶
type Daemon_QuitClient interface { Recv() (*QuitResponse, error) grpc.ClientStream }
type Daemon_QuitServer ¶
type Daemon_QuitServer interface { Send(*QuitResponse) error grpc.ServerStream }
type Daemon_RemoveClient ¶
type Daemon_RemoveClient interface { Recv() (*RemoveResponse, error) grpc.ClientStream }
type Daemon_RemoveServer ¶
type Daemon_RemoveServer interface { Send(*RemoveResponse) error grpc.ServerStream }
type Daemon_ResetClient ¶ added in v2.2.3
type Daemon_ResetClient interface { Recv() (*ResetResponse, error) grpc.ClientStream }
type Daemon_ResetServer ¶ added in v2.2.3
type Daemon_ResetServer interface { Send(*ResetResponse) error grpc.ServerStream }
type Daemon_SshConnectClient ¶
type Daemon_SshConnectClient interface { Send(*SshConnectRequest) error Recv() (*SshConnectResponse, error) grpc.ClientStream }
type Daemon_SshConnectServer ¶
type Daemon_SshConnectServer interface { Send(*SshConnectResponse) error Recv() (*SshConnectRequest, error) grpc.ServerStream }
type DisconnectRequest ¶
type DisconnectRequest struct { // 1) disconnect by id ID *int32 `protobuf:"varint,1,opt,name=ID,proto3,oneof" json:"ID,omitempty"` // 2) disconnect all All *bool `protobuf:"varint,2,opt,name=All,proto3,oneof" json:"All,omitempty"` // 3) disconnect by kubeConfig KubeconfigBytes *string `protobuf:"bytes,3,opt,name=KubeconfigBytes,proto3,oneof" json:"KubeconfigBytes,omitempty"` Namespace *string `protobuf:"bytes,4,opt,name=Namespace,proto3,oneof" json:"Namespace,omitempty"` SshJump *SshJump `protobuf:"bytes,5,opt,name=SshJump,proto3" json:"SshJump,omitempty"` // 4) disconnect by cluster ids ClusterIDs []string `protobuf:"bytes,6,rep,name=ClusterIDs,proto3" json:"ClusterIDs,omitempty"` // contains filtered or unexported fields }
func (*DisconnectRequest) Descriptor
deprecated
func (*DisconnectRequest) Descriptor() ([]byte, []int)
Deprecated: Use DisconnectRequest.ProtoReflect.Descriptor instead.
func (*DisconnectRequest) GetAll ¶
func (x *DisconnectRequest) GetAll() bool
func (*DisconnectRequest) GetClusterIDs ¶ added in v2.2.7
func (x *DisconnectRequest) GetClusterIDs() []string
func (*DisconnectRequest) GetID ¶
func (x *DisconnectRequest) GetID() int32
func (*DisconnectRequest) GetKubeconfigBytes ¶ added in v2.2.3
func (x *DisconnectRequest) GetKubeconfigBytes() string
func (*DisconnectRequest) GetNamespace ¶ added in v2.2.3
func (x *DisconnectRequest) GetNamespace() string
func (*DisconnectRequest) GetSshJump ¶ added in v2.2.3
func (x *DisconnectRequest) GetSshJump() *SshJump
func (*DisconnectRequest) ProtoMessage ¶
func (*DisconnectRequest) ProtoMessage()
func (*DisconnectRequest) ProtoReflect ¶
func (x *DisconnectRequest) ProtoReflect() protoreflect.Message
func (*DisconnectRequest) Reset ¶
func (x *DisconnectRequest) Reset()
func (*DisconnectRequest) String ¶
func (x *DisconnectRequest) String() string
type DisconnectResponse ¶
type DisconnectResponse struct { Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"` // contains filtered or unexported fields }
func (*DisconnectResponse) Descriptor
deprecated
func (*DisconnectResponse) Descriptor() ([]byte, []int)
Deprecated: Use DisconnectResponse.ProtoReflect.Descriptor instead.
func (*DisconnectResponse) GetMessage ¶
func (x *DisconnectResponse) GetMessage() string
func (*DisconnectResponse) ProtoMessage ¶
func (*DisconnectResponse) ProtoMessage()
func (*DisconnectResponse) ProtoReflect ¶
func (x *DisconnectResponse) ProtoReflect() protoreflect.Message
func (*DisconnectResponse) Reset ¶
func (x *DisconnectResponse) Reset()
func (*DisconnectResponse) String ¶
func (x *DisconnectResponse) String() string
type ExtraRoute ¶ added in v2.2.3
type ExtraRoute struct { ExtraCIDR []string `protobuf:"bytes,1,rep,name=ExtraCIDR,proto3" json:"ExtraCIDR,omitempty"` ExtraDomain []string `protobuf:"bytes,2,rep,name=ExtraDomain,proto3" json:"ExtraDomain,omitempty"` ExtraNodeIP bool `protobuf:"varint,3,opt,name=ExtraNodeIP,proto3" json:"ExtraNodeIP,omitempty"` // contains filtered or unexported fields }
func (*ExtraRoute) Descriptor
deprecated
added in
v2.2.3
func (*ExtraRoute) Descriptor() ([]byte, []int)
Deprecated: Use ExtraRoute.ProtoReflect.Descriptor instead.
func (*ExtraRoute) GetExtraCIDR ¶ added in v2.2.3
func (x *ExtraRoute) GetExtraCIDR() []string
func (*ExtraRoute) GetExtraDomain ¶ added in v2.2.3
func (x *ExtraRoute) GetExtraDomain() []string
func (*ExtraRoute) GetExtraNodeIP ¶ added in v2.2.3
func (x *ExtraRoute) GetExtraNodeIP() bool
func (*ExtraRoute) ProtoMessage ¶ added in v2.2.3
func (*ExtraRoute) ProtoMessage()
func (*ExtraRoute) ProtoReflect ¶ added in v2.2.3
func (x *ExtraRoute) ProtoReflect() protoreflect.Message
func (*ExtraRoute) Reset ¶ added in v2.2.3
func (x *ExtraRoute) Reset()
func (*ExtraRoute) String ¶ added in v2.2.3
func (x *ExtraRoute) String() string
type GetRequest ¶
type GetRequest struct { Namespace string `protobuf:"bytes,2,opt,name=Namespace,proto3" json:"Namespace,omitempty"` Resource string `protobuf:"bytes,4,opt,name=resource,proto3" json:"resource,omitempty"` // contains filtered or unexported fields }
func (*GetRequest) Descriptor
deprecated
func (*GetRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetRequest.ProtoReflect.Descriptor instead.
func (*GetRequest) GetNamespace ¶
func (x *GetRequest) GetNamespace() string
func (*GetRequest) GetResource ¶
func (x *GetRequest) GetResource() string
func (*GetRequest) ProtoMessage ¶
func (*GetRequest) ProtoMessage()
func (*GetRequest) ProtoReflect ¶
func (x *GetRequest) ProtoReflect() protoreflect.Message
func (*GetRequest) Reset ¶
func (x *GetRequest) Reset()
func (*GetRequest) String ¶
func (x *GetRequest) String() string
type GetResponse ¶
type GetResponse struct { Metadata []string `protobuf:"bytes,1,rep,name=metadata,proto3" json:"metadata,omitempty"` // contains filtered or unexported fields }
func (*GetResponse) Descriptor
deprecated
func (*GetResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetResponse.ProtoReflect.Descriptor instead.
func (*GetResponse) GetMetadata ¶
func (x *GetResponse) GetMetadata() []string
func (*GetResponse) ProtoMessage ¶
func (*GetResponse) ProtoMessage()
func (*GetResponse) ProtoReflect ¶
func (x *GetResponse) ProtoReflect() protoreflect.Message
func (*GetResponse) Reset ¶
func (x *GetResponse) Reset()
func (*GetResponse) String ¶
func (x *GetResponse) String() string
type IdentifyRequest ¶ added in v2.2.9
type IdentifyRequest struct {
// contains filtered or unexported fields
}
func (*IdentifyRequest) Descriptor
deprecated
added in
v2.2.9
func (*IdentifyRequest) Descriptor() ([]byte, []int)
Deprecated: Use IdentifyRequest.ProtoReflect.Descriptor instead.
func (*IdentifyRequest) ProtoMessage ¶ added in v2.2.9
func (*IdentifyRequest) ProtoMessage()
func (*IdentifyRequest) ProtoReflect ¶ added in v2.2.9
func (x *IdentifyRequest) ProtoReflect() protoreflect.Message
func (*IdentifyRequest) Reset ¶ added in v2.2.9
func (x *IdentifyRequest) Reset()
func (*IdentifyRequest) String ¶ added in v2.2.9
func (x *IdentifyRequest) String() string
type IdentifyResponse ¶ added in v2.2.9
type IdentifyResponse struct { ID string `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"` // contains filtered or unexported fields }
func (*IdentifyResponse) Descriptor
deprecated
added in
v2.2.9
func (*IdentifyResponse) Descriptor() ([]byte, []int)
Deprecated: Use IdentifyResponse.ProtoReflect.Descriptor instead.
func (*IdentifyResponse) GetID ¶ added in v2.2.9
func (x *IdentifyResponse) GetID() string
func (*IdentifyResponse) ProtoMessage ¶ added in v2.2.9
func (*IdentifyResponse) ProtoMessage()
func (*IdentifyResponse) ProtoReflect ¶ added in v2.2.9
func (x *IdentifyResponse) ProtoReflect() protoreflect.Message
func (*IdentifyResponse) Reset ¶ added in v2.2.9
func (x *IdentifyResponse) Reset()
func (*IdentifyResponse) String ¶ added in v2.2.9
func (x *IdentifyResponse) String() string
type LeaveRequest ¶
type LeaveRequest struct { Workloads []string `protobuf:"bytes,1,rep,name=Workloads,proto3" json:"Workloads,omitempty"` // contains filtered or unexported fields }
func (*LeaveRequest) Descriptor
deprecated
func (*LeaveRequest) Descriptor() ([]byte, []int)
Deprecated: Use LeaveRequest.ProtoReflect.Descriptor instead.
func (*LeaveRequest) GetWorkloads ¶
func (x *LeaveRequest) GetWorkloads() []string
func (*LeaveRequest) ProtoMessage ¶
func (*LeaveRequest) ProtoMessage()
func (*LeaveRequest) ProtoReflect ¶
func (x *LeaveRequest) ProtoReflect() protoreflect.Message
func (*LeaveRequest) Reset ¶
func (x *LeaveRequest) Reset()
func (*LeaveRequest) String ¶
func (x *LeaveRequest) String() string
type LeaveResponse ¶
type LeaveResponse struct { Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"` // contains filtered or unexported fields }
func (*LeaveResponse) Descriptor
deprecated
func (*LeaveResponse) Descriptor() ([]byte, []int)
Deprecated: Use LeaveResponse.ProtoReflect.Descriptor instead.
func (*LeaveResponse) GetMessage ¶
func (x *LeaveResponse) GetMessage() string
func (*LeaveResponse) ProtoMessage ¶
func (*LeaveResponse) ProtoMessage()
func (*LeaveResponse) ProtoReflect ¶
func (x *LeaveResponse) ProtoReflect() protoreflect.Message
func (*LeaveResponse) Reset ¶
func (x *LeaveResponse) Reset()
func (*LeaveResponse) String ¶
func (x *LeaveResponse) String() string
type ListRequest ¶
type ListRequest struct {
// contains filtered or unexported fields
}
func (*ListRequest) Descriptor
deprecated
func (*ListRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListRequest.ProtoReflect.Descriptor instead.
func (*ListRequest) ProtoMessage ¶
func (*ListRequest) ProtoMessage()
func (*ListRequest) ProtoReflect ¶
func (x *ListRequest) ProtoReflect() protoreflect.Message
func (*ListRequest) Reset ¶
func (x *ListRequest) Reset()
func (*ListRequest) String ¶
func (x *ListRequest) String() string
type ListResponse ¶
type ListResponse struct { Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"` // contains filtered or unexported fields }
func (*ListResponse) Descriptor
deprecated
func (*ListResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListResponse.ProtoReflect.Descriptor instead.
func (*ListResponse) GetMessage ¶
func (x *ListResponse) GetMessage() string
func (*ListResponse) ProtoMessage ¶
func (*ListResponse) ProtoMessage()
func (*ListResponse) ProtoReflect ¶
func (x *ListResponse) ProtoReflect() protoreflect.Message
func (*ListResponse) Reset ¶
func (x *ListResponse) Reset()
func (*ListResponse) String ¶
func (x *ListResponse) String() string
type LogRequest ¶
type LogRequest struct { Follow bool `protobuf:"varint,1,opt,name=Follow,proto3" json:"Follow,omitempty"` // contains filtered or unexported fields }
func (*LogRequest) Descriptor
deprecated
func (*LogRequest) Descriptor() ([]byte, []int)
Deprecated: Use LogRequest.ProtoReflect.Descriptor instead.
func (*LogRequest) GetFollow ¶
func (x *LogRequest) GetFollow() bool
func (*LogRequest) ProtoMessage ¶
func (*LogRequest) ProtoMessage()
func (*LogRequest) ProtoReflect ¶
func (x *LogRequest) ProtoReflect() protoreflect.Message
func (*LogRequest) Reset ¶
func (x *LogRequest) Reset()
func (*LogRequest) String ¶
func (x *LogRequest) String() string
type LogResponse ¶
type LogResponse struct { Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"` // contains filtered or unexported fields }
func (*LogResponse) Descriptor
deprecated
func (*LogResponse) Descriptor() ([]byte, []int)
Deprecated: Use LogResponse.ProtoReflect.Descriptor instead.
func (*LogResponse) GetMessage ¶
func (x *LogResponse) GetMessage() string
func (*LogResponse) ProtoMessage ¶
func (*LogResponse) ProtoMessage()
func (*LogResponse) ProtoReflect ¶
func (x *LogResponse) ProtoReflect() protoreflect.Message
func (*LogResponse) Reset ¶
func (x *LogResponse) Reset()
func (*LogResponse) String ¶
func (x *LogResponse) String() string
type Proxy ¶ added in v2.2.8
type Proxy struct { ClusterID string `protobuf:"bytes,1,opt,name=ClusterID,proto3" json:"ClusterID,omitempty"` Cluster string `protobuf:"bytes,2,opt,name=Cluster,proto3" json:"Cluster,omitempty"` Kubeconfig string `protobuf:"bytes,3,opt,name=Kubeconfig,proto3" json:"Kubeconfig,omitempty"` Namespace string `protobuf:"bytes,4,opt,name=Namespace,proto3" json:"Namespace,omitempty"` Workload string `protobuf:"bytes,5,opt,name=Workload,proto3" json:"Workload,omitempty"` RuleList []*ProxyRule `protobuf:"bytes,6,rep,name=RuleList,proto3" json:"RuleList,omitempty"` // contains filtered or unexported fields }
func (*Proxy) Descriptor
deprecated
added in
v2.2.8
func (*Proxy) GetCluster ¶ added in v2.2.8
func (*Proxy) GetClusterID ¶ added in v2.2.8
func (*Proxy) GetKubeconfig ¶ added in v2.2.8
func (*Proxy) GetNamespace ¶ added in v2.2.8
func (*Proxy) GetRuleList ¶ added in v2.2.8
func (*Proxy) GetWorkload ¶ added in v2.2.8
func (*Proxy) ProtoMessage ¶ added in v2.2.8
func (*Proxy) ProtoMessage()
func (*Proxy) ProtoReflect ¶ added in v2.2.8
func (x *Proxy) ProtoReflect() protoreflect.Message
type ProxyRule ¶ added in v2.2.8
type ProxyRule struct { Headers map[string]string `` /* 155-byte string literal not displayed */ LocalTunIPv4 string `protobuf:"bytes,2,opt,name=LocalTunIPv4,proto3" json:"LocalTunIPv4,omitempty"` LocalTunIPv6 string `protobuf:"bytes,3,opt,name=LocalTunIPv6,proto3" json:"LocalTunIPv6,omitempty"` CurrentDevice bool `protobuf:"varint,4,opt,name=CurrentDevice,proto3" json:"CurrentDevice,omitempty"` PortMap map[int32]int32 `` /* 157-byte string literal not displayed */ // contains filtered or unexported fields }
func (*ProxyRule) Descriptor
deprecated
added in
v2.2.8
func (*ProxyRule) GetCurrentDevice ¶ added in v2.2.8
func (*ProxyRule) GetHeaders ¶ added in v2.2.8
func (*ProxyRule) GetLocalTunIPv4 ¶ added in v2.2.8
func (*ProxyRule) GetLocalTunIPv6 ¶ added in v2.2.8
func (*ProxyRule) GetPortMap ¶ added in v2.2.8
func (*ProxyRule) ProtoMessage ¶ added in v2.2.8
func (*ProxyRule) ProtoMessage()
func (*ProxyRule) ProtoReflect ¶ added in v2.2.8
func (x *ProxyRule) ProtoReflect() protoreflect.Message
type QuitRequest ¶
type QuitRequest struct {
// contains filtered or unexported fields
}
func (*QuitRequest) Descriptor
deprecated
func (*QuitRequest) Descriptor() ([]byte, []int)
Deprecated: Use QuitRequest.ProtoReflect.Descriptor instead.
func (*QuitRequest) ProtoMessage ¶
func (*QuitRequest) ProtoMessage()
func (*QuitRequest) ProtoReflect ¶
func (x *QuitRequest) ProtoReflect() protoreflect.Message
func (*QuitRequest) Reset ¶
func (x *QuitRequest) Reset()
func (*QuitRequest) String ¶
func (x *QuitRequest) String() string
type QuitResponse ¶
type QuitResponse struct { Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"` // contains filtered or unexported fields }
func (*QuitResponse) Descriptor
deprecated
func (*QuitResponse) Descriptor() ([]byte, []int)
Deprecated: Use QuitResponse.ProtoReflect.Descriptor instead.
func (*QuitResponse) GetMessage ¶
func (x *QuitResponse) GetMessage() string
func (*QuitResponse) ProtoMessage ¶
func (*QuitResponse) ProtoMessage()
func (*QuitResponse) ProtoReflect ¶
func (x *QuitResponse) ProtoReflect() protoreflect.Message
func (*QuitResponse) Reset ¶
func (x *QuitResponse) Reset()
func (*QuitResponse) String ¶
func (x *QuitResponse) String() string
type RemoveRequest ¶
type RemoveRequest struct { Workloads []string `protobuf:"bytes,1,rep,name=Workloads,proto3" json:"Workloads,omitempty"` // contains filtered or unexported fields }
func (*RemoveRequest) Descriptor
deprecated
func (*RemoveRequest) Descriptor() ([]byte, []int)
Deprecated: Use RemoveRequest.ProtoReflect.Descriptor instead.
func (*RemoveRequest) GetWorkloads ¶
func (x *RemoveRequest) GetWorkloads() []string
func (*RemoveRequest) ProtoMessage ¶
func (*RemoveRequest) ProtoMessage()
func (*RemoveRequest) ProtoReflect ¶
func (x *RemoveRequest) ProtoReflect() protoreflect.Message
func (*RemoveRequest) Reset ¶
func (x *RemoveRequest) Reset()
func (*RemoveRequest) String ¶
func (x *RemoveRequest) String() string
type RemoveResponse ¶
type RemoveResponse struct { Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"` // contains filtered or unexported fields }
func (*RemoveResponse) Descriptor
deprecated
func (*RemoveResponse) Descriptor() ([]byte, []int)
Deprecated: Use RemoveResponse.ProtoReflect.Descriptor instead.
func (*RemoveResponse) GetMessage ¶
func (x *RemoveResponse) GetMessage() string
func (*RemoveResponse) ProtoMessage ¶
func (*RemoveResponse) ProtoMessage()
func (*RemoveResponse) ProtoReflect ¶
func (x *RemoveResponse) ProtoReflect() protoreflect.Message
func (*RemoveResponse) Reset ¶
func (x *RemoveResponse) Reset()
func (*RemoveResponse) String ¶
func (x *RemoveResponse) String() string
type ResetRequest ¶ added in v2.2.3
type ResetRequest struct { KubeconfigBytes string `protobuf:"bytes,1,opt,name=KubeconfigBytes,proto3" json:"KubeconfigBytes,omitempty"` Namespace string `protobuf:"bytes,2,opt,name=Namespace,proto3" json:"Namespace,omitempty"` // ssh jump SshJump *SshJump `protobuf:"bytes,3,opt,name=SshJump,proto3" json:"SshJump,omitempty"` // contains filtered or unexported fields }
func (*ResetRequest) Descriptor
deprecated
added in
v2.2.3
func (*ResetRequest) Descriptor() ([]byte, []int)
Deprecated: Use ResetRequest.ProtoReflect.Descriptor instead.
func (*ResetRequest) GetKubeconfigBytes ¶ added in v2.2.3
func (x *ResetRequest) GetKubeconfigBytes() string
func (*ResetRequest) GetNamespace ¶ added in v2.2.3
func (x *ResetRequest) GetNamespace() string
func (*ResetRequest) GetSshJump ¶ added in v2.2.3
func (x *ResetRequest) GetSshJump() *SshJump
func (*ResetRequest) ProtoMessage ¶ added in v2.2.3
func (*ResetRequest) ProtoMessage()
func (*ResetRequest) ProtoReflect ¶ added in v2.2.3
func (x *ResetRequest) ProtoReflect() protoreflect.Message
func (*ResetRequest) Reset ¶ added in v2.2.3
func (x *ResetRequest) Reset()
func (*ResetRequest) String ¶ added in v2.2.3
func (x *ResetRequest) String() string
type ResetResponse ¶ added in v2.2.3
type ResetResponse struct { Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"` // contains filtered or unexported fields }
func (*ResetResponse) Descriptor
deprecated
added in
v2.2.3
func (*ResetResponse) Descriptor() ([]byte, []int)
Deprecated: Use ResetResponse.ProtoReflect.Descriptor instead.
func (*ResetResponse) GetMessage ¶ added in v2.2.3
func (x *ResetResponse) GetMessage() string
func (*ResetResponse) ProtoMessage ¶ added in v2.2.3
func (*ResetResponse) ProtoMessage()
func (*ResetResponse) ProtoReflect ¶ added in v2.2.3
func (x *ResetResponse) ProtoReflect() protoreflect.Message
func (*ResetResponse) Reset ¶ added in v2.2.3
func (x *ResetResponse) Reset()
func (*ResetResponse) String ¶ added in v2.2.3
func (x *ResetResponse) String() string
type SshConnectRequest ¶
type SshConnectRequest struct { Stdin string `protobuf:"bytes,1,opt,name=Stdin,proto3" json:"Stdin,omitempty"` SshJump *SshJump `protobuf:"bytes,2,opt,name=SshJump,proto3" json:"SshJump,omitempty"` // contains filtered or unexported fields }
func (*SshConnectRequest) Descriptor
deprecated
func (*SshConnectRequest) Descriptor() ([]byte, []int)
Deprecated: Use SshConnectRequest.ProtoReflect.Descriptor instead.
func (*SshConnectRequest) GetSshJump ¶
func (x *SshConnectRequest) GetSshJump() *SshJump
func (*SshConnectRequest) GetStdin ¶
func (x *SshConnectRequest) GetStdin() string
func (*SshConnectRequest) ProtoMessage ¶
func (*SshConnectRequest) ProtoMessage()
func (*SshConnectRequest) ProtoReflect ¶
func (x *SshConnectRequest) ProtoReflect() protoreflect.Message
func (*SshConnectRequest) Reset ¶
func (x *SshConnectRequest) Reset()
func (*SshConnectRequest) String ¶
func (x *SshConnectRequest) String() string
type SshConnectResponse ¶
type SshConnectResponse struct { Stdout string `protobuf:"bytes,1,opt,name=Stdout,proto3" json:"Stdout,omitempty"` Stderr string `protobuf:"bytes,2,opt,name=Stderr,proto3" json:"Stderr,omitempty"` // contains filtered or unexported fields }
func (*SshConnectResponse) Descriptor
deprecated
func (*SshConnectResponse) Descriptor() ([]byte, []int)
Deprecated: Use SshConnectResponse.ProtoReflect.Descriptor instead.
func (*SshConnectResponse) GetStderr ¶
func (x *SshConnectResponse) GetStderr() string
func (*SshConnectResponse) GetStdout ¶
func (x *SshConnectResponse) GetStdout() string
func (*SshConnectResponse) ProtoMessage ¶
func (*SshConnectResponse) ProtoMessage()
func (*SshConnectResponse) ProtoReflect ¶
func (x *SshConnectResponse) ProtoReflect() protoreflect.Message
func (*SshConnectResponse) Reset ¶
func (x *SshConnectResponse) Reset()
func (*SshConnectResponse) String ¶
func (x *SshConnectResponse) String() string
type SshJump ¶
type SshJump struct { Addr string `protobuf:"bytes,1,opt,name=Addr,proto3" json:"Addr,omitempty"` User string `protobuf:"bytes,2,opt,name=User,proto3" json:"User,omitempty"` Password string `protobuf:"bytes,3,opt,name=Password,proto3" json:"Password,omitempty"` Keyfile string `protobuf:"bytes,4,opt,name=Keyfile,proto3" json:"Keyfile,omitempty"` Jump string `protobuf:"bytes,5,opt,name=Jump,proto3" json:"Jump,omitempty"` ConfigAlias string `protobuf:"bytes,6,opt,name=ConfigAlias,proto3" json:"ConfigAlias,omitempty"` RemoteKubeconfig string `protobuf:"bytes,7,opt,name=RemoteKubeconfig,proto3" json:"RemoteKubeconfig,omitempty"` GSSAPIKeytabConf string `protobuf:"bytes,8,opt,name=GSSAPIKeytabConf,proto3" json:"GSSAPIKeytabConf,omitempty"` GSSAPIPassword string `protobuf:"bytes,9,opt,name=GSSAPIPassword,proto3" json:"GSSAPIPassword,omitempty"` GSSAPICacheFile string `protobuf:"bytes,10,opt,name=GSSAPICacheFile,proto3" json:"GSSAPICacheFile,omitempty"` // contains filtered or unexported fields }
func (*SshJump) Descriptor
deprecated
func (*SshJump) GetConfigAlias ¶
func (*SshJump) GetGSSAPICacheFile ¶
func (*SshJump) GetGSSAPIKeytabConf ¶
func (*SshJump) GetGSSAPIPassword ¶
func (*SshJump) GetKeyfile ¶
func (*SshJump) GetPassword ¶
func (*SshJump) GetRemoteKubeconfig ¶
func (*SshJump) ProtoMessage ¶
func (*SshJump) ProtoMessage()
func (*SshJump) ProtoReflect ¶
func (x *SshJump) ProtoReflect() protoreflect.Message
type SshStartRequest ¶
type SshStartRequest struct { ClientIP string `protobuf:"bytes,1,opt,name=ClientIP,proto3" json:"ClientIP,omitempty"` // contains filtered or unexported fields }
func (*SshStartRequest) Descriptor
deprecated
func (*SshStartRequest) Descriptor() ([]byte, []int)
Deprecated: Use SshStartRequest.ProtoReflect.Descriptor instead.
func (*SshStartRequest) GetClientIP ¶
func (x *SshStartRequest) GetClientIP() string
func (*SshStartRequest) ProtoMessage ¶
func (*SshStartRequest) ProtoMessage()
func (*SshStartRequest) ProtoReflect ¶
func (x *SshStartRequest) ProtoReflect() protoreflect.Message
func (*SshStartRequest) Reset ¶
func (x *SshStartRequest) Reset()
func (*SshStartRequest) String ¶
func (x *SshStartRequest) String() string
type SshStartResponse ¶
type SshStartResponse struct { ServerIP string `protobuf:"bytes,1,opt,name=ServerIP,proto3" json:"ServerIP,omitempty"` // contains filtered or unexported fields }
func (*SshStartResponse) Descriptor
deprecated
func (*SshStartResponse) Descriptor() ([]byte, []int)
Deprecated: Use SshStartResponse.ProtoReflect.Descriptor instead.
func (*SshStartResponse) GetServerIP ¶
func (x *SshStartResponse) GetServerIP() string
func (*SshStartResponse) ProtoMessage ¶
func (*SshStartResponse) ProtoMessage()
func (*SshStartResponse) ProtoReflect ¶
func (x *SshStartResponse) ProtoReflect() protoreflect.Message
func (*SshStartResponse) Reset ¶
func (x *SshStartResponse) Reset()
func (*SshStartResponse) String ¶
func (x *SshStartResponse) String() string
type SshStopRequest ¶
type SshStopRequest struct { ClientIP string `protobuf:"bytes,1,opt,name=ClientIP,proto3" json:"ClientIP,omitempty"` // contains filtered or unexported fields }
func (*SshStopRequest) Descriptor
deprecated
func (*SshStopRequest) Descriptor() ([]byte, []int)
Deprecated: Use SshStopRequest.ProtoReflect.Descriptor instead.
func (*SshStopRequest) GetClientIP ¶
func (x *SshStopRequest) GetClientIP() string
func (*SshStopRequest) ProtoMessage ¶
func (*SshStopRequest) ProtoMessage()
func (*SshStopRequest) ProtoReflect ¶
func (x *SshStopRequest) ProtoReflect() protoreflect.Message
func (*SshStopRequest) Reset ¶
func (x *SshStopRequest) Reset()
func (*SshStopRequest) String ¶
func (x *SshStopRequest) String() string
type SshStopResponse ¶
type SshStopResponse struct { ServerIP string `protobuf:"bytes,1,opt,name=ServerIP,proto3" json:"ServerIP,omitempty"` // contains filtered or unexported fields }
func (*SshStopResponse) Descriptor
deprecated
func (*SshStopResponse) Descriptor() ([]byte, []int)
Deprecated: Use SshStopResponse.ProtoReflect.Descriptor instead.
func (*SshStopResponse) GetServerIP ¶
func (x *SshStopResponse) GetServerIP() string
func (*SshStopResponse) ProtoMessage ¶
func (*SshStopResponse) ProtoMessage()
func (*SshStopResponse) ProtoReflect ¶
func (x *SshStopResponse) ProtoReflect() protoreflect.Message
func (*SshStopResponse) Reset ¶
func (x *SshStopResponse) Reset()
func (*SshStopResponse) String ¶
func (x *SshStopResponse) String() string
type Status ¶ added in v2.2.7
type Status struct { ID int32 `protobuf:"varint,1,opt,name=ID,proto3" json:"ID,omitempty"` ClusterID string `protobuf:"bytes,2,opt,name=ClusterID,proto3" json:"ClusterID,omitempty"` Cluster string `protobuf:"bytes,3,opt,name=Cluster,proto3" json:"Cluster,omitempty"` Mode string `protobuf:"bytes,4,opt,name=Mode,proto3" json:"Mode,omitempty"` Kubeconfig string `protobuf:"bytes,5,opt,name=Kubeconfig,proto3" json:"Kubeconfig,omitempty"` Namespace string `protobuf:"bytes,6,opt,name=Namespace,proto3" json:"Namespace,omitempty"` Status string `protobuf:"bytes,7,opt,name=Status,proto3" json:"Status,omitempty"` Netif string `protobuf:"bytes,8,opt,name=Netif,proto3" json:"Netif,omitempty"` ProxyList []*Proxy `protobuf:"bytes,9,rep,name=ProxyList,proto3" json:"ProxyList,omitempty"` CloneList []*Clone `protobuf:"bytes,10,rep,name=CloneList,proto3" json:"CloneList,omitempty"` // contains filtered or unexported fields }
func (*Status) Descriptor
deprecated
added in
v2.2.7
func (*Status) GetCloneList ¶ added in v2.2.8
func (*Status) GetCluster ¶ added in v2.2.7
func (*Status) GetClusterID ¶ added in v2.2.7
func (*Status) GetKubeconfig ¶ added in v2.2.7
func (*Status) GetNamespace ¶ added in v2.2.7
func (*Status) GetProxyList ¶ added in v2.2.8
func (*Status) ProtoMessage ¶ added in v2.2.7
func (*Status) ProtoMessage()
func (*Status) ProtoReflect ¶ added in v2.2.7
func (x *Status) ProtoReflect() protoreflect.Message
type StatusRequest ¶
type StatusRequest struct { ClusterIDs []string `protobuf:"bytes,1,rep,name=ClusterIDs,proto3" json:"ClusterIDs,omitempty"` // contains filtered or unexported fields }
func (*StatusRequest) Descriptor
deprecated
func (*StatusRequest) Descriptor() ([]byte, []int)
Deprecated: Use StatusRequest.ProtoReflect.Descriptor instead.
func (*StatusRequest) GetClusterIDs ¶ added in v2.2.7
func (x *StatusRequest) GetClusterIDs() []string
func (*StatusRequest) ProtoMessage ¶
func (*StatusRequest) ProtoMessage()
func (*StatusRequest) ProtoReflect ¶
func (x *StatusRequest) ProtoReflect() protoreflect.Message
func (*StatusRequest) Reset ¶
func (x *StatusRequest) Reset()
func (*StatusRequest) String ¶
func (x *StatusRequest) String() string
type StatusResponse ¶
type StatusResponse struct { List []*Status `protobuf:"bytes,1,rep,name=List,proto3" json:"List,omitempty"` // contains filtered or unexported fields }
func (*StatusResponse) Descriptor
deprecated
func (*StatusResponse) Descriptor() ([]byte, []int)
Deprecated: Use StatusResponse.ProtoReflect.Descriptor instead.
func (*StatusResponse) GetList ¶ added in v2.2.7
func (x *StatusResponse) GetList() []*Status
func (*StatusResponse) ProtoMessage ¶
func (*StatusResponse) ProtoMessage()
func (*StatusResponse) ProtoReflect ¶
func (x *StatusResponse) ProtoReflect() protoreflect.Message
func (*StatusResponse) Reset ¶
func (x *StatusResponse) Reset()
func (*StatusResponse) String ¶
func (x *StatusResponse) String() string
type UnimplementedDaemonServer ¶
type UnimplementedDaemonServer struct { }
UnimplementedDaemonServer must be embedded to have forward compatible implementations.
func (UnimplementedDaemonServer) Clone ¶
func (UnimplementedDaemonServer) Clone(*CloneRequest, Daemon_CloneServer) error
func (UnimplementedDaemonServer) ConfigAdd ¶
func (UnimplementedDaemonServer) ConfigAdd(context.Context, *ConfigAddRequest) (*ConfigAddResponse, error)
func (UnimplementedDaemonServer) ConfigRemove ¶
func (UnimplementedDaemonServer) ConfigRemove(context.Context, *ConfigRemoveRequest) (*ConfigRemoveResponse, error)
func (UnimplementedDaemonServer) Connect ¶
func (UnimplementedDaemonServer) Connect(*ConnectRequest, Daemon_ConnectServer) error
func (UnimplementedDaemonServer) ConnectFork ¶
func (UnimplementedDaemonServer) ConnectFork(*ConnectRequest, Daemon_ConnectForkServer) error
func (UnimplementedDaemonServer) Disconnect ¶
func (UnimplementedDaemonServer) Disconnect(*DisconnectRequest, Daemon_DisconnectServer) error
func (UnimplementedDaemonServer) Get ¶
func (UnimplementedDaemonServer) Get(context.Context, *GetRequest) (*GetResponse, error)
func (UnimplementedDaemonServer) Identify ¶ added in v2.2.9
func (UnimplementedDaemonServer) Identify(context.Context, *IdentifyRequest) (*IdentifyResponse, error)
func (UnimplementedDaemonServer) Leave ¶
func (UnimplementedDaemonServer) Leave(*LeaveRequest, Daemon_LeaveServer) error
func (UnimplementedDaemonServer) List ¶
func (UnimplementedDaemonServer) List(context.Context, *ListRequest) (*ListResponse, error)
func (UnimplementedDaemonServer) Logs ¶
func (UnimplementedDaemonServer) Logs(*LogRequest, Daemon_LogsServer) error
func (UnimplementedDaemonServer) Proxy ¶
func (UnimplementedDaemonServer) Proxy(*ConnectRequest, Daemon_ProxyServer) error
func (UnimplementedDaemonServer) Quit ¶
func (UnimplementedDaemonServer) Quit(*QuitRequest, Daemon_QuitServer) error
func (UnimplementedDaemonServer) Remove ¶
func (UnimplementedDaemonServer) Remove(*RemoveRequest, Daemon_RemoveServer) error
func (UnimplementedDaemonServer) Reset ¶ added in v2.2.3
func (UnimplementedDaemonServer) Reset(*ResetRequest, Daemon_ResetServer) error
func (UnimplementedDaemonServer) SshConnect ¶
func (UnimplementedDaemonServer) SshConnect(Daemon_SshConnectServer) error
func (UnimplementedDaemonServer) SshStart ¶
func (UnimplementedDaemonServer) SshStart(context.Context, *SshStartRequest) (*SshStartResponse, error)
func (UnimplementedDaemonServer) SshStop ¶
func (UnimplementedDaemonServer) SshStop(context.Context, *SshStopRequest) (*SshStopResponse, error)
func (UnimplementedDaemonServer) Status ¶
func (UnimplementedDaemonServer) Status(context.Context, *StatusRequest) (*StatusResponse, error)
func (UnimplementedDaemonServer) Upgrade ¶
func (UnimplementedDaemonServer) Upgrade(context.Context, *UpgradeRequest) (*UpgradeResponse, error)
func (UnimplementedDaemonServer) Version ¶
func (UnimplementedDaemonServer) Version(context.Context, *VersionRequest) (*VersionResponse, error)
type UnsafeDaemonServer ¶
type UnsafeDaemonServer interface {
// contains filtered or unexported methods
}
UnsafeDaemonServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DaemonServer will result in compilation errors.
type UpgradeRequest ¶
type UpgradeRequest struct { ClientVersion string `protobuf:"bytes,1,opt,name=ClientVersion,proto3" json:"ClientVersion,omitempty"` // contains filtered or unexported fields }
func (*UpgradeRequest) Descriptor
deprecated
func (*UpgradeRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpgradeRequest.ProtoReflect.Descriptor instead.
func (*UpgradeRequest) GetClientVersion ¶
func (x *UpgradeRequest) GetClientVersion() string
func (*UpgradeRequest) ProtoMessage ¶
func (*UpgradeRequest) ProtoMessage()
func (*UpgradeRequest) ProtoReflect ¶
func (x *UpgradeRequest) ProtoReflect() protoreflect.Message
func (*UpgradeRequest) Reset ¶
func (x *UpgradeRequest) Reset()
func (*UpgradeRequest) String ¶
func (x *UpgradeRequest) String() string
type UpgradeResponse ¶
type UpgradeResponse struct { NeedUpgrade bool `protobuf:"varint,1,opt,name=NeedUpgrade,proto3" json:"NeedUpgrade,omitempty"` // contains filtered or unexported fields }
func (*UpgradeResponse) Descriptor
deprecated
func (*UpgradeResponse) Descriptor() ([]byte, []int)
Deprecated: Use UpgradeResponse.ProtoReflect.Descriptor instead.
func (*UpgradeResponse) GetNeedUpgrade ¶
func (x *UpgradeResponse) GetNeedUpgrade() bool
func (*UpgradeResponse) ProtoMessage ¶
func (*UpgradeResponse) ProtoMessage()
func (*UpgradeResponse) ProtoReflect ¶
func (x *UpgradeResponse) ProtoReflect() protoreflect.Message
func (*UpgradeResponse) Reset ¶
func (x *UpgradeResponse) Reset()
func (*UpgradeResponse) String ¶
func (x *UpgradeResponse) String() string
type VersionRequest ¶
type VersionRequest struct {
// contains filtered or unexported fields
}
func (*VersionRequest) Descriptor
deprecated
func (*VersionRequest) Descriptor() ([]byte, []int)
Deprecated: Use VersionRequest.ProtoReflect.Descriptor instead.
func (*VersionRequest) ProtoMessage ¶
func (*VersionRequest) ProtoMessage()
func (*VersionRequest) ProtoReflect ¶
func (x *VersionRequest) ProtoReflect() protoreflect.Message
func (*VersionRequest) Reset ¶
func (x *VersionRequest) Reset()
func (*VersionRequest) String ¶
func (x *VersionRequest) String() string
type VersionResponse ¶
type VersionResponse struct { Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"` // contains filtered or unexported fields }
func (*VersionResponse) Descriptor
deprecated
func (*VersionResponse) Descriptor() ([]byte, []int)
Deprecated: Use VersionResponse.ProtoReflect.Descriptor instead.
func (*VersionResponse) GetVersion ¶
func (x *VersionResponse) GetVersion() string
func (*VersionResponse) ProtoMessage ¶
func (*VersionResponse) ProtoMessage()
func (*VersionResponse) ProtoReflect ¶
func (x *VersionResponse) ProtoReflect() protoreflect.Message
func (*VersionResponse) Reset ¶
func (x *VersionResponse) Reset()
func (*VersionResponse) String ¶
func (x *VersionResponse) String() string