rpc

package
v2.2.4 Latest Latest
Warning

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

 Go to latest Published: Apr 2, 2024 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

View Source 
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"
)

Variables

View Source 
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,
		},
	},
	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)

View Source 
var File_daemon_proto protoreflect.FileDescriptor

Functions

func RegisterDaemonServer 

func RegisterDaemonServer(s grpc.ServiceRegistrar, srv DaemonServer)

Types

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"`
	UseLocalDNS     bool              `protobuf:"varint,5,opt,name=UseLocalDNS,proto3" json:"UseLocalDNS,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"`
	// 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) GetNamespace 

func (x *CloneRequest) GetNamespace() string

func (*CloneRequest) GetOriginKubeconfigPath 

func (x *CloneRequest) GetOriginKubeconfigPath() 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) GetUseLocalDNS 

func (x *CloneRequest) GetUseLocalDNS() 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 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"`
	UseLocalDNS     bool              `protobuf:"varint,6,opt,name=UseLocalDNS,proto3" json:"UseLocalDNS,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) GetUseLocalDNS 

func (x *ConnectRequest) GetUseLocalDNS() 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)
}

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
	// 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,10,opt,name=SshJump,proto3" json:"SshJump,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) 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 []*Metadata `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() []*Metadata

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 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 Metadata 

type Metadata struct {
	Name      string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// contains filtered or unexported fields
}

func (*Metadata) Descriptor deprecated 

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

Deprecated: Use Metadata.ProtoReflect.Descriptor instead.

func (*Metadata) GetName 

func (x *Metadata) GetName() string

func (*Metadata) GetNamespace 

func (x *Metadata) GetNamespace() string

func (*Metadata) ProtoMessage 

func (*Metadata) ProtoMessage()

func (*Metadata) ProtoReflect 

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

func (*Metadata) Reset 

func (x *Metadata) Reset()

func (*Metadata) String 

func (x *Metadata) String() string

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"`
	ConfigAlias      string `protobuf:"bytes,5,opt,name=ConfigAlias,proto3" json:"ConfigAlias,omitempty"`
	RemoteKubeconfig string `protobuf:"bytes,6,opt,name=RemoteKubeconfig,proto3" json:"RemoteKubeconfig,omitempty"`
	GSSAPIKeytabConf string `protobuf:"bytes,7,opt,name=GSSAPIKeytabConf,proto3" json:"GSSAPIKeytabConf,omitempty"`
	GSSAPIPassword   string `protobuf:"bytes,8,opt,name=GSSAPIPassword,proto3" json:"GSSAPIPassword,omitempty"`
	GSSAPICacheFile  string `protobuf:"bytes,9,opt,name=GSSAPICacheFile,proto3" json:"GSSAPICacheFile,omitempty"`
	// contains filtered or unexported fields
}

func (*SshJump) Descriptor deprecated 

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

Deprecated: Use SshJump.ProtoReflect.Descriptor instead.

func (*SshJump) GetAddr 

func (x *SshJump) GetAddr() string

func (*SshJump) GetConfigAlias 

func (x *SshJump) GetConfigAlias() string

func (*SshJump) GetGSSAPICacheFile 

func (x *SshJump) GetGSSAPICacheFile() string

func (*SshJump) GetGSSAPIKeytabConf 

func (x *SshJump) GetGSSAPIKeytabConf() string

func (*SshJump) GetGSSAPIPassword 

func (x *SshJump) GetGSSAPIPassword() string

func (*SshJump) GetKeyfile 

func (x *SshJump) GetKeyfile() string

func (*SshJump) GetPassword 

func (x *SshJump) GetPassword() string

func (*SshJump) GetRemoteKubeconfig 

func (x *SshJump) GetRemoteKubeconfig() string

func (*SshJump) GetUser 

func (x *SshJump) GetUser() string

func (*SshJump) ProtoMessage 

func (*SshJump) ProtoMessage()

func (*SshJump) ProtoReflect 

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

func (*SshJump) Reset 

func (x *SshJump) Reset()

func (*SshJump) String 

func (x *SshJump) String() string

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 StatusRequest 

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

func (*StatusRequest) Descriptor deprecated 

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

Deprecated: Use StatusRequest.ProtoReflect.Descriptor instead.

func (*StatusRequest) GetName 

func (x *StatusRequest) GetName() 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 {
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*StatusResponse) Descriptor deprecated 

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

Deprecated: Use StatusResponse.ProtoReflect.Descriptor instead.

func (*StatusResponse) GetMessage 

func (x *StatusResponse) GetMessage() string

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) 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"`
	ClientCommitId string `protobuf:"bytes,2,opt,name=ClientCommitId,proto3" json:"ClientCommitId,omitempty"`
	// contains filtered or unexported fields
}

func (*UpgradeRequest) Descriptor deprecated 

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

Deprecated: Use UpgradeRequest.ProtoReflect.Descriptor instead.

func (*UpgradeRequest) GetClientCommitId 

func (x *UpgradeRequest) GetClientCommitId() string

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

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.