connector

package
v2.8.3-rc.3 Latest Latest
Warning

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

 Go to latest Published: Oct 27, 2022 License: Apache-2.0 Imports: 13 Imported by: 15

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	Result_ErrorCategory_name = map[int32]string{
		0: "UNSPECIFIED",
		1: "USER",
		2: "CONFIG",
		3: "NO_DAEMON_LOGS",
		4: "UNKNOWN",
	}
	Result_ErrorCategory_value = map[string]int32{
		"UNSPECIFIED":    0,
		"USER":           1,
		"CONFIG":         2,
		"NO_DAEMON_LOGS": 3,
		"UNKNOWN":        4,
	}
)

Enum value maps for Result_ErrorCategory.

View Source 
var (
	ConnectInfo_ErrType_name = map[int32]string{
		0: "UNSPECIFIED",
		2: "ALREADY_CONNECTED",
		7: "MUST_RESTART",
		3: "DISCONNECTED",
		4: "CLUSTER_FAILED",
		6: "TRAFFIC_MANAGER_FAILED",
		8: "DAEMON_FAILED",
	}
	ConnectInfo_ErrType_value = map[string]int32{
		"UNSPECIFIED":            0,
		"ALREADY_CONNECTED":      2,
		"MUST_RESTART":           7,
		"DISCONNECTED":           3,
		"CLUSTER_FAILED":         4,
		"TRAFFIC_MANAGER_FAILED": 6,
		"DAEMON_FAILED":          8,
	}
)

Enum value maps for ConnectInfo_ErrType.

View Source 
var (
	HelmRequest_Type_name = map[int32]string{
		0: "UNSPECIFIED",
		1: "INSTALL",
		2: "UPGRADE",
		3: "UNINSTALL",
	}
	HelmRequest_Type_value = map[string]int32{
		"UNSPECIFIED": 0,
		"INSTALL":     1,
		"UPGRADE":     2,
		"UNINSTALL":   3,
	}
)

Enum value maps for HelmRequest_Type.

View Source 
var (
	UninstallRequest_UninstallType_name = map[int32]string{
		0: "UNSPECIFIED",
		1: "NAMED_AGENTS",
		2: "ALL_AGENTS",
	}
	UninstallRequest_UninstallType_value = map[string]int32{
		"UNSPECIFIED":  0,
		"NAMED_AGENTS": 1,
		"ALL_AGENTS":   2,
	}
)

Enum value maps for UninstallRequest_UninstallType.

View Source 
var (
	ListRequest_Filter_name = map[int32]string{
		0: "UNSPECIFIED",
		1: "INTERCEPTS",
		2: "INSTALLED_AGENTS",
		3: "INTERCEPTABLE",
		4: "EVERYTHING",
	}
	ListRequest_Filter_value = map[string]int32{
		"UNSPECIFIED":      0,
		"INTERCEPTS":       1,
		"INSTALLED_AGENTS": 2,
		"INTERCEPTABLE":    3,
		"EVERYTHING":       4,
	}
)

Enum value maps for ListRequest_Filter.

View Source 
var (
	LoginResult_Code_name = map[int32]string{
		0: "UNSPECIFIED",
		1: "OLD_LOGIN_REUSED",
		2: "NEW_LOGIN_SUCCEEDED",
	}
	LoginResult_Code_value = map[string]int32{
		"UNSPECIFIED":         0,
		"OLD_LOGIN_REUSED":    1,
		"NEW_LOGIN_SUCCEEDED": 2,
	}
)

Enum value maps for LoginResult_Code.

View Source 
var Connector_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "telepresence.connector.Connector",
	HandlerType: (*ConnectorServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Version",
			Handler:    _Connector_Version_Handler,
		},
		{
			MethodName: "RootDaemonVersion",
			Handler:    _Connector_RootDaemonVersion_Handler,
		},
		{
			MethodName: "Connect",
			Handler:    _Connector_Connect_Handler,
		},
		{
			MethodName: "Disconnect",
			Handler:    _Connector_Disconnect_Handler,
		},
		{
			MethodName: "GetClusterSubnets",
			Handler:    _Connector_GetClusterSubnets_Handler,
		},
		{
			MethodName: "Status",
			Handler:    _Connector_Status_Handler,
		},
		{
			MethodName: "CanIntercept",
			Handler:    _Connector_CanIntercept_Handler,
		},
		{
			MethodName: "CreateIntercept",
			Handler:    _Connector_CreateIntercept_Handler,
		},
		{
			MethodName: "RemoveIntercept",
			Handler:    _Connector_RemoveIntercept_Handler,
		},
		{
			MethodName: "Helm",
			Handler:    _Connector_Helm_Handler,
		},
		{
			MethodName: "Uninstall",
			Handler:    _Connector_Uninstall_Handler,
		},
		{
			MethodName: "List",
			Handler:    _Connector_List_Handler,
		},
		{
			MethodName: "Login",
			Handler:    _Connector_Login_Handler,
		},
		{
			MethodName: "Logout",
			Handler:    _Connector_Logout_Handler,
		},
		{
			MethodName: "GetCloudUserInfo",
			Handler:    _Connector_GetCloudUserInfo_Handler,
		},
		{
			MethodName: "GetCloudAPIKey",
			Handler:    _Connector_GetCloudAPIKey_Handler,
		},
		{
			MethodName: "GetCloudLicense",
			Handler:    _Connector_GetCloudLicense_Handler,
		},
		{
			MethodName: "GetIngressInfos",
			Handler:    _Connector_GetIngressInfos_Handler,
		},
		{
			MethodName: "SetLogLevel",
			Handler:    _Connector_SetLogLevel_Handler,
		},
		{
			MethodName: "Quit",
			Handler:    _Connector_Quit_Handler,
		},
		{
			MethodName: "ListCommands",
			Handler:    _Connector_ListCommands_Handler,
		},
		{
			MethodName: "ValidArgsForCommand",
			Handler:    _Connector_ValidArgsForCommand_Handler,
		},
		{
			MethodName: "ResolveIngressInfo",
			Handler:    _Connector_ResolveIngressInfo_Handler,
		},
		{
			MethodName: "GatherLogs",
			Handler:    _Connector_GatherLogs_Handler,
		},
		{
			MethodName: "AddInterceptor",
			Handler:    _Connector_AddInterceptor_Handler,
		},
		{
			MethodName: "RemoveInterceptor",
			Handler:    _Connector_RemoveInterceptor_Handler,
		},
		{
			MethodName: "GetNamespaces",
			Handler:    _Connector_GetNamespaces_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "WatchWorkloads",
			Handler:       _Connector_WatchWorkloads_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "UserNotifications",
			Handler:       _Connector_UserNotifications_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "RunCommand",
			Handler:       _Connector_RunCommand_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "rpc/connector/connector.proto",
}

Connector_ServiceDesc is the grpc.ServiceDesc for Connector 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_rpc_connector_connector_proto protoreflect.FileDescriptor

Functions

func RegisterConnectorServer 

func RegisterConnectorServer(s grpc.ServiceRegistrar, srv ConnectorServer)

Types

type CommandGroups added in v2.5.0 

type CommandGroups struct {
	CommandGroups map[string]*CommandGroups_Commands `` /* 188-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*CommandGroups) Descriptor deprecated added in v2.5.0 

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

Deprecated: Use CommandGroups.ProtoReflect.Descriptor instead.

func (*CommandGroups) GetCommandGroups added in v2.5.0 

func (x *CommandGroups) GetCommandGroups() map[string]*CommandGroups_Commands

func (*CommandGroups) ProtoMessage added in v2.5.0 

func (*CommandGroups) ProtoMessage()

func (*CommandGroups) ProtoReflect added in v2.5.0 

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

func (*CommandGroups) Reset added in v2.5.0 

func (x *CommandGroups) Reset()

func (*CommandGroups) String added in v2.5.0 

func (x *CommandGroups) String() string

type CommandGroups_Command added in v2.5.0 

type CommandGroups_Command struct {
	Name      string                `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	ShortHelp string                `protobuf:"bytes,2,opt,name=short_help,json=shortHelp,proto3" json:"short_help,omitempty"`
	LongHelp  string                `protobuf:"bytes,3,opt,name=long_help,json=longHelp,proto3" json:"long_help,omitempty"`
	Flags     []*CommandGroups_Flag `protobuf:"bytes,4,rep,name=flags,proto3" json:"flags,omitempty"`
	// contains filtered or unexported fields
}

func (*CommandGroups_Command) Descriptor deprecated added in v2.5.0 

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

Deprecated: Use CommandGroups_Command.ProtoReflect.Descriptor instead.

func (*CommandGroups_Command) GetFlags added in v2.5.0 

func (x *CommandGroups_Command) GetFlags() []*CommandGroups_Flag

func (*CommandGroups_Command) GetLongHelp added in v2.5.0 

func (x *CommandGroups_Command) GetLongHelp() string

func (*CommandGroups_Command) GetName added in v2.5.0 

func (x *CommandGroups_Command) GetName() string

func (*CommandGroups_Command) GetShortHelp added in v2.5.0 

func (x *CommandGroups_Command) GetShortHelp() string

func (*CommandGroups_Command) ProtoMessage added in v2.5.0 

func (*CommandGroups_Command) ProtoMessage()

func (*CommandGroups_Command) ProtoReflect added in v2.5.0 

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

func (*CommandGroups_Command) Reset added in v2.5.0 

func (x *CommandGroups_Command) Reset()

func (*CommandGroups_Command) String added in v2.5.0 

func (x *CommandGroups_Command) String() string

type CommandGroups_Commands added in v2.5.0 

type CommandGroups_Commands struct {
	Commands []*CommandGroups_Command `protobuf:"bytes,1,rep,name=commands,proto3" json:"commands,omitempty"`
	// contains filtered or unexported fields
}

func (*CommandGroups_Commands) Descriptor deprecated added in v2.5.0 

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

Deprecated: Use CommandGroups_Commands.ProtoReflect.Descriptor instead.

func (*CommandGroups_Commands) GetCommands added in v2.5.0 

func (x *CommandGroups_Commands) GetCommands() []*CommandGroups_Command

func (*CommandGroups_Commands) ProtoMessage added in v2.5.0 

func (*CommandGroups_Commands) ProtoMessage()

func (*CommandGroups_Commands) ProtoReflect added in v2.5.0 

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

func (*CommandGroups_Commands) Reset added in v2.5.0 

func (x *CommandGroups_Commands) Reset()

func (*CommandGroups_Commands) String added in v2.5.0 

func (x *CommandGroups_Commands) String() string

type CommandGroups_Flag added in v2.5.0 

type CommandGroups_Flag struct {
	Type         string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Flag         string `protobuf:"bytes,2,opt,name=flag,proto3" json:"flag,omitempty"`
	Help         string `protobuf:"bytes,3,opt,name=help,proto3" json:"help,omitempty"`
	Shorthand    string `protobuf:"bytes,4,opt,name=shorthand,proto3" json:"shorthand,omitempty"`
	DefaultValue string `protobuf:"bytes,5,opt,name=default_value,json=defaultValue,proto3" json:"default_value,omitempty"`
	// contains filtered or unexported fields
}

func (*CommandGroups_Flag) Descriptor deprecated added in v2.5.0 

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

Deprecated: Use CommandGroups_Flag.ProtoReflect.Descriptor instead.

func (*CommandGroups_Flag) GetDefaultValue added in v2.5.0 

func (x *CommandGroups_Flag) GetDefaultValue() string

func (*CommandGroups_Flag) GetFlag added in v2.5.0 

func (x *CommandGroups_Flag) GetFlag() string

func (*CommandGroups_Flag) GetHelp added in v2.5.0 

func (x *CommandGroups_Flag) GetHelp() string

func (*CommandGroups_Flag) GetShorthand added in v2.5.0 

func (x *CommandGroups_Flag) GetShorthand() string

func (*CommandGroups_Flag) GetType added in v2.5.0 

func (x *CommandGroups_Flag) GetType() string

func (*CommandGroups_Flag) ProtoMessage added in v2.5.0 

func (*CommandGroups_Flag) ProtoMessage()

func (*CommandGroups_Flag) ProtoReflect added in v2.5.0 

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

func (*CommandGroups_Flag) Reset added in v2.5.0 

func (x *CommandGroups_Flag) Reset()

func (*CommandGroups_Flag) String added in v2.5.0 

func (x *CommandGroups_Flag) String() string

type ConnectInfo 

type ConnectInfo struct {
	Error ConnectInfo_ErrType `protobuf:"varint,1,opt,name=error,proto3,enum=telepresence.connector.ConnectInfo_ErrType" json:"error,omitempty"`
	// only set for some error codes, see above
	ErrorText      string                         `protobuf:"bytes,2,opt,name=error_text,json=errorText,proto3" json:"error_text,omitempty"`
	ErrorCategory  int32                          `protobuf:"varint,12,opt,name=error_category,json=errorCategory,proto3" json:"error_category,omitempty"`
	ClusterServer  string                         `protobuf:"bytes,3,opt,name=cluster_server,json=clusterServer,proto3" json:"cluster_server,omitempty"`
	ClusterContext string                         `protobuf:"bytes,4,opt,name=cluster_context,json=clusterContext,proto3" json:"cluster_context,omitempty"`
	Intercepts     *manager.InterceptInfoSnapshot `protobuf:"bytes,8,opt,name=intercepts,proto3" json:"intercepts,omitempty"`
	SessionInfo    *manager.SessionInfo           `protobuf:"bytes,10,opt,name=session_info,json=sessionInfo,proto3" json:"session_info,omitempty"`
	ClusterId      string                         `protobuf:"bytes,11,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	DaemonStatus   *daemon.DaemonStatus           `protobuf:"bytes,13,opt,name=daemon_status,json=daemonStatus,proto3" json:"daemon_status,omitempty"`
	// contains filtered or unexported fields
}

func (*ConnectInfo) Descriptor deprecated 

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

Deprecated: Use ConnectInfo.ProtoReflect.Descriptor instead.

func (*ConnectInfo) GetClusterContext 

func (x *ConnectInfo) GetClusterContext() string

func (*ConnectInfo) GetClusterId 

func (x *ConnectInfo) GetClusterId() string

func (*ConnectInfo) GetClusterServer 

func (x *ConnectInfo) GetClusterServer() string

func (*ConnectInfo) GetDaemonStatus added in v2.8.0 

func (x *ConnectInfo) GetDaemonStatus() *daemon.DaemonStatus

func (*ConnectInfo) GetError 

func (x *ConnectInfo) GetError() ConnectInfo_ErrType

func (*ConnectInfo) GetErrorCategory added in v2.4.3 

func (x *ConnectInfo) GetErrorCategory() int32

func (*ConnectInfo) GetErrorText 

func (x *ConnectInfo) GetErrorText() string

func (*ConnectInfo) GetIntercepts 

func (x *ConnectInfo) GetIntercepts() *manager.InterceptInfoSnapshot

func (*ConnectInfo) GetSessionInfo 

func (x *ConnectInfo) GetSessionInfo() *manager.SessionInfo

func (*ConnectInfo) ProtoMessage 

func (*ConnectInfo) ProtoMessage()

func (*ConnectInfo) ProtoReflect 

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

func (*ConnectInfo) Reset 

func (x *ConnectInfo) Reset()

func (*ConnectInfo) String 

func (x *ConnectInfo) String() string

type ConnectInfo_ErrType 

type ConnectInfo_ErrType int32
const (
	ConnectInfo_UNSPECIFIED       ConnectInfo_ErrType = 0 // success
	ConnectInfo_ALREADY_CONNECTED ConnectInfo_ErrType = 2 // success
	ConnectInfo_MUST_RESTART      ConnectInfo_ErrType = 7 // would-be-success, but kubeconfig has changed
	// failure: Connect has not yet been called (only returned from Status)
	ConnectInfo_DISCONNECTED ConnectInfo_ErrType = 3
	// failure: error parsing kubeconfig or talking to the cluster; error_text and error_category are set
	ConnectInfo_CLUSTER_FAILED ConnectInfo_ErrType = 4
	// failure: error talking to the in-cluster traffic-manager; error_text and error_category are set
	ConnectInfo_TRAFFIC_MANAGER_FAILED ConnectInfo_ErrType = 6
	// failure: error talking to the on-laptop root daemon; error_text and error_category are set
	ConnectInfo_DAEMON_FAILED ConnectInfo_ErrType = 8
)

func (ConnectInfo_ErrType) Descriptor 

func (ConnectInfo_ErrType) Descriptor() protoreflect.EnumDescriptor

func (ConnectInfo_ErrType) Enum 

func (x ConnectInfo_ErrType) Enum() *ConnectInfo_ErrType

func (ConnectInfo_ErrType) EnumDescriptor deprecated 

func (ConnectInfo_ErrType) EnumDescriptor() ([]byte, []int)

Deprecated: Use ConnectInfo_ErrType.Descriptor instead.

func (ConnectInfo_ErrType) Number 

func (x ConnectInfo_ErrType) Number() protoreflect.EnumNumber

func (ConnectInfo_ErrType) String 

func (x ConnectInfo_ErrType) String() string

func (ConnectInfo_ErrType) Type 

func (ConnectInfo_ErrType) Type() protoreflect.EnumType

type ConnectRequest 

type ConnectRequest struct {
	KubeFlags        map[string]string `` /* 176-byte string literal not displayed */
	MappedNamespaces []string          `protobuf:"bytes,2,rep,name=mapped_namespaces,json=mappedNamespaces,proto3" json:"mapped_namespaces,omitempty"`
	IsPodDaemon      bool              `protobuf:"varint,4,opt,name=is_pod_daemon,json=isPodDaemon,proto3" json:"is_pod_daemon,omitempty"`
	// contains filtered or unexported fields
}

ConnectRequest contains the information needed to connect ot a cluster.

func (*ConnectRequest) Descriptor deprecated 

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

Deprecated: Use ConnectRequest.ProtoReflect.Descriptor instead.

func (*ConnectRequest) GetIsPodDaemon added in v2.7.0 

func (x *ConnectRequest) GetIsPodDaemon() bool

func (*ConnectRequest) GetKubeFlags 

func (x *ConnectRequest) GetKubeFlags() map[string]string

func (*ConnectRequest) GetMappedNamespaces 

func (x *ConnectRequest) GetMappedNamespaces() []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 ConnectorClient 

type ConnectorClient interface {
	// Returns version information from the Connector
	Version(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*common.VersionInfo, error)
	// Returns version information from the Root Daemon
	RootDaemonVersion(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*common.VersionInfo, error)
	// Connects to the cluster and connects the laptop's network (via
	// the daemon process) to the cluster's network.  A result code of
	// UNSPECIFIED indicates that the connection was successfully
	// initiated; if already connected, then either ALREADY_CONNECTED or
	// MUST_RESTART is returned, based on whether the current connection
	// is in agreement with the ConnectionRequest.
	Connect(ctx context.Context, in *ConnectRequest, opts ...grpc.CallOption) (*ConnectInfo, error)
	// Disconnects the cluster
	Disconnect(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// GetClusterSubnets gets the outbound info that has been set on daemon
	GetClusterSubnets(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*daemon.ClusterSubnets, error)
	// Status returns the status of the current connection or DISCONNECTED
	// if no connection has been established.
	Status(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ConnectInfo, error)
	// Queries the connector whether it is possible to create the given intercept.
	CanIntercept(ctx context.Context, in *CreateInterceptRequest, opts ...grpc.CallOption) (*InterceptResult, error)
	// Adds an intercept to a workload.  Requires having already called
	// Connect.
	CreateIntercept(ctx context.Context, in *CreateInterceptRequest, opts ...grpc.CallOption) (*InterceptResult, error)
	// Deactivates and removes an existent workload intercept.
	// Requires having already called Connect.
	RemoveIntercept(ctx context.Context, in *manager.RemoveInterceptRequest2, opts ...grpc.CallOption) (*InterceptResult, error)
	// Installs, Upgrades, or Uninstalls the traffic-manager in the cluster.
	Helm(ctx context.Context, in *HelmRequest, opts ...grpc.CallOption) (*Result, error)
	// Uninstalls traffic-agents from the cluster.
	// Requires having already called Connect.
	Uninstall(ctx context.Context, in *UninstallRequest, opts ...grpc.CallOption) (*Result, error)
	// Returns a list of workloads and their current intercept status.
	// Requires having already called Connect.
	List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*WorkloadInfoSnapshot, error)
	// Watch all workloads in the mapped namespaces
	WatchWorkloads(ctx context.Context, in *WatchWorkloadsRequest, opts ...grpc.CallOption) (Connector_WatchWorkloadsClient, error)
	// Returns a stream of messages to display to the user.  Does NOT
	// require having called anything else first.
	UserNotifications(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (Connector_UserNotificationsClient, error)
	Login(ctx context.Context, in *LoginRequest, opts ...grpc.CallOption) (*LoginResult, error)
	// Returns an error with code=NotFound if not currently logged in.
	Logout(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)
	GetCloudUserInfo(ctx context.Context, in *UserInfoRequest, opts ...grpc.CallOption) (*UserInfo, error)
	GetCloudAPIKey(ctx context.Context, in *KeyRequest, opts ...grpc.CallOption) (*KeyData, error)
	GetCloudLicense(ctx context.Context, in *LicenseRequest, opts ...grpc.CallOption) (*LicenseData, error)
	GetIngressInfos(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*IngressInfos, error)
	// SetLogLevel will temporarily set the log-level for the daemon for a duration that is determined by the request.
	SetLogLevel(ctx context.Context, in *manager.LogLevelRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Quits (terminates) the connector process.
	Quit(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// ListCommands returns a list of CLI commands that are implemented remotely by this daemon.
	ListCommands(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*CommandGroups, error)
	// RunCommand executes a CLI command.
	RunCommand(ctx context.Context, opts ...grpc.CallOption) (Connector_RunCommandClient, error)
	// ValidArgsForCommand handles autocompletion
	ValidArgsForCommand(ctx context.Context, in *ValidArgsForCommandRequest, opts ...grpc.CallOption) (*ValidArgsForCommandResponse, error)
	// ResolveIngressInfo is a temporary rpc intended to allow the cli to ask
	// the cloud for default ingress values
	ResolveIngressInfo(ctx context.Context, in *userdaemon.IngressInfoRequest, opts ...grpc.CallOption) (*userdaemon.IngressInfoResponse, error)
	// GatherLogs will acquire logs for the various Telepresence components in kubernetes
	// (pending the request) and return them to the caller
	GatherLogs(ctx context.Context, in *LogsRequest, opts ...grpc.CallOption) (*LogsResponse, error)
	// AddInterceptor tells the connector that a given process is serving a specific
	// intercept. The connector must kill this process when the intercept ends
	AddInterceptor(ctx context.Context, in *Interceptor, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// RemoveInterceptor removes a previously added interceptor
	RemoveInterceptor(ctx context.Context, in *Interceptor, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// GetNamespaces gets the mapped namespaces with an optional prefix
	GetNamespaces(ctx context.Context, in *GetNamespacesRequest, opts ...grpc.CallOption) (*GetNamespacesResponse, error)
}

ConnectorClient is the client API for Connector 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 NewConnectorClient 

func NewConnectorClient(cc grpc.ClientConnInterface) ConnectorClient

type ConnectorServer 

type ConnectorServer interface {
	// Returns version information from the Connector
	Version(context.Context, *emptypb.Empty) (*common.VersionInfo, error)
	// Returns version information from the Root Daemon
	RootDaemonVersion(context.Context, *emptypb.Empty) (*common.VersionInfo, error)
	// Connects to the cluster and connects the laptop's network (via
	// the daemon process) to the cluster's network.  A result code of
	// UNSPECIFIED indicates that the connection was successfully
	// initiated; if already connected, then either ALREADY_CONNECTED or
	// MUST_RESTART is returned, based on whether the current connection
	// is in agreement with the ConnectionRequest.
	Connect(context.Context, *ConnectRequest) (*ConnectInfo, error)
	// Disconnects the cluster
	Disconnect(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
	// GetClusterSubnets gets the outbound info that has been set on daemon
	GetClusterSubnets(context.Context, *emptypb.Empty) (*daemon.ClusterSubnets, error)
	// Status returns the status of the current connection or DISCONNECTED
	// if no connection has been established.
	Status(context.Context, *emptypb.Empty) (*ConnectInfo, error)
	// Queries the connector whether it is possible to create the given intercept.
	CanIntercept(context.Context, *CreateInterceptRequest) (*InterceptResult, error)
	// Adds an intercept to a workload.  Requires having already called
	// Connect.
	CreateIntercept(context.Context, *CreateInterceptRequest) (*InterceptResult, error)
	// Deactivates and removes an existent workload intercept.
	// Requires having already called Connect.
	RemoveIntercept(context.Context, *manager.RemoveInterceptRequest2) (*InterceptResult, error)
	// Installs, Upgrades, or Uninstalls the traffic-manager in the cluster.
	Helm(context.Context, *HelmRequest) (*Result, error)
	// Uninstalls traffic-agents from the cluster.
	// Requires having already called Connect.
	Uninstall(context.Context, *UninstallRequest) (*Result, error)
	// Returns a list of workloads and their current intercept status.
	// Requires having already called Connect.
	List(context.Context, *ListRequest) (*WorkloadInfoSnapshot, error)
	// Watch all workloads in the mapped namespaces
	WatchWorkloads(*WatchWorkloadsRequest, Connector_WatchWorkloadsServer) error
	// Returns a stream of messages to display to the user.  Does NOT
	// require having called anything else first.
	UserNotifications(*emptypb.Empty, Connector_UserNotificationsServer) error
	Login(context.Context, *LoginRequest) (*LoginResult, error)
	// Returns an error with code=NotFound if not currently logged in.
	Logout(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
	GetCloudUserInfo(context.Context, *UserInfoRequest) (*UserInfo, error)
	GetCloudAPIKey(context.Context, *KeyRequest) (*KeyData, error)
	GetCloudLicense(context.Context, *LicenseRequest) (*LicenseData, error)
	GetIngressInfos(context.Context, *emptypb.Empty) (*IngressInfos, error)
	// SetLogLevel will temporarily set the log-level for the daemon for a duration that is determined by the request.
	SetLogLevel(context.Context, *manager.LogLevelRequest) (*emptypb.Empty, error)
	// Quits (terminates) the connector process.
	Quit(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
	// ListCommands returns a list of CLI commands that are implemented remotely by this daemon.
	ListCommands(context.Context, *emptypb.Empty) (*CommandGroups, error)
	// RunCommand executes a CLI command.
	RunCommand(Connector_RunCommandServer) error
	// ValidArgsForCommand handles autocompletion
	ValidArgsForCommand(context.Context, *ValidArgsForCommandRequest) (*ValidArgsForCommandResponse, error)
	// ResolveIngressInfo is a temporary rpc intended to allow the cli to ask
	// the cloud for default ingress values
	ResolveIngressInfo(context.Context, *userdaemon.IngressInfoRequest) (*userdaemon.IngressInfoResponse, error)
	// GatherLogs will acquire logs for the various Telepresence components in kubernetes
	// (pending the request) and return them to the caller
	GatherLogs(context.Context, *LogsRequest) (*LogsResponse, error)
	// AddInterceptor tells the connector that a given process is serving a specific
	// intercept. The connector must kill this process when the intercept ends
	AddInterceptor(context.Context, *Interceptor) (*emptypb.Empty, error)
	// RemoveInterceptor removes a previously added interceptor
	RemoveInterceptor(context.Context, *Interceptor) (*emptypb.Empty, error)
	// GetNamespaces gets the mapped namespaces with an optional prefix
	GetNamespaces(context.Context, *GetNamespacesRequest) (*GetNamespacesResponse, error)
	// contains filtered or unexported methods
}

ConnectorServer is the server API for Connector service. All implementations must embed UnimplementedConnectorServer for forward compatibility

type Connector_RunCommandClient added in v2.7.2 

type Connector_RunCommandClient interface {
	Send(*RunCommandRequest) error
	Recv() (*StreamResult, error)
	grpc.ClientStream
}

type Connector_RunCommandServer added in v2.7.2 

type Connector_RunCommandServer interface {
	Send(*StreamResult) error
	Recv() (*RunCommandRequest, error)
	grpc.ServerStream
}

type Connector_UserNotificationsClient added in v2.1.4 

type Connector_UserNotificationsClient interface {
	Recv() (*Notification, error)
	grpc.ClientStream
}

type Connector_UserNotificationsServer added in v2.1.4 

type Connector_UserNotificationsServer interface {
	Send(*Notification) error
	grpc.ServerStream
}

type Connector_WatchWorkloadsClient added in v2.5.0 

type Connector_WatchWorkloadsClient interface {
	Recv() (*WorkloadInfoSnapshot, error)
	grpc.ClientStream
}

type Connector_WatchWorkloadsServer added in v2.5.0 

type Connector_WatchWorkloadsServer interface {
	Send(*WorkloadInfoSnapshot) error
	grpc.ServerStream
}

type CreateInterceptRequest 

type CreateInterceptRequest struct {

	// No need to set spec.client; the connector will fill that in for
	// you.
	Spec        *manager.InterceptSpec `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"`
	MountPoint  string                 `protobuf:"bytes,2,opt,name=mount_point,json=mountPoint,proto3" json:"mount_point,omitempty"`
	AgentImage  string                 `protobuf:"bytes,3,opt,name=agent_image,json=agentImage,proto3" json:"agent_image,omitempty"`
	IsPodDaemon bool                   `protobuf:"varint,4,opt,name=is_pod_daemon,json=isPodDaemon,proto3" json:"is_pod_daemon,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateInterceptRequest) Descriptor deprecated 

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

Deprecated: Use CreateInterceptRequest.ProtoReflect.Descriptor instead.

func (*CreateInterceptRequest) GetAgentImage 

func (x *CreateInterceptRequest) GetAgentImage() string

func (*CreateInterceptRequest) GetIsPodDaemon added in v2.7.0 

func (x *CreateInterceptRequest) GetIsPodDaemon() bool

func (*CreateInterceptRequest) GetMountPoint 

func (x *CreateInterceptRequest) GetMountPoint() string

func (*CreateInterceptRequest) GetSpec 

func (x *CreateInterceptRequest) GetSpec() *manager.InterceptSpec

func (*CreateInterceptRequest) ProtoMessage 

func (*CreateInterceptRequest) ProtoMessage()

func (*CreateInterceptRequest) ProtoReflect 

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

func (*CreateInterceptRequest) Reset 

func (x *CreateInterceptRequest) Reset()

func (*CreateInterceptRequest) String 

func (x *CreateInterceptRequest) String() string

type GetNamespacesRequest added in v2.7.2 

type GetNamespacesRequest struct {
	ForClientAccess bool   `protobuf:"varint,1,opt,name=for_client_access,json=forClientAccess,proto3" json:"for_client_access,omitempty"`
	Prefix          string `protobuf:"bytes,2,opt,name=prefix,proto3" json:"prefix,omitempty"`
	// contains filtered or unexported fields
}

func (*GetNamespacesRequest) Descriptor deprecated added in v2.7.2 

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

Deprecated: Use GetNamespacesRequest.ProtoReflect.Descriptor instead.

func (*GetNamespacesRequest) GetForClientAccess added in v2.7.2 

func (x *GetNamespacesRequest) GetForClientAccess() bool

func (*GetNamespacesRequest) GetPrefix added in v2.7.2 

func (x *GetNamespacesRequest) GetPrefix() string

func (*GetNamespacesRequest) ProtoMessage added in v2.7.2 

func (*GetNamespacesRequest) ProtoMessage()

func (*GetNamespacesRequest) ProtoReflect added in v2.7.2 

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

func (*GetNamespacesRequest) Reset added in v2.7.2 

func (x *GetNamespacesRequest) Reset()

func (*GetNamespacesRequest) String added in v2.7.2 

func (x *GetNamespacesRequest) String() string

type GetNamespacesResponse added in v2.7.2 

type GetNamespacesResponse struct {
	Namespaces []string `protobuf:"bytes,2,rep,name=namespaces,proto3" json:"namespaces,omitempty"`
	// contains filtered or unexported fields
}

func (*GetNamespacesResponse) Descriptor deprecated added in v2.7.2 

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

Deprecated: Use GetNamespacesResponse.ProtoReflect.Descriptor instead.

func (*GetNamespacesResponse) GetNamespaces added in v2.7.2 

func (x *GetNamespacesResponse) GetNamespaces() []string

func (*GetNamespacesResponse) ProtoMessage added in v2.7.2 

func (*GetNamespacesResponse) ProtoMessage()

func (*GetNamespacesResponse) ProtoReflect added in v2.7.2 

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

func (*GetNamespacesResponse) Reset added in v2.7.2 

func (x *GetNamespacesResponse) Reset()

func (*GetNamespacesResponse) String added in v2.7.2 

func (x *GetNamespacesResponse) String() string

type HelmRequest added in v2.7.1 

type HelmRequest struct {
	ConnectRequest *ConnectRequest  `protobuf:"bytes,1,opt,name=connect_request,json=connectRequest,proto3" json:"connect_request,omitempty"`
	Type           HelmRequest_Type `protobuf:"varint,2,opt,name=type,proto3,enum=telepresence.connector.HelmRequest_Type" json:"type,omitempty"`
	ValuePaths     []string         `protobuf:"bytes,3,rep,name=value_paths,json=valuePaths,proto3" json:"value_paths,omitempty"`
	ValuePairs     []string         `protobuf:"bytes,4,rep,name=value_pairs,json=valuePairs,proto3" json:"value_pairs,omitempty"`
	// contains filtered or unexported fields
}

func (*HelmRequest) Descriptor deprecated added in v2.7.1 

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

Deprecated: Use HelmRequest.ProtoReflect.Descriptor instead.

func (*HelmRequest) GetConnectRequest added in v2.7.1 

func (x *HelmRequest) GetConnectRequest() *ConnectRequest

func (*HelmRequest) GetType added in v2.7.1 

func (x *HelmRequest) GetType() HelmRequest_Type

func (*HelmRequest) GetValuePairs added in v2.8.3 

func (x *HelmRequest) GetValuePairs() []string

func (*HelmRequest) GetValuePaths added in v2.7.1 

func (x *HelmRequest) GetValuePaths() []string

func (*HelmRequest) ProtoMessage added in v2.7.1 

func (*HelmRequest) ProtoMessage()

func (*HelmRequest) ProtoReflect added in v2.7.1 

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

func (*HelmRequest) Reset added in v2.7.1 

func (x *HelmRequest) Reset()

func (*HelmRequest) String added in v2.7.1 

func (x *HelmRequest) String() string

type HelmRequest_Type added in v2.7.1 

type HelmRequest_Type int32
const (
	HelmRequest_UNSPECIFIED HelmRequest_Type = 0
	HelmRequest_INSTALL     HelmRequest_Type = 1
	HelmRequest_UPGRADE     HelmRequest_Type = 2
	HelmRequest_UNINSTALL   HelmRequest_Type = 3
)

func (HelmRequest_Type) Descriptor added in v2.7.1 

func (HelmRequest_Type) Descriptor() protoreflect.EnumDescriptor

func (HelmRequest_Type) Enum added in v2.7.1 

func (x HelmRequest_Type) Enum() *HelmRequest_Type

func (HelmRequest_Type) EnumDescriptor deprecated added in v2.7.1 

func (HelmRequest_Type) EnumDescriptor() ([]byte, []int)

Deprecated: Use HelmRequest_Type.Descriptor instead.

func (HelmRequest_Type) Number added in v2.7.1 

func (x HelmRequest_Type) Number() protoreflect.EnumNumber

func (HelmRequest_Type) String added in v2.7.1 

func (x HelmRequest_Type) String() string

func (HelmRequest_Type) Type added in v2.7.1 

func (HelmRequest_Type) Type() protoreflect.EnumType

type IngressInfos added in v2.5.0 

type IngressInfos struct {
	IngressInfos []*manager.IngressInfo `protobuf:"bytes,1,rep,name=ingress_infos,json=ingressInfos,proto3" json:"ingress_infos,omitempty"`
	// contains filtered or unexported fields
}

func (*IngressInfos) Descriptor deprecated added in v2.5.0 

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

Deprecated: Use IngressInfos.ProtoReflect.Descriptor instead.

func (*IngressInfos) GetIngressInfos added in v2.5.0 

func (x *IngressInfos) GetIngressInfos() []*manager.IngressInfo

func (*IngressInfos) ProtoMessage added in v2.5.0 

func (*IngressInfos) ProtoMessage()

func (*IngressInfos) ProtoReflect added in v2.5.0 

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

func (*IngressInfos) Reset added in v2.5.0 

func (x *IngressInfos) Reset()

func (*IngressInfos) String added in v2.5.0 

func (x *IngressInfos) String() string

type InterceptResult 

type InterceptResult struct {
	InterceptInfo *manager.InterceptInfo `protobuf:"bytes,1,opt,name=intercept_info,json=interceptInfo,proto3" json:"intercept_info,omitempty"`
	Error         common.InterceptError  `protobuf:"varint,2,opt,name=error,proto3,enum=telepresence.common.InterceptError" json:"error,omitempty"`
	ErrorText     string                 `protobuf:"bytes,3,opt,name=error_text,json=errorText,proto3" json:"error_text,omitempty"`
	ErrorCategory int32                  `protobuf:"varint,7,opt,name=error_category,json=errorCategory,proto3" json:"error_category,omitempty"`
	// The service uid associated with the workload intercepted
	ServiceUid string `protobuf:"bytes,5,opt,name=service_uid,json=serviceUid,proto3" json:"service_uid,omitempty"`
	// The kind of workload in this intercept
	WorkloadKind string `protobuf:"bytes,6,opt,name=workload_kind,json=workloadKind,proto3" json:"workload_kind,omitempty"`
	// The port number that service_port_identifier resolved into is
	// used as the default port for the ingress for pro intercepts
	ServiceProps *userdaemon.IngressInfoRequest `protobuf:"bytes,8,opt,name=service_props,json=serviceProps,proto3" json:"service_props,omitempty"`
	// contains filtered or unexported fields
}

func (*InterceptResult) Descriptor deprecated 

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

Deprecated: Use InterceptResult.ProtoReflect.Descriptor instead.

func (*InterceptResult) GetError 

func (x *InterceptResult) GetError() common.InterceptError

func (*InterceptResult) GetErrorCategory added in v2.4.3 

func (x *InterceptResult) GetErrorCategory() int32

func (*InterceptResult) GetErrorText 

func (x *InterceptResult) GetErrorText() string

func (*InterceptResult) GetInterceptInfo 

func (x *InterceptResult) GetInterceptInfo() *manager.InterceptInfo

func (*InterceptResult) GetServiceProps added in v2.5.0 

func (x *InterceptResult) GetServiceProps() *userdaemon.IngressInfoRequest

func (*InterceptResult) GetServiceUid added in v2.1.2 

func (x *InterceptResult) GetServiceUid() string

func (*InterceptResult) GetWorkloadKind added in v2.1.3 

func (x *InterceptResult) GetWorkloadKind() string

func (*InterceptResult) ProtoMessage 

func (*InterceptResult) ProtoMessage()

func (*InterceptResult) ProtoReflect 

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

func (*InterceptResult) Reset 

func (x *InterceptResult) Reset()

func (*InterceptResult) String 

func (x *InterceptResult) String() string

type Interceptor added in v2.6.0 

type Interceptor struct {

	// The ID of the intercept that is served by this interceptor process
	InterceptId string `protobuf:"bytes,1,opt,name=intercept_id,json=interceptId,proto3" json:"intercept_id,omitempty"`
	// The pid of the interceptor process
	Pid int32 `protobuf:"varint,2,opt,name=pid,proto3" json:"pid,omitempty"`
	// contains filtered or unexported fields
}

func (*Interceptor) Descriptor deprecated added in v2.6.0 

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

Deprecated: Use Interceptor.ProtoReflect.Descriptor instead.

func (*Interceptor) GetInterceptId added in v2.6.0 

func (x *Interceptor) GetInterceptId() string

func (*Interceptor) GetPid added in v2.6.0 

func (x *Interceptor) GetPid() int32

func (*Interceptor) ProtoMessage added in v2.6.0 

func (*Interceptor) ProtoMessage()

func (*Interceptor) ProtoReflect added in v2.6.0 

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

func (*Interceptor) Reset added in v2.6.0 

func (x *Interceptor) Reset()

func (*Interceptor) String added in v2.6.0 

func (x *Interceptor) String() string

type KeyData added in v2.1.4 

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

func (*KeyData) Descriptor deprecated added in v2.1.4 

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

Deprecated: Use KeyData.ProtoReflect.Descriptor instead.

func (*KeyData) GetApiKey added in v2.1.4 

func (x *KeyData) GetApiKey() string

func (*KeyData) ProtoMessage added in v2.1.4 

func (*KeyData) ProtoMessage()

func (*KeyData) ProtoReflect added in v2.1.4 

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

func (*KeyData) Reset added in v2.1.4 

func (x *KeyData) Reset()

func (*KeyData) String added in v2.1.4 

func (x *KeyData) String() string

type KeyRequest added in v2.1.4 

type KeyRequest struct {
	AutoLogin   bool   `protobuf:"varint,1,opt,name=auto_login,json=autoLogin,proto3" json:"auto_login,omitempty"`
	Description string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	// contains filtered or unexported fields
}

func (*KeyRequest) Descriptor deprecated added in v2.1.4 

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

Deprecated: Use KeyRequest.ProtoReflect.Descriptor instead.

func (*KeyRequest) GetAutoLogin added in v2.1.4 

func (x *KeyRequest) GetAutoLogin() bool

func (*KeyRequest) GetDescription added in v2.1.4 

func (x *KeyRequest) GetDescription() string

func (*KeyRequest) ProtoMessage added in v2.1.4 

func (*KeyRequest) ProtoMessage()

func (*KeyRequest) ProtoReflect added in v2.1.4 

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

func (*KeyRequest) Reset added in v2.1.4 

func (x *KeyRequest) Reset()

func (*KeyRequest) String added in v2.1.4 

func (x *KeyRequest) String() string

type LicenseData added in v2.2.0 

type LicenseData struct {
	License    string `protobuf:"bytes,1,opt,name=license,proto3" json:"license,omitempty"`
	HostDomain string `protobuf:"bytes,2,opt,name=host_domain,json=hostDomain,proto3" json:"host_domain,omitempty"`
	// contains filtered or unexported fields
}

func (*LicenseData) Descriptor deprecated added in v2.2.0 

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

Deprecated: Use LicenseData.ProtoReflect.Descriptor instead.

func (*LicenseData) GetHostDomain added in v2.2.0 

func (x *LicenseData) GetHostDomain() string

func (*LicenseData) GetLicense added in v2.2.0 

func (x *LicenseData) GetLicense() string

func (*LicenseData) ProtoMessage added in v2.2.0 

func (*LicenseData) ProtoMessage()

func (*LicenseData) ProtoReflect added in v2.2.0 

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

func (*LicenseData) Reset added in v2.2.0 

func (x *LicenseData) Reset()

func (*LicenseData) String added in v2.2.0 

func (x *LicenseData) String() string

type LicenseRequest added in v2.2.0 

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

func (*LicenseRequest) Descriptor deprecated added in v2.2.0 

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

Deprecated: Use LicenseRequest.ProtoReflect.Descriptor instead.

func (*LicenseRequest) GetId added in v2.2.0 

func (x *LicenseRequest) GetId() string

func (*LicenseRequest) ProtoMessage added in v2.2.0 

func (*LicenseRequest) ProtoMessage()

func (*LicenseRequest) ProtoReflect added in v2.2.0 

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

func (*LicenseRequest) Reset added in v2.2.0 

func (x *LicenseRequest) Reset()

func (*LicenseRequest) String added in v2.2.0 

func (x *LicenseRequest) String() string

type ListRequest 

type ListRequest struct {
	Filter ListRequest_Filter `protobuf:"varint,1,opt,name=filter,proto3,enum=telepresence.connector.ListRequest_Filter" json:"filter,omitempty"`
	// Namespace to list.
	Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// contains filtered or unexported fields
}

func (*ListRequest) Descriptor deprecated 

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

Deprecated: Use ListRequest.ProtoReflect.Descriptor instead.

func (*ListRequest) GetFilter 

func (x *ListRequest) GetFilter() ListRequest_Filter

func (*ListRequest) GetNamespace 

func (x *ListRequest) GetNamespace() string

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 ListRequest_Filter 

type ListRequest_Filter int32
const (
	ListRequest_UNSPECIFIED      ListRequest_Filter = 0
	ListRequest_INTERCEPTS       ListRequest_Filter = 1
	ListRequest_INSTALLED_AGENTS ListRequest_Filter = 2
	ListRequest_INTERCEPTABLE    ListRequest_Filter = 3
	ListRequest_EVERYTHING       ListRequest_Filter = 4
)

func (ListRequest_Filter) Descriptor 

func (ListRequest_Filter) Descriptor() protoreflect.EnumDescriptor

func (ListRequest_Filter) Enum 

func (x ListRequest_Filter) Enum() *ListRequest_Filter

func (ListRequest_Filter) EnumDescriptor deprecated 

func (ListRequest_Filter) EnumDescriptor() ([]byte, []int)

Deprecated: Use ListRequest_Filter.Descriptor instead.

func (ListRequest_Filter) Number 

func (x ListRequest_Filter) Number() protoreflect.EnumNumber

func (ListRequest_Filter) String 

func (x ListRequest_Filter) String() string

func (ListRequest_Filter) Type 

func (ListRequest_Filter) Type() protoreflect.EnumType

type LoginRequest added in v2.3.7 

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

func (*LoginRequest) Descriptor deprecated added in v2.3.7 

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

Deprecated: Use LoginRequest.ProtoReflect.Descriptor instead.

func (*LoginRequest) GetApiKey added in v2.3.7 

func (x *LoginRequest) GetApiKey() string

func (*LoginRequest) ProtoMessage added in v2.3.7 

func (*LoginRequest) ProtoMessage()

func (*LoginRequest) ProtoReflect added in v2.3.7 

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

func (*LoginRequest) Reset added in v2.3.7 

func (x *LoginRequest) Reset()

func (*LoginRequest) String added in v2.3.7 

func (x *LoginRequest) String() string

type LoginResult added in v2.1.4 

type LoginResult struct {
	Code LoginResult_Code `protobuf:"varint,1,opt,name=code,proto3,enum=telepresence.connector.LoginResult_Code" json:"code,omitempty"`
	// contains filtered or unexported fields
}

func (*LoginResult) Descriptor deprecated added in v2.1.4 

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

Deprecated: Use LoginResult.ProtoReflect.Descriptor instead.

func (*LoginResult) GetCode added in v2.1.4 

func (x *LoginResult) GetCode() LoginResult_Code

func (*LoginResult) ProtoMessage added in v2.1.4 

func (*LoginResult) ProtoMessage()

func (*LoginResult) ProtoReflect added in v2.1.4 

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

func (*LoginResult) Reset added in v2.1.4 

func (x *LoginResult) Reset()

func (*LoginResult) String added in v2.1.4 

func (x *LoginResult) String() string

type LoginResult_Code added in v2.1.4 

type LoginResult_Code int32
const (
	LoginResult_UNSPECIFIED         LoginResult_Code = 0
	LoginResult_OLD_LOGIN_REUSED    LoginResult_Code = 1 // success; already logged in
	LoginResult_NEW_LOGIN_SUCCEEDED LoginResult_Code = 2 // success
)

func (LoginResult_Code) Descriptor added in v2.1.4 

func (LoginResult_Code) Descriptor() protoreflect.EnumDescriptor

func (LoginResult_Code) Enum added in v2.1.4 

func (x LoginResult_Code) Enum() *LoginResult_Code

func (LoginResult_Code) EnumDescriptor deprecated added in v2.1.4 

func (LoginResult_Code) EnumDescriptor() ([]byte, []int)

Deprecated: Use LoginResult_Code.Descriptor instead.

func (LoginResult_Code) Number added in v2.1.4 

func (x LoginResult_Code) Number() protoreflect.EnumNumber

func (LoginResult_Code) String added in v2.1.4 

func (x LoginResult_Code) String() string

func (LoginResult_Code) Type added in v2.1.4 

func (LoginResult_Code) Type() protoreflect.EnumType

type LogsRequest added in v2.5.5 

type LogsRequest struct {

	// Whether or not logs from the traffic-manager are desired.
	TrafficManager bool `protobuf:"varint,1,opt,name=traffic_manager,json=trafficManager,proto3" json:"traffic_manager,omitempty"`
	// Whether or not to get the pod yaml deployed to the cluster.
	GetPodYaml bool `protobuf:"varint,2,opt,name=get_pod_yaml,json=getPodYaml,proto3" json:"get_pod_yaml,omitempty"`
	// The traffic-agent(s) logs are desired from. Can be `all`, `False`,
	// or substring to filter based on pod names.
	Agents string `protobuf:"bytes,3,opt,name=agents,proto3" json:"agents,omitempty"`
	// Directory that the logs will be exported to
	ExportDir string `protobuf:"bytes,4,opt,name=export_dir,json=exportDir,proto3" json:"export_dir,omitempty"`
	// contains filtered or unexported fields
}

func (*LogsRequest) Descriptor deprecated added in v2.5.5 

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

Deprecated: Use LogsRequest.ProtoReflect.Descriptor instead.

func (*LogsRequest) GetAgents added in v2.5.5 

func (x *LogsRequest) GetAgents() string

func (*LogsRequest) GetExportDir added in v2.5.6 

func (x *LogsRequest) GetExportDir() string

func (*LogsRequest) GetGetPodYaml added in v2.5.5 

func (x *LogsRequest) GetGetPodYaml() bool

func (*LogsRequest) GetTrafficManager added in v2.5.5 

func (x *LogsRequest) GetTrafficManager() bool

func (*LogsRequest) ProtoMessage added in v2.5.5 

func (*LogsRequest) ProtoMessage()

func (*LogsRequest) ProtoReflect added in v2.5.5 

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

func (*LogsRequest) Reset added in v2.5.5 

func (x *LogsRequest) Reset()

func (*LogsRequest) String added in v2.5.5 

func (x *LogsRequest) String() string

type LogsResponse added in v2.5.5 

type LogsResponse struct {

	// General error that isn't associated with a pod such as failing to list the pods.
	Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	// pod_info contains one entry per created file name name. The value is either the string
	// "ok" indicating that the file exists, or an error string with info why it could not
	// be created.
	PodInfo map[string]string `` /* 170-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*LogsResponse) Descriptor deprecated added in v2.5.5 

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

Deprecated: Use LogsResponse.ProtoReflect.Descriptor instead.

func (*LogsResponse) GetError added in v2.5.6 

func (x *LogsResponse) GetError() string

func (*LogsResponse) GetPodInfo added in v2.5.6 

func (x *LogsResponse) GetPodInfo() map[string]string

func (*LogsResponse) ProtoMessage added in v2.5.5 

func (*LogsResponse) ProtoMessage()

func (*LogsResponse) ProtoReflect added in v2.5.5 

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

func (*LogsResponse) Reset added in v2.5.5 

func (x *LogsResponse) Reset()

func (*LogsResponse) String added in v2.5.5 

func (x *LogsResponse) String() string

type Notification added in v2.1.4 

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

func (*Notification) Descriptor deprecated added in v2.1.4 

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

Deprecated: Use Notification.ProtoReflect.Descriptor instead.

func (*Notification) GetMessage added in v2.1.4 

func (x *Notification) GetMessage() string

func (*Notification) ProtoMessage added in v2.1.4 

func (*Notification) ProtoMessage()

func (*Notification) ProtoReflect added in v2.1.4 

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

func (*Notification) Reset added in v2.1.4 

func (x *Notification) Reset()

func (*Notification) String added in v2.1.4 

func (x *Notification) String() string

type Result added in v2.7.1 

type Result struct {
	Data          []byte               `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	ErrorCategory Result_ErrorCategory `` /* 150-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Result) Descriptor deprecated added in v2.7.1 

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

Deprecated: Use Result.ProtoReflect.Descriptor instead.

func (*Result) GetData added in v2.7.2 

func (x *Result) GetData() []byte

func (*Result) GetErrorCategory added in v2.7.1 

func (x *Result) GetErrorCategory() Result_ErrorCategory

func (*Result) ProtoMessage added in v2.7.1 

func (*Result) ProtoMessage()

func (*Result) ProtoReflect added in v2.7.1 

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

func (*Result) Reset added in v2.7.1 

func (x *Result) Reset()

func (*Result) String added in v2.7.1 

func (x *Result) String() string

type Result_ErrorCategory added in v2.7.2 

type Result_ErrorCategory int32
const (
	Result_UNSPECIFIED    Result_ErrorCategory = 0 // No error
	Result_USER           Result_ErrorCategory = 1
	Result_CONFIG         Result_ErrorCategory = 2
	Result_NO_DAEMON_LOGS Result_ErrorCategory = 3
	Result_UNKNOWN        Result_ErrorCategory = 4
)

func (Result_ErrorCategory) Descriptor added in v2.7.2 

func (Result_ErrorCategory) Descriptor() protoreflect.EnumDescriptor

func (Result_ErrorCategory) Enum added in v2.7.2 

func (x Result_ErrorCategory) Enum() *Result_ErrorCategory

func (Result_ErrorCategory) EnumDescriptor deprecated added in v2.7.2 

func (Result_ErrorCategory) EnumDescriptor() ([]byte, []int)

Deprecated: Use Result_ErrorCategory.Descriptor instead.

func (Result_ErrorCategory) Number added in v2.7.2 

func (x Result_ErrorCategory) Number() protoreflect.EnumNumber

func (Result_ErrorCategory) String added in v2.7.2 

func (x Result_ErrorCategory) String() string

func (Result_ErrorCategory) Type added in v2.7.2 

func (Result_ErrorCategory) Type() protoreflect.EnumType

type RunCommandRequest added in v2.5.0 

type RunCommandRequest struct {

	// Types that are assignable to COrD:
	//
	//	*RunCommandRequest_Command_
	//	*RunCommandRequest_Data
	//	*RunCommandRequest_SoftCancel
	COrD isRunCommandRequest_COrD `protobuf_oneof:"c_or_d"`
	// contains filtered or unexported fields
}

RunCommandRequest is the message that is streamed to RunCommand. The first message contains the actual command and its parameters. Subsequent messages will only contain data.

func (*RunCommandRequest) Descriptor deprecated added in v2.5.0 

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

Deprecated: Use RunCommandRequest.ProtoReflect.Descriptor instead.

func (*RunCommandRequest) GetCOrD added in v2.7.2 

func (m *RunCommandRequest) GetCOrD() isRunCommandRequest_COrD

func (*RunCommandRequest) GetCommand added in v2.7.2 

func (x *RunCommandRequest) GetCommand() *RunCommandRequest_Command

func (*RunCommandRequest) GetData added in v2.7.2 

func (x *RunCommandRequest) GetData() []byte

func (*RunCommandRequest) GetSoftCancel added in v2.7.3 

func (x *RunCommandRequest) GetSoftCancel() bool

func (*RunCommandRequest) ProtoMessage added in v2.5.0 

func (*RunCommandRequest) ProtoMessage()

func (*RunCommandRequest) ProtoReflect added in v2.5.0 

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

func (*RunCommandRequest) Reset added in v2.5.0 

func (x *RunCommandRequest) Reset()

func (*RunCommandRequest) String added in v2.5.0 

func (x *RunCommandRequest) String() string

type RunCommandRequest_Command added in v2.7.2 

type RunCommandRequest_Command struct {
	OsArgs []string `protobuf:"bytes,1,rep,name=os_args,json=osArgs,proto3" json:"os_args,omitempty"`
	Cwd    string   `protobuf:"bytes,2,opt,name=cwd,proto3" json:"cwd,omitempty"`
	// contains filtered or unexported fields
}

func (*RunCommandRequest_Command) Descriptor deprecated added in v2.7.2 

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

Deprecated: Use RunCommandRequest_Command.ProtoReflect.Descriptor instead.

func (*RunCommandRequest_Command) GetCwd added in v2.7.2 

func (x *RunCommandRequest_Command) GetCwd() string

func (*RunCommandRequest_Command) GetOsArgs added in v2.7.2 

func (x *RunCommandRequest_Command) GetOsArgs() []string

func (*RunCommandRequest_Command) ProtoMessage added in v2.7.2 

func (*RunCommandRequest_Command) ProtoMessage()

func (*RunCommandRequest_Command) ProtoReflect added in v2.7.2 

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

func (*RunCommandRequest_Command) Reset added in v2.7.2 

func (x *RunCommandRequest_Command) Reset()

func (*RunCommandRequest_Command) String added in v2.7.2 

func (x *RunCommandRequest_Command) String() string

type RunCommandRequest_Command_ added in v2.7.2 

type RunCommandRequest_Command_ struct {
	Command *RunCommandRequest_Command `protobuf:"bytes,1,opt,name=command,proto3,oneof"`
}

type RunCommandRequest_Data added in v2.7.2 

type RunCommandRequest_Data struct {
	Data []byte `protobuf:"bytes,2,opt,name=data,proto3,oneof"`
}

type RunCommandRequest_SoftCancel added in v2.7.3 

type RunCommandRequest_SoftCancel struct {
	SoftCancel bool `protobuf:"varint,3,opt,name=soft_cancel,json=softCancel,proto3,oneof"`
}

type StreamResult added in v2.7.2 

type StreamResult struct {
	Data  *Result `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	Final bool    `protobuf:"varint,2,opt,name=final,proto3" json:"final,omitempty"`
	// contains filtered or unexported fields
}

StreamResult is like Result, but with a boolean final to indicate that a message is the last one on a stream. The stream can be closed by either actually closing it (receiver gets an EOF) or by sending a StreamResult with final = true. The latter method should be used when the called method ends with an error (non-gRPC related) that must be propagated to the caller.

func (*StreamResult) Descriptor deprecated added in v2.7.2 

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

Deprecated: Use StreamResult.ProtoReflect.Descriptor instead.

func (*StreamResult) GetData added in v2.7.2 

func (x *StreamResult) GetData() *Result

func (*StreamResult) GetFinal added in v2.7.2 

func (x *StreamResult) GetFinal() bool

func (*StreamResult) ProtoMessage added in v2.7.2 

func (*StreamResult) ProtoMessage()

func (*StreamResult) ProtoReflect added in v2.7.2 

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

func (*StreamResult) Reset added in v2.7.2 

func (x *StreamResult) Reset()

func (*StreamResult) String added in v2.7.2 

func (x *StreamResult) String() string

type UnimplementedConnectorServer 

type UnimplementedConnectorServer struct {
}

UnimplementedConnectorServer must be embedded to have forward compatible implementations.

func (UnimplementedConnectorServer) AddInterceptor added in v2.6.0 

func (UnimplementedConnectorServer) AddInterceptor(context.Context, *Interceptor) (*emptypb.Empty, error)

func (UnimplementedConnectorServer) CanIntercept added in v2.4.10 

func (UnimplementedConnectorServer) CanIntercept(context.Context, *CreateInterceptRequest) (*InterceptResult, error)

func (UnimplementedConnectorServer) Connect 

func (UnimplementedConnectorServer) Connect(context.Context, *ConnectRequest) (*ConnectInfo, error)

func (UnimplementedConnectorServer) CreateIntercept 

func (UnimplementedConnectorServer) CreateIntercept(context.Context, *CreateInterceptRequest) (*InterceptResult, error)

func (UnimplementedConnectorServer) Disconnect added in v2.5.0 

func (UnimplementedConnectorServer) Disconnect(context.Context, *emptypb.Empty) (*emptypb.Empty, error)

func (UnimplementedConnectorServer) GatherLogs added in v2.5.5 

func (UnimplementedConnectorServer) GatherLogs(context.Context, *LogsRequest) (*LogsResponse, error)

func (UnimplementedConnectorServer) GetCloudAPIKey added in v2.1.4 

func (UnimplementedConnectorServer) GetCloudAPIKey(context.Context, *KeyRequest) (*KeyData, error)

func (UnimplementedConnectorServer) GetCloudLicense added in v2.2.0 

func (UnimplementedConnectorServer) GetCloudLicense(context.Context, *LicenseRequest) (*LicenseData, error)

func (UnimplementedConnectorServer) GetCloudUserInfo added in v2.3.7 

func (UnimplementedConnectorServer) GetCloudUserInfo(context.Context, *UserInfoRequest) (*UserInfo, error)

func (UnimplementedConnectorServer) GetClusterSubnets added in v2.8.0 

func (UnimplementedConnectorServer) GetClusterSubnets(context.Context, *emptypb.Empty) (*daemon.ClusterSubnets, error)

func (UnimplementedConnectorServer) GetIngressInfos added in v2.5.0 

func (UnimplementedConnectorServer) GetIngressInfos(context.Context, *emptypb.Empty) (*IngressInfos, error)

func (UnimplementedConnectorServer) GetNamespaces added in v2.7.2 

func (UnimplementedConnectorServer) GetNamespaces(context.Context, *GetNamespacesRequest) (*GetNamespacesResponse, error)

func (UnimplementedConnectorServer) Helm added in v2.7.1 

func (UnimplementedConnectorServer) Helm(context.Context, *HelmRequest) (*Result, error)

func (UnimplementedConnectorServer) List 

func (UnimplementedConnectorServer) List(context.Context, *ListRequest) (*WorkloadInfoSnapshot, error)

func (UnimplementedConnectorServer) ListCommands added in v2.5.0 

func (UnimplementedConnectorServer) ListCommands(context.Context, *emptypb.Empty) (*CommandGroups, error)

func (UnimplementedConnectorServer) Login added in v2.1.4 

func (UnimplementedConnectorServer) Login(context.Context, *LoginRequest) (*LoginResult, error)

func (UnimplementedConnectorServer) Logout added in v2.1.4 

func (UnimplementedConnectorServer) Logout(context.Context, *emptypb.Empty) (*emptypb.Empty, error)

func (UnimplementedConnectorServer) Quit 

func (UnimplementedConnectorServer) Quit(context.Context, *emptypb.Empty) (*emptypb.Empty, error)

func (UnimplementedConnectorServer) RemoveIntercept 

func (UnimplementedConnectorServer) RemoveIntercept(context.Context, *manager.RemoveInterceptRequest2) (*InterceptResult, error)

func (UnimplementedConnectorServer) RemoveInterceptor added in v2.6.0 

func (UnimplementedConnectorServer) RemoveInterceptor(context.Context, *Interceptor) (*emptypb.Empty, error)

func (UnimplementedConnectorServer) ResolveIngressInfo added in v2.5.0 

func (UnimplementedConnectorServer) ResolveIngressInfo(context.Context, *userdaemon.IngressInfoRequest) (*userdaemon.IngressInfoResponse, error)

func (UnimplementedConnectorServer) RootDaemonVersion added in v2.8.0 

func (UnimplementedConnectorServer) RootDaemonVersion(context.Context, *emptypb.Empty) (*common.VersionInfo, error)

func (UnimplementedConnectorServer) RunCommand added in v2.5.0 

func (UnimplementedConnectorServer) RunCommand(Connector_RunCommandServer) error

func (UnimplementedConnectorServer) SetLogLevel added in v2.4.2 

func (UnimplementedConnectorServer) SetLogLevel(context.Context, *manager.LogLevelRequest) (*emptypb.Empty, error)

func (UnimplementedConnectorServer) Status added in v2.1.4 

func (UnimplementedConnectorServer) Status(context.Context, *emptypb.Empty) (*ConnectInfo, error)

func (UnimplementedConnectorServer) Uninstall 

func (UnimplementedConnectorServer) Uninstall(context.Context, *UninstallRequest) (*Result, error)

func (UnimplementedConnectorServer) UserNotifications added in v2.1.4 

func (UnimplementedConnectorServer) UserNotifications(*emptypb.Empty, Connector_UserNotificationsServer) error

func (UnimplementedConnectorServer) ValidArgsForCommand added in v2.7.2 

func (UnimplementedConnectorServer) ValidArgsForCommand(context.Context, *ValidArgsForCommandRequest) (*ValidArgsForCommandResponse, error)

func (UnimplementedConnectorServer) Version 

func (UnimplementedConnectorServer) Version(context.Context, *emptypb.Empty) (*common.VersionInfo, error)

func (UnimplementedConnectorServer) WatchWorkloads added in v2.5.0 

func (UnimplementedConnectorServer) WatchWorkloads(*WatchWorkloadsRequest, Connector_WatchWorkloadsServer) error

type UninstallRequest 

type UninstallRequest struct {
	UninstallType UninstallRequest_UninstallType `` /* 160-byte string literal not displayed */
	Agents        []string                       `protobuf:"bytes,2,rep,name=agents,proto3" json:"agents,omitempty"`
	// Namespace of agents to remove.
	Namespace string `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// contains filtered or unexported fields
}

func (*UninstallRequest) Descriptor deprecated 

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

Deprecated: Use UninstallRequest.ProtoReflect.Descriptor instead.

func (*UninstallRequest) GetAgents 

func (x *UninstallRequest) GetAgents() []string

func (*UninstallRequest) GetNamespace 

func (x *UninstallRequest) GetNamespace() string

func (*UninstallRequest) GetUninstallType 

func (x *UninstallRequest) GetUninstallType() UninstallRequest_UninstallType

func (*UninstallRequest) ProtoMessage 

func (*UninstallRequest) ProtoMessage()

func (*UninstallRequest) ProtoReflect 

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

func (*UninstallRequest) Reset 

func (x *UninstallRequest) Reset()

func (*UninstallRequest) String 

func (x *UninstallRequest) String() string

type UninstallRequest_UninstallType 

type UninstallRequest_UninstallType int32
const (
	UninstallRequest_UNSPECIFIED UninstallRequest_UninstallType = 0
	// Uninstalls an agent from the named workloads
	UninstallRequest_NAMED_AGENTS UninstallRequest_UninstallType = 1
	// Uninstalls all agents
	UninstallRequest_ALL_AGENTS UninstallRequest_UninstallType = 2
)

func (UninstallRequest_UninstallType) Descriptor 

func (UninstallRequest_UninstallType) Descriptor() protoreflect.EnumDescriptor

func (UninstallRequest_UninstallType) Enum 

func (x UninstallRequest_UninstallType) Enum() *UninstallRequest_UninstallType

func (UninstallRequest_UninstallType) EnumDescriptor deprecated 

func (UninstallRequest_UninstallType) EnumDescriptor() ([]byte, []int)

Deprecated: Use UninstallRequest_UninstallType.Descriptor instead.

func (UninstallRequest_UninstallType) Number 

func (x UninstallRequest_UninstallType) Number() protoreflect.EnumNumber

func (UninstallRequest_UninstallType) String 

func (x UninstallRequest_UninstallType) String() string

func (UninstallRequest_UninstallType) Type 

func (UninstallRequest_UninstallType) Type() protoreflect.EnumType

type UnsafeConnectorServer 

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

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

type UserInfo added in v2.3.7 

type UserInfo struct {
	Id               string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name             string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	AvatarUrl        string `protobuf:"bytes,3,opt,name=avatarUrl,proto3" json:"avatarUrl,omitempty"`
	AccountId        string `protobuf:"bytes,4,opt,name=accountId,proto3" json:"accountId,omitempty"`
	AccountName      string `protobuf:"bytes,5,opt,name=accountName,proto3" json:"accountName,omitempty"`
	AccountAvatarUrl string `protobuf:"bytes,6,opt,name=accountAvatarUrl,proto3" json:"accountAvatarUrl,omitempty"`
	Email            string `protobuf:"bytes,7,opt,name=email,proto3" json:"email,omitempty"`
	// contains filtered or unexported fields
}

func (*UserInfo) Descriptor deprecated added in v2.3.7 

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

Deprecated: Use UserInfo.ProtoReflect.Descriptor instead.

func (*UserInfo) GetAccountAvatarUrl added in v2.3.7 

func (x *UserInfo) GetAccountAvatarUrl() string

func (*UserInfo) GetAccountId added in v2.3.7 

func (x *UserInfo) GetAccountId() string

func (*UserInfo) GetAccountName added in v2.3.7 

func (x *UserInfo) GetAccountName() string

func (*UserInfo) GetAvatarUrl added in v2.3.7 

func (x *UserInfo) GetAvatarUrl() string

func (*UserInfo) GetEmail added in v2.5.4 

func (x *UserInfo) GetEmail() string

func (*UserInfo) GetId added in v2.3.7 

func (x *UserInfo) GetId() string

func (*UserInfo) GetName added in v2.3.7 

func (x *UserInfo) GetName() string

func (*UserInfo) ProtoMessage added in v2.3.7 

func (*UserInfo) ProtoMessage()

func (*UserInfo) ProtoReflect added in v2.3.7 

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

func (*UserInfo) Reset added in v2.3.7 

func (x *UserInfo) Reset()

func (*UserInfo) String added in v2.3.7 

func (x *UserInfo) String() string

type UserInfoRequest added in v2.3.7 

type UserInfoRequest struct {
	AutoLogin bool `protobuf:"varint,1,opt,name=auto_login,json=autoLogin,proto3" json:"auto_login,omitempty"`
	Refresh   bool `protobuf:"varint,2,opt,name=refresh,proto3" json:"refresh,omitempty"`
	// contains filtered or unexported fields
}

func (*UserInfoRequest) Descriptor deprecated added in v2.3.7 

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

Deprecated: Use UserInfoRequest.ProtoReflect.Descriptor instead.

func (*UserInfoRequest) GetAutoLogin added in v2.3.7 

func (x *UserInfoRequest) GetAutoLogin() bool

func (*UserInfoRequest) GetRefresh added in v2.3.7 

func (x *UserInfoRequest) GetRefresh() bool

func (*UserInfoRequest) ProtoMessage added in v2.3.7 

func (*UserInfoRequest) ProtoMessage()

func (*UserInfoRequest) ProtoReflect added in v2.3.7 

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

func (*UserInfoRequest) Reset added in v2.3.7 

func (x *UserInfoRequest) Reset()

func (*UserInfoRequest) String added in v2.3.7 

func (x *UserInfoRequest) String() string

type ValidArgsForCommandRequest added in v2.7.2 

type ValidArgsForCommandRequest struct {
	CmdName    string   `protobuf:"bytes,1,opt,name=cmd_name,json=cmdName,proto3" json:"cmd_name,omitempty"`
	OsArgs     []string `protobuf:"bytes,2,rep,name=os_args,json=osArgs,proto3" json:"os_args,omitempty"`
	ToComplete string   `protobuf:"bytes,3,opt,name=to_complete,json=toComplete,proto3" json:"to_complete,omitempty"`
	// contains filtered or unexported fields
}

func (*ValidArgsForCommandRequest) Descriptor deprecated added in v2.7.2 

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

Deprecated: Use ValidArgsForCommandRequest.ProtoReflect.Descriptor instead.

func (*ValidArgsForCommandRequest) GetCmdName added in v2.7.2 

func (x *ValidArgsForCommandRequest) GetCmdName() string

func (*ValidArgsForCommandRequest) GetOsArgs added in v2.7.2 

func (x *ValidArgsForCommandRequest) GetOsArgs() []string

func (*ValidArgsForCommandRequest) GetToComplete added in v2.7.2 

func (x *ValidArgsForCommandRequest) GetToComplete() string

func (*ValidArgsForCommandRequest) ProtoMessage added in v2.7.2 

func (*ValidArgsForCommandRequest) ProtoMessage()

func (*ValidArgsForCommandRequest) ProtoReflect added in v2.7.2 

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

func (*ValidArgsForCommandRequest) Reset added in v2.7.2 

func (x *ValidArgsForCommandRequest) Reset()

func (*ValidArgsForCommandRequest) String added in v2.7.2 

func (x *ValidArgsForCommandRequest) String() string

type ValidArgsForCommandResponse added in v2.7.2 

type ValidArgsForCommandResponse struct {
	Completions        []string `protobuf:"bytes,1,rep,name=completions,proto3" json:"completions,omitempty"`
	ShellCompDirective int32    `protobuf:"varint,2,opt,name=shell_comp_directive,json=shellCompDirective,proto3" json:"shell_comp_directive,omitempty"`
	// contains filtered or unexported fields
}

func (*ValidArgsForCommandResponse) Descriptor deprecated added in v2.7.2 

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

Deprecated: Use ValidArgsForCommandResponse.ProtoReflect.Descriptor instead.

func (*ValidArgsForCommandResponse) GetCompletions added in v2.7.2 

func (x *ValidArgsForCommandResponse) GetCompletions() []string

func (*ValidArgsForCommandResponse) GetShellCompDirective added in v2.7.2 

func (x *ValidArgsForCommandResponse) GetShellCompDirective() int32

func (*ValidArgsForCommandResponse) ProtoMessage added in v2.7.2 

func (*ValidArgsForCommandResponse) ProtoMessage()

func (*ValidArgsForCommandResponse) ProtoReflect added in v2.7.2 

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

func (*ValidArgsForCommandResponse) Reset added in v2.7.2 

func (x *ValidArgsForCommandResponse) Reset()

func (*ValidArgsForCommandResponse) String added in v2.7.2 

func (x *ValidArgsForCommandResponse) String() string

type WatchWorkloadsRequest added in v2.5.0 

type WatchWorkloadsRequest struct {

	// Namespace to watch.
	Namespaces []string `protobuf:"bytes,1,rep,name=namespaces,proto3" json:"namespaces,omitempty"`
	// contains filtered or unexported fields
}

func (*WatchWorkloadsRequest) Descriptor deprecated added in v2.5.0 

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

Deprecated: Use WatchWorkloadsRequest.ProtoReflect.Descriptor instead.

func (*WatchWorkloadsRequest) GetNamespaces added in v2.5.0 

func (x *WatchWorkloadsRequest) GetNamespaces() []string

func (*WatchWorkloadsRequest) ProtoMessage added in v2.5.0 

func (*WatchWorkloadsRequest) ProtoMessage()

func (*WatchWorkloadsRequest) ProtoReflect added in v2.5.0 

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

func (*WatchWorkloadsRequest) Reset added in v2.5.0 

func (x *WatchWorkloadsRequest) Reset()

func (*WatchWorkloadsRequest) String added in v2.5.0 

func (x *WatchWorkloadsRequest) String() string

type WorkloadInfo added in v2.1.3 

type WorkloadInfo struct {

	// Name of workload
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Namespace of workload
	Namespace string `protobuf:"bytes,6,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// Reason why workload cannot be intercepted, or empty if it can.
	NotInterceptableReason string `` /* 129-byte string literal not displayed */
	// AgentInfo reported from the traffic manager in case the workload has a traffic-agent installed
	AgentInfo *manager.AgentInfo `protobuf:"bytes,3,opt,name=agent_info,json=agentInfo,proto3" json:"agent_info,omitempty"`
	// InterceptInfos reported from the traffic manager in case the workload is currently intercepted
	InterceptInfos []*manager.InterceptInfo `protobuf:"bytes,9,rep,name=intercept_infos,json=interceptInfos,proto3" json:"intercept_infos,omitempty"`
	// Workload Resource type (e.g. Deployment, ReplicaSet, StatefulSet)
	WorkloadResourceType string                         `protobuf:"bytes,5,opt,name=workload_resource_type,json=workloadResourceType,proto3" json:"workload_resource_type,omitempty"`
	Service              *WorkloadInfo_ServiceReference `protobuf:"bytes,7,opt,name=service,proto3,oneof" json:"service,omitempty"`
	Uid                  string                         `protobuf:"bytes,8,opt,name=uid,proto3" json:"uid,omitempty"`
	// contains filtered or unexported fields
}

WorkloadInfo contains information about a workload https://kubernetes.io/docs/concepts/workloads/

func (*WorkloadInfo) Descriptor deprecated added in v2.1.3 

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

Deprecated: Use WorkloadInfo.ProtoReflect.Descriptor instead.

func (*WorkloadInfo) GetAgentInfo added in v2.1.3 

func (x *WorkloadInfo) GetAgentInfo() *manager.AgentInfo

func (*WorkloadInfo) GetInterceptInfos added in v2.6.0 

func (x *WorkloadInfo) GetInterceptInfos() []*manager.InterceptInfo

func (*WorkloadInfo) GetName added in v2.1.3 

func (x *WorkloadInfo) GetName() string

func (*WorkloadInfo) GetNamespace added in v2.5.0 

func (x *WorkloadInfo) GetNamespace() string

func (*WorkloadInfo) GetNotInterceptableReason added in v2.1.3 

func (x *WorkloadInfo) GetNotInterceptableReason() string

func (*WorkloadInfo) GetService added in v2.5.0 

func (x *WorkloadInfo) GetService() *WorkloadInfo_ServiceReference

func (*WorkloadInfo) GetUid added in v2.5.0 

func (x *WorkloadInfo) GetUid() string

func (*WorkloadInfo) GetWorkloadResourceType added in v2.1.3 

func (x *WorkloadInfo) GetWorkloadResourceType() string

func (*WorkloadInfo) ProtoMessage added in v2.1.3 

func (*WorkloadInfo) ProtoMessage()

func (*WorkloadInfo) ProtoReflect added in v2.1.3 

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

func (*WorkloadInfo) Reset added in v2.1.3 

func (x *WorkloadInfo) Reset()

func (*WorkloadInfo) String added in v2.1.3 

func (x *WorkloadInfo) String() string

type WorkloadInfoSnapshot added in v2.1.3 

type WorkloadInfoSnapshot struct {
	Workloads []*WorkloadInfo `protobuf:"bytes,1,rep,name=workloads,proto3" json:"workloads,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkloadInfoSnapshot) Descriptor deprecated added in v2.1.3 

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

Deprecated: Use WorkloadInfoSnapshot.ProtoReflect.Descriptor instead.

func (*WorkloadInfoSnapshot) GetWorkloads added in v2.1.3 

func (x *WorkloadInfoSnapshot) GetWorkloads() []*WorkloadInfo

func (*WorkloadInfoSnapshot) ProtoMessage added in v2.1.3 

func (*WorkloadInfoSnapshot) ProtoMessage()

func (*WorkloadInfoSnapshot) ProtoReflect added in v2.1.3 

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

func (*WorkloadInfoSnapshot) Reset added in v2.1.3 

func (x *WorkloadInfoSnapshot) Reset()

func (*WorkloadInfoSnapshot) String added in v2.1.3 

func (x *WorkloadInfoSnapshot) String() string

type WorkloadInfo_ServiceReference added in v2.5.0 

type WorkloadInfo_ServiceReference 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"`
	Uid       string                                `protobuf:"bytes,3,opt,name=uid,proto3" json:"uid,omitempty"`
	Ports     []*WorkloadInfo_ServiceReference_Port `protobuf:"bytes,4,rep,name=ports,proto3" json:"ports,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkloadInfo_ServiceReference) Descriptor deprecated added in v2.5.0 

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

Deprecated: Use WorkloadInfo_ServiceReference.ProtoReflect.Descriptor instead.

func (*WorkloadInfo_ServiceReference) GetName added in v2.5.0 

func (x *WorkloadInfo_ServiceReference) GetName() string

func (*WorkloadInfo_ServiceReference) GetNamespace added in v2.5.0 

func (x *WorkloadInfo_ServiceReference) GetNamespace() string

func (*WorkloadInfo_ServiceReference) GetPorts added in v2.5.0 

func (x *WorkloadInfo_ServiceReference) GetPorts() []*WorkloadInfo_ServiceReference_Port

func (*WorkloadInfo_ServiceReference) GetUid added in v2.5.0 

func (x *WorkloadInfo_ServiceReference) GetUid() string

func (*WorkloadInfo_ServiceReference) ProtoMessage added in v2.5.0 

func (*WorkloadInfo_ServiceReference) ProtoMessage()

func (*WorkloadInfo_ServiceReference) ProtoReflect added in v2.5.0 

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

func (*WorkloadInfo_ServiceReference) Reset added in v2.5.0 

func (x *WorkloadInfo_ServiceReference) Reset()

func (*WorkloadInfo_ServiceReference) String added in v2.5.0 

func (x *WorkloadInfo_ServiceReference) String() string

type WorkloadInfo_ServiceReference_Port added in v2.5.0 

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

func (*WorkloadInfo_ServiceReference_Port) Descriptor deprecated added in v2.5.0 

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

Deprecated: Use WorkloadInfo_ServiceReference_Port.ProtoReflect.Descriptor instead.

func (*WorkloadInfo_ServiceReference_Port) GetName added in v2.5.0 

func (x *WorkloadInfo_ServiceReference_Port) GetName() string

func (*WorkloadInfo_ServiceReference_Port) GetPort added in v2.5.0 

func (x *WorkloadInfo_ServiceReference_Port) GetPort() int32

func (*WorkloadInfo_ServiceReference_Port) ProtoMessage added in v2.5.0 

func (*WorkloadInfo_ServiceReference_Port) ProtoMessage()

func (*WorkloadInfo_ServiceReference_Port) ProtoReflect added in v2.5.0 

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

func (*WorkloadInfo_ServiceReference_Port) Reset added in v2.5.0 

func (x *WorkloadInfo_ServiceReference_Port) Reset()

func (*WorkloadInfo_ServiceReference_Port) String added in v2.5.0 

func (x *WorkloadInfo_ServiceReference_Port) 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.