rpc

package
v2.2.8 Latest Latest
Warning

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

Go to latest
Published: May 3, 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 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"`
	RuleList   []*CloneRule `protobuf:"bytes,6,rep,name=RuleList,proto3" json:"RuleList,omitempty"`
	// contains filtered or unexported fields
}

func (*Clone) Descriptor deprecated added in v2.2.8

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

Deprecated: Use Clone.ProtoReflect.Descriptor instead.

func (*Clone) GetCluster added in v2.2.8

func (x *Clone) GetCluster() string

func (*Clone) GetClusterID added in v2.2.8

func (x *Clone) GetClusterID() string

func (*Clone) GetKubeconfig added in v2.2.8

func (x *Clone) GetKubeconfig() string

func (*Clone) GetNamespace added in v2.2.8

func (x *Clone) GetNamespace() string

func (*Clone) GetRuleList added in v2.2.8

func (x *Clone) GetRuleList() []*CloneRule

func (*Clone) GetWorkload added in v2.2.8

func (x *Clone) GetWorkload() string

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

func (*Clone) Reset added in v2.2.8

func (x *Clone) Reset()

func (*Clone) String added in v2.2.8

func (x *Clone) String() string

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"`
	// 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) 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) Descriptor() ([]byte, []int)

Deprecated: Use CloneRule.ProtoReflect.Descriptor instead.

func (*CloneRule) GetDstCluster added in v2.2.8

func (x *CloneRule) GetDstCluster() string

func (*CloneRule) GetDstClusterID added in v2.2.8

func (x *CloneRule) GetDstClusterID() string

func (*CloneRule) GetDstKubeconfig added in v2.2.8

func (x *CloneRule) GetDstKubeconfig() string

func (*CloneRule) GetDstNamespace added in v2.2.8

func (x *CloneRule) GetDstNamespace() string

func (*CloneRule) GetDstWorkload added in v2.2.8

func (x *CloneRule) GetDstWorkload() string

func (*CloneRule) GetHeaders added in v2.2.8

func (x *CloneRule) GetHeaders() map[string]string

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

func (*CloneRule) Reset added in v2.2.8

func (x *CloneRule) Reset()

func (*CloneRule) String added in v2.2.8

func (x *CloneRule) 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"`
	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)
}

DaemonClient is the client API for Daemon service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.golang.ir/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewDaemonClient

func NewDaemonClient(cc grpc.ClientConnInterface) DaemonClient

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 []*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 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) Descriptor() ([]byte, []int)

Deprecated: Use Proxy.ProtoReflect.Descriptor instead.

func (*Proxy) GetCluster added in v2.2.8

func (x *Proxy) GetCluster() string

func (*Proxy) GetClusterID added in v2.2.8

func (x *Proxy) GetClusterID() string

func (*Proxy) GetKubeconfig added in v2.2.8

func (x *Proxy) GetKubeconfig() string

func (*Proxy) GetNamespace added in v2.2.8

func (x *Proxy) GetNamespace() string

func (*Proxy) GetRuleList added in v2.2.8

func (x *Proxy) GetRuleList() []*ProxyRule

func (*Proxy) GetWorkload added in v2.2.8

func (x *Proxy) GetWorkload() string

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

func (*Proxy) Reset added in v2.2.8

func (x *Proxy) Reset()

func (*Proxy) String added in v2.2.8

func (x *Proxy) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use ProxyRule.ProtoReflect.Descriptor instead.

func (*ProxyRule) GetCurrentDevice added in v2.2.8

func (x *ProxyRule) GetCurrentDevice() bool

func (*ProxyRule) GetHeaders added in v2.2.8

func (x *ProxyRule) GetHeaders() map[string]string

func (*ProxyRule) GetLocalTunIPv4 added in v2.2.8

func (x *ProxyRule) GetLocalTunIPv4() string

func (*ProxyRule) GetLocalTunIPv6 added in v2.2.8

func (x *ProxyRule) GetLocalTunIPv6() string

func (*ProxyRule) GetPortMap added in v2.2.8

func (x *ProxyRule) GetPortMap() map[int32]int32

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

func (*ProxyRule) Reset added in v2.2.8

func (x *ProxyRule) Reset()

func (*ProxyRule) String added in v2.2.8

func (x *ProxyRule) 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"`
	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) 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) GetJump added in v2.2.8

func (x *SshJump) GetJump() 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 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) Descriptor() ([]byte, []int)

Deprecated: Use Status.ProtoReflect.Descriptor instead.

func (*Status) GetCloneList added in v2.2.8

func (x *Status) GetCloneList() []*Clone

func (*Status) GetCluster added in v2.2.7

func (x *Status) GetCluster() string

func (*Status) GetClusterID added in v2.2.7

func (x *Status) GetClusterID() string

func (*Status) GetID added in v2.2.7

func (x *Status) GetID() int32

func (*Status) GetKubeconfig added in v2.2.7

func (x *Status) GetKubeconfig() string

func (*Status) GetMode added in v2.2.7

func (x *Status) GetMode() string

func (*Status) GetNamespace added in v2.2.7

func (x *Status) GetNamespace() string

func (*Status) GetNetif added in v2.2.7

func (x *Status) GetNetif() string

func (*Status) GetProxyList added in v2.2.8

func (x *Status) GetProxyList() []*Proxy

func (*Status) GetStatus added in v2.2.7

func (x *Status) GetStatus() string

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

func (*Status) Reset added in v2.2.7

func (x *Status) Reset()

func (*Status) String added in v2.2.7

func (x *Status) String() string

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) ConfigAdd

func (UnimplementedDaemonServer) ConfigRemove

func (UnimplementedDaemonServer) Connect

func (UnimplementedDaemonServer) ConnectFork

func (UnimplementedDaemonServer) Disconnect

func (UnimplementedDaemonServer) Get

func (UnimplementedDaemonServer) Leave

func (UnimplementedDaemonServer) List

func (UnimplementedDaemonServer) Logs

func (UnimplementedDaemonServer) Proxy

func (UnimplementedDaemonServer) Quit

func (UnimplementedDaemonServer) Remove

func (UnimplementedDaemonServer) Reset added in v2.2.3

func (UnimplementedDaemonServer) SshConnect

func (UnimplementedDaemonServer) SshStart

func (UnimplementedDaemonServer) SshStop

func (UnimplementedDaemonServer) Status

func (UnimplementedDaemonServer) Upgrade

func (UnimplementedDaemonServer) Version

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL