manager

package
v2.21.1 Latest Latest
Warning

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

 Go to latest Published: Dec 17, 2024 License: Apache-2.0 Imports: 11 Imported by: 25

Documentation

Index

Constants

View Source 
const (
	Manager_Version_FullMethodName                   = "/telepresence.manager.Manager/Version"
	Manager_GetAgentImageFQN_FullMethodName          = "/telepresence.manager.Manager/GetAgentImageFQN"
	Manager_GetAgentConfig_FullMethodName            = "/telepresence.manager.Manager/GetAgentConfig"
	Manager_GetLicense_FullMethodName                = "/telepresence.manager.Manager/GetLicense"
	Manager_CanConnectAmbassadorCloud_FullMethodName = "/telepresence.manager.Manager/CanConnectAmbassadorCloud"
	Manager_GetCloudConfig_FullMethodName            = "/telepresence.manager.Manager/GetCloudConfig"
	Manager_GetClientConfig_FullMethodName           = "/telepresence.manager.Manager/GetClientConfig"
	Manager_GetTelepresenceAPI_FullMethodName        = "/telepresence.manager.Manager/GetTelepresenceAPI"
	Manager_ArriveAsClient_FullMethodName            = "/telepresence.manager.Manager/ArriveAsClient"
	Manager_ArriveAsAgent_FullMethodName             = "/telepresence.manager.Manager/ArriveAsAgent"
	Manager_Remain_FullMethodName                    = "/telepresence.manager.Manager/Remain"
	Manager_Depart_FullMethodName                    = "/telepresence.manager.Manager/Depart"
	Manager_SetLogLevel_FullMethodName               = "/telepresence.manager.Manager/SetLogLevel"
	Manager_GetLogs_FullMethodName                   = "/telepresence.manager.Manager/GetLogs"
	Manager_WatchAgentPods_FullMethodName            = "/telepresence.manager.Manager/WatchAgentPods"
	Manager_WatchAgents_FullMethodName               = "/telepresence.manager.Manager/WatchAgents"
	Manager_WatchAgentsNS_FullMethodName             = "/telepresence.manager.Manager/WatchAgentsNS"
	Manager_WatchIntercepts_FullMethodName           = "/telepresence.manager.Manager/WatchIntercepts"
	Manager_WatchWorkloads_FullMethodName            = "/telepresence.manager.Manager/WatchWorkloads"
	Manager_WatchClusterInfo_FullMethodName          = "/telepresence.manager.Manager/WatchClusterInfo"
	Manager_EnsureAgent_FullMethodName               = "/telepresence.manager.Manager/EnsureAgent"
	Manager_PrepareIntercept_FullMethodName          = "/telepresence.manager.Manager/PrepareIntercept"
	Manager_CreateIntercept_FullMethodName           = "/telepresence.manager.Manager/CreateIntercept"
	Manager_RemoveIntercept_FullMethodName           = "/telepresence.manager.Manager/RemoveIntercept"
	Manager_UpdateIntercept_FullMethodName           = "/telepresence.manager.Manager/UpdateIntercept"
	Manager_GetIntercept_FullMethodName              = "/telepresence.manager.Manager/GetIntercept"
	Manager_ReviewIntercept_FullMethodName           = "/telepresence.manager.Manager/ReviewIntercept"
	Manager_GetKnownWorkloadKinds_FullMethodName     = "/telepresence.manager.Manager/GetKnownWorkloadKinds"
	Manager_LookupDNS_FullMethodName                 = "/telepresence.manager.Manager/LookupDNS"
	Manager_AgentLookupDNSResponse_FullMethodName    = "/telepresence.manager.Manager/AgentLookupDNSResponse"
	Manager_WatchLookupDNS_FullMethodName            = "/telepresence.manager.Manager/WatchLookupDNS"
	Manager_WatchLogLevel_FullMethodName             = "/telepresence.manager.Manager/WatchLogLevel"
	Manager_Tunnel_FullMethodName                    = "/telepresence.manager.Manager/Tunnel"
	Manager_ReportMetrics_FullMethodName             = "/telepresence.manager.Manager/ReportMetrics"
	Manager_WatchDial_FullMethodName                 = "/telepresence.manager.Manager/WatchDial"
)

Variables

View Source 
var (
	InterceptDispositionType_name = map[int32]string{
		0: "UNSPECIFIED",
		1: "ACTIVE",
		2: "WAITING",
		9: "REMOVED",
		3: "NO_CLIENT",
		4: "NO_AGENT",
		5: "NO_MECHANISM",
		6: "NO_PORTS",
		7: "AGENT_ERROR",
		8: "BAD_ARGS",
	}
	InterceptDispositionType_value = map[string]int32{
		"UNSPECIFIED":  0,
		"ACTIVE":       1,
		"WAITING":      2,
		"REMOVED":      9,
		"NO_CLIENT":    3,
		"NO_AGENT":     4,
		"NO_MECHANISM": 5,
		"NO_PORTS":     6,
		"AGENT_ERROR":  7,
		"BAD_ARGS":     8,
	}
)

Enum value maps for InterceptDispositionType.

View Source 
var (
	WorkloadInfo_Kind_name = map[int32]string{
		0: "UNSPECIFIED",
		1: "DEPLOYMENT",
		2: "REPLICASET",
		3: "STATEFULSET",
		4: "ROLLOUT",
	}
	WorkloadInfo_Kind_value = map[string]int32{
		"UNSPECIFIED": 0,
		"DEPLOYMENT":  1,
		"REPLICASET":  2,
		"STATEFULSET": 3,
		"ROLLOUT":     4,
	}
)

Enum value maps for WorkloadInfo_Kind.

View Source 
var (
	WorkloadInfo_State_name = map[int32]string{
		0: "UNKNOWN_UNSPECIFIED",
		1: "AVAILABLE",
		2: "PROGRESSING",
		3: "FAILURE",
	}
	WorkloadInfo_State_value = map[string]int32{
		"UNKNOWN_UNSPECIFIED": 0,
		"AVAILABLE":           1,
		"PROGRESSING":         2,
		"FAILURE":             3,
	}
)

Enum value maps for WorkloadInfo_State.

View Source 
var (
	WorkloadInfo_AgentState_name = map[int32]string{
		0: "NO_AGENT_UNSPECIFIED",
		1: "INSTALLED",
		2: "INTERCEPTED",
	}
	WorkloadInfo_AgentState_value = map[string]int32{
		"NO_AGENT_UNSPECIFIED": 0,
		"INSTALLED":            1,
		"INTERCEPTED":          2,
	}
)

Enum value maps for WorkloadInfo_AgentState.

View Source 
var (
	WorkloadEvent_Type_name = map[int32]string{
		0: "ADDED_UNSPECIFIED",
		1: "MODIFIED",
		2: "DELETED",
	}
	WorkloadEvent_Type_value = map[string]int32{
		"ADDED_UNSPECIFIED": 0,
		"MODIFIED":          1,
		"DELETED":           2,
	}
)

Enum value maps for WorkloadEvent_Type.

View Source 
var File_manager_manager_proto protoreflect.FileDescriptor
View Source 
var Manager_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "telepresence.manager.Manager",
	HandlerType: (*ManagerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Version",
			Handler:    _Manager_Version_Handler,
		},
		{
			MethodName: "GetAgentImageFQN",
			Handler:    _Manager_GetAgentImageFQN_Handler,
		},
		{
			MethodName: "GetAgentConfig",
			Handler:    _Manager_GetAgentConfig_Handler,
		},
		{
			MethodName: "GetLicense",
			Handler:    _Manager_GetLicense_Handler,
		},
		{
			MethodName: "CanConnectAmbassadorCloud",
			Handler:    _Manager_CanConnectAmbassadorCloud_Handler,
		},
		{
			MethodName: "GetCloudConfig",
			Handler:    _Manager_GetCloudConfig_Handler,
		},
		{
			MethodName: "GetClientConfig",
			Handler:    _Manager_GetClientConfig_Handler,
		},
		{
			MethodName: "GetTelepresenceAPI",
			Handler:    _Manager_GetTelepresenceAPI_Handler,
		},
		{
			MethodName: "ArriveAsClient",
			Handler:    _Manager_ArriveAsClient_Handler,
		},
		{
			MethodName: "ArriveAsAgent",
			Handler:    _Manager_ArriveAsAgent_Handler,
		},
		{
			MethodName: "Remain",
			Handler:    _Manager_Remain_Handler,
		},
		{
			MethodName: "Depart",
			Handler:    _Manager_Depart_Handler,
		},
		{
			MethodName: "SetLogLevel",
			Handler:    _Manager_SetLogLevel_Handler,
		},
		{
			MethodName: "GetLogs",
			Handler:    _Manager_GetLogs_Handler,
		},
		{
			MethodName: "EnsureAgent",
			Handler:    _Manager_EnsureAgent_Handler,
		},
		{
			MethodName: "PrepareIntercept",
			Handler:    _Manager_PrepareIntercept_Handler,
		},
		{
			MethodName: "CreateIntercept",
			Handler:    _Manager_CreateIntercept_Handler,
		},
		{
			MethodName: "RemoveIntercept",
			Handler:    _Manager_RemoveIntercept_Handler,
		},
		{
			MethodName: "UpdateIntercept",
			Handler:    _Manager_UpdateIntercept_Handler,
		},
		{
			MethodName: "GetIntercept",
			Handler:    _Manager_GetIntercept_Handler,
		},
		{
			MethodName: "ReviewIntercept",
			Handler:    _Manager_ReviewIntercept_Handler,
		},
		{
			MethodName: "GetKnownWorkloadKinds",
			Handler:    _Manager_GetKnownWorkloadKinds_Handler,
		},
		{
			MethodName: "LookupDNS",
			Handler:    _Manager_LookupDNS_Handler,
		},
		{
			MethodName: "AgentLookupDNSResponse",
			Handler:    _Manager_AgentLookupDNSResponse_Handler,
		},
		{
			MethodName: "ReportMetrics",
			Handler:    _Manager_ReportMetrics_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "WatchAgentPods",
			Handler:       _Manager_WatchAgentPods_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "WatchAgents",
			Handler:       _Manager_WatchAgents_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "WatchAgentsNS",
			Handler:       _Manager_WatchAgentsNS_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "WatchIntercepts",
			Handler:       _Manager_WatchIntercepts_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "WatchWorkloads",
			Handler:       _Manager_WatchWorkloads_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "WatchClusterInfo",
			Handler:       _Manager_WatchClusterInfo_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "WatchLookupDNS",
			Handler:       _Manager_WatchLookupDNS_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "WatchLogLevel",
			Handler:       _Manager_WatchLogLevel_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "Tunnel",
			Handler:       _Manager_Tunnel_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
		{
			StreamName:    "WatchDial",
			Handler:       _Manager_WatchDial_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "manager/manager.proto",
}

Manager_ServiceDesc is the grpc.ServiceDesc for Manager service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterManagerServer 

func RegisterManagerServer(s grpc.ServiceRegistrar, srv ManagerServer)

Types

type AgentConfigRequest added in v2.21.0 

type AgentConfigRequest struct {
	Session *SessionInfo `protobuf:"bytes,1,opt,name=session,proto3" json:"session,omitempty"`
	Name    string       `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*AgentConfigRequest) Descriptor deprecated added in v2.21.0 

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

Deprecated: Use AgentConfigRequest.ProtoReflect.Descriptor instead.

func (*AgentConfigRequest) GetName added in v2.21.0 

func (x *AgentConfigRequest) GetName() string

func (*AgentConfigRequest) GetSession added in v2.21.0 

func (x *AgentConfigRequest) GetSession() *SessionInfo

func (*AgentConfigRequest) ProtoMessage added in v2.21.0 

func (*AgentConfigRequest) ProtoMessage()

func (*AgentConfigRequest) ProtoReflect added in v2.21.0 

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

func (*AgentConfigRequest) Reset added in v2.21.0 

func (x *AgentConfigRequest) Reset()

func (*AgentConfigRequest) String added in v2.21.0 

func (x *AgentConfigRequest) String() string

type AgentConfigResponse added in v2.21.0 

type AgentConfigResponse struct {
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*AgentConfigResponse) Descriptor deprecated added in v2.21.0 

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

Deprecated: Use AgentConfigResponse.ProtoReflect.Descriptor instead.

func (*AgentConfigResponse) GetData added in v2.21.0 

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

func (*AgentConfigResponse) ProtoMessage added in v2.21.0 

func (*AgentConfigResponse) ProtoMessage()

func (*AgentConfigResponse) ProtoReflect added in v2.21.0 

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

func (*AgentConfigResponse) Reset added in v2.21.0 

func (x *AgentConfigResponse) Reset()

func (*AgentConfigResponse) String added in v2.21.0 

func (x *AgentConfigResponse) String() string

type AgentImageFQN added in v2.18.0 

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

func (*AgentImageFQN) Descriptor deprecated added in v2.18.0 

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

Deprecated: Use AgentImageFQN.ProtoReflect.Descriptor instead.

func (*AgentImageFQN) GetFQN added in v2.18.0 

func (x *AgentImageFQN) GetFQN() string

func (*AgentImageFQN) ProtoMessage added in v2.18.0 

func (*AgentImageFQN) ProtoMessage()

func (*AgentImageFQN) ProtoReflect added in v2.18.0 

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

func (*AgentImageFQN) Reset added in v2.18.0 

func (x *AgentImageFQN) Reset()

func (*AgentImageFQN) String added in v2.18.0 

func (x *AgentImageFQN) String() string

type AgentInfo 

type AgentInfo struct {
	Name      string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // name of the Workload
	Kind      string `protobuf:"bytes,13,opt,name=kind,proto3" json:"kind,omitempty"`
	Namespace string `protobuf:"bytes,7,opt,name=namespace,proto3" json:"namespace,omitempty"`                 // namespace of the Workload
	PodName   string `protobuf:"bytes,8,opt,name=pod_name,json=podName,proto3" json:"pod_name,omitempty"`      // Pod name (from metadata.name)
	PodIp     string `protobuf:"bytes,2,opt,name=pod_ip,json=podIp,proto3" json:"pod_ip,omitempty"`            // Pod IP (from status.podIP)
	ApiPort   int32  `protobuf:"varint,9,opt,name=api_port,json=apiPort,proto3" json:"api_port,omitempty"`     // Port number for the agent gRPC API
	SftpPort  int32  `protobuf:"varint,10,opt,name=sftp_port,json=sftpPort,proto3" json:"sftp_port,omitempty"` // Port number for the agent SFTP server
	FtpPort   int32  `protobuf:"varint,11,opt,name=ftp_port,json=ftpPort,proto3" json:"ftp_port,omitempty"`    // Port number for the agent FTP server
	Product   string `protobuf:"bytes,3,opt,name=product,proto3" json:"product,omitempty"`                     // distinguish open source, our closed source, someone else's thing
	Version   string `protobuf:"bytes,4,opt,name=version,proto3" json:"version,omitempty"`
	// This is a list of the mechanisms that the Agent advertises that
	// it supports.
	Mechanisms []*AgentInfo_Mechanism              `protobuf:"bytes,5,rep,name=mechanisms,proto3" json:"mechanisms,omitempty"`
	Containers map[string]*AgentInfo_ContainerInfo `` /* 162-byte string literal not displayed */
	// contains filtered or unexported fields
}

AgentInfo is the self-reported metadata that an Agent (app-sidecar) reports at boot-up when it connects to the Telepresence Manager.

func (*AgentInfo) Descriptor deprecated 

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

Deprecated: Use AgentInfo.ProtoReflect.Descriptor instead.

func (*AgentInfo) GetApiPort added in v2.17.0 

func (x *AgentInfo) GetApiPort() int32

func (*AgentInfo) GetContainers added in v2.21.0 

func (x *AgentInfo) GetContainers() map[string]*AgentInfo_ContainerInfo

func (*AgentInfo) GetFtpPort added in v2.21.0 

func (x *AgentInfo) GetFtpPort() int32

func (*AgentInfo) GetKind added in v2.21.0 

func (x *AgentInfo) GetKind() string

func (*AgentInfo) GetMechanisms 

func (x *AgentInfo) GetMechanisms() []*AgentInfo_Mechanism

func (*AgentInfo) GetName 

func (x *AgentInfo) GetName() string

func (*AgentInfo) GetNamespace 

func (x *AgentInfo) GetNamespace() string

func (*AgentInfo) GetPodIp added in v2.3.0 

func (x *AgentInfo) GetPodIp() string

func (*AgentInfo) GetPodName added in v2.17.0 

func (x *AgentInfo) GetPodName() string

func (*AgentInfo) GetProduct 

func (x *AgentInfo) GetProduct() string

func (*AgentInfo) GetSftpPort added in v2.21.0 

func (x *AgentInfo) GetSftpPort() int32

func (*AgentInfo) GetVersion 

func (x *AgentInfo) GetVersion() string

func (*AgentInfo) ProtoMessage 

func (*AgentInfo) ProtoMessage()

func (*AgentInfo) ProtoReflect 

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

func (*AgentInfo) Reset 

func (x *AgentInfo) Reset()

func (*AgentInfo) String 

func (x *AgentInfo) String() string

type AgentInfoSnapshot 

type AgentInfoSnapshot struct {
	Agents []*AgentInfo `protobuf:"bytes,1,rep,name=agents,proto3" json:"agents,omitempty"`
	// contains filtered or unexported fields
}

func (*AgentInfoSnapshot) Descriptor deprecated 

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

Deprecated: Use AgentInfoSnapshot.ProtoReflect.Descriptor instead.

func (*AgentInfoSnapshot) GetAgents 

func (x *AgentInfoSnapshot) GetAgents() []*AgentInfo

func (*AgentInfoSnapshot) ProtoMessage 

func (*AgentInfoSnapshot) ProtoMessage()

func (*AgentInfoSnapshot) ProtoReflect 

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

func (*AgentInfoSnapshot) Reset 

func (x *AgentInfoSnapshot) Reset()

func (*AgentInfoSnapshot) String 

func (x *AgentInfoSnapshot) String() string

type AgentInfo_ContainerInfo added in v2.21.0 

type AgentInfo_ContainerInfo struct {

	// The container environment
	Environment map[string]string `` /* 163-byte string literal not displayed */
	// The directory where the intercept mounts can be found in the agent
	MountPoint string `protobuf:"bytes,4,opt,name=mount_point,json=mountPoint,proto3" json:"mount_point,omitempty"`
	// contains filtered or unexported fields
}

func (*AgentInfo_ContainerInfo) Descriptor deprecated added in v2.21.0 

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

Deprecated: Use AgentInfo_ContainerInfo.ProtoReflect.Descriptor instead.

func (*AgentInfo_ContainerInfo) GetEnvironment added in v2.21.0 

func (x *AgentInfo_ContainerInfo) GetEnvironment() map[string]string

func (*AgentInfo_ContainerInfo) GetMountPoint added in v2.21.0 

func (x *AgentInfo_ContainerInfo) GetMountPoint() string

func (*AgentInfo_ContainerInfo) ProtoMessage added in v2.21.0 

func (*AgentInfo_ContainerInfo) ProtoMessage()

func (*AgentInfo_ContainerInfo) ProtoReflect added in v2.21.0 

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

func (*AgentInfo_ContainerInfo) Reset added in v2.21.0 

func (x *AgentInfo_ContainerInfo) Reset()

func (*AgentInfo_ContainerInfo) String added in v2.21.0 

func (x *AgentInfo_ContainerInfo) String() string

type AgentInfo_Mechanism 

type AgentInfo_Mechanism struct {
	Name    string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`       // "tcp" or "http" or "grpc" or ...
	Product string `protobuf:"bytes,2,opt,name=product,proto3" json:"product,omitempty"` // distinguish open source, our closed source, someone else's thing
	Version string `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

"Mechanisms" are the ways that an Agent can decide handle incoming requests, and decide whether to send them to the in-cluster service, or whether to intercept them. The "tcp" mechanism is the only one in Telepresence open source, and handles things at the TCP-level and either intercepts all TCP streams or doesn't intercept anything. Other Agents than the Telepresence one may implement more mechanisms, such as Ambassador Labs' "Service Preview" Agent which implements the "http" mechanism which handles th "http" mechanism, which handles things at the HTTP-request-level and can decide to intercept individual HTTP requests based on the request headers.

func (*AgentInfo_Mechanism) Descriptor deprecated 

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

Deprecated: Use AgentInfo_Mechanism.ProtoReflect.Descriptor instead.

func (*AgentInfo_Mechanism) GetName 

func (x *AgentInfo_Mechanism) GetName() string

func (*AgentInfo_Mechanism) GetProduct 

func (x *AgentInfo_Mechanism) GetProduct() string

func (*AgentInfo_Mechanism) GetVersion 

func (x *AgentInfo_Mechanism) GetVersion() string

func (*AgentInfo_Mechanism) ProtoMessage 

func (*AgentInfo_Mechanism) ProtoMessage()

func (*AgentInfo_Mechanism) ProtoReflect 

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

func (*AgentInfo_Mechanism) Reset 

func (x *AgentInfo_Mechanism) Reset()

func (*AgentInfo_Mechanism) String 

func (x *AgentInfo_Mechanism) String() string

type AgentPodInfo added in v2.17.0 

type AgentPodInfo struct {
	PodName      string `protobuf:"bytes,1,opt,name=pod_name,json=podName,proto3" json:"pod_name,omitempty"`
	Namespace    string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	PodIp        []byte `protobuf:"bytes,3,opt,name=pod_ip,json=podIp,proto3" json:"pod_ip,omitempty"`
	ApiPort      int32  `protobuf:"varint,4,opt,name=api_port,json=apiPort,proto3" json:"api_port,omitempty"`
	Intercepted  bool   `protobuf:"varint,5,opt,name=intercepted,proto3" json:"intercepted,omitempty"`
	WorkloadName string `protobuf:"bytes,6,opt,name=workload_name,json=workloadName,proto3" json:"workload_name,omitempty"`
	// contains filtered or unexported fields
}

func (*AgentPodInfo) Descriptor deprecated added in v2.17.0 

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

Deprecated: Use AgentPodInfo.ProtoReflect.Descriptor instead.

func (*AgentPodInfo) GetApiPort added in v2.17.0 

func (x *AgentPodInfo) GetApiPort() int32

func (*AgentPodInfo) GetIntercepted added in v2.17.0 

func (x *AgentPodInfo) GetIntercepted() bool

func (*AgentPodInfo) GetNamespace added in v2.17.0 

func (x *AgentPodInfo) GetNamespace() string

func (*AgentPodInfo) GetPodIp added in v2.17.0 

func (x *AgentPodInfo) GetPodIp() []byte

func (*AgentPodInfo) GetPodName added in v2.17.0 

func (x *AgentPodInfo) GetPodName() string

func (*AgentPodInfo) GetWorkloadName added in v2.18.0 

func (x *AgentPodInfo) GetWorkloadName() string

func (*AgentPodInfo) ProtoMessage added in v2.17.0 

func (*AgentPodInfo) ProtoMessage()

func (*AgentPodInfo) ProtoReflect added in v2.17.0 

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

func (*AgentPodInfo) Reset added in v2.17.0 

func (x *AgentPodInfo) Reset()

func (*AgentPodInfo) String added in v2.17.0 

func (x *AgentPodInfo) String() string

type AgentPodInfoSnapshot added in v2.17.0 

type AgentPodInfoSnapshot struct {
	Agents []*AgentPodInfo `protobuf:"bytes,1,rep,name=agents,proto3" json:"agents,omitempty"`
	// contains filtered or unexported fields
}

func (*AgentPodInfoSnapshot) Descriptor deprecated added in v2.17.0 

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

Deprecated: Use AgentPodInfoSnapshot.ProtoReflect.Descriptor instead.

func (*AgentPodInfoSnapshot) GetAgents added in v2.17.0 

func (x *AgentPodInfoSnapshot) GetAgents() []*AgentPodInfo

func (*AgentPodInfoSnapshot) ProtoMessage added in v2.17.0 

func (*AgentPodInfoSnapshot) ProtoMessage()

func (*AgentPodInfoSnapshot) ProtoReflect added in v2.17.0 

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

func (*AgentPodInfoSnapshot) Reset added in v2.17.0 

func (x *AgentPodInfoSnapshot) Reset()

func (*AgentPodInfoSnapshot) String added in v2.17.0 

func (x *AgentPodInfoSnapshot) String() string

type AgentsRequest added in v2.5.5 

type AgentsRequest struct {
	Session    *SessionInfo `protobuf:"bytes,1,opt,name=session,proto3" json:"session,omitempty"`
	Namespaces []string     `protobuf:"bytes,2,rep,name=namespaces,proto3" json:"namespaces,omitempty"`
	// contains filtered or unexported fields
}

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

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

Deprecated: Use AgentsRequest.ProtoReflect.Descriptor instead.

func (*AgentsRequest) GetNamespaces added in v2.5.5 

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

func (*AgentsRequest) GetSession added in v2.5.5 

func (x *AgentsRequest) GetSession() *SessionInfo

func (*AgentsRequest) ProtoMessage added in v2.5.5 

func (*AgentsRequest) ProtoMessage()

func (*AgentsRequest) ProtoReflect added in v2.5.5 

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

func (*AgentsRequest) Reset added in v2.5.5 

func (x *AgentsRequest) Reset()

func (*AgentsRequest) String added in v2.5.5 

func (x *AgentsRequest) String() string

type AmbassadorCloudConfig added in v2.2.2 

type AmbassadorCloudConfig struct {
	Host    string `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	Port    string `protobuf:"bytes,2,opt,name=port,proto3" json:"port,omitempty"`
	ProxyCa []byte `protobuf:"bytes,3,opt,name=proxy_ca,json=proxyCa,proto3,oneof" json:"proxy_ca,omitempty"`
	// contains filtered or unexported fields
}

The host and port used to connect to Ambassador Cloud. Used by the agents to communicate over gRPC to have Ambassador Cloud review intercepts

func (*AmbassadorCloudConfig) Descriptor deprecated added in v2.2.2 

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

Deprecated: Use AmbassadorCloudConfig.ProtoReflect.Descriptor instead.

func (*AmbassadorCloudConfig) GetHost added in v2.2.2 

func (x *AmbassadorCloudConfig) GetHost() string

func (*AmbassadorCloudConfig) GetPort added in v2.2.2 

func (x *AmbassadorCloudConfig) GetPort() string

func (*AmbassadorCloudConfig) GetProxyCa added in v2.6.5 

func (x *AmbassadorCloudConfig) GetProxyCa() []byte

func (*AmbassadorCloudConfig) ProtoMessage added in v2.2.2 

func (*AmbassadorCloudConfig) ProtoMessage()

func (*AmbassadorCloudConfig) ProtoReflect added in v2.2.2 

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

func (*AmbassadorCloudConfig) Reset added in v2.2.2 

func (x *AmbassadorCloudConfig) Reset()

func (*AmbassadorCloudConfig) String added in v2.2.2 

func (x *AmbassadorCloudConfig) String() string

type AmbassadorCloudConnection added in v2.2.0 

type AmbassadorCloudConnection struct {
	CanConnect bool `protobuf:"varint,1,opt,name=can_connect,json=canConnect,proto3" json:"can_connect,omitempty"`
	// contains filtered or unexported fields
}

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

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

Deprecated: Use AmbassadorCloudConnection.ProtoReflect.Descriptor instead.

func (*AmbassadorCloudConnection) GetCanConnect added in v2.2.0 

func (x *AmbassadorCloudConnection) GetCanConnect() bool

func (*AmbassadorCloudConnection) ProtoMessage added in v2.2.0 

func (*AmbassadorCloudConnection) ProtoMessage()

func (*AmbassadorCloudConnection) ProtoReflect added in v2.2.0 

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

func (*AmbassadorCloudConnection) Reset added in v2.2.0 

func (x *AmbassadorCloudConnection) Reset()

func (*AmbassadorCloudConnection) String added in v2.2.0 

func (x *AmbassadorCloudConnection) String() string

type CLIConfig added in v2.9.0 

type CLIConfig struct {

	// config_yaml is a yaml blob containing the client config.
	ConfigYaml []byte `protobuf:"bytes,1,opt,name=config_yaml,json=configYaml,proto3" json:"config_yaml,omitempty"`
	// contains filtered or unexported fields
}

func (*CLIConfig) Descriptor deprecated added in v2.9.0 

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

Deprecated: Use CLIConfig.ProtoReflect.Descriptor instead.

func (*CLIConfig) GetConfigYaml added in v2.9.0 

func (x *CLIConfig) GetConfigYaml() []byte

func (*CLIConfig) ProtoMessage added in v2.9.0 

func (*CLIConfig) ProtoMessage()

func (*CLIConfig) ProtoReflect added in v2.9.0 

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

func (*CLIConfig) Reset added in v2.9.0 

func (x *CLIConfig) Reset()

func (*CLIConfig) String added in v2.9.0 

func (x *CLIConfig) String() string

type ClientInfo 

type ClientInfo struct {
	Name      string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`           // user@hostname
	Namespace string `protobuf:"bytes,6,opt,name=namespace,proto3" json:"namespace,omitempty"` // namespace that the client is connected to
	InstallId string `protobuf:"bytes,2,opt,name=install_id,json=installId,proto3" json:"install_id,omitempty"`
	Product   string `protobuf:"bytes,3,opt,name=product,proto3" json:"product,omitempty"` // "telepresence"
	Version   string `protobuf:"bytes,4,opt,name=version,proto3" json:"version,omitempty"`
	ApiKey    string `protobuf:"bytes,5,opt,name=api_key,json=apiKey,proto3" json:"api_key,omitempty"`
	// contains filtered or unexported fields
}

ClientInfo is the self-reported metadata that the on-laptop Telepresence client reports whenever it connects to the in-cluster Manager.

func (*ClientInfo) Descriptor deprecated 

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

Deprecated: Use ClientInfo.ProtoReflect.Descriptor instead.

func (*ClientInfo) GetApiKey added in v2.1.4 

func (x *ClientInfo) GetApiKey() string

func (*ClientInfo) GetInstallId 

func (x *ClientInfo) GetInstallId() string

func (*ClientInfo) GetName 

func (x *ClientInfo) GetName() string

func (*ClientInfo) GetNamespace added in v2.16.0 

func (x *ClientInfo) GetNamespace() string

func (*ClientInfo) GetProduct 

func (x *ClientInfo) GetProduct() string

func (*ClientInfo) GetVersion 

func (x *ClientInfo) GetVersion() string

func (*ClientInfo) ProtoMessage 

func (*ClientInfo) ProtoMessage()

func (*ClientInfo) ProtoReflect 

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

func (*ClientInfo) Reset 

func (x *ClientInfo) Reset()

func (*ClientInfo) String 

func (x *ClientInfo) String() string

type ClusterInfo added in v2.3.2 

type ClusterInfo struct {

	// service_subnet is the Kubernetes service subnet
	ServiceSubnet *IPNet `protobuf:"bytes,2,opt,name=service_subnet,json=serviceSubnet,proto3" json:"service_subnet,omitempty"`
	// pod_subnets are the subnets used for Kubenetes pods.
	PodSubnets []*IPNet `protobuf:"bytes,3,rep,name=pod_subnets,json=podSubnets,proto3" json:"pod_subnets,omitempty"`
	// manager_pod_ip is the ip address of the traffic manager
	ManagerPodIp []byte `protobuf:"bytes,5,opt,name=manager_pod_ip,json=managerPodIp,proto3" json:"manager_pod_ip,omitempty"`
	// manager_pod_port is the port of the traffic manager
	ManagerPodPort int32 `protobuf:"varint,8,opt,name=manager_pod_port,json=managerPodPort,proto3" json:"manager_pod_port,omitempty"`
	// injector_svc_ip is the ip address of the traffic manager's agent injector service
	InjectorSvcIp []byte `protobuf:"bytes,9,opt,name=injector_svc_ip,json=injectorSvcIp,proto3" json:"injector_svc_ip,omitempty"`
	// injector_svc_port is the port of the traffic manager's agent injector service
	InjectorSvcPort int32 `protobuf:"varint,10,opt,name=injector_svc_port,json=injectorSvcPort,proto3" json:"injector_svc_port,omitempty"`
	// injector_svc_host is the http host of the traffic manager's agent injector service
	InjectorSvcHost string `protobuf:"bytes,11,opt,name=injector_svc_host,json=injectorSvcHost,proto3" json:"injector_svc_host,omitempty"`
	// Router configuration
	Routing *Routing `protobuf:"bytes,6,opt,name=routing,proto3" json:"routing,omitempty"`
	// DNS configuration
	Dns *DNS `protobuf:"bytes,7,opt,name=dns,proto3" json:"dns,omitempty"`
	// kube_dns_ip is the IP address of the kube-dns.kube-system service,
	// Deprecated: Use dns.kube_ip
	KubeDnsIp []byte `protobuf:"bytes,1,opt,name=kube_dns_ip,json=kubeDnsIp,proto3" json:"kube_dns_ip,omitempty"`
	// cluster_domain is the domain of the cluster, ending with a dot, e.g. "cluster.local."
	// Deprecated: Use dns.cluster_domain
	ClusterDomain string `protobuf:"bytes,4,opt,name=cluster_domain,json=clusterDomain,proto3" json:"cluster_domain,omitempty"`
	// contains filtered or unexported fields
}

ClusterInfo contains information that the root daemon needs in order to establish outbound traffic to the cluster.

func (*ClusterInfo) Descriptor deprecated added in v2.3.2 

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

Deprecated: Use ClusterInfo.ProtoReflect.Descriptor instead.

func (*ClusterInfo) GetClusterDomain added in v2.4.3 

func (x *ClusterInfo) GetClusterDomain() string

func (*ClusterInfo) GetDns added in v2.8.0 

func (x *ClusterInfo) GetDns() *DNS

func (*ClusterInfo) GetInjectorSvcHost added in v2.12.0 

func (x *ClusterInfo) GetInjectorSvcHost() string

func (*ClusterInfo) GetInjectorSvcIp added in v2.12.0 

func (x *ClusterInfo) GetInjectorSvcIp() []byte

func (*ClusterInfo) GetInjectorSvcPort added in v2.12.0 

func (x *ClusterInfo) GetInjectorSvcPort() int32

func (*ClusterInfo) GetKubeDnsIp added in v2.3.2 

func (x *ClusterInfo) GetKubeDnsIp() []byte

func (*ClusterInfo) GetManagerPodIp added in v2.5.4 

func (x *ClusterInfo) GetManagerPodIp() []byte

func (*ClusterInfo) GetManagerPodPort added in v2.8.0 

func (x *ClusterInfo) GetManagerPodPort() int32

func (*ClusterInfo) GetPodSubnets added in v2.3.2 

func (x *ClusterInfo) GetPodSubnets() []*IPNet

func (*ClusterInfo) GetRouting added in v2.8.0 

func (x *ClusterInfo) GetRouting() *Routing

func (*ClusterInfo) GetServiceSubnet added in v2.3.2 

func (x *ClusterInfo) GetServiceSubnet() *IPNet

func (*ClusterInfo) ProtoMessage added in v2.3.2 

func (*ClusterInfo) ProtoMessage()

func (*ClusterInfo) ProtoReflect added in v2.3.2 

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

func (*ClusterInfo) Reset added in v2.3.2 

func (x *ClusterInfo) Reset()

func (*ClusterInfo) String added in v2.3.2 

func (x *ClusterInfo) String() string

type CreateInterceptRequest 

type CreateInterceptRequest struct {
	Session       *SessionInfo   `protobuf:"bytes,1,opt,name=session,proto3" json:"session,omitempty"`
	InterceptSpec *InterceptSpec `protobuf:"bytes,2,opt,name=intercept_spec,json=interceptSpec,proto3" json:"intercept_spec,omitempty"`
	ApiKey        string         `protobuf:"bytes,3,opt,name=api_key,json=apiKey,proto3" json:"api_key,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateInterceptRequest) Descriptor deprecated 

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

Deprecated: Use CreateInterceptRequest.ProtoReflect.Descriptor instead.

func (*CreateInterceptRequest) GetApiKey added in v2.2.2 

func (x *CreateInterceptRequest) GetApiKey() string

func (*CreateInterceptRequest) GetInterceptSpec 

func (x *CreateInterceptRequest) GetInterceptSpec() *InterceptSpec

func (*CreateInterceptRequest) GetSession 

func (x *CreateInterceptRequest) GetSession() *SessionInfo

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 DNS added in v2.8.0 

type DNS struct {
	IncludeSuffixes []string `protobuf:"bytes,1,rep,name=include_suffixes,json=includeSuffixes,proto3" json:"include_suffixes,omitempty"`
	ExcludeSuffixes []string `protobuf:"bytes,2,rep,name=exclude_suffixes,json=excludeSuffixes,proto3" json:"exclude_suffixes,omitempty"`
	// kube_dns_ip is the IP address of the kube-dns.kube-system service,
	// Deprecated: No longer used by clients >= 2.8.0
	KubeIp []byte `protobuf:"bytes,3,opt,name=kube_ip,json=kubeIp,proto3" json:"kube_ip,omitempty"`
	// cluster_domain is the domain of the cluster, ending with a dot, e.g. "cluster.local."
	ClusterDomain string `protobuf:"bytes,4,opt,name=cluster_domain,json=clusterDomain,proto3" json:"cluster_domain,omitempty"`
	// contains filtered or unexported fields
}

func (*DNS) Descriptor deprecated added in v2.8.0 

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

Deprecated: Use DNS.ProtoReflect.Descriptor instead.

func (*DNS) GetClusterDomain added in v2.8.0 

func (x *DNS) GetClusterDomain() string

func (*DNS) GetExcludeSuffixes added in v2.8.0 

func (x *DNS) GetExcludeSuffixes() []string

func (*DNS) GetIncludeSuffixes added in v2.8.0 

func (x *DNS) GetIncludeSuffixes() []string

func (*DNS) GetKubeIp added in v2.8.0 

func (x *DNS) GetKubeIp() []byte

func (*DNS) ProtoMessage added in v2.8.0 

func (*DNS) ProtoMessage()

func (*DNS) ProtoReflect added in v2.8.0 

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

func (*DNS) Reset added in v2.8.0 

func (x *DNS) Reset()

func (*DNS) String added in v2.8.0 

func (x *DNS) String() string

type DNSAgentResponse added in v2.8.0 

type DNSAgentResponse struct {

	// Agent session
	Session *SessionInfo `protobuf:"bytes,1,opt,name=session,proto3" json:"session,omitempty"`
	// DNSRequest is the request that this is a response to
	Request *DNSRequest `protobuf:"bytes,2,opt,name=request,proto3" json:"request,omitempty"`
	// The response, which might be nil in case no address was found
	Response *DNSResponse `protobuf:"bytes,3,opt,name=response,proto3" json:"response,omitempty"`
	// contains filtered or unexported fields
}

func (*DNSAgentResponse) Descriptor deprecated added in v2.8.0 

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

Deprecated: Use DNSAgentResponse.ProtoReflect.Descriptor instead.

func (*DNSAgentResponse) GetRequest added in v2.8.0 

func (x *DNSAgentResponse) GetRequest() *DNSRequest

func (*DNSAgentResponse) GetResponse added in v2.8.0 

func (x *DNSAgentResponse) GetResponse() *DNSResponse

func (*DNSAgentResponse) GetSession added in v2.8.0 

func (x *DNSAgentResponse) GetSession() *SessionInfo

func (*DNSAgentResponse) ProtoMessage added in v2.8.0 

func (*DNSAgentResponse) ProtoMessage()

func (*DNSAgentResponse) ProtoReflect added in v2.8.0 

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

func (*DNSAgentResponse) Reset added in v2.8.0 

func (x *DNSAgentResponse) Reset()

func (*DNSAgentResponse) String added in v2.8.0 

func (x *DNSAgentResponse) String() string

type DNSRequest added in v2.8.0 

type DNSRequest struct {

	// Client session
	Session *SessionInfo `protobuf:"bytes,1,opt,name=session,proto3" json:"session,omitempty"`
	Name    string       `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Type    uint32       `protobuf:"varint,3,opt,name=type,proto3" json:"type,omitempty"`
	// contains filtered or unexported fields
}

LookupHost request sent from a client

func (*DNSRequest) Descriptor deprecated added in v2.8.0 

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

Deprecated: Use DNSRequest.ProtoReflect.Descriptor instead.

func (*DNSRequest) GetName added in v2.8.0 

func (x *DNSRequest) GetName() string

func (*DNSRequest) GetSession added in v2.8.0 

func (x *DNSRequest) GetSession() *SessionInfo

func (*DNSRequest) GetType added in v2.8.0 

func (x *DNSRequest) GetType() uint32

func (*DNSRequest) ProtoMessage added in v2.8.0 

func (*DNSRequest) ProtoMessage()

func (*DNSRequest) ProtoReflect added in v2.8.0 

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

func (*DNSRequest) Reset added in v2.8.0 

func (x *DNSRequest) Reset()

func (*DNSRequest) String added in v2.8.0 

func (x *DNSRequest) String() string

type DNSResponse added in v2.8.0 

type DNSResponse struct {

	// DNS return code
	RCode int32 `protobuf:"varint,1,opt,name=r_code,json=rCode,proto3" json:"r_code,omitempty"`
	// rrs is an array of packed RR records
	Rrs []byte `protobuf:"bytes,2,opt,name=rrs,proto3" json:"rrs,omitempty"`
	// contains filtered or unexported fields
}

func (*DNSResponse) Descriptor deprecated added in v2.8.0 

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

Deprecated: Use DNSResponse.ProtoReflect.Descriptor instead.

func (*DNSResponse) GetRCode added in v2.8.0 

func (x *DNSResponse) GetRCode() int32

func (*DNSResponse) GetRrs added in v2.8.0 

func (x *DNSResponse) GetRrs() []byte

func (*DNSResponse) ProtoMessage added in v2.8.0 

func (*DNSResponse) ProtoMessage()

func (*DNSResponse) ProtoReflect added in v2.8.0 

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

func (*DNSResponse) Reset added in v2.8.0 

func (x *DNSResponse) Reset()

func (*DNSResponse) String added in v2.8.0 

func (x *DNSResponse) String() string

type DialRequest added in v2.4.5 

type DialRequest struct {
	ConnId           []byte `protobuf:"bytes,1,opt,name=conn_id,json=connId,proto3" json:"conn_id,omitempty"`
	RoundtripLatency int64  `protobuf:"varint,2,opt,name=roundtrip_latency,json=roundtripLatency,proto3" json:"roundtrip_latency,omitempty"`
	DialTimeout      int64  `protobuf:"varint,3,opt,name=dial_timeout,json=dialTimeout,proto3" json:"dial_timeout,omitempty"`
	// contains filtered or unexported fields
}

func (*DialRequest) Descriptor deprecated added in v2.4.5 

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

Deprecated: Use DialRequest.ProtoReflect.Descriptor instead.

func (*DialRequest) GetConnId added in v2.4.5 

func (x *DialRequest) GetConnId() []byte

func (*DialRequest) GetDialTimeout added in v2.4.5 

func (x *DialRequest) GetDialTimeout() int64

func (*DialRequest) GetRoundtripLatency added in v2.4.5 

func (x *DialRequest) GetRoundtripLatency() int64

func (*DialRequest) ProtoMessage added in v2.4.5 

func (*DialRequest) ProtoMessage()

func (*DialRequest) ProtoReflect added in v2.4.5 

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

func (*DialRequest) Reset added in v2.4.5 

func (x *DialRequest) Reset()

func (*DialRequest) String added in v2.4.5 

func (x *DialRequest) String() string

type EnsureAgentRequest added in v2.18.0 

type EnsureAgentRequest struct {
	Session *SessionInfo `protobuf:"bytes,1,opt,name=session,proto3" json:"session,omitempty"`
	Name    string       `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*EnsureAgentRequest) Descriptor deprecated added in v2.18.0 

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

Deprecated: Use EnsureAgentRequest.ProtoReflect.Descriptor instead.

func (*EnsureAgentRequest) GetName added in v2.18.0 

func (x *EnsureAgentRequest) GetName() string

func (*EnsureAgentRequest) GetSession added in v2.18.0 

func (x *EnsureAgentRequest) GetSession() *SessionInfo

func (*EnsureAgentRequest) ProtoMessage added in v2.18.0 

func (*EnsureAgentRequest) ProtoMessage()

func (*EnsureAgentRequest) ProtoReflect added in v2.18.0 

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

func (*EnsureAgentRequest) Reset added in v2.18.0 

func (x *EnsureAgentRequest) Reset()

func (*EnsureAgentRequest) String added in v2.18.0 

func (x *EnsureAgentRequest) String() string

type GetInterceptRequest added in v2.4.5 

type GetInterceptRequest struct {
	Session *SessionInfo `protobuf:"bytes,1,opt,name=session,proto3" json:"session,omitempty"`
	Name    string       `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*GetInterceptRequest) Descriptor deprecated added in v2.4.5 

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

Deprecated: Use GetInterceptRequest.ProtoReflect.Descriptor instead.

func (*GetInterceptRequest) GetName added in v2.4.5 

func (x *GetInterceptRequest) GetName() string

func (*GetInterceptRequest) GetSession added in v2.4.5 

func (x *GetInterceptRequest) GetSession() *SessionInfo

func (*GetInterceptRequest) ProtoMessage added in v2.4.5 

func (*GetInterceptRequest) ProtoMessage()

func (*GetInterceptRequest) ProtoReflect added in v2.4.5 

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

func (*GetInterceptRequest) Reset added in v2.4.5 

func (x *GetInterceptRequest) Reset()

func (*GetInterceptRequest) String added in v2.4.5 

func (x *GetInterceptRequest) String() string

type GetLogsRequest added in v2.4.4 

type GetLogsRequest 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"`
	// The traffic-agent(s) logs are desired from. Can be `all`, `False`,
	// or substring to filter based on pod names.
	Agents string `protobuf:"bytes,2,opt,name=agents,proto3" json:"agents,omitempty"`
	// Whether or not to get the pod yaml deployed to the cluster.
	GetPodYaml bool `protobuf:"varint,3,opt,name=get_pod_yaml,json=getPodYaml,proto3" json:"get_pod_yaml,omitempty"`
	// contains filtered or unexported fields
}

Deprecated.

func (*GetLogsRequest) Descriptor deprecated added in v2.4.4 

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

Deprecated: Use GetLogsRequest.ProtoReflect.Descriptor instead.

func (*GetLogsRequest) GetAgents added in v2.4.4 

func (x *GetLogsRequest) GetAgents() string

func (*GetLogsRequest) GetGetPodYaml added in v2.4.5 

func (x *GetLogsRequest) GetGetPodYaml() bool

func (*GetLogsRequest) GetTrafficManager added in v2.4.4 

func (x *GetLogsRequest) GetTrafficManager() bool

func (*GetLogsRequest) ProtoMessage added in v2.4.4 

func (*GetLogsRequest) ProtoMessage()

func (*GetLogsRequest) ProtoReflect added in v2.4.4 

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

func (*GetLogsRequest) Reset added in v2.4.4 

func (x *GetLogsRequest) Reset()

func (*GetLogsRequest) String added in v2.4.4 

func (x *GetLogsRequest) String() string

type IPNet added in v2.3.2 

type IPNet struct {
	Ip   []byte `protobuf:"bytes,1,opt,name=ip,proto3" json:"ip,omitempty"`
	Mask int32  `protobuf:"varint,2,opt,name=mask,proto3" json:"mask,omitempty"`
	// contains filtered or unexported fields
}

IPNet is a subnet. e.g. 10.43.0.0/16

func (*IPNet) Descriptor deprecated added in v2.3.2 

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

Deprecated: Use IPNet.ProtoReflect.Descriptor instead.

func (*IPNet) GetIp added in v2.3.2 

func (x *IPNet) GetIp() []byte

func (*IPNet) GetMask added in v2.3.2 

func (x *IPNet) GetMask() int32

func (*IPNet) ProtoMessage added in v2.3.2 

func (*IPNet) ProtoMessage()

func (*IPNet) ProtoReflect added in v2.3.2 

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

func (*IPNet) Reset added in v2.3.2 

func (x *IPNet) Reset()

func (*IPNet) String added in v2.3.2 

func (x *IPNet) String() string

type IngressInfo 

type IngressInfo struct {

	// The layer-3 host
	Host string `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	// The layer-4 port
	Port int32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
	// Whether or not to use TLS on the port
	UseTls bool `protobuf:"varint,3,opt,name=use_tls,json=useTls,proto3" json:"use_tls,omitempty"`
	// The layer-5 host
	L5Host string `protobuf:"bytes,4,opt,name=l5host,proto3" json:"l5host,omitempty"`
	// contains filtered or unexported fields
}

func (*IngressInfo) Descriptor deprecated 

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

Deprecated: Use IngressInfo.ProtoReflect.Descriptor instead.

func (*IngressInfo) GetHost 

func (x *IngressInfo) GetHost() string

func (*IngressInfo) GetL5Host 

func (x *IngressInfo) GetL5Host() string

func (*IngressInfo) GetPort 

func (x *IngressInfo) GetPort() int32

func (*IngressInfo) GetUseTls 

func (x *IngressInfo) GetUseTls() bool

func (*IngressInfo) ProtoMessage 

func (*IngressInfo) ProtoMessage()

func (*IngressInfo) ProtoReflect 

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

func (*IngressInfo) Reset 

func (x *IngressInfo) Reset()

func (*IngressInfo) String 

func (x *IngressInfo) String() string

type InterceptDispositionType 

type InterceptDispositionType int32
const (
	InterceptDispositionType_UNSPECIFIED InterceptDispositionType = 0
	InterceptDispositionType_ACTIVE      InterceptDispositionType = 1
	InterceptDispositionType_WAITING     InterceptDispositionType = 2
	InterceptDispositionType_REMOVED     InterceptDispositionType = 9
	// What does "NO_CLIENT" mean?  The Manager garbage-collects the
	// intercept if the client goes away.
	InterceptDispositionType_NO_CLIENT InterceptDispositionType = 3
	// NO_AGENT indicates that there are no currently-running agents
	// that can service the intercept, or that there is a inconsistency
	// between the agents that are running.  This may be an ephemeral
	// state, such as inconsistency between agents during the middle of
	// a rolling update.
	InterceptDispositionType_NO_AGENT InterceptDispositionType = 4
	// NO_MECHANISM indicates that the agent(s) that would handle this
	// intercept do not report that they support the mechanism of the
	// intercept.  For example, if you are running the OSS agent but ask
	// for an intercept using the "http" mechanism, which requires the
	// Ambassador Telepresence agent.
	InterceptDispositionType_NO_MECHANISM InterceptDispositionType = 5
	// NO_PORT indicates that the manager was unable to allocate a port
	// to act as the rendezvous point between the client and the agent.
	InterceptDispositionType_NO_PORTS InterceptDispositionType = 6
	// AGENT_ERROR indicates that the intercept was submitted to an
	// agent, but that the agent rejected it (by calling
	// ReviewIntercept).
	InterceptDispositionType_AGENT_ERROR InterceptDispositionType = 7
	// BAD_ARGS indicates that something about the mechanism_args is
	// invalid.
	InterceptDispositionType_BAD_ARGS InterceptDispositionType = 8
)

func (InterceptDispositionType) Descriptor 

func (InterceptDispositionType) Descriptor() protoreflect.EnumDescriptor

func (InterceptDispositionType) Enum 

func (x InterceptDispositionType) Enum() *InterceptDispositionType

func (InterceptDispositionType) EnumDescriptor deprecated 

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

Deprecated: Use InterceptDispositionType.Descriptor instead.

func (InterceptDispositionType) Number 

func (x InterceptDispositionType) Number() protoreflect.EnumNumber

func (InterceptDispositionType) String 

func (x InterceptDispositionType) String() string

func (InterceptDispositionType) Type 

func (InterceptDispositionType) Type() protoreflect.EnumType

type InterceptInfo 

type InterceptInfo struct {
	Spec          *InterceptSpec `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"`
	Id            string         `protobuf:"bytes,5,opt,name=id,proto3" json:"id,omitempty"`
	ClientSession *SessionInfo   `protobuf:"bytes,6,opt,name=client_session,json=clientSession,proto3" json:"client_session,omitempty"`
	// api_key is the api_key provided by the user's machine
	// if they are logged in.  This is used by extensions to
	// authenticate with external APIs, such as SystemA.
	ApiKey string `protobuf:"bytes,13,opt,name=api_key,json=apiKey,proto3" json:"api_key,omitempty"`
	// preview_domain is the SystemA domain that will proxy in traffic
	// to this intercept, and preview_ingress is where it will get
	// proxied to.  They both get set by the manager when the client
	// makes a call to UpdateIntercept with add_preview_domain set.
	PreviewDomain string       `protobuf:"bytes,7,opt,name=preview_domain,json=previewDomain,proto3" json:"preview_domain,omitempty"`
	PreviewSpec   *PreviewSpec `protobuf:"bytes,9,opt,name=preview_spec,json=previewSpec,proto3" json:"preview_spec,omitempty"`
	// The current intercept state; a status code and a human-friendly
	// message to go along with the status code.  These may be set
	// manager itself, or may be set by the agent's call to
	// ReviewIntercept.
	Disposition InterceptDispositionType `` /* 127-byte string literal not displayed */
	Message     string                   `protobuf:"bytes,4,opt,name=message,proto3" json:"message,omitempty"`
	// Name and port to use when establishing port-forward to the pod's
	// gRPC API.
	PodName  string `protobuf:"bytes,19,opt,name=pod_name,json=podName,proto3" json:"pod_name,omitempty"`
	ApiPort  int32  `protobuf:"varint,20,opt,name=api_port,json=apiPort,proto3" json:"api_port,omitempty"`
	PodIp    string `protobuf:"bytes,10,opt,name=pod_ip,json=podIp,proto3" json:"pod_ip,omitempty"`
	SftpPort int32  `protobuf:"varint,11,opt,name=sftp_port,json=sftpPort,proto3" json:"sftp_port,omitempty"`
	FtpPort  int32  `protobuf:"varint,18,opt,name=ftp_port,json=ftpPort,proto3" json:"ftp_port,omitempty"`
	// The directory where the client mounts the remote mount_point. Only
	// set when obtaining InterceptInfo from the user daemon.
	ClientMountPoint string `protobuf:"bytes,2,opt,name=client_mount_point,json=clientMountPoint,proto3" json:"client_mount_point,omitempty"`
	// The directory where the intercept mounts can be found in the agent
	MountPoint string `protobuf:"bytes,16,opt,name=mount_point,json=mountPoint,proto3" json:"mount_point,omitempty"`
	// A human-friendly description of what the spec.mechanism_args say.
	// This is set by the agent's call to ReviewIntercept.
	MechanismArgsDesc string `protobuf:"bytes,12,opt,name=mechanism_args_desc,json=mechanismArgsDesc,proto3" json:"mechanism_args_desc,omitempty"`
	// Headers used by the workstation API-server
	Headers map[string]string `` /* 156-byte string literal not displayed */
	// Metadata used by the workstation API-server
	Metadata map[string]string `` /* 158-byte string literal not displayed */
	// The environment of the intercepted app
	Environment map[string]string `` /* 164-byte string literal not displayed */
	// Timestamp for last modification made by traffic-manager
	ModifiedAt *timestamppb.Timestamp `protobuf:"bytes,21,opt,name=modified_at,json=modifiedAt,proto3" json:"modified_at,omitempty"`
	// contains filtered or unexported fields
}

InterceptInfo contains information about a live intercept in an agent

func (*InterceptInfo) Descriptor deprecated 

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

Deprecated: Use InterceptInfo.ProtoReflect.Descriptor instead.

func (*InterceptInfo) GetApiKey added in v2.2.2 

func (x *InterceptInfo) GetApiKey() string

func (*InterceptInfo) GetApiPort added in v2.17.0 

func (x *InterceptInfo) GetApiPort() int32

func (*InterceptInfo) GetClientMountPoint added in v2.6.0 

func (x *InterceptInfo) GetClientMountPoint() string

func (*InterceptInfo) GetClientSession 

func (x *InterceptInfo) GetClientSession() *SessionInfo

func (*InterceptInfo) GetDisposition 

func (x *InterceptInfo) GetDisposition() InterceptDispositionType

func (*InterceptInfo) GetEnvironment added in v2.6.0 

func (x *InterceptInfo) GetEnvironment() map[string]string

func (*InterceptInfo) GetFtpPort added in v2.7.4 

func (x *InterceptInfo) GetFtpPort() int32

func (*InterceptInfo) GetHeaders added in v2.4.8 

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

func (*InterceptInfo) GetId 

func (x *InterceptInfo) GetId() string

func (*InterceptInfo) GetMechanismArgsDesc 

func (x *InterceptInfo) GetMechanismArgsDesc() string

func (*InterceptInfo) GetMessage 

func (x *InterceptInfo) GetMessage() string

func (*InterceptInfo) GetMetadata added in v2.5.0 

func (x *InterceptInfo) GetMetadata() map[string]string

func (*InterceptInfo) GetModifiedAt added in v2.17.0 

func (x *InterceptInfo) GetModifiedAt() *timestamppb.Timestamp

func (*InterceptInfo) GetMountPoint added in v2.6.0 

func (x *InterceptInfo) GetMountPoint() string

func (*InterceptInfo) GetPodIp added in v2.3.0 

func (x *InterceptInfo) GetPodIp() string

func (*InterceptInfo) GetPodName 

func (x *InterceptInfo) GetPodName() string

func (*InterceptInfo) GetPreviewDomain 

func (x *InterceptInfo) GetPreviewDomain() string

func (*InterceptInfo) GetPreviewSpec 

func (x *InterceptInfo) GetPreviewSpec() *PreviewSpec

func (*InterceptInfo) GetSftpPort added in v2.3.0 

func (x *InterceptInfo) GetSftpPort() int32

func (*InterceptInfo) GetSpec 

func (x *InterceptInfo) GetSpec() *InterceptSpec

func (*InterceptInfo) ProtoMessage 

func (*InterceptInfo) ProtoMessage()

func (*InterceptInfo) ProtoReflect 

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

func (*InterceptInfo) Reset 

func (x *InterceptInfo) Reset()

func (*InterceptInfo) String 

func (x *InterceptInfo) String() string

type InterceptInfoSnapshot 

type InterceptInfoSnapshot struct {
	Intercepts []*InterceptInfo `protobuf:"bytes,1,rep,name=intercepts,proto3" json:"intercepts,omitempty"`
	// contains filtered or unexported fields
}

func (*InterceptInfoSnapshot) Descriptor deprecated 

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

Deprecated: Use InterceptInfoSnapshot.ProtoReflect.Descriptor instead.

func (*InterceptInfoSnapshot) GetIntercepts 

func (x *InterceptInfoSnapshot) GetIntercepts() []*InterceptInfo

func (*InterceptInfoSnapshot) ProtoMessage 

func (*InterceptInfoSnapshot) ProtoMessage()

func (*InterceptInfoSnapshot) ProtoReflect 

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

func (*InterceptInfoSnapshot) Reset 

func (x *InterceptInfoSnapshot) Reset()

func (*InterceptInfoSnapshot) String 

func (x *InterceptInfoSnapshot) String() string

type InterceptSpec 

type InterceptSpec struct {

	// A human-friendly name for this intercept.  This is usually the
	// same as the agent name below; the name/namespace of the
	// Workload, but it could be something else.  It is invalid for
	// the same client to attempt to create multiple intercepts with the
	// same name.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Same as ClientInfo.Name; "user@hostname".
	Client string `protobuf:"bytes,2,opt,name=client,proto3" json:"client,omitempty"`
	// Same as AgentInfo.Name of the Workload.
	Agent string `protobuf:"bytes,3,opt,name=agent,proto3" json:"agent,omitempty"`
	// Kind of the Workload
	WorkloadKind string `protobuf:"bytes,13,opt,name=workload_kind,json=workloadKind,proto3" json:"workload_kind,omitempty"`
	// Same as AgentInfo.Namespace of the Workload
	Namespace string `protobuf:"bytes,8,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// How to decide which subset of requests to that agent to intercept.
	Mechanism string `protobuf:"bytes,4,opt,name=mechanism,proto3" json:"mechanism,omitempty"`
	// Additional mechanism-specific arguments.  This is passed as list
	// of CLI-style --flags.  See the documentation for
	// github.com/telepresenceio/telepresence/v2/pkg/client/cli/extensions
	// for more information about writing an extension descriptor file
	// to control what these values are.
	MechanismArgs []string `protobuf:"bytes,9,rep,name=mechanism_args,json=mechanismArgs,proto3" json:"mechanism_args,omitempty"`
	TargetHost    string   `protobuf:"bytes,6,opt,name=target_host,json=targetHost,proto3" json:"target_host,omitempty"`
	// The port on the workstation that the intercept is redirected to
	TargetPort int32 `protobuf:"varint,7,opt,name=target_port,json=targetPort,proto3" json:"target_port,omitempty"`
	// Identifier for the service or container port: either the name or port number
	// optionally followed by a "/TCP" or "/UDP"
	PortIdentifier string `protobuf:"bytes,10,opt,name=port_identifier,json=portIdentifier,proto3" json:"port_identifier,omitempty"`
	// The resolved service port name
	ServicePortName string `protobuf:"bytes,19,opt,name=service_port_name,json=servicePortName,proto3" json:"service_port_name,omitempty"`
	// The resolved service port
	ServicePort int32 `protobuf:"varint,20,opt,name=service_port,json=servicePort,proto3" json:"service_port,omitempty"`
	// .uid.metadata of service associated with intercept
	ServiceUid string `protobuf:"bytes,12,opt,name=service_uid,json=serviceUid,proto3" json:"service_uid,omitempty"`
	// name of the aforementioned service
	ServiceName string `protobuf:"bytes,14,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty"`
	// The resolved protocol used by the container port
	Protocol string `protobuf:"bytes,21,opt,name=protocol,proto3" json:"protocol,omitempty"` // TCP or UDP
	// Name of container that provides environment and mounts. This is normally the container
	// that owns the container_port, but in some cases it will differ because the container_port
	// is owned by some kind of routing mechanism (such as nginx).
	ContainerName string `protobuf:"bytes,24,opt,name=container_name,json=containerName,proto3" json:"container_name,omitempty"`
	// The resolved container port
	ContainerPort int32 `protobuf:"varint,23,opt,name=container_port,json=containerPort,proto3" json:"container_port,omitempty"`
	// Extra ports that will be forwarded from the intercepting client's localhost
	// to the intercepted pod. Each entry is a string containing a port number followed
	// by an optional "/TCP" or "/UDP".
	LocalPorts []string `protobuf:"bytes,18,rep,name=local_ports,json=localPorts,proto3" json:"local_ports,omitempty"`
	// The delay imposed by a call roundtrip between the traffic-agent and
	// the client on the workstation. This delay is added to the dial_timeout
	// when the workstation performs a dial on behalf of the traffic-agent.
	RoundtripLatency int64 `protobuf:"varint,16,opt,name=roundtrip_latency,json=roundtripLatency,proto3" json:"roundtrip_latency,omitempty"`
	// The dial timeout to use when a dial is made on the intercepting workstation.
	DialTimeout int64 `protobuf:"varint,17,opt,name=dial_timeout,json=dialTimeout,proto3" json:"dial_timeout,omitempty"`
	// Extra ports that will be forwarded from the intercepting client's localhost
	// to the intercepted pod.
	// Deprecated: use local_ports instead
	ExtraPorts []int32 `protobuf:"varint,15,rep,packed,name=extra_ports,json=extraPorts,proto3" json:"extra_ports,omitempty"`
	// Whether to replace the running container.
	Replace bool `protobuf:"varint,22,opt,name=replace,proto3" json:"replace,omitempty"`
	// contains filtered or unexported fields
}

InterceptSpec contains static information about an intercept. It is shared by all running agent instances.

func (*InterceptSpec) Descriptor deprecated 

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

Deprecated: Use InterceptSpec.ProtoReflect.Descriptor instead.

func (*InterceptSpec) GetAgent 

func (x *InterceptSpec) GetAgent() string

func (*InterceptSpec) GetClient 

func (x *InterceptSpec) GetClient() string

func (*InterceptSpec) GetContainerName added in v2.21.0 

func (x *InterceptSpec) GetContainerName() string

func (*InterceptSpec) GetContainerPort added in v2.20.0 

func (x *InterceptSpec) GetContainerPort() int32

func (*InterceptSpec) GetDialTimeout added in v2.4.5 

func (x *InterceptSpec) GetDialTimeout() int64

func (*InterceptSpec) GetExtraPorts added in v2.3.3 

func (x *InterceptSpec) GetExtraPorts() []int32

func (*InterceptSpec) GetLocalPorts added in v2.6.8 

func (x *InterceptSpec) GetLocalPorts() []string

func (*InterceptSpec) GetMechanism 

func (x *InterceptSpec) GetMechanism() string

func (*InterceptSpec) GetMechanismArgs 

func (x *InterceptSpec) GetMechanismArgs() []string

func (*InterceptSpec) GetName 

func (x *InterceptSpec) GetName() string

func (*InterceptSpec) GetNamespace 

func (x *InterceptSpec) GetNamespace() string

func (*InterceptSpec) GetPortIdentifier added in v2.20.0 

func (x *InterceptSpec) GetPortIdentifier() string

func (*InterceptSpec) GetProtocol added in v2.9.0 

func (x *InterceptSpec) GetProtocol() string

func (*InterceptSpec) GetReplace added in v2.16.0 

func (x *InterceptSpec) GetReplace() bool

func (*InterceptSpec) GetRoundtripLatency added in v2.4.5 

func (x *InterceptSpec) GetRoundtripLatency() int64

func (*InterceptSpec) GetServiceName added in v2.1.3 

func (x *InterceptSpec) GetServiceName() string

func (*InterceptSpec) GetServicePort added in v2.9.0 

func (x *InterceptSpec) GetServicePort() int32

func (*InterceptSpec) GetServicePortName 

func (x *InterceptSpec) GetServicePortName() string

func (*InterceptSpec) GetServiceUid added in v2.1.2 

func (x *InterceptSpec) GetServiceUid() string

func (*InterceptSpec) GetTargetHost 

func (x *InterceptSpec) GetTargetHost() string

func (*InterceptSpec) GetTargetPort 

func (x *InterceptSpec) GetTargetPort() int32

func (*InterceptSpec) GetWorkloadKind added in v2.1.3 

func (x *InterceptSpec) GetWorkloadKind() string

func (*InterceptSpec) ProtoMessage 

func (*InterceptSpec) ProtoMessage()

func (*InterceptSpec) ProtoReflect 

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

func (*InterceptSpec) Reset 

func (x *InterceptSpec) Reset()

func (*InterceptSpec) String 

func (x *InterceptSpec) String() string

type KnownWorkloadKinds added in v2.20.0 

type KnownWorkloadKinds struct {
	Kinds []WorkloadInfo_Kind `protobuf:"varint,1,rep,packed,name=kinds,proto3,enum=telepresence.manager.WorkloadInfo_Kind" json:"kinds,omitempty"`
	// contains filtered or unexported fields
}

func (*KnownWorkloadKinds) Descriptor deprecated added in v2.20.0 

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

Deprecated: Use KnownWorkloadKinds.ProtoReflect.Descriptor instead.

func (*KnownWorkloadKinds) GetKinds added in v2.20.0 

func (x *KnownWorkloadKinds) GetKinds() []WorkloadInfo_Kind

func (*KnownWorkloadKinds) ProtoMessage added in v2.20.0 

func (*KnownWorkloadKinds) ProtoMessage()

func (*KnownWorkloadKinds) ProtoReflect added in v2.20.0 

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

func (*KnownWorkloadKinds) Reset added in v2.20.0 

func (x *KnownWorkloadKinds) Reset()

func (*KnownWorkloadKinds) String added in v2.20.0 

func (x *KnownWorkloadKinds) String() string

type License added in v2.2.0 

type License struct {
	License string `protobuf:"bytes,1,opt,name=license,proto3" json:"license,omitempty"`
	Host    string `protobuf:"bytes,2,opt,name=host,proto3" json:"host,omitempty"`
	// cluster_id is really the id of the namespace where the traffic-manager is installed.
	ClusterId string `protobuf:"bytes,3,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	ErrMsg    string `protobuf:"bytes,4,opt,name=err_msg,json=errMsg,proto3" json:"err_msg,omitempty"`
	Valid     bool   `protobuf:"varint,5,opt,name=valid,proto3" json:"valid,omitempty"`
	// contains filtered or unexported fields
}

All of a license's fields come from the license secret

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

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

Deprecated: Use License.ProtoReflect.Descriptor instead.

func (*License) GetClusterId added in v2.2.2 

func (x *License) GetClusterId() string

func (*License) GetErrMsg added in v2.4.5 

func (x *License) GetErrMsg() string

func (*License) GetHost added in v2.2.0 

func (x *License) GetHost() string

func (*License) GetLicense added in v2.2.0 

func (x *License) GetLicense() string

func (*License) GetValid added in v2.21.0 

func (x *License) GetValid() bool

func (*License) ProtoMessage added in v2.2.0 

func (*License) ProtoMessage()

func (*License) ProtoReflect added in v2.2.0 

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

func (*License) Reset added in v2.2.0 

func (x *License) Reset()

func (*License) String added in v2.2.0 

func (x *License) String() string

type LogLevelRequest added in v2.4.2 

type LogLevelRequest struct {
	LogLevel string `protobuf:"bytes,1,opt,name=log_level,json=logLevel,proto3" json:"log_level,omitempty"`
	// The time that this log-level will be in effect before
	// falling back to the configured log-level.
	Duration *durationpb.Duration `protobuf:"bytes,2,opt,name=duration,proto3" json:"duration,omitempty"`
	// contains filtered or unexported fields
}

func (*LogLevelRequest) Descriptor deprecated added in v2.4.2 

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

Deprecated: Use LogLevelRequest.ProtoReflect.Descriptor instead.

func (*LogLevelRequest) GetDuration added in v2.4.2 

func (x *LogLevelRequest) GetDuration() *durationpb.Duration

func (*LogLevelRequest) GetLogLevel added in v2.4.2 

func (x *LogLevelRequest) GetLogLevel() string

func (*LogLevelRequest) ProtoMessage added in v2.4.2 

func (*LogLevelRequest) ProtoMessage()

func (*LogLevelRequest) ProtoReflect added in v2.4.2 

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

func (*LogLevelRequest) Reset added in v2.4.2 

func (x *LogLevelRequest) Reset()

func (*LogLevelRequest) String added in v2.4.2 

func (x *LogLevelRequest) String() string

type LogsResponse added in v2.4.4 

type LogsResponse struct {

	// The map contains assocations between <podName.namespace> and the logs
	// from that pod.
	PodLogs map[string]string `` /* 170-byte string literal not displayed */
	// Errors encountered when getting logs from the traffic-manager
	// and/or traffic-agents.
	ErrMsg string `protobuf:"bytes,2,opt,name=err_msg,json=errMsg,proto3" json:"err_msg,omitempty"`
	// The map contains assocations between <podName.namespace> and the pod's
	// yaml.
	PodYaml map[string]string `` /* 170-byte string literal not displayed */
	// contains filtered or unexported fields
}

Deprecated.

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

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

Deprecated: Use LogsResponse.ProtoReflect.Descriptor instead.

func (*LogsResponse) GetErrMsg added in v2.4.4 

func (x *LogsResponse) GetErrMsg() string

func (*LogsResponse) GetPodLogs added in v2.4.4 

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

func (*LogsResponse) GetPodYaml added in v2.4.5 

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

func (*LogsResponse) ProtoMessage added in v2.4.4 

func (*LogsResponse) ProtoMessage()

func (*LogsResponse) ProtoReflect added in v2.4.4 

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

func (*LogsResponse) Reset added in v2.4.4 

func (x *LogsResponse) Reset()

func (*LogsResponse) String added in v2.4.4 

func (x *LogsResponse) String() string

type ManagerClient 

type ManagerClient interface {
	// Version returns the version information of the Manager.
	Version(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*VersionInfo2, error)
	// GetAgentImageFQN returns fully qualified name of the image that is injected into intercepted pods.
	GetAgentImageFQN(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*AgentImageFQN, error)
	// GetAgentConfig returns the agent configuration for a specific workload.
	GetAgentConfig(ctx context.Context, in *AgentConfigRequest, opts ...grpc.CallOption) (*AgentConfigResponse, error)
	// GetLicense returns the License information (the license itself and
	// domain that granted it) known to the manager.
	GetLicense(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*License, error)
	// CanConnectAmbassadorCloud returns whether or not the cluster is able to talk to
	// Ambassador Cloud
	CanConnectAmbassadorCloud(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*AmbassadorCloudConnection, error)
	// GetCloudConfig returns the config (host + port) for Ambassador Cloud for use
	// by the agents.
	GetCloudConfig(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*AmbassadorCloudConfig, error)
	// GetClientConfig returns the config that connected clients should use for this manager.
	GetClientConfig(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*CLIConfig, error)
	// GetTelepresenceAPI returns information about the TelepresenceAPI server
	GetTelepresenceAPI(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*TelepresenceAPIInfo, error)
	// ArriveAsClient establishes a session between a client and the Manager.
	ArriveAsClient(ctx context.Context, in *ClientInfo, opts ...grpc.CallOption) (*SessionInfo, error)
	// ArriveAsAgent establishes a session between an agent and the Manager.
	ArriveAsAgent(ctx context.Context, in *AgentInfo, opts ...grpc.CallOption) (*SessionInfo, error)
	// Remain indicates that the session is still valid, and potentially
	// updates the auth token for the session.
	Remain(ctx context.Context, in *RemainRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Depart terminates a session.
	Depart(ctx context.Context, in *SessionInfo, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// SetLogLevel will temporarily set the log-level for the traffic-manager and all
	// traffic-agents for a duration that is determined b the request.
	SetLogLevel(ctx context.Context, in *LogLevelRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// GetLogs will acquire logs for the various Telepresence components in kubernetes
	// (pending the request) and return them to the caller
	// Deprecated: Will return an empty response
	GetLogs(ctx context.Context, in *GetLogsRequest, opts ...grpc.CallOption) (*LogsResponse, error)
	// WatchAgentPods notifies a client of the set of known Agents from the client
	// connections namespace that the client can connect to when port-forwards are
	// allowed.
	WatchAgentPods(ctx context.Context, in *SessionInfo, opts ...grpc.CallOption) (grpc.ServerStreamingClient[AgentPodInfoSnapshot], error)
	// WatchAgents notifies a client of the set of known Agents.
	//
	// A session ID is required; if no session ID is given then the call
	// returns immediately, having not delivered any snapshots.
	WatchAgents(ctx context.Context, in *SessionInfo, opts ...grpc.CallOption) (grpc.ServerStreamingClient[AgentInfoSnapshot], error)
	// WatchAgentsNS is like WatchAgents but limited to a set of namespaces
	WatchAgentsNS(ctx context.Context, in *AgentsRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[AgentInfoSnapshot], error)
	// WatchIntercepts notifies a client or agent of the set of intercepts
	// relevant to that client or agent.
	//
	// If a session ID is given, then only intercepts associated with
	// that session are watched.  If no session ID is given, then all
	// intercepts are watched.
	WatchIntercepts(ctx context.Context, in *SessionInfo, opts ...grpc.CallOption) (grpc.ServerStreamingClient[InterceptInfoSnapshot], error)
	// WatchWorkloads notifies a client of the set of Workloads from the client
	// connection's namespace.
	WatchWorkloads(ctx context.Context, in *WorkloadEventsRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[WorkloadEventsDelta], error)
	// WatchClusterInfo returns information needed when establishing
	// connectivity to the cluster.
	WatchClusterInfo(ctx context.Context, in *SessionInfo, opts ...grpc.CallOption) (grpc.ServerStreamingClient[ClusterInfo], error)
	// EnsureAgent ensures that an agent is injected to the pods of a workload and
	// returns the agents, sorted by pod name.
	EnsureAgent(ctx context.Context, in *EnsureAgentRequest, opts ...grpc.CallOption) (*AgentInfoSnapshot, error)
	// Request that the traffic-manager makes the preparations necessary to
	// create the given intercept.
	PrepareIntercept(ctx context.Context, in *CreateInterceptRequest, opts ...grpc.CallOption) (*PreparedIntercept, error)
	// CreateIntercept lets a client create an intercept.  It will be
	// created in the "WATING" disposition, and it will remain in that
	// state until the Agent (the app-sidecar) calls ReviewIntercept()
	// to transition it to the "ACTIVE" disposition (or one of the error
	// dispositions).
	CreateIntercept(ctx context.Context, in *CreateInterceptRequest, opts ...grpc.CallOption) (*InterceptInfo, error)
	// RemoveIntercept lets a client remove an intercept.
	RemoveIntercept(ctx context.Context, in *RemoveInterceptRequest2, opts ...grpc.CallOption) (*emptypb.Empty, error)
	UpdateIntercept(ctx context.Context, in *UpdateInterceptRequest, opts ...grpc.CallOption) (*InterceptInfo, error)
	// GetIntercept gets info from intercept name
	GetIntercept(ctx context.Context, in *GetInterceptRequest, opts ...grpc.CallOption) (*InterceptInfo, error)
	// ReviewIntercept lets an agent approve or reject an intercept by
	// changing the disposition from "WATING" to "ACTIVE" or to an
	// error, and setting a human-readable status message.
	ReviewIntercept(ctx context.Context, in *ReviewInterceptRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// GetKnownWorkloadKinds returns the known workload kinds
	// that the manager can handle. This set may include Deployment, StatefulSet, ReplicaSet, Rollout (Argo Rollouts)
	// as configured in the manager's Helm values.
	GetKnownWorkloadKinds(ctx context.Context, in *SessionInfo, opts ...grpc.CallOption) (*KnownWorkloadKinds, error)
	// LookupDNS performs a DNS lookup in the cluster. If the caller has intercepts
	// active, the lookup will be performed from the intercepted pods.
	LookupDNS(ctx context.Context, in *DNSRequest, opts ...grpc.CallOption) (*DNSResponse, error)
	// AgentLookupHostResponse lets an agent respond for lookup requests
	AgentLookupDNSResponse(ctx context.Context, in *DNSAgentResponse, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// WatchLookupHost lets an agent receive lookup requests
	WatchLookupDNS(ctx context.Context, in *SessionInfo, opts ...grpc.CallOption) (grpc.ServerStreamingClient[DNSRequest], error)
	// WatchLogLevel lets an agent receive log-level updates
	WatchLogLevel(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (grpc.ServerStreamingClient[LogLevelRequest], error)
	// A Tunnel represents one single connection where the client or
	// traffic-agent represents one end (the client-side) and the
	// traffic-manager represents the other (the server side). The first
	// message that a client sends when the tunnel is established is will
	// always contain the session ID, connection ID, and timeouts used by
	// the dialer endpoints.
	Tunnel(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[TunnelMessage, TunnelMessage], error)
	// ReportMetrics is used by a traffic-agent to report metrics for streams
	// established when clients connect directly to traffic-agents using port-forward.
	ReportMetrics(ctx context.Context, in *TunnelMetrics, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// WatchDial makes it possible for the client side to receive
	// DialRequests from the traffic-manager. Requests are sent when an
	// intercepted traffic-agent creates a Tunnel that needs to be extended
	// to the Telepresence client on the workstation, or the other way around,
	// when that client creates a tunnel that needs to be extended to an
	// intercepted traffic agent. The receiver of the request dials a
	// connection and responds with a Tunnel. The manager then connects the
	// two tunnels.
	WatchDial(ctx context.Context, in *SessionInfo, opts ...grpc.CallOption) (grpc.ServerStreamingClient[DialRequest], error)
}

ManagerClient is the client API for Manager 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 NewManagerClient 

func NewManagerClient(cc grpc.ClientConnInterface) ManagerClient

type ManagerServer 

type ManagerServer interface {
	// Version returns the version information of the Manager.
	Version(context.Context, *emptypb.Empty) (*VersionInfo2, error)
	// GetAgentImageFQN returns fully qualified name of the image that is injected into intercepted pods.
	GetAgentImageFQN(context.Context, *emptypb.Empty) (*AgentImageFQN, error)
	// GetAgentConfig returns the agent configuration for a specific workload.
	GetAgentConfig(context.Context, *AgentConfigRequest) (*AgentConfigResponse, error)
	// GetLicense returns the License information (the license itself and
	// domain that granted it) known to the manager.
	GetLicense(context.Context, *emptypb.Empty) (*License, error)
	// CanConnectAmbassadorCloud returns whether or not the cluster is able to talk to
	// Ambassador Cloud
	CanConnectAmbassadorCloud(context.Context, *emptypb.Empty) (*AmbassadorCloudConnection, error)
	// GetCloudConfig returns the config (host + port) for Ambassador Cloud for use
	// by the agents.
	GetCloudConfig(context.Context, *emptypb.Empty) (*AmbassadorCloudConfig, error)
	// GetClientConfig returns the config that connected clients should use for this manager.
	GetClientConfig(context.Context, *emptypb.Empty) (*CLIConfig, error)
	// GetTelepresenceAPI returns information about the TelepresenceAPI server
	GetTelepresenceAPI(context.Context, *emptypb.Empty) (*TelepresenceAPIInfo, error)
	// ArriveAsClient establishes a session between a client and the Manager.
	ArriveAsClient(context.Context, *ClientInfo) (*SessionInfo, error)
	// ArriveAsAgent establishes a session between an agent and the Manager.
	ArriveAsAgent(context.Context, *AgentInfo) (*SessionInfo, error)
	// Remain indicates that the session is still valid, and potentially
	// updates the auth token for the session.
	Remain(context.Context, *RemainRequest) (*emptypb.Empty, error)
	// Depart terminates a session.
	Depart(context.Context, *SessionInfo) (*emptypb.Empty, error)
	// SetLogLevel will temporarily set the log-level for the traffic-manager and all
	// traffic-agents for a duration that is determined b the request.
	SetLogLevel(context.Context, *LogLevelRequest) (*emptypb.Empty, error)
	// GetLogs will acquire logs for the various Telepresence components in kubernetes
	// (pending the request) and return them to the caller
	// Deprecated: Will return an empty response
	GetLogs(context.Context, *GetLogsRequest) (*LogsResponse, error)
	// WatchAgentPods notifies a client of the set of known Agents from the client
	// connections namespace that the client can connect to when port-forwards are
	// allowed.
	WatchAgentPods(*SessionInfo, grpc.ServerStreamingServer[AgentPodInfoSnapshot]) error
	// WatchAgents notifies a client of the set of known Agents.
	//
	// A session ID is required; if no session ID is given then the call
	// returns immediately, having not delivered any snapshots.
	WatchAgents(*SessionInfo, grpc.ServerStreamingServer[AgentInfoSnapshot]) error
	// WatchAgentsNS is like WatchAgents but limited to a set of namespaces
	WatchAgentsNS(*AgentsRequest, grpc.ServerStreamingServer[AgentInfoSnapshot]) error
	// WatchIntercepts notifies a client or agent of the set of intercepts
	// relevant to that client or agent.
	//
	// If a session ID is given, then only intercepts associated with
	// that session are watched.  If no session ID is given, then all
	// intercepts are watched.
	WatchIntercepts(*SessionInfo, grpc.ServerStreamingServer[InterceptInfoSnapshot]) error
	// WatchWorkloads notifies a client of the set of Workloads from the client
	// connection's namespace.
	WatchWorkloads(*WorkloadEventsRequest, grpc.ServerStreamingServer[WorkloadEventsDelta]) error
	// WatchClusterInfo returns information needed when establishing
	// connectivity to the cluster.
	WatchClusterInfo(*SessionInfo, grpc.ServerStreamingServer[ClusterInfo]) error
	// EnsureAgent ensures that an agent is injected to the pods of a workload and
	// returns the agents, sorted by pod name.
	EnsureAgent(context.Context, *EnsureAgentRequest) (*AgentInfoSnapshot, error)
	// Request that the traffic-manager makes the preparations necessary to
	// create the given intercept.
	PrepareIntercept(context.Context, *CreateInterceptRequest) (*PreparedIntercept, error)
	// CreateIntercept lets a client create an intercept.  It will be
	// created in the "WATING" disposition, and it will remain in that
	// state until the Agent (the app-sidecar) calls ReviewIntercept()
	// to transition it to the "ACTIVE" disposition (or one of the error
	// dispositions).
	CreateIntercept(context.Context, *CreateInterceptRequest) (*InterceptInfo, error)
	// RemoveIntercept lets a client remove an intercept.
	RemoveIntercept(context.Context, *RemoveInterceptRequest2) (*emptypb.Empty, error)
	UpdateIntercept(context.Context, *UpdateInterceptRequest) (*InterceptInfo, error)
	// GetIntercept gets info from intercept name
	GetIntercept(context.Context, *GetInterceptRequest) (*InterceptInfo, error)
	// ReviewIntercept lets an agent approve or reject an intercept by
	// changing the disposition from "WATING" to "ACTIVE" or to an
	// error, and setting a human-readable status message.
	ReviewIntercept(context.Context, *ReviewInterceptRequest) (*emptypb.Empty, error)
	// GetKnownWorkloadKinds returns the known workload kinds
	// that the manager can handle. This set may include Deployment, StatefulSet, ReplicaSet, Rollout (Argo Rollouts)
	// as configured in the manager's Helm values.
	GetKnownWorkloadKinds(context.Context, *SessionInfo) (*KnownWorkloadKinds, error)
	// LookupDNS performs a DNS lookup in the cluster. If the caller has intercepts
	// active, the lookup will be performed from the intercepted pods.
	LookupDNS(context.Context, *DNSRequest) (*DNSResponse, error)
	// AgentLookupHostResponse lets an agent respond for lookup requests
	AgentLookupDNSResponse(context.Context, *DNSAgentResponse) (*emptypb.Empty, error)
	// WatchLookupHost lets an agent receive lookup requests
	WatchLookupDNS(*SessionInfo, grpc.ServerStreamingServer[DNSRequest]) error
	// WatchLogLevel lets an agent receive log-level updates
	WatchLogLevel(*emptypb.Empty, grpc.ServerStreamingServer[LogLevelRequest]) error
	// A Tunnel represents one single connection where the client or
	// traffic-agent represents one end (the client-side) and the
	// traffic-manager represents the other (the server side). The first
	// message that a client sends when the tunnel is established is will
	// always contain the session ID, connection ID, and timeouts used by
	// the dialer endpoints.
	Tunnel(grpc.BidiStreamingServer[TunnelMessage, TunnelMessage]) error
	// ReportMetrics is used by a traffic-agent to report metrics for streams
	// established when clients connect directly to traffic-agents using port-forward.
	ReportMetrics(context.Context, *TunnelMetrics) (*emptypb.Empty, error)
	// WatchDial makes it possible for the client side to receive
	// DialRequests from the traffic-manager. Requests are sent when an
	// intercepted traffic-agent creates a Tunnel that needs to be extended
	// to the Telepresence client on the workstation, or the other way around,
	// when that client creates a tunnel that needs to be extended to an
	// intercepted traffic agent. The receiver of the request dials a
	// connection and responds with a Tunnel. The manager then connects the
	// two tunnels.
	WatchDial(*SessionInfo, grpc.ServerStreamingServer[DialRequest]) error
	// contains filtered or unexported methods
}

ManagerServer is the server API for Manager service. All implementations must embed UnimplementedManagerServer for forward compatibility.

type Manager_TunnelClient added in v2.4.5 

type Manager_TunnelClient = grpc.BidiStreamingClient[TunnelMessage, TunnelMessage]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type Manager_TunnelServer added in v2.4.5 

type Manager_TunnelServer = grpc.BidiStreamingServer[TunnelMessage, TunnelMessage]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type Manager_WatchAgentPodsClient added in v2.17.0 

type Manager_WatchAgentPodsClient = grpc.ServerStreamingClient[AgentPodInfoSnapshot]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type Manager_WatchAgentPodsServer added in v2.17.0 

type Manager_WatchAgentPodsServer = grpc.ServerStreamingServer[AgentPodInfoSnapshot]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type Manager_WatchAgentsClient 

type Manager_WatchAgentsClient = grpc.ServerStreamingClient[AgentInfoSnapshot]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type Manager_WatchAgentsNSClient added in v2.5.5 

type Manager_WatchAgentsNSClient = grpc.ServerStreamingClient[AgentInfoSnapshot]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type Manager_WatchAgentsNSServer added in v2.5.5 

type Manager_WatchAgentsNSServer = grpc.ServerStreamingServer[AgentInfoSnapshot]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type Manager_WatchAgentsServer 

type Manager_WatchAgentsServer = grpc.ServerStreamingServer[AgentInfoSnapshot]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type Manager_WatchClusterInfoClient added in v2.3.2 

type Manager_WatchClusterInfoClient = grpc.ServerStreamingClient[ClusterInfo]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type Manager_WatchClusterInfoServer added in v2.3.2 

type Manager_WatchClusterInfoServer = grpc.ServerStreamingServer[ClusterInfo]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type Manager_WatchDialClient added in v2.4.5 

type Manager_WatchDialClient = grpc.ServerStreamingClient[DialRequest]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type Manager_WatchDialServer added in v2.4.5 

type Manager_WatchDialServer = grpc.ServerStreamingServer[DialRequest]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type Manager_WatchInterceptsClient 

type Manager_WatchInterceptsClient = grpc.ServerStreamingClient[InterceptInfoSnapshot]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type Manager_WatchInterceptsServer 

type Manager_WatchInterceptsServer = grpc.ServerStreamingServer[InterceptInfoSnapshot]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type Manager_WatchLogLevelClient added in v2.4.2 

type Manager_WatchLogLevelClient = grpc.ServerStreamingClient[LogLevelRequest]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type Manager_WatchLogLevelServer added in v2.4.2 

type Manager_WatchLogLevelServer = grpc.ServerStreamingServer[LogLevelRequest]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type Manager_WatchLookupDNSClient added in v2.8.0 

type Manager_WatchLookupDNSClient = grpc.ServerStreamingClient[DNSRequest]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type Manager_WatchLookupDNSServer added in v2.8.0 

type Manager_WatchLookupDNSServer = grpc.ServerStreamingServer[DNSRequest]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type Manager_WatchWorkloadsClient added in v2.19.0 

type Manager_WatchWorkloadsClient = grpc.ServerStreamingClient[WorkloadEventsDelta]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type Manager_WatchWorkloadsServer added in v2.19.0 

type Manager_WatchWorkloadsServer = grpc.ServerStreamingServer[WorkloadEventsDelta]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type PreparedIntercept added in v2.6.0 

type PreparedIntercept struct {
	Error           string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	ErrorCategory   int32  `protobuf:"varint,2,opt,name=error_category,json=errorCategory,proto3" json:"error_category,omitempty"`
	Namespace       string `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"`
	ServiceUid      string `protobuf:"bytes,4,opt,name=service_uid,json=serviceUid,proto3" json:"service_uid,omitempty"`
	ServiceName     string `protobuf:"bytes,5,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty"`
	ServicePortName string `protobuf:"bytes,6,opt,name=service_port_name,json=servicePortName,proto3" json:"service_port_name,omitempty"`
	ServicePort     int32  `protobuf:"varint,7,opt,name=service_port,json=servicePort,proto3" json:"service_port,omitempty"`
	WorkloadKind    string `protobuf:"bytes,8,opt,name=workload_kind,json=workloadKind,proto3" json:"workload_kind,omitempty"`
	AgentImage      string `protobuf:"bytes,9,opt,name=agent_image,json=agentImage,proto3" json:"agent_image,omitempty"`
	Protocol        string `protobuf:"bytes,10,opt,name=protocol,proto3" json:"protocol,omitempty"` // TCP or UDP
	ContainerName   string `protobuf:"bytes,11,opt,name=container_name,json=containerName,proto3" json:"container_name,omitempty"`
	ContainerPort   int32  `protobuf:"varint,12,opt,name=container_port,json=containerPort,proto3" json:"container_port,omitempty"`
	// contains filtered or unexported fields
}

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

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

Deprecated: Use PreparedIntercept.ProtoReflect.Descriptor instead.

func (*PreparedIntercept) GetAgentImage added in v2.6.0 

func (x *PreparedIntercept) GetAgentImage() string

func (*PreparedIntercept) GetContainerName added in v2.20.0 

func (x *PreparedIntercept) GetContainerName() string

func (*PreparedIntercept) GetContainerPort added in v2.20.0 

func (x *PreparedIntercept) GetContainerPort() int32

func (*PreparedIntercept) GetError added in v2.6.0 

func (x *PreparedIntercept) GetError() string

func (*PreparedIntercept) GetErrorCategory added in v2.6.0 

func (x *PreparedIntercept) GetErrorCategory() int32

func (*PreparedIntercept) GetNamespace added in v2.6.0 

func (x *PreparedIntercept) GetNamespace() string

func (*PreparedIntercept) GetProtocol added in v2.6.8 

func (x *PreparedIntercept) GetProtocol() string

func (*PreparedIntercept) GetServiceName added in v2.6.0 

func (x *PreparedIntercept) GetServiceName() string

func (*PreparedIntercept) GetServicePort added in v2.6.0 

func (x *PreparedIntercept) GetServicePort() int32

func (*PreparedIntercept) GetServicePortName added in v2.6.0 

func (x *PreparedIntercept) GetServicePortName() string

func (*PreparedIntercept) GetServiceUid added in v2.6.0 

func (x *PreparedIntercept) GetServiceUid() string

func (*PreparedIntercept) GetWorkloadKind added in v2.6.0 

func (x *PreparedIntercept) GetWorkloadKind() string

func (*PreparedIntercept) ProtoMessage added in v2.6.0 

func (*PreparedIntercept) ProtoMessage()

func (*PreparedIntercept) ProtoReflect added in v2.6.0 

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

func (*PreparedIntercept) Reset added in v2.6.0 

func (x *PreparedIntercept) Reset()

func (*PreparedIntercept) String added in v2.6.0 

func (x *PreparedIntercept) String() string

type PreviewSpec 

type PreviewSpec struct {
	Ingress           *IngressInfo      `protobuf:"bytes,1,opt,name=ingress,proto3" json:"ingress,omitempty"`
	DisplayBanner     bool              `protobuf:"varint,2,opt,name=display_banner,json=displayBanner,proto3" json:"display_banner,omitempty"`
	PullRequestUrl    string            `protobuf:"bytes,3,opt,name=pull_request_url,json=pullRequestUrl,proto3" json:"pull_request_url,omitempty"`
	AddRequestHeaders map[string]string `` /* 202-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*PreviewSpec) Descriptor deprecated 

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

Deprecated: Use PreviewSpec.ProtoReflect.Descriptor instead.

func (*PreviewSpec) GetAddRequestHeaders added in v2.7.0 

func (x *PreviewSpec) GetAddRequestHeaders() map[string]string

func (*PreviewSpec) GetDisplayBanner 

func (x *PreviewSpec) GetDisplayBanner() bool

func (*PreviewSpec) GetIngress 

func (x *PreviewSpec) GetIngress() *IngressInfo

func (*PreviewSpec) GetPullRequestUrl added in v2.7.0 

func (x *PreviewSpec) GetPullRequestUrl() string

func (*PreviewSpec) ProtoMessage 

func (*PreviewSpec) ProtoMessage()

func (*PreviewSpec) ProtoReflect 

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

func (*PreviewSpec) Reset 

func (x *PreviewSpec) Reset()

func (*PreviewSpec) String 

func (x *PreviewSpec) String() string

type RemainRequest 

type RemainRequest struct {
	Session *SessionInfo `protobuf:"bytes,1,opt,name=session,proto3" json:"session,omitempty"`
	ApiKey  string       `protobuf:"bytes,2,opt,name=api_key,json=apiKey,proto3" json:"api_key,omitempty"`
	// contains filtered or unexported fields
}

func (*RemainRequest) Descriptor deprecated 

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

Deprecated: Use RemainRequest.ProtoReflect.Descriptor instead.

func (*RemainRequest) GetApiKey added in v2.1.4 

func (x *RemainRequest) GetApiKey() string

func (*RemainRequest) GetSession 

func (x *RemainRequest) GetSession() *SessionInfo

func (*RemainRequest) ProtoMessage 

func (*RemainRequest) ProtoMessage()

func (*RemainRequest) ProtoReflect 

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

func (*RemainRequest) Reset 

func (x *RemainRequest) Reset()

func (*RemainRequest) String 

func (x *RemainRequest) String() string

type RemoveInterceptRequest2 

type RemoveInterceptRequest2 struct {
	Session *SessionInfo `protobuf:"bytes,1,opt,name=session,proto3" json:"session,omitempty"`
	Name    string       `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveInterceptRequest2) Descriptor deprecated 

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

Deprecated: Use RemoveInterceptRequest2.ProtoReflect.Descriptor instead.

func (*RemoveInterceptRequest2) GetName 

func (x *RemoveInterceptRequest2) GetName() string

func (*RemoveInterceptRequest2) GetSession 

func (x *RemoveInterceptRequest2) GetSession() *SessionInfo

func (*RemoveInterceptRequest2) ProtoMessage 

func (*RemoveInterceptRequest2) ProtoMessage()

func (*RemoveInterceptRequest2) ProtoReflect 

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

func (*RemoveInterceptRequest2) Reset 

func (x *RemoveInterceptRequest2) Reset()

func (*RemoveInterceptRequest2) String 

func (x *RemoveInterceptRequest2) String() string

type ReviewInterceptRequest 

type ReviewInterceptRequest struct {
	Session     *SessionInfo             `protobuf:"bytes,1,opt,name=session,proto3" json:"session,omitempty"`
	Id          string                   `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	Disposition InterceptDispositionType `` /* 127-byte string literal not displayed */
	Message     string                   `protobuf:"bytes,4,opt,name=message,proto3" json:"message,omitempty"`
	// pod IP and sftp port to use when doing sshfs mounts
	PodIp    string `protobuf:"bytes,5,opt,name=pod_ip,json=podIp,proto3" json:"pod_ip,omitempty"`
	SftpPort int32  `protobuf:"varint,6,opt,name=sftp_port,json=sftpPort,proto3" json:"sftp_port,omitempty"`
	FtpPort  int32  `protobuf:"varint,12,opt,name=ftp_port,json=ftpPort,proto3" json:"ftp_port,omitempty"`
	// The directory where the intercept mounts can be found in the agent
	MountPoint string `protobuf:"bytes,10,opt,name=mount_point,json=mountPoint,proto3" json:"mount_point,omitempty"`
	// A human-friendly description of what the
	// InterceptSpec.mechanism_args say.
	MechanismArgsDesc string `protobuf:"bytes,7,opt,name=mechanism_args_desc,json=mechanismArgsDesc,proto3" json:"mechanism_args_desc,omitempty"`
	// Headers used by the workstation API-server
	Headers map[string]string `` /* 155-byte string literal not displayed */
	// Metadata used by the workstation API-server
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// The environment of the intercepted app
	Environment map[string]string `` /* 164-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ReviewInterceptRequest) Descriptor deprecated 

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

Deprecated: Use ReviewInterceptRequest.ProtoReflect.Descriptor instead.

func (*ReviewInterceptRequest) GetDisposition 

func (x *ReviewInterceptRequest) GetDisposition() InterceptDispositionType

func (*ReviewInterceptRequest) GetEnvironment added in v2.6.0 

func (x *ReviewInterceptRequest) GetEnvironment() map[string]string

func (*ReviewInterceptRequest) GetFtpPort added in v2.7.4 

func (x *ReviewInterceptRequest) GetFtpPort() int32

func (*ReviewInterceptRequest) GetHeaders added in v2.4.8 

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

func (*ReviewInterceptRequest) GetId 

func (x *ReviewInterceptRequest) GetId() string

func (*ReviewInterceptRequest) GetMechanismArgsDesc 

func (x *ReviewInterceptRequest) GetMechanismArgsDesc() string

func (*ReviewInterceptRequest) GetMessage 

func (x *ReviewInterceptRequest) GetMessage() string

func (*ReviewInterceptRequest) GetMetadata added in v2.5.0 

func (x *ReviewInterceptRequest) GetMetadata() map[string]string

func (*ReviewInterceptRequest) GetMountPoint added in v2.6.0 

func (x *ReviewInterceptRequest) GetMountPoint() string

func (*ReviewInterceptRequest) GetPodIp added in v2.3.0 

func (x *ReviewInterceptRequest) GetPodIp() string

func (*ReviewInterceptRequest) GetSession 

func (x *ReviewInterceptRequest) GetSession() *SessionInfo

func (*ReviewInterceptRequest) GetSftpPort added in v2.3.0 

func (x *ReviewInterceptRequest) GetSftpPort() int32

func (*ReviewInterceptRequest) ProtoMessage 

func (*ReviewInterceptRequest) ProtoMessage()

func (*ReviewInterceptRequest) ProtoReflect 

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

func (*ReviewInterceptRequest) Reset 

func (x *ReviewInterceptRequest) Reset()

func (*ReviewInterceptRequest) String 

func (x *ReviewInterceptRequest) String() string

type Routing added in v2.8.0 

type Routing struct {
	AlsoProxySubnets        []*IPNet `protobuf:"bytes,1,rep,name=also_proxy_subnets,json=alsoProxySubnets,proto3" json:"also_proxy_subnets,omitempty"`
	NeverProxySubnets       []*IPNet `protobuf:"bytes,2,rep,name=never_proxy_subnets,json=neverProxySubnets,proto3" json:"never_proxy_subnets,omitempty"`
	AllowConflictingSubnets []*IPNet `` /* 132-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Routing) Descriptor deprecated added in v2.8.0 

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

Deprecated: Use Routing.ProtoReflect.Descriptor instead.

func (*Routing) GetAllowConflictingSubnets added in v2.14.0 

func (x *Routing) GetAllowConflictingSubnets() []*IPNet

func (*Routing) GetAlsoProxySubnets added in v2.8.0 

func (x *Routing) GetAlsoProxySubnets() []*IPNet

func (*Routing) GetNeverProxySubnets added in v2.8.0 

func (x *Routing) GetNeverProxySubnets() []*IPNet

func (*Routing) ProtoMessage added in v2.8.0 

func (*Routing) ProtoMessage()

func (*Routing) ProtoReflect added in v2.8.0 

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

func (*Routing) Reset added in v2.8.0 

func (x *Routing) Reset()

func (*Routing) String added in v2.8.0 

func (x *Routing) String() string

type SessionInfo 

type SessionInfo struct {
	SessionId string  `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	ClusterId string  `protobuf:"bytes,2,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	InstallId *string `protobuf:"bytes,3,opt,name=install_id,json=installId,proto3,oneof" json:"install_id,omitempty"`
	// contains filtered or unexported fields
}

func (*SessionInfo) Descriptor deprecated 

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

Deprecated: Use SessionInfo.ProtoReflect.Descriptor instead.

func (*SessionInfo) GetClusterId added in v2.6.3 

func (x *SessionInfo) GetClusterId() string

func (*SessionInfo) GetInstallId added in v2.6.3 

func (x *SessionInfo) GetInstallId() string

func (*SessionInfo) GetSessionId 

func (x *SessionInfo) GetSessionId() string

func (*SessionInfo) ProtoMessage 

func (*SessionInfo) ProtoMessage()

func (*SessionInfo) ProtoReflect 

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

func (*SessionInfo) Reset 

func (x *SessionInfo) Reset()

func (*SessionInfo) String 

func (x *SessionInfo) String() string

type TelepresenceAPIInfo added in v2.4.8 

type TelepresenceAPIInfo struct {

	// The port that the TelepresenceAPI is using, or 0 if it's not enabled
	Port int32 `protobuf:"varint,1,opt,name=port,proto3" json:"port,omitempty"`
	// contains filtered or unexported fields
}

func (*TelepresenceAPIInfo) Descriptor deprecated added in v2.4.8 

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

Deprecated: Use TelepresenceAPIInfo.ProtoReflect.Descriptor instead.

func (*TelepresenceAPIInfo) GetPort added in v2.4.8 

func (x *TelepresenceAPIInfo) GetPort() int32

func (*TelepresenceAPIInfo) ProtoMessage added in v2.4.8 

func (*TelepresenceAPIInfo) ProtoMessage()

func (*TelepresenceAPIInfo) ProtoReflect added in v2.4.8 

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

func (*TelepresenceAPIInfo) Reset added in v2.4.8 

func (x *TelepresenceAPIInfo) Reset()

func (*TelepresenceAPIInfo) String added in v2.4.8 

func (x *TelepresenceAPIInfo) String() string

type TunnelMessage added in v2.4.5 

type TunnelMessage struct {
	Payload []byte `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

TunnelMessage is a message sent over a Tunnel. First byte indicates type of message

func (*TunnelMessage) Descriptor deprecated added in v2.4.5 

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

Deprecated: Use TunnelMessage.ProtoReflect.Descriptor instead.

func (*TunnelMessage) GetPayload added in v2.4.5 

func (x *TunnelMessage) GetPayload() []byte

func (*TunnelMessage) ProtoMessage added in v2.4.5 

func (*TunnelMessage) ProtoMessage()

func (*TunnelMessage) ProtoReflect added in v2.4.5 

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

func (*TunnelMessage) Reset added in v2.4.5 

func (x *TunnelMessage) Reset()

func (*TunnelMessage) String added in v2.4.5 

func (x *TunnelMessage) String() string

type TunnelMetrics added in v2.17.0 

type TunnelMetrics struct {
	ClientSessionId string `protobuf:"bytes,1,opt,name=client_session_id,json=clientSessionId,proto3" json:"client_session_id,omitempty"`
	// Number of bytes sent from the client to the traffic-agent.
	IngressBytes uint64 `protobuf:"varint,2,opt,name=ingress_bytes,json=ingressBytes,proto3" json:"ingress_bytes,omitempty"`
	// Number of bytes sent from traffic-agent to the client.
	EgressBytes uint64 `protobuf:"varint,3,opt,name=egress_bytes,json=egressBytes,proto3" json:"egress_bytes,omitempty"`
	// contains filtered or unexported fields
}

func (*TunnelMetrics) Descriptor deprecated added in v2.17.0 

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

Deprecated: Use TunnelMetrics.ProtoReflect.Descriptor instead.

func (*TunnelMetrics) GetClientSessionId added in v2.17.0 

func (x *TunnelMetrics) GetClientSessionId() string

func (*TunnelMetrics) GetEgressBytes added in v2.17.0 

func (x *TunnelMetrics) GetEgressBytes() uint64

func (*TunnelMetrics) GetIngressBytes added in v2.17.0 

func (x *TunnelMetrics) GetIngressBytes() uint64

func (*TunnelMetrics) ProtoMessage added in v2.17.0 

func (*TunnelMetrics) ProtoMessage()

func (*TunnelMetrics) ProtoReflect added in v2.17.0 

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

func (*TunnelMetrics) Reset added in v2.17.0 

func (x *TunnelMetrics) Reset()

func (*TunnelMetrics) String added in v2.17.0 

func (x *TunnelMetrics) String() string

type UnimplementedManagerServer 

type UnimplementedManagerServer struct{}

UnimplementedManagerServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedManagerServer) AgentLookupDNSResponse added in v2.8.0 

func (UnimplementedManagerServer) AgentLookupDNSResponse(context.Context, *DNSAgentResponse) (*emptypb.Empty, error)

func (UnimplementedManagerServer) ArriveAsAgent 

func (UnimplementedManagerServer) ArriveAsAgent(context.Context, *AgentInfo) (*SessionInfo, error)

func (UnimplementedManagerServer) ArriveAsClient 

func (UnimplementedManagerServer) ArriveAsClient(context.Context, *ClientInfo) (*SessionInfo, error)

func (UnimplementedManagerServer) CanConnectAmbassadorCloud added in v2.2.0 

func (UnimplementedManagerServer) CanConnectAmbassadorCloud(context.Context, *emptypb.Empty) (*AmbassadorCloudConnection, error)

func (UnimplementedManagerServer) CreateIntercept 

func (UnimplementedManagerServer) CreateIntercept(context.Context, *CreateInterceptRequest) (*InterceptInfo, error)

func (UnimplementedManagerServer) Depart 

func (UnimplementedManagerServer) Depart(context.Context, *SessionInfo) (*emptypb.Empty, error)

func (UnimplementedManagerServer) EnsureAgent added in v2.18.0 

func (UnimplementedManagerServer) EnsureAgent(context.Context, *EnsureAgentRequest) (*AgentInfoSnapshot, error)

func (UnimplementedManagerServer) GetAgentConfig added in v2.21.0 

func (UnimplementedManagerServer) GetAgentConfig(context.Context, *AgentConfigRequest) (*AgentConfigResponse, error)

func (UnimplementedManagerServer) GetAgentImageFQN added in v2.18.0 

func (UnimplementedManagerServer) GetAgentImageFQN(context.Context, *emptypb.Empty) (*AgentImageFQN, error)

func (UnimplementedManagerServer) GetClientConfig added in v2.9.0 

func (UnimplementedManagerServer) GetClientConfig(context.Context, *emptypb.Empty) (*CLIConfig, error)

func (UnimplementedManagerServer) GetCloudConfig added in v2.2.2 

func (UnimplementedManagerServer) GetCloudConfig(context.Context, *emptypb.Empty) (*AmbassadorCloudConfig, error)

func (UnimplementedManagerServer) GetIntercept added in v2.4.5 

func (UnimplementedManagerServer) GetIntercept(context.Context, *GetInterceptRequest) (*InterceptInfo, error)

func (UnimplementedManagerServer) GetKnownWorkloadKinds added in v2.20.0 

func (UnimplementedManagerServer) GetKnownWorkloadKinds(context.Context, *SessionInfo) (*KnownWorkloadKinds, error)

func (UnimplementedManagerServer) GetLicense added in v2.2.0 

func (UnimplementedManagerServer) GetLicense(context.Context, *emptypb.Empty) (*License, error)

func (UnimplementedManagerServer) GetLogs added in v2.4.4 

func (UnimplementedManagerServer) GetLogs(context.Context, *GetLogsRequest) (*LogsResponse, error)

func (UnimplementedManagerServer) GetTelepresenceAPI added in v2.4.8 

func (UnimplementedManagerServer) GetTelepresenceAPI(context.Context, *emptypb.Empty) (*TelepresenceAPIInfo, error)

func (UnimplementedManagerServer) LookupDNS added in v2.8.0 

func (UnimplementedManagerServer) LookupDNS(context.Context, *DNSRequest) (*DNSResponse, error)

func (UnimplementedManagerServer) PrepareIntercept added in v2.6.0 

func (UnimplementedManagerServer) PrepareIntercept(context.Context, *CreateInterceptRequest) (*PreparedIntercept, error)

func (UnimplementedManagerServer) Remain 

func (UnimplementedManagerServer) Remain(context.Context, *RemainRequest) (*emptypb.Empty, error)

func (UnimplementedManagerServer) RemoveIntercept 

func (UnimplementedManagerServer) RemoveIntercept(context.Context, *RemoveInterceptRequest2) (*emptypb.Empty, error)

func (UnimplementedManagerServer) ReportMetrics added in v2.17.0 

func (UnimplementedManagerServer) ReportMetrics(context.Context, *TunnelMetrics) (*emptypb.Empty, error)

func (UnimplementedManagerServer) ReviewIntercept 

func (UnimplementedManagerServer) ReviewIntercept(context.Context, *ReviewInterceptRequest) (*emptypb.Empty, error)

func (UnimplementedManagerServer) SetLogLevel added in v2.4.2 

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

func (UnimplementedManagerServer) Tunnel added in v2.4.5 

func (UnimplementedManagerServer) Tunnel(grpc.BidiStreamingServer[TunnelMessage, TunnelMessage]) error

func (UnimplementedManagerServer) UpdateIntercept 

func (UnimplementedManagerServer) UpdateIntercept(context.Context, *UpdateInterceptRequest) (*InterceptInfo, error)

func (UnimplementedManagerServer) Version 

func (UnimplementedManagerServer) Version(context.Context, *emptypb.Empty) (*VersionInfo2, error)

func (UnimplementedManagerServer) WatchAgentPods added in v2.17.0 

func (UnimplementedManagerServer) WatchAgentPods(*SessionInfo, grpc.ServerStreamingServer[AgentPodInfoSnapshot]) error

func (UnimplementedManagerServer) WatchAgents 

func (UnimplementedManagerServer) WatchAgents(*SessionInfo, grpc.ServerStreamingServer[AgentInfoSnapshot]) error

func (UnimplementedManagerServer) WatchAgentsNS added in v2.5.5 

func (UnimplementedManagerServer) WatchAgentsNS(*AgentsRequest, grpc.ServerStreamingServer[AgentInfoSnapshot]) error

func (UnimplementedManagerServer) WatchClusterInfo added in v2.3.2 

func (UnimplementedManagerServer) WatchClusterInfo(*SessionInfo, grpc.ServerStreamingServer[ClusterInfo]) error

func (UnimplementedManagerServer) WatchDial added in v2.4.5 

func (UnimplementedManagerServer) WatchDial(*SessionInfo, grpc.ServerStreamingServer[DialRequest]) error

func (UnimplementedManagerServer) WatchIntercepts 

func (UnimplementedManagerServer) WatchIntercepts(*SessionInfo, grpc.ServerStreamingServer[InterceptInfoSnapshot]) error

func (UnimplementedManagerServer) WatchLogLevel added in v2.4.2 

func (UnimplementedManagerServer) WatchLogLevel(*emptypb.Empty, grpc.ServerStreamingServer[LogLevelRequest]) error

func (UnimplementedManagerServer) WatchLookupDNS added in v2.8.0 

func (UnimplementedManagerServer) WatchLookupDNS(*SessionInfo, grpc.ServerStreamingServer[DNSRequest]) error

func (UnimplementedManagerServer) WatchWorkloads added in v2.19.0 

func (UnimplementedManagerServer) WatchWorkloads(*WorkloadEventsRequest, grpc.ServerStreamingServer[WorkloadEventsDelta]) error

type UnsafeManagerServer 

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

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

type UpdateInterceptRequest 

type UpdateInterceptRequest struct {
	Session *SessionInfo `protobuf:"bytes,1,opt,name=session,proto3" json:"session,omitempty"`
	Name    string       `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// Types that are assignable to PreviewDomainAction:
	//
	//	*UpdateInterceptRequest_AddPreviewDomain
	//	*UpdateInterceptRequest_RemovePreviewDomain
	PreviewDomainAction isUpdateInterceptRequest_PreviewDomainAction `protobuf_oneof:"preview_domain_action"`
	// contains filtered or unexported fields
}

func (*UpdateInterceptRequest) Descriptor deprecated 

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

Deprecated: Use UpdateInterceptRequest.ProtoReflect.Descriptor instead.

func (*UpdateInterceptRequest) GetAddPreviewDomain 

func (x *UpdateInterceptRequest) GetAddPreviewDomain() *PreviewSpec

func (*UpdateInterceptRequest) GetName 

func (x *UpdateInterceptRequest) GetName() string

func (*UpdateInterceptRequest) GetPreviewDomainAction 

func (m *UpdateInterceptRequest) GetPreviewDomainAction() isUpdateInterceptRequest_PreviewDomainAction

func (*UpdateInterceptRequest) GetRemovePreviewDomain 

func (x *UpdateInterceptRequest) GetRemovePreviewDomain() bool

func (*UpdateInterceptRequest) GetSession 

func (x *UpdateInterceptRequest) GetSession() *SessionInfo

func (*UpdateInterceptRequest) ProtoMessage 

func (*UpdateInterceptRequest) ProtoMessage()

func (*UpdateInterceptRequest) ProtoReflect 

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

func (*UpdateInterceptRequest) Reset 

func (x *UpdateInterceptRequest) Reset()

func (*UpdateInterceptRequest) String 

func (x *UpdateInterceptRequest) String() string

type UpdateInterceptRequest_AddPreviewDomain 

type UpdateInterceptRequest_AddPreviewDomain struct {
	AddPreviewDomain *PreviewSpec `protobuf:"bytes,5,opt,name=add_preview_domain,json=addPreviewDomain,proto3,oneof"`
}

type UpdateInterceptRequest_RemovePreviewDomain 

type UpdateInterceptRequest_RemovePreviewDomain struct {
	RemovePreviewDomain bool `protobuf:"varint,4,opt,name=remove_preview_domain,json=removePreviewDomain,proto3,oneof"`
}

type VersionInfo2 

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

VersionInfo2 is different than telepresence.common.VersionInfo in that it is limited to just name and version.

func (*VersionInfo2) Descriptor deprecated 

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

Deprecated: Use VersionInfo2.ProtoReflect.Descriptor instead.

func (*VersionInfo2) GetName added in v2.10.0 

func (x *VersionInfo2) GetName() string

func (*VersionInfo2) GetVersion 

func (x *VersionInfo2) GetVersion() string

func (*VersionInfo2) ProtoMessage 

func (*VersionInfo2) ProtoMessage()

func (*VersionInfo2) ProtoReflect 

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

func (*VersionInfo2) Reset 

func (x *VersionInfo2) Reset()

func (*VersionInfo2) String 

func (x *VersionInfo2) String() string

type WorkloadEvent added in v2.19.0 

type WorkloadEvent struct {
	Type     WorkloadEvent_Type `protobuf:"varint,1,opt,name=type,proto3,enum=telepresence.manager.WorkloadEvent_Type" json:"type,omitempty"`
	Workload *WorkloadInfo      `protobuf:"bytes,2,opt,name=workload,proto3" json:"workload,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkloadEvent) Descriptor deprecated added in v2.19.0 

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

Deprecated: Use WorkloadEvent.ProtoReflect.Descriptor instead.

func (*WorkloadEvent) GetType added in v2.19.0 

func (x *WorkloadEvent) GetType() WorkloadEvent_Type

func (*WorkloadEvent) GetWorkload added in v2.19.0 

func (x *WorkloadEvent) GetWorkload() *WorkloadInfo

func (*WorkloadEvent) ProtoMessage added in v2.19.0 

func (*WorkloadEvent) ProtoMessage()

func (*WorkloadEvent) ProtoReflect added in v2.19.0 

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

func (*WorkloadEvent) Reset added in v2.19.0 

func (x *WorkloadEvent) Reset()

func (*WorkloadEvent) String added in v2.19.0 

func (x *WorkloadEvent) String() string

type WorkloadEvent_Type added in v2.19.0 

type WorkloadEvent_Type int32
const (
	WorkloadEvent_ADDED_UNSPECIFIED WorkloadEvent_Type = 0
	WorkloadEvent_MODIFIED          WorkloadEvent_Type = 1
	WorkloadEvent_DELETED           WorkloadEvent_Type = 2
)

func (WorkloadEvent_Type) Descriptor added in v2.19.0 

func (WorkloadEvent_Type) Descriptor() protoreflect.EnumDescriptor

func (WorkloadEvent_Type) Enum added in v2.19.0 

func (x WorkloadEvent_Type) Enum() *WorkloadEvent_Type

func (WorkloadEvent_Type) EnumDescriptor deprecated added in v2.19.0 

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

Deprecated: Use WorkloadEvent_Type.Descriptor instead.

func (WorkloadEvent_Type) Number added in v2.19.0 

func (x WorkloadEvent_Type) Number() protoreflect.EnumNumber

func (WorkloadEvent_Type) String added in v2.19.0 

func (x WorkloadEvent_Type) String() string

func (WorkloadEvent_Type) Type added in v2.19.0 

func (WorkloadEvent_Type) Type() protoreflect.EnumType

type WorkloadEventsDelta added in v2.19.0 

type WorkloadEventsDelta struct {

	// The timestamp from which this delta is computed. Typically
	// equal to the time when the previous delta was sent.
	Since  *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=since,proto3" json:"since,omitempty"`
	Events []*WorkloadEvent       `protobuf:"bytes,2,rep,name=events,proto3" json:"events,omitempty"`
	// contains filtered or unexported fields
}

WorkloadEventDelta contains the changes made to the subscribed namespace since the time given in the timestamp. A watcher can rely on that received deltas are consecutive.

func (*WorkloadEventsDelta) Descriptor deprecated added in v2.19.0 

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

Deprecated: Use WorkloadEventsDelta.ProtoReflect.Descriptor instead.

func (*WorkloadEventsDelta) GetEvents added in v2.19.0 

func (x *WorkloadEventsDelta) GetEvents() []*WorkloadEvent

func (*WorkloadEventsDelta) GetSince added in v2.19.0 

func (x *WorkloadEventsDelta) GetSince() *timestamppb.Timestamp

func (*WorkloadEventsDelta) ProtoMessage added in v2.19.0 

func (*WorkloadEventsDelta) ProtoMessage()

func (*WorkloadEventsDelta) ProtoReflect added in v2.19.0 

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

func (*WorkloadEventsDelta) Reset added in v2.19.0 

func (x *WorkloadEventsDelta) Reset()

func (*WorkloadEventsDelta) String added in v2.19.0 

func (x *WorkloadEventsDelta) String() string

type WorkloadEventsRequest added in v2.19.0 

type WorkloadEventsRequest struct {

	// The session_info identifies the client connection, and hence the
	// namespace for the resulting watcher.
	SessionInfo *SessionInfo `protobuf:"bytes,1,opt,name=session_info,json=sessionInfo,proto3" json:"session_info,omitempty"`
	// The timestamp from which the first delta should be computed. Set to
	// undefined to get a delta that contains everything.
	Since *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=since,proto3" json:"since,omitempty"`
	// The namespace to watch. Must be one of the namespaces that are
	// managed by the traffic-manager. Defaults to the connected namespace.
	Namespace string `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkloadEventsRequest) Descriptor deprecated added in v2.19.0 

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

Deprecated: Use WorkloadEventsRequest.ProtoReflect.Descriptor instead.

func (*WorkloadEventsRequest) GetNamespace added in v2.21.0 

func (x *WorkloadEventsRequest) GetNamespace() string

func (*WorkloadEventsRequest) GetSessionInfo added in v2.19.0 

func (x *WorkloadEventsRequest) GetSessionInfo() *SessionInfo

func (*WorkloadEventsRequest) GetSince added in v2.19.0 

func (x *WorkloadEventsRequest) GetSince() *timestamppb.Timestamp

func (*WorkloadEventsRequest) ProtoMessage added in v2.19.0 

func (*WorkloadEventsRequest) ProtoMessage()

func (*WorkloadEventsRequest) ProtoReflect added in v2.19.0 

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

func (*WorkloadEventsRequest) Reset added in v2.19.0 

func (x *WorkloadEventsRequest) Reset()

func (*WorkloadEventsRequest) String added in v2.19.0 

func (x *WorkloadEventsRequest) String() string

type WorkloadInfo added in v2.19.0 

type WorkloadInfo struct {
	Kind             WorkloadInfo_Kind         `protobuf:"varint,1,opt,name=kind,proto3,enum=telepresence.manager.WorkloadInfo_Kind" json:"kind,omitempty"`
	Name             string                    `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Namespace        string                    `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Uid              string                    `protobuf:"bytes,7,opt,name=uid,proto3" json:"uid,omitempty"`
	AgentState       WorkloadInfo_AgentState   `` /* 142-byte string literal not displayed */
	InterceptClients []*WorkloadInfo_Intercept `protobuf:"bytes,5,rep,name=intercept_clients,json=interceptClients,proto3" json:"intercept_clients,omitempty"`
	State            WorkloadInfo_State        `protobuf:"varint,6,opt,name=state,proto3,enum=telepresence.manager.WorkloadInfo_State" json:"state,omitempty"`
	// contains filtered or unexported fields
}

WorkloadInfo contains information about a workload (typically a Deployment).

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

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

Deprecated: Use WorkloadInfo.ProtoReflect.Descriptor instead.

func (*WorkloadInfo) GetAgentState added in v2.19.0 

func (x *WorkloadInfo) GetAgentState() WorkloadInfo_AgentState

func (*WorkloadInfo) GetInterceptClients added in v2.19.1 

func (x *WorkloadInfo) GetInterceptClients() []*WorkloadInfo_Intercept

func (*WorkloadInfo) GetKind added in v2.19.0 

func (x *WorkloadInfo) GetKind() WorkloadInfo_Kind

func (*WorkloadInfo) GetName added in v2.19.0 

func (x *WorkloadInfo) GetName() string

func (*WorkloadInfo) GetNamespace added in v2.19.0 

func (x *WorkloadInfo) GetNamespace() string

func (*WorkloadInfo) GetState added in v2.19.1 

func (x *WorkloadInfo) GetState() WorkloadInfo_State

func (*WorkloadInfo) GetUid added in v2.21.0 

func (x *WorkloadInfo) GetUid() string

func (*WorkloadInfo) ProtoMessage added in v2.19.0 

func (*WorkloadInfo) ProtoMessage()

func (*WorkloadInfo) ProtoReflect added in v2.19.0 

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

func (*WorkloadInfo) Reset added in v2.19.0 

func (x *WorkloadInfo) Reset()

func (*WorkloadInfo) String added in v2.19.0 

func (x *WorkloadInfo) String() string

type WorkloadInfo_AgentState added in v2.19.0 

type WorkloadInfo_AgentState int32
const (
	// Workload has never been intercepted, so no agent has been installed.
	WorkloadInfo_NO_AGENT_UNSPECIFIED WorkloadInfo_AgentState = 0
	// An agent has been installed into workload's pods, but it is not currently intercepted.
	WorkloadInfo_INSTALLED WorkloadInfo_AgentState = 1
	// The workload (or rather its pods) is currently intercepted.
	WorkloadInfo_INTERCEPTED WorkloadInfo_AgentState = 2
)

func (WorkloadInfo_AgentState) Descriptor added in v2.19.0 

func (WorkloadInfo_AgentState) Descriptor() protoreflect.EnumDescriptor

func (WorkloadInfo_AgentState) Enum added in v2.19.0 

func (x WorkloadInfo_AgentState) Enum() *WorkloadInfo_AgentState

func (WorkloadInfo_AgentState) EnumDescriptor deprecated added in v2.19.0 

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

Deprecated: Use WorkloadInfo_AgentState.Descriptor instead.

func (WorkloadInfo_AgentState) Number added in v2.19.0 

func (x WorkloadInfo_AgentState) Number() protoreflect.EnumNumber

func (WorkloadInfo_AgentState) String added in v2.19.0 

func (x WorkloadInfo_AgentState) String() string

func (WorkloadInfo_AgentState) Type added in v2.19.0 

func (WorkloadInfo_AgentState) Type() protoreflect.EnumType

type WorkloadInfo_Intercept added in v2.19.1 

type WorkloadInfo_Intercept struct {

	// name of intercepting client
	Client string `protobuf:"bytes,1,opt,name=client,proto3" json:"client,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkloadInfo_Intercept) Descriptor deprecated added in v2.19.1 

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

Deprecated: Use WorkloadInfo_Intercept.ProtoReflect.Descriptor instead.

func (*WorkloadInfo_Intercept) GetClient added in v2.19.1 

func (x *WorkloadInfo_Intercept) GetClient() string

func (*WorkloadInfo_Intercept) ProtoMessage added in v2.19.1 

func (*WorkloadInfo_Intercept) ProtoMessage()

func (*WorkloadInfo_Intercept) ProtoReflect added in v2.19.1 

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

func (*WorkloadInfo_Intercept) Reset added in v2.19.1 

func (x *WorkloadInfo_Intercept) Reset()

func (*WorkloadInfo_Intercept) String added in v2.19.1 

func (x *WorkloadInfo_Intercept) String() string

type WorkloadInfo_Kind added in v2.19.0 

type WorkloadInfo_Kind int32
const (
	WorkloadInfo_UNSPECIFIED WorkloadInfo_Kind = 0
	WorkloadInfo_DEPLOYMENT  WorkloadInfo_Kind = 1
	WorkloadInfo_REPLICASET  WorkloadInfo_Kind = 2
	WorkloadInfo_STATEFULSET WorkloadInfo_Kind = 3
	WorkloadInfo_ROLLOUT     WorkloadInfo_Kind = 4
)

func (WorkloadInfo_Kind) Descriptor added in v2.19.0 

func (WorkloadInfo_Kind) Descriptor() protoreflect.EnumDescriptor

func (WorkloadInfo_Kind) Enum added in v2.19.0 

func (x WorkloadInfo_Kind) Enum() *WorkloadInfo_Kind

func (WorkloadInfo_Kind) EnumDescriptor deprecated added in v2.19.0 

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

Deprecated: Use WorkloadInfo_Kind.Descriptor instead.

func (WorkloadInfo_Kind) Number added in v2.19.0 

func (x WorkloadInfo_Kind) Number() protoreflect.EnumNumber

func (WorkloadInfo_Kind) String added in v2.19.0 

func (x WorkloadInfo_Kind) String() string

func (WorkloadInfo_Kind) Type added in v2.19.0 

func (WorkloadInfo_Kind) Type() protoreflect.EnumType

type WorkloadInfo_State added in v2.19.1 

type WorkloadInfo_State int32
const (
	// The state of this workload is not known.
	WorkloadInfo_UNKNOWN_UNSPECIFIED WorkloadInfo_State = 0
	// Available means the deployment is available, ie. at least the minimum available
	// replicas required are up and running for at least minReadySeconds.
	WorkloadInfo_AVAILABLE WorkloadInfo_State = 1
	// Progressing means the workload is progressing. Progress for a workload is
	// considered when a new replica set is created or adopted, and when new pods scale
	// up or old pods scale down. Progress is not estimated for paused workloads or
	// when progressDeadlineSeconds is not specified.
	WorkloadInfo_PROGRESSING WorkloadInfo_State = 2
	// FAILURE means that one of its pods fails to be created or deleted.
	WorkloadInfo_FAILURE WorkloadInfo_State = 3
)

func (WorkloadInfo_State) Descriptor added in v2.19.1 

func (WorkloadInfo_State) Descriptor() protoreflect.EnumDescriptor

func (WorkloadInfo_State) Enum added in v2.19.1 

func (x WorkloadInfo_State) Enum() *WorkloadInfo_State

func (WorkloadInfo_State) EnumDescriptor deprecated added in v2.19.1 

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

Deprecated: Use WorkloadInfo_State.Descriptor instead.

func (WorkloadInfo_State) Number added in v2.19.1 

func (x WorkloadInfo_State) Number() protoreflect.EnumNumber

func (WorkloadInfo_State) String added in v2.19.1 

func (x WorkloadInfo_State) String() string

func (WorkloadInfo_State) Type added in v2.19.1 

func (WorkloadInfo_State) Type() protoreflect.EnumType

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.