manager

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
}

type AgentInfo struct {
	Name      string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`                       // name of the Workload
	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
	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"`
	// The environment of the app
	// Deprecated: Only older agents will set this. Newer ones will instead
	// use the InterceptInfo.environment because the environment differs depending
	// on what container it is that gets intercepted
	Environment map[string]string `` /* 163-byte string literal not displayed */
	// contains filtered or unexported fields
}

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

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
}

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
}

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

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
}

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
}

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

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
}

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
}

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
}

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
}

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
}

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
}

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
}

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
}

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"`
	TraceContext     map[string]string `` /* 185-byte string literal not displayed */
	// contains filtered or unexported fields
}

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
}

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
}

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
}

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
}

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
}

type InterceptDispositionType int32

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
}

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

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 port: either the name or port number
	// optionally followed by a "/TCP" or "/UDP"
	ServicePortIdentifier string `` /* 127-byte string literal not displayed */
	// 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"`
	// The resolved protocol used by the service port
	Protocol string `protobuf:"bytes,21,opt,name=protocol,proto3" json:"protocol,omitempty"` // TCP or UDP
	// .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"`
	// 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"`
	// Used to be mount_point and only utilized when passing the spec between
	// the user daemon and the CLI. It's now moved to InterceptInfo
	Reserved string `protobuf:"bytes,11,opt,name=reserved,proto3" json:"reserved,omitempty"`
	// Whether to replace the running container.
	Replace bool `protobuf:"varint,22,opt,name=replace,proto3" json:"replace,omitempty"`
	// contains filtered or unexported fields
}

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"`
	// contains filtered or unexported fields
}

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
}

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
}

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)
	// 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) (Manager_WatchAgentPodsClient, 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) (Manager_WatchAgentsClient, error)
	// WatchAgentsNS is like WatchAgents but limited to a set of namespaces
	WatchAgentsNS(ctx context.Context, in *AgentsRequest, opts ...grpc.CallOption) (Manager_WatchAgentsNSClient, 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) (Manager_WatchInterceptsClient, error)
	// WatchClusterInfo returns information needed when establishing
	// connectivity to the cluster.
	WatchClusterInfo(ctx context.Context, in *SessionInfo, opts ...grpc.CallOption) (Manager_WatchClusterInfoClient, error)
	// EnsureAgent ensures that an agent is injected to the pods of a workload
	EnsureAgent(ctx context.Context, in *EnsureAgentRequest, opts ...grpc.CallOption) (*emptypb.Empty, 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)
	// 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) (Manager_WatchLookupDNSClient, error)
	// WatchLogLevel lets an agent receive log-level updates
	WatchLogLevel(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (Manager_WatchLogLevelClient, 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) (Manager_TunnelClient, 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) (Manager_WatchDialClient, error)
}

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)
	// 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, Manager_WatchAgentPodsServer) 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, Manager_WatchAgentsServer) error
	// WatchAgentsNS is like WatchAgents but limited to a set of namespaces
	WatchAgentsNS(*AgentsRequest, Manager_WatchAgentsNSServer) 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, Manager_WatchInterceptsServer) error
	// WatchClusterInfo returns information needed when establishing
	// connectivity to the cluster.
	WatchClusterInfo(*SessionInfo, Manager_WatchClusterInfoServer) error
	// EnsureAgent ensures that an agent is injected to the pods of a workload
	EnsureAgent(context.Context, *EnsureAgentRequest) (*emptypb.Empty, 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)
	// 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, Manager_WatchLookupDNSServer) error
	// WatchLogLevel lets an agent receive log-level updates
	WatchLogLevel(*emptypb.Empty, Manager_WatchLogLevelServer) 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(Manager_TunnelServer) 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, Manager_WatchDialServer) error
	// contains filtered or unexported methods
}

type Manager_TunnelClient interface {
	Send(*TunnelMessage) error
	Recv() (*TunnelMessage, error)
	grpc.ClientStream
}

type Manager_TunnelServer interface {
	Send(*TunnelMessage) error
	Recv() (*TunnelMessage, error)
	grpc.ServerStream
}

type Manager_WatchAgentPodsClient interface {
	Recv() (*AgentPodInfoSnapshot, error)
	grpc.ClientStream
}

type Manager_WatchAgentPodsServer interface {
	Send(*AgentPodInfoSnapshot) error
	grpc.ServerStream
}

type Manager_WatchAgentsClient interface {
	Recv() (*AgentInfoSnapshot, error)
	grpc.ClientStream
}

type Manager_WatchAgentsNSClient interface {
	Recv() (*AgentInfoSnapshot, error)
	grpc.ClientStream
}

type Manager_WatchAgentsNSServer interface {
	Send(*AgentInfoSnapshot) error
	grpc.ServerStream
}

type Manager_WatchAgentsServer interface {
	Send(*AgentInfoSnapshot) error
	grpc.ServerStream
}

type Manager_WatchClusterInfoClient interface {
	Recv() (*ClusterInfo, error)
	grpc.ClientStream
}

type Manager_WatchClusterInfoServer interface {
	Send(*ClusterInfo) error
	grpc.ServerStream
}

type Manager_WatchDialClient interface {
	Recv() (*DialRequest, error)
	grpc.ClientStream
}

type Manager_WatchDialServer interface {
	Send(*DialRequest) error
	grpc.ServerStream
}

type Manager_WatchInterceptsClient interface {
	Recv() (*InterceptInfoSnapshot, error)
	grpc.ClientStream
}

type Manager_WatchInterceptsServer interface {
	Send(*InterceptInfoSnapshot) error
	grpc.ServerStream
}

type Manager_WatchLogLevelClient interface {
	Recv() (*LogLevelRequest, error)
	grpc.ClientStream
}

type Manager_WatchLogLevelServer interface {
	Send(*LogLevelRequest) error
	grpc.ServerStream
}

type Manager_WatchLookupDNSClient interface {
	Recv() (*DNSRequest, error)
	grpc.ClientStream
}

type Manager_WatchLookupDNSServer interface {
	Send(*DNSRequest) error
	grpc.ServerStream
}

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"`
	Protocol        string `protobuf:"bytes,10,opt,name=protocol,proto3" json:"protocol,omitempty"` // TCP or UDP
	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"`
	// contains filtered or unexported fields
}

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
}

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
}

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
}

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
}

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
}

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
}

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
}

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

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
}

type UnimplementedManagerServer struct {
}