manager

package
v2.4.4-rc.1 Latest Latest
Warning

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

 Go to latest Published: Sep 27, 2021 License: Apache-2.0 Imports: 10 Imported by: 25

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	InterceptDispositionType_name = map[int32]string{
		0: "UNSPECIFIED",
		1: "ACTIVE",
		2: "WAITING",
		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,
		"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 File_rpc_manager_manager_proto protoreflect.FileDescriptor
View Source 
var File_rpc_manager_systema_proto protoreflect.FileDescriptor
View Source 
var ManagerProxy_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "telepresence.manager.ManagerProxy",
	HandlerType: (*ManagerProxyServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "HandleConnection",
			Handler:       _ManagerProxy_HandleConnection_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "rpc/manager/systema.proto",
}

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

View Source 
var Manager_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "telepresence.manager.Manager",
	HandlerType: (*ManagerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Version",
			Handler:    _Manager_Version_Handler,
		},
		{
			MethodName: "GetLicense",
			Handler:    _Manager_GetLicense_Handler,
		},
		{
			MethodName: "CanConnectAmbassadorCloud",
			Handler:    _Manager_CanConnectAmbassadorCloud_Handler,
		},
		{
			MethodName: "GetCloudConfig",
			Handler:    _Manager_GetCloudConfig_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: "CreateIntercept",
			Handler:    _Manager_CreateIntercept_Handler,
		},
		{
			MethodName: "RemoveIntercept",
			Handler:    _Manager_RemoveIntercept_Handler,
		},
		{
			MethodName: "UpdateIntercept",
			Handler:    _Manager_UpdateIntercept_Handler,
		},
		{
			MethodName: "ReviewIntercept",
			Handler:    _Manager_ReviewIntercept_Handler,
		},
		{
			MethodName: "LookupHost",
			Handler:    _Manager_LookupHost_Handler,
		},
		{
			MethodName: "AgentLookupHostResponse",
			Handler:    _Manager_AgentLookupHostResponse_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "WatchAgents",
			Handler:       _Manager_WatchAgents_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "WatchIntercepts",
			Handler:       _Manager_WatchIntercepts_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "WatchClusterInfo",
			Handler:       _Manager_WatchClusterInfo_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "ClientTunnel",
			Handler:       _Manager_ClientTunnel_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
		{
			StreamName:    "AgentTunnel",
			Handler:       _Manager_AgentTunnel_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
		{
			StreamName:    "WatchLookupHost",
			Handler:       _Manager_WatchLookupHost_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "WatchLogLevel",
			Handler:       _Manager_WatchLogLevel_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "rpc/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 RegisterManagerProxyServer 

func RegisterManagerProxyServer(s grpc.ServiceRegistrar, srv ManagerProxyServer)

func RegisterManagerServer 

func RegisterManagerServer(s grpc.ServiceRegistrar, srv ManagerServer)

Types

type AgentInfo 

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
	PodIp     string `protobuf:"bytes,2,opt,name=pod_ip,json=podIp,proto3" json:"pod_ip,omitempty"` // Pod IP (from status.podIP)
	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
	Environment map[string]string `` /* 163-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) GetEnvironment 

func (x *AgentInfo) GetEnvironment() map[string]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) GetProduct 

func (x *AgentInfo) GetProduct() string

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_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 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"`
	// 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) 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 ClientInfo 

type ClientInfo struct {
	Name      string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // user@hostname
	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) 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 {

	// kube_dns_ip is the IP address of the kube-dns.kube-system service,
	KubeDnsIp []byte `protobuf:"bytes,1,opt,name=kube_dns_ip,json=kubeDnsIp,proto3" json:"kube_dns_ip,omitempty"`
	// 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"`
	// 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
}

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) GetKubeDnsIp added in v2.3.2 

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

func (*ClusterInfo) GetPodSubnets added in v2.3.2 

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

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 ConnMessage added in v2.3.0 

type ConnMessage struct {

	// conn_id is composed of L4 protocol, source IP, source port, destination IP and destination port
	ConnId  []byte `protobuf:"bytes,1,opt,name=conn_id,json=connId,proto3" json:"conn_id,omitempty"`
	Payload []byte `protobuf:"bytes,5,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

ConnMessage is a payload intended for a connection with a given id.

func (*ConnMessage) Descriptor deprecated added in v2.3.0 

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

Deprecated: Use ConnMessage.ProtoReflect.Descriptor instead.

func (*ConnMessage) GetConnId added in v2.3.0 

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

func (*ConnMessage) GetPayload added in v2.3.0 

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

func (*ConnMessage) ProtoMessage added in v2.3.0 

func (*ConnMessage) ProtoMessage()

func (*ConnMessage) ProtoReflect added in v2.3.0 

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

func (*ConnMessage) Reset added in v2.3.0 

func (x *ConnMessage) Reset()

func (*ConnMessage) String added in v2.3.0 

func (x *ConnMessage) String() string

type ConnectionChunk 

type ConnectionChunk struct {

	// Types that are assignable to Value:
	//	*ConnectionChunk_InterceptId
	//	*ConnectionChunk_Data
	//	*ConnectionChunk_Error
	Value isConnectionChunk_Value `protobuf_oneof:"value"`
	// contains filtered or unexported fields
}

func (*ConnectionChunk) Descriptor deprecated 

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

Deprecated: Use ConnectionChunk.ProtoReflect.Descriptor instead.

func (*ConnectionChunk) GetData 

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

func (*ConnectionChunk) GetError 

func (x *ConnectionChunk) GetError() string

func (*ConnectionChunk) GetInterceptId 

func (x *ConnectionChunk) GetInterceptId() string

func (*ConnectionChunk) GetValue 

func (m *ConnectionChunk) GetValue() isConnectionChunk_Value

func (*ConnectionChunk) ProtoMessage 

func (*ConnectionChunk) ProtoMessage()

func (*ConnectionChunk) ProtoReflect 

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

func (*ConnectionChunk) Reset 

func (x *ConnectionChunk) Reset()

func (*ConnectionChunk) String 

func (x *ConnectionChunk) String() string

type ConnectionChunk_Data 

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

type ConnectionChunk_Error 

type ConnectionChunk_Error struct {
	Error string `protobuf:"bytes,3,opt,name=error,proto3,oneof"` // TODO: Probably have a better error type
}

type ConnectionChunk_InterceptId 

type ConnectionChunk_InterceptId struct {
	InterceptId string `protobuf:"bytes,1,opt,name=intercept_id,json=interceptId,proto3,oneof"`
}

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

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) 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
	// 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"`
	// The Pod name and sftp port to use when doing sshfs mounts.  These
	// are set by the agent's call to ReviewIntercept.
	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"`
	// 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"`
	// contains filtered or unexported fields
}

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

func (x *InterceptInfo) GetClientSession() *SessionInfo

func (*InterceptInfo) GetDisposition 

func (x *InterceptInfo) GetDisposition() InterceptDispositionType

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) GetPodIp added in v2.3.0 

func (x *InterceptInfo) GetPodIp() 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 usally 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"`
	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
	ServicePortIdentifier string `` /* 127-byte string literal not displayed */
	// Path to where the intercepted volumes were mounted locally
	MountPoint string `protobuf:"bytes,11,opt,name=mount_point,json=mountPoint,proto3" json:"mount_point,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"`
	// extra ports that will be forwarded to the intercepting client
	ExtraPorts []int32 `protobuf:"varint,15,rep,packed,name=extra_ports,json=extraPorts,proto3" json:"extra_ports,omitempty"`
	// contains filtered or unexported fields
}

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) GetExtraPorts added in v2.3.3 

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

func (*InterceptSpec) GetMechanism 

func (x *InterceptSpec) GetMechanism() string

func (*InterceptSpec) GetMechanismArgs 

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

func (*InterceptSpec) GetMountPoint 

func (x *InterceptSpec) GetMountPoint() string

func (*InterceptSpec) GetName 

func (x *InterceptSpec) GetName() string

func (*InterceptSpec) GetNamespace 

func (x *InterceptSpec) GetNamespace() string

func (*InterceptSpec) GetServiceName added in v2.1.3 

func (x *InterceptSpec) GetServiceName() string

func (*InterceptSpec) GetServicePortIdentifier added in v2.1.5 

func (x *InterceptSpec) GetServicePortIdentifier() 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 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"`
	ClusterId string `protobuf:"bytes,3,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,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) 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) 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"`
	// contains filtered or unexported fields
}

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) 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 LookupHostAgentResponse added in v2.3.0 

type LookupHostAgentResponse struct {

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

func (*LookupHostAgentResponse) Descriptor deprecated added in v2.3.0 

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

Deprecated: Use LookupHostAgentResponse.ProtoReflect.Descriptor instead.

func (*LookupHostAgentResponse) GetRequest added in v2.3.0 

func (x *LookupHostAgentResponse) GetRequest() *LookupHostRequest

func (*LookupHostAgentResponse) GetResponse added in v2.3.0 

func (x *LookupHostAgentResponse) GetResponse() *LookupHostResponse

func (*LookupHostAgentResponse) GetSession added in v2.3.0 

func (x *LookupHostAgentResponse) GetSession() *SessionInfo

func (*LookupHostAgentResponse) ProtoMessage added in v2.3.0 

func (*LookupHostAgentResponse) ProtoMessage()

func (*LookupHostAgentResponse) ProtoReflect added in v2.3.0 

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

func (*LookupHostAgentResponse) Reset added in v2.3.0 

func (x *LookupHostAgentResponse) Reset()

func (*LookupHostAgentResponse) String added in v2.3.0 

func (x *LookupHostAgentResponse) String() string

type LookupHostRequest added in v2.3.0 

type LookupHostRequest struct {

	// Client session
	Session *SessionInfo `protobuf:"bytes,1,opt,name=session,proto3" json:"session,omitempty"`
	Host    string       `protobuf:"bytes,2,opt,name=host,proto3" json:"host,omitempty"`
	// contains filtered or unexported fields
}

LookupHost request sent from a client

func (*LookupHostRequest) Descriptor deprecated added in v2.3.0 

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

Deprecated: Use LookupHostRequest.ProtoReflect.Descriptor instead.

func (*LookupHostRequest) GetHost added in v2.3.0 

func (x *LookupHostRequest) GetHost() string

func (*LookupHostRequest) GetSession added in v2.3.0 

func (x *LookupHostRequest) GetSession() *SessionInfo

func (*LookupHostRequest) ProtoMessage added in v2.3.0 

func (*LookupHostRequest) ProtoMessage()

func (*LookupHostRequest) ProtoReflect added in v2.3.0 

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

func (*LookupHostRequest) Reset added in v2.3.0 

func (x *LookupHostRequest) Reset()

func (*LookupHostRequest) String added in v2.3.0 

func (x *LookupHostRequest) String() string

type LookupHostResponse added in v2.3.0 

type LookupHostResponse struct {
	Ips [][]byte `protobuf:"bytes,1,rep,name=ips,proto3" json:"ips,omitempty"`
	// contains filtered or unexported fields
}

func (*LookupHostResponse) Descriptor deprecated added in v2.3.0 

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

Deprecated: Use LookupHostResponse.ProtoReflect.Descriptor instead.

func (*LookupHostResponse) GetIps added in v2.3.0 

func (x *LookupHostResponse) GetIps() [][]byte

func (*LookupHostResponse) ProtoMessage added in v2.3.0 

func (*LookupHostResponse) ProtoMessage()

func (*LookupHostResponse) ProtoReflect added in v2.3.0 

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

func (*LookupHostResponse) Reset added in v2.3.0 

func (x *LookupHostResponse) Reset()

func (*LookupHostResponse) String added in v2.3.0 

func (x *LookupHostResponse) 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)
	// 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)
	// 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
	GetLogs(ctx context.Context, in *GetLogsRequest, opts ...grpc.CallOption) (*LogsResponse, 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)
	// 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)
	// 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)
	// 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)
	// ClientTunnel receives messages from the client and dispatches them to tracked
	// net.Conn instances in the traffic-manager. Responses from tracked instances
	// are sent back on the returned message stream
	ClientTunnel(ctx context.Context, opts ...grpc.CallOption) (Manager_ClientTunnelClient, error)
	// AgentTunnel receives messages from the agent and dispatches them to tracked
	// net.Conn instances in the traffic-manager. Responses from tracked instances
	// are sent back on the returned message stream
	AgentTunnel(ctx context.Context, opts ...grpc.CallOption) (Manager_AgentTunnelClient, error)
	// LookupHost performs a DNS lookup in the cluster. If the caller has intercepts
	// active, the lookup will be performed from the intercepted pods.
	LookupHost(ctx context.Context, in *LookupHostRequest, opts ...grpc.CallOption) (*LookupHostResponse, error)
	// AgentLookupHostResponse lets an agent respond for lookup requests
	AgentLookupHostResponse(ctx context.Context, in *LookupHostAgentResponse, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// WatchLookupHost lets an agent receive lookup requests
	WatchLookupHost(ctx context.Context, in *SessionInfo, opts ...grpc.CallOption) (Manager_WatchLookupHostClient, error)
	// WatchLogLevel lets an agent receive log-level updates
	WatchLogLevel(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (Manager_WatchLogLevelClient, 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 ManagerProxyClient 

type ManagerProxyClient interface {
	// The first argument chunk must be an "intercept_id"; after that no
	// chunk may be an intercept_id.  System A calls this when it
	// recieves a connection to "XYZ.preview.edgestack.me", and that
	// domain belongs to an intercept that belongs to this manager.
	HandleConnection(ctx context.Context, opts ...grpc.CallOption) (ManagerProxy_HandleConnectionClient, error)
}

ManagerProxyClient is the client API for ManagerProxy 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 NewManagerProxyClient 

func NewManagerProxyClient(cc grpc.ClientConnInterface) ManagerProxyClient

type ManagerProxyServer 

type ManagerProxyServer interface {
	// The first argument chunk must be an "intercept_id"; after that no
	// chunk may be an intercept_id.  System A calls this when it
	// recieves a connection to "XYZ.preview.edgestack.me", and that
	// domain belongs to an intercept that belongs to this manager.
	HandleConnection(ManagerProxy_HandleConnectionServer) error
	// contains filtered or unexported methods
}

ManagerProxyServer is the server API for ManagerProxy service. All implementations must embed UnimplementedManagerProxyServer for forward compatibility

type ManagerProxy_HandleConnectionClient 

type ManagerProxy_HandleConnectionClient interface {
	Send(*ConnectionChunk) error
	Recv() (*ConnectionChunk, error)
	grpc.ClientStream
}

type ManagerProxy_HandleConnectionServer 

type ManagerProxy_HandleConnectionServer interface {
	Send(*ConnectionChunk) error
	Recv() (*ConnectionChunk, error)
	grpc.ServerStream
}

type ManagerServer 

type ManagerServer interface {
	// Version returns the version information of the Manager.
	Version(context.Context, *emptypb.Empty) (*VersionInfo2, 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)
	// 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
	GetLogs(context.Context, *GetLogsRequest) (*LogsResponse, 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
	// 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
	// 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)
	// 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)
	// ClientTunnel receives messages from the client and dispatches them to tracked
	// net.Conn instances in the traffic-manager. Responses from tracked instances
	// are sent back on the returned message stream
	ClientTunnel(Manager_ClientTunnelServer) error
	// AgentTunnel receives messages from the agent and dispatches them to tracked
	// net.Conn instances in the traffic-manager. Responses from tracked instances
	// are sent back on the returned message stream
	AgentTunnel(Manager_AgentTunnelServer) error
	// LookupHost performs a DNS lookup in the cluster. If the caller has intercepts
	// active, the lookup will be performed from the intercepted pods.
	LookupHost(context.Context, *LookupHostRequest) (*LookupHostResponse, error)
	// AgentLookupHostResponse lets an agent respond for lookup requests
	AgentLookupHostResponse(context.Context, *LookupHostAgentResponse) (*emptypb.Empty, error)
	// WatchLookupHost lets an agent receive lookup requests
	WatchLookupHost(*SessionInfo, Manager_WatchLookupHostServer) error
	// WatchLogLevel lets an agent receive log-level updates
	WatchLogLevel(*emptypb.Empty, Manager_WatchLogLevelServer) error
	// contains filtered or unexported methods
}

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

type Manager_AgentTunnelClient added in v2.3.2 

type Manager_AgentTunnelClient interface {
	Send(*ConnMessage) error
	Recv() (*ConnMessage, error)
	grpc.ClientStream
}

type Manager_AgentTunnelServer added in v2.3.2 

type Manager_AgentTunnelServer interface {
	Send(*ConnMessage) error
	Recv() (*ConnMessage, error)
	grpc.ServerStream
}

type Manager_ClientTunnelClient added in v2.3.2 

type Manager_ClientTunnelClient interface {
	Send(*ConnMessage) error
	Recv() (*ConnMessage, error)
	grpc.ClientStream
}

type Manager_ClientTunnelServer added in v2.3.2 

type Manager_ClientTunnelServer interface {
	Send(*ConnMessage) error
	Recv() (*ConnMessage, error)
	grpc.ServerStream
}

type Manager_WatchAgentsClient 

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

type Manager_WatchAgentsServer 

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

type Manager_WatchClusterInfoClient added in v2.3.2 

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

type Manager_WatchClusterInfoServer added in v2.3.2 

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

type Manager_WatchInterceptsClient 

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

type Manager_WatchInterceptsServer 

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

type Manager_WatchLogLevelClient added in v2.4.2 

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

type Manager_WatchLogLevelServer added in v2.4.2 

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

type Manager_WatchLookupHostClient added in v2.3.0 

type Manager_WatchLookupHostClient interface {
	Recv() (*LookupHostRequest, error)
	grpc.ClientStream
}

type Manager_WatchLookupHostServer added in v2.3.0 

type Manager_WatchLookupHostServer interface {
	Send(*LookupHostRequest) error
	grpc.ServerStream
}

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

func (*PreviewSpec) Descriptor deprecated 

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

Deprecated: Use PreviewSpec.ProtoReflect.Descriptor instead.

func (*PreviewSpec) GetDisplayBanner 

func (x *PreviewSpec) GetDisplayBanner() bool

func (*PreviewSpec) GetIngress 

func (x *PreviewSpec) GetIngress() *IngressInfo

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"`
	// 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"`
	// 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) GetId 

func (x *ReviewInterceptRequest) GetId() string

func (*ReviewInterceptRequest) GetMechanismArgsDesc 

func (x *ReviewInterceptRequest) GetMechanismArgsDesc() string

func (*ReviewInterceptRequest) GetMessage 

func (x *ReviewInterceptRequest) GetMessage() 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 SessionInfo 

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

func (*SessionInfo) Descriptor deprecated 

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

Deprecated: Use SessionInfo.ProtoReflect.Descriptor instead.

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 UnimplementedManagerProxyServer 

type UnimplementedManagerProxyServer struct {
}

UnimplementedManagerProxyServer must be embedded to have forward compatible implementations.

func (UnimplementedManagerProxyServer) HandleConnection 

func (UnimplementedManagerProxyServer) HandleConnection(ManagerProxy_HandleConnectionServer) error

type UnimplementedManagerServer 

type UnimplementedManagerServer struct {
}

UnimplementedManagerServer must be embedded to have forward compatible implementations.

func (UnimplementedManagerServer) AgentLookupHostResponse added in v2.3.0 

func (UnimplementedManagerServer) AgentLookupHostResponse(context.Context, *LookupHostAgentResponse) (*emptypb.Empty, error)

func (UnimplementedManagerServer) AgentTunnel added in v2.3.2 

func (UnimplementedManagerServer) AgentTunnel(Manager_AgentTunnelServer) 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) ClientTunnel added in v2.3.2 

func (UnimplementedManagerServer) ClientTunnel(Manager_ClientTunnelServer) 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) GetCloudConfig added in v2.2.2 

func (UnimplementedManagerServer) GetCloudConfig(context.Context, *emptypb.Empty) (*AmbassadorCloudConfig, 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) LookupHost added in v2.3.0 

func (UnimplementedManagerServer) LookupHost(context.Context, *LookupHostRequest) (*LookupHostResponse, 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) 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) UpdateIntercept 

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

func (UnimplementedManagerServer) Version 

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

func (UnimplementedManagerServer) WatchAgents 

func (UnimplementedManagerServer) WatchAgents(*SessionInfo, Manager_WatchAgentsServer) error

func (UnimplementedManagerServer) WatchClusterInfo added in v2.3.2 

func (UnimplementedManagerServer) WatchClusterInfo(*SessionInfo, Manager_WatchClusterInfoServer) error

func (UnimplementedManagerServer) WatchIntercepts 

func (UnimplementedManagerServer) WatchIntercepts(*SessionInfo, Manager_WatchInterceptsServer) error

func (UnimplementedManagerServer) WatchLogLevel added in v2.4.2 

func (UnimplementedManagerServer) WatchLogLevel(*emptypb.Empty, Manager_WatchLogLevelServer) error

func (UnimplementedManagerServer) WatchLookupHost added in v2.3.0 

func (UnimplementedManagerServer) WatchLookupHost(*SessionInfo, Manager_WatchLookupHostServer) error

type UnsafeManagerProxyServer 

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

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

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 {
	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 does not contain an 'api_version' integer.

func (*VersionInfo2) Descriptor deprecated 

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

Deprecated: Use VersionInfo2.ProtoReflect.Descriptor instead.

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

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.