manager

Dec 13, 2024

Changes in this version

+ const Manager_GetAgentConfig_FullMethodName

+ type AgentConfigRequest struct

+ Name string

+ Session *SessionInfo

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

+ func (*AgentConfigRequest) ProtoMessage()

+ func (x *AgentConfigRequest) GetName() string

+ func (x *AgentConfigRequest) GetSession() *SessionInfo

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

+ func (x *AgentConfigRequest) Reset()

+ func (x *AgentConfigRequest) String() string

+ type AgentConfigResponse struct

+ Data []byte

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

+ func (*AgentConfigResponse) ProtoMessage()

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

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

+ func (x *AgentConfigResponse) Reset()

+ func (x *AgentConfigResponse) String() string

type AgentInfo

+ Containers map[string]*AgentInfo_ContainerInfo

+ FtpPort int32

+ Kind string

+ SftpPort int32

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

+ func (x *AgentInfo) GetFtpPort() int32

+ func (x *AgentInfo) GetKind() string

+ func (x *AgentInfo) GetSftpPort() int32

+ type AgentInfo_ContainerInfo struct

+ Environment map[string]string

+ MountPoint string

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

+ func (*AgentInfo_ContainerInfo) ProtoMessage()

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

+ func (x *AgentInfo_ContainerInfo) GetMountPoint() string

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

+ func (x *AgentInfo_ContainerInfo) Reset()

+ func (x *AgentInfo_ContainerInfo) String() string

type InterceptSpec

+ ContainerName string

+ func (x *InterceptSpec) GetContainerName() string

type License

+ Valid bool

+ func (x *License) GetValid() bool

type ManagerClient

+ GetAgentConfig func(ctx context.Context, in *AgentConfigRequest, opts ...grpc.CallOption) (*AgentConfigResponse, error)

type ManagerServer

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

type UnimplementedManagerServer

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

type WorkloadEventsRequest

+ Namespace string

+ func (x *WorkloadEventsRequest) GetNamespace() string

type WorkloadInfo

+ Uid string

+ func (x *WorkloadInfo) GetUid() string

Oct 3, 2024

Changes in this version

+ const Manager_GetKnownWorkloadKinds_FullMethodName

type InterceptSpec

+ ContainerPort int32

+ PortIdentifier string

+ func (x *InterceptSpec) GetContainerPort() int32

+ func (x *InterceptSpec) GetPortIdentifier() string

+ type KnownWorkloadKinds struct

+ Kinds []WorkloadInfo_Kind

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

+ func (*KnownWorkloadKinds) ProtoMessage()

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

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

+ func (x *KnownWorkloadKinds) Reset()

+ func (x *KnownWorkloadKinds) String() string

type ManagerClient

+ GetKnownWorkloadKinds func(ctx context.Context, in *SessionInfo, opts ...grpc.CallOption) (*KnownWorkloadKinds, error)

type ManagerServer

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

type PreparedIntercept

+ ContainerName string

+ ContainerPort int32

+ func (x *PreparedIntercept) GetContainerName() string

+ func (x *PreparedIntercept) GetContainerPort() int32

type UnimplementedManagerServer

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

type WorkloadInfo_Kind

+ const WorkloadInfo_ROLLOUT

Jul 12, 2024

Changes in this version

+ var WorkloadInfo_State_name = map[int32]string

+ var WorkloadInfo_State_value = map[string]int32

type WorkloadInfo

+ InterceptClients []*WorkloadInfo_Intercept

+ State WorkloadInfo_State

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

+ func (x *WorkloadInfo) GetState() WorkloadInfo_State

+ type WorkloadInfo_Intercept struct

+ Client string

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

+ func (*WorkloadInfo_Intercept) ProtoMessage()

+ func (x *WorkloadInfo_Intercept) GetClient() string

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

+ func (x *WorkloadInfo_Intercept) Reset()

+ func (x *WorkloadInfo_Intercept) String() string

+ type WorkloadInfo_State int32

+ const WorkloadInfo_AVAILABLE

+ const WorkloadInfo_FAILURE

+ const WorkloadInfo_PROGRESSING

+ const WorkloadInfo_UNKNOWN_UNSPECIFIED

+ func (WorkloadInfo_State) Descriptor() protoreflect.EnumDescriptor

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

+ func (WorkloadInfo_State) Type() protoreflect.EnumType

+ func (x WorkloadInfo_State) Enum() *WorkloadInfo_State

+ func (x WorkloadInfo_State) Number() protoreflect.EnumNumber

+ func (x WorkloadInfo_State) String() string

Jun 14, 2024

Changes in this version

+ const Manager_WatchWorkloads_FullMethodName

+ var WorkloadEvent_Type_name = map[int32]string

+ var WorkloadEvent_Type_value = map[string]int32

+ var WorkloadInfo_AgentState_name = map[int32]string

+ var WorkloadInfo_AgentState_value = map[string]int32

+ var WorkloadInfo_Kind_name = map[int32]string

+ var WorkloadInfo_Kind_value = map[string]int32

type ManagerClient

+ WatchWorkloads func(ctx context.Context, in *WorkloadEventsRequest, opts ...grpc.CallOption) (Manager_WatchWorkloadsClient, error)

type ManagerServer

+ WatchWorkloads func(*WorkloadEventsRequest, Manager_WatchWorkloadsServer) error

+ type Manager_WatchWorkloadsClient interface

+ Recv func() (*WorkloadEventsDelta, error)

+ type Manager_WatchWorkloadsServer interface

+ Send func(*WorkloadEventsDelta) error

type UnimplementedManagerServer

+ func (UnimplementedManagerServer) WatchWorkloads(*WorkloadEventsRequest, Manager_WatchWorkloadsServer) error

+ type WorkloadEvent struct

+ Type WorkloadEvent_Type

+ Workload *WorkloadInfo

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

+ func (*WorkloadEvent) ProtoMessage()

+ func (x *WorkloadEvent) GetType() WorkloadEvent_Type

+ func (x *WorkloadEvent) GetWorkload() *WorkloadInfo

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

+ func (x *WorkloadEvent) Reset()

+ func (x *WorkloadEvent) String() string

+ type WorkloadEvent_Type int32

+ const WorkloadEvent_ADDED_UNSPECIFIED

+ const WorkloadEvent_DELETED

+ const WorkloadEvent_MODIFIED

+ func (WorkloadEvent_Type) Descriptor() protoreflect.EnumDescriptor

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

+ func (WorkloadEvent_Type) Type() protoreflect.EnumType

+ func (x WorkloadEvent_Type) Enum() *WorkloadEvent_Type

+ func (x WorkloadEvent_Type) Number() protoreflect.EnumNumber

+ func (x WorkloadEvent_Type) String() string

+ type WorkloadEventsDelta struct

+ Events []*WorkloadEvent

+ Since *timestamppb.Timestamp

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

+ func (*WorkloadEventsDelta) ProtoMessage()

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

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

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

+ func (x *WorkloadEventsDelta) Reset()

+ func (x *WorkloadEventsDelta) String() string

+ type WorkloadEventsRequest struct

+ SessionInfo *SessionInfo

+ Since *timestamppb.Timestamp

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

+ func (*WorkloadEventsRequest) ProtoMessage()

+ func (x *WorkloadEventsRequest) GetSessionInfo() *SessionInfo

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

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

+ func (x *WorkloadEventsRequest) Reset()

+ func (x *WorkloadEventsRequest) String() string

+ type WorkloadInfo struct

+ AgentState WorkloadInfo_AgentState

+ Kind WorkloadInfo_Kind

+ Name string

+ Namespace string

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

+ func (*WorkloadInfo) ProtoMessage()

+ func (x *WorkloadInfo) GetAgentState() WorkloadInfo_AgentState

+ func (x *WorkloadInfo) GetKind() WorkloadInfo_Kind

+ func (x *WorkloadInfo) GetName() string

+ func (x *WorkloadInfo) GetNamespace() string

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

+ func (x *WorkloadInfo) Reset()

+ func (x *WorkloadInfo) String() string

+ type WorkloadInfo_AgentState int32

+ const WorkloadInfo_INSTALLED

+ const WorkloadInfo_INTERCEPTED

+ const WorkloadInfo_NO_AGENT_UNSPECIFIED

+ func (WorkloadInfo_AgentState) Descriptor() protoreflect.EnumDescriptor

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

+ func (WorkloadInfo_AgentState) Type() protoreflect.EnumType

+ func (x WorkloadInfo_AgentState) Enum() *WorkloadInfo_AgentState

+ func (x WorkloadInfo_AgentState) Number() protoreflect.EnumNumber

+ func (x WorkloadInfo_AgentState) String() string

+ type WorkloadInfo_Kind int32

+ const WorkloadInfo_DEPLOYMENT

+ const WorkloadInfo_REPLICASET

+ const WorkloadInfo_STATEFULSET

+ const WorkloadInfo_UNSPECIFIED

+ func (WorkloadInfo_Kind) Descriptor() protoreflect.EnumDescriptor

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

+ func (WorkloadInfo_Kind) Type() protoreflect.EnumType

+ func (x WorkloadInfo_Kind) Enum() *WorkloadInfo_Kind

+ func (x WorkloadInfo_Kind) Number() protoreflect.EnumNumber

+ func (x WorkloadInfo_Kind) String() string

Feb 10, 2024

Changes in this version

+ const Manager_EnsureAgent_FullMethodName

+ const Manager_GetAgentImageFQN_FullMethodName

+ type AgentImageFQN struct

+ FQN string

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

+ func (*AgentImageFQN) ProtoMessage()

+ func (x *AgentImageFQN) GetFQN() string

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

+ func (x *AgentImageFQN) Reset()

+ func (x *AgentImageFQN) String() string

type AgentPodInfo

+ WorkloadName string

+ func (x *AgentPodInfo) GetWorkloadName() string

+ type EnsureAgentRequest struct

+ Name string

+ Session *SessionInfo

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

+ func (*EnsureAgentRequest) ProtoMessage()

+ func (x *EnsureAgentRequest) GetName() string

+ func (x *EnsureAgentRequest) GetSession() *SessionInfo

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

+ func (x *EnsureAgentRequest) Reset()

+ func (x *EnsureAgentRequest) String() string

type ManagerClient

+ EnsureAgent func(ctx context.Context, in *EnsureAgentRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ GetAgentImageFQN func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*AgentImageFQN, error)

type ManagerServer

+ EnsureAgent func(context.Context, *EnsureAgentRequest) (*emptypb.Empty, error)

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

type UnimplementedManagerServer

+ func (UnimplementedManagerServer) EnsureAgent(context.Context, *EnsureAgentRequest) (*emptypb.Empty, error)

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

Nov 14, 2023

Changes in this version

+ const Manager_ReportMetrics_FullMethodName

+ const Manager_WatchAgentPods_FullMethodName

type AgentInfo

+ ApiPort int32

+ PodName string

+ func (x *AgentInfo) GetApiPort() int32

+ func (x *AgentInfo) GetPodName() string

+ type AgentPodInfo struct

+ ApiPort int32

+ Intercepted bool

+ Namespace string

+ PodIp []byte

+ PodName string

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

+ func (*AgentPodInfo) ProtoMessage()

+ func (x *AgentPodInfo) GetApiPort() int32

+ func (x *AgentPodInfo) GetIntercepted() bool

+ func (x *AgentPodInfo) GetNamespace() string

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

+ func (x *AgentPodInfo) GetPodName() string

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

+ func (x *AgentPodInfo) Reset()

+ func (x *AgentPodInfo) String() string

+ type AgentPodInfoSnapshot struct

+ Agents []*AgentPodInfo

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

+ func (*AgentPodInfoSnapshot) ProtoMessage()

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

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

+ func (x *AgentPodInfoSnapshot) Reset()

+ func (x *AgentPodInfoSnapshot) String() string

type InterceptDispositionType

+ const InterceptDispositionType_REMOVED

type InterceptInfo

+ ApiPort int32

+ ModifiedAt *timestamppb.Timestamp

+ func (x *InterceptInfo) GetApiPort() int32

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

type ManagerClient

+ ReportMetrics func(ctx context.Context, in *TunnelMetrics, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ WatchAgentPods func(ctx context.Context, in *SessionInfo, opts ...grpc.CallOption) (Manager_WatchAgentPodsClient, error)

type ManagerServer

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

+ WatchAgentPods func(*SessionInfo, Manager_WatchAgentPodsServer) error

+ type Manager_WatchAgentPodsClient interface

+ Recv func() (*AgentPodInfoSnapshot, error)

+ type Manager_WatchAgentPodsServer interface

+ Send func(*AgentPodInfoSnapshot) error

+ type TunnelMetrics struct

+ ClientSessionId string

+ EgressBytes uint64

+ IngressBytes uint64

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

+ func (*TunnelMetrics) ProtoMessage()

+ func (x *TunnelMetrics) GetClientSessionId() string

+ func (x *TunnelMetrics) GetEgressBytes() uint64

+ func (x *TunnelMetrics) GetIngressBytes() uint64

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

+ func (x *TunnelMetrics) Reset()

+ func (x *TunnelMetrics) String() string

type UnimplementedManagerServer

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

+ func (UnimplementedManagerServer) WatchAgentPods(*SessionInfo, Manager_WatchAgentPodsServer) error

Oct 2, 2023

Changes in this version

type ClientInfo

+ Namespace string

+ func (x *ClientInfo) GetNamespace() string

type InterceptSpec

+ Replace bool

+ func (x *InterceptSpec) GetReplace() bool

Jun 12, 2023

Changes in this version

type Routing

+ AllowConflictingSubnets []*IPNet

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

Apr 18, 2023

Changes in this version

+ const ManagerProxy_HandleConnection_FullMethodName

+ const Manager_AgentLookupDNSResponse_FullMethodName

+ const Manager_AgentLookupHostResponse_FullMethodName

+ const Manager_AgentTunnel_FullMethodName

+ const Manager_ArriveAsAgent_FullMethodName

+ const Manager_ArriveAsClient_FullMethodName

+ const Manager_CanConnectAmbassadorCloud_FullMethodName

+ const Manager_ClientTunnel_FullMethodName

+ const Manager_CreateIntercept_FullMethodName

+ const Manager_Depart_FullMethodName

+ const Manager_GetClientConfig_FullMethodName

+ const Manager_GetCloudConfig_FullMethodName

+ const Manager_GetIntercept_FullMethodName

+ const Manager_GetLicense_FullMethodName

+ const Manager_GetLogs_FullMethodName

+ const Manager_GetTelepresenceAPI_FullMethodName

+ const Manager_LookupDNS_FullMethodName

+ const Manager_LookupHost_FullMethodName

+ const Manager_PrepareIntercept_FullMethodName

+ const Manager_Remain_FullMethodName

+ const Manager_RemoveIntercept_FullMethodName

+ const Manager_ReviewIntercept_FullMethodName

+ const Manager_SetLogLevel_FullMethodName

+ const Manager_Tunnel_FullMethodName

+ const Manager_UpdateIntercept_FullMethodName

+ const Manager_Version_FullMethodName

+ const Manager_WatchAgentsNS_FullMethodName

+ const Manager_WatchAgents_FullMethodName

+ const Manager_WatchClusterInfo_FullMethodName

+ const Manager_WatchDial_FullMethodName

+ const Manager_WatchIntercepts_FullMethodName

+ const Manager_WatchLogLevel_FullMethodName

+ const Manager_WatchLookupDNS_FullMethodName

+ const Manager_WatchLookupHost_FullMethodName

Mar 20, 2023

Changes in this version

type ClusterInfo

+ InjectorSvcHost string

+ InjectorSvcIp []byte

+ InjectorSvcPort int32

+ func (x *ClusterInfo) GetInjectorSvcHost() string

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

+ func (x *ClusterInfo) GetInjectorSvcPort() int32

Jan 11, 2023

Changes in this version

type VersionInfo2

+ Name string

+ func (x *VersionInfo2) GetName() string

Nov 15, 2022

Changes in this version

+ var File_manager_manager_proto protoreflect.FileDescriptor

+ var File_manager_systema_proto protoreflect.FileDescriptor

+ type CLIConfig struct

+ ConfigYaml []byte

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

+ func (*CLIConfig) ProtoMessage()

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

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

+ func (x *CLIConfig) Reset()

+ func (x *CLIConfig) String() string

type InterceptSpec

+ Protocol string

+ ServicePort int32

+ func (x *InterceptSpec) GetProtocol() string

+ func (x *InterceptSpec) GetServicePort() int32

type ManagerClient

+ GetClientConfig func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*CLIConfig, error)

type ManagerServer

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

type UnimplementedManagerServer

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

Oct 14, 2022

Changes in this version

type ClusterInfo

+ Dns *DNS

+ ManagerPodPort int32

+ Routing *Routing

+ func (x *ClusterInfo) GetDns() *DNS

+ func (x *ClusterInfo) GetManagerPodPort() int32

+ func (x *ClusterInfo) GetRouting() *Routing

+ type DNS struct

+ ClusterDomain string

+ ExcludeSuffixes []string

+ IncludeSuffixes []string

+ KubeIp []byte

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

+ func (*DNS) ProtoMessage()

+ func (x *DNS) GetClusterDomain() string

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

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

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

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

+ func (x *DNS) Reset()

+ func (x *DNS) String() string

+ type DNSAgentResponse struct

+ Request *DNSRequest

+ Response *DNSResponse

+ Session *SessionInfo

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

+ func (*DNSAgentResponse) ProtoMessage()

+ func (x *DNSAgentResponse) GetRequest() *DNSRequest

+ func (x *DNSAgentResponse) GetResponse() *DNSResponse

+ func (x *DNSAgentResponse) GetSession() *SessionInfo

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

+ func (x *DNSAgentResponse) Reset()

+ func (x *DNSAgentResponse) String() string

+ type DNSRequest struct

+ Name string

+ Session *SessionInfo

+ Type uint32

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

+ func (*DNSRequest) ProtoMessage()

+ func (x *DNSRequest) GetName() string

+ func (x *DNSRequest) GetSession() *SessionInfo

+ func (x *DNSRequest) GetType() uint32

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

+ func (x *DNSRequest) Reset()

+ func (x *DNSRequest) String() string

+ type DNSResponse struct

+ RCode int32

+ Rrs []byte

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

+ func (*DNSResponse) ProtoMessage()

+ func (x *DNSResponse) GetRCode() int32

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

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

+ func (x *DNSResponse) Reset()

+ func (x *DNSResponse) String() string

type LookupHostRequest

+ Name string

+ func (x *LookupHostRequest) GetName() string

type ManagerClient

+ AgentLookupDNSResponse func(ctx context.Context, in *DNSAgentResponse, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ LookupDNS func(ctx context.Context, in *DNSRequest, opts ...grpc.CallOption) (*DNSResponse, error)

+ WatchLookupDNS func(ctx context.Context, in *SessionInfo, opts ...grpc.CallOption) (Manager_WatchLookupDNSClient, error)

type ManagerServer

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

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

+ WatchLookupDNS func(*SessionInfo, Manager_WatchLookupDNSServer) error

+ type Manager_WatchLookupDNSClient interface

+ Recv func() (*DNSRequest, error)

+ type Manager_WatchLookupDNSServer interface

+ Send func(*DNSRequest) error

+ type Routing struct

+ AlsoProxySubnets []*IPNet

+ NeverProxySubnets []*IPNet

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

+ func (*Routing) ProtoMessage()

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

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

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

+ func (x *Routing) Reset()

+ func (x *Routing) String() string

type UnimplementedManagerServer

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

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

+ func (UnimplementedManagerServer) WatchLookupDNS(*SessionInfo, Manager_WatchLookupDNSServer) error

Sep 14, 2022

Changes in this version

type InterceptInfo

+ FtpPort int32

+ func (x *InterceptInfo) GetFtpPort() int32

type ReviewInterceptRequest

+ FtpPort int32

+ func (x *ReviewInterceptRequest) GetFtpPort() int32

Aug 8, 2022

Changes in this version

type ClusterInfo

+ DnsConfig *DNSConfig

+ func (x *ClusterInfo) GetDnsConfig() *DNSConfig

+ type DNSConfig struct

+ AlsoProxySubnets []*IPNet

+ NeverProxySubnets []*IPNet

+ func (*DNSConfig) Descriptor() ([]byte, []int)

+ func (*DNSConfig) ProtoMessage()

+ func (x *DNSConfig) GetAlsoProxySubnets() []*IPNet

+ func (x *DNSConfig) GetNeverProxySubnets() []*IPNet

+ func (x *DNSConfig) ProtoReflect() protoreflect.Message

+ func (x *DNSConfig) Reset()

+ func (x *DNSConfig) String() string

type DialRequest

+ TraceContext map[string]string

+ func (x *DialRequest) GetTraceContext() map[string]string

type PreviewSpec

+ AddRequestHeaders map[string]string

+ PullRequestUrl string

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

+ func (x *PreviewSpec) GetPullRequestUrl() string

Jun 23, 2022

Changes in this version

type InterceptSpec

+ LocalPorts []string

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

type PreparedIntercept

+ Protocol string

+ func (x *PreparedIntercept) GetProtocol() string

Jun 3, 2022

Changes in this version

type AmbassadorCloudConfig

+ ProxyCa []byte

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

May 21, 2022

Changes in this version

type SessionInfo

+ ClusterId string

+ InstallId *string

+ func (x *SessionInfo) GetClusterId() string

+ func (x *SessionInfo) GetInstallId() string

May 13, 2022

Changes in this version

type InterceptInfo

+ ClientMountPoint string

+ Environment map[string]string

+ MountPoint string

+ func (x *InterceptInfo) GetClientMountPoint() string

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

+ func (x *InterceptInfo) GetMountPoint() string

type InterceptSpec

+ Reserved string

+ func (x *InterceptSpec) GetReserved() string

type ManagerClient

+ PrepareIntercept func(ctx context.Context, in *CreateInterceptRequest, opts ...grpc.CallOption) (*PreparedIntercept, error)

type ManagerServer

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

+ type PreparedIntercept struct

+ AgentImage string

+ Error string

+ ErrorCategory int32

+ Namespace string

+ ServiceName string

+ ServicePort int32

+ ServicePortName string

+ ServiceUid string

+ WorkloadKind string

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

+ func (*PreparedIntercept) ProtoMessage()

+ func (x *PreparedIntercept) GetAgentImage() string

+ func (x *PreparedIntercept) GetError() string

+ func (x *PreparedIntercept) GetErrorCategory() int32

+ func (x *PreparedIntercept) GetNamespace() string

+ func (x *PreparedIntercept) GetServiceName() string

+ func (x *PreparedIntercept) GetServicePort() int32

+ func (x *PreparedIntercept) GetServicePortName() string

+ func (x *PreparedIntercept) GetServiceUid() string

+ func (x *PreparedIntercept) GetWorkloadKind() string

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

+ func (x *PreparedIntercept) Reset()

+ func (x *PreparedIntercept) String() string

type ReviewInterceptRequest

+ Environment map[string]string

+ MountPoint string

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

+ func (x *ReviewInterceptRequest) GetMountPoint() string

type UnimplementedManagerServer

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

Apr 8, 2022

Changes in this version

+ type AgentsRequest struct

+ Namespaces []string

+ Session *SessionInfo

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

+ func (*AgentsRequest) ProtoMessage()

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

+ func (x *AgentsRequest) GetSession() *SessionInfo

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

+ func (x *AgentsRequest) Reset()

+ func (x *AgentsRequest) String() string

type ManagerClient

+ WatchAgentsNS func(ctx context.Context, in *AgentsRequest, opts ...grpc.CallOption) (Manager_WatchAgentsNSClient, error)

type ManagerServer

+ WatchAgentsNS func(*AgentsRequest, Manager_WatchAgentsNSServer) error

+ type Manager_WatchAgentsNSClient interface

+ Recv func() (*AgentInfoSnapshot, error)

+ type Manager_WatchAgentsNSServer interface

+ Send func(*AgentInfoSnapshot) error

type UnimplementedManagerServer

+ func (UnimplementedManagerServer) WatchAgentsNS(*AgentsRequest, Manager_WatchAgentsNSServer) error

Mar 29, 2022

Changes in this version

type ClusterInfo

+ ManagerPodIp []byte

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

Feb 19, 2022

Changes in this version

type InterceptInfo

+ Metadata map[string]string

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

type ReviewInterceptRequest

+ Metadata map[string]string

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

Dec 3, 2021

Changes in this version

type InterceptInfo

+ Headers map[string]string

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

type ManagerClient

+ GetTelepresenceAPI func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*TelepresenceAPIInfo, error)

type ManagerServer

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

type ReviewInterceptRequest

+ Headers map[string]string

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

+ type TelepresenceAPIInfo struct

+ Port int32

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

+ func (*TelepresenceAPIInfo) ProtoMessage()

+ func (x *TelepresenceAPIInfo) GetPort() int32

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

+ func (x *TelepresenceAPIInfo) Reset()

+ func (x *TelepresenceAPIInfo) String() string

type UnimplementedManagerServer

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

Oct 15, 2021

Changes in this version

+ type DialRequest struct

+ ConnId []byte

+ DialTimeout int64

+ RoundtripLatency int64

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

+ func (*DialRequest) ProtoMessage()

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

+ func (x *DialRequest) GetDialTimeout() int64

+ func (x *DialRequest) GetRoundtripLatency() int64

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

+ func (x *DialRequest) Reset()

+ func (x *DialRequest) String() string

+ type GetInterceptRequest struct

+ Name string

+ Session *SessionInfo

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

+ func (*GetInterceptRequest) ProtoMessage()

+ func (x *GetInterceptRequest) GetName() string

+ func (x *GetInterceptRequest) GetSession() *SessionInfo

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

+ func (x *GetInterceptRequest) Reset()

+ func (x *GetInterceptRequest) String() string

type GetLogsRequest

+ GetPodYaml bool

+ func (x *GetLogsRequest) GetGetPodYaml() bool

type InterceptSpec

+ DialTimeout int64

+ RoundtripLatency int64

+ func (x *InterceptSpec) GetDialTimeout() int64

+ func (x *InterceptSpec) GetRoundtripLatency() int64

type License

+ ErrMsg string

+ func (x *License) GetErrMsg() string

type LogsResponse

+ PodYaml map[string]string

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

type ManagerClient

+ GetIntercept func(ctx context.Context, in *GetInterceptRequest, opts ...grpc.CallOption) (*InterceptInfo, error)

+ Tunnel func(ctx context.Context, opts ...grpc.CallOption) (Manager_TunnelClient, error)

+ WatchDial func(ctx context.Context, in *SessionInfo, opts ...grpc.CallOption) (Manager_WatchDialClient, error)

type ManagerServer

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

+ Tunnel func(Manager_TunnelServer) error

+ WatchDial func(*SessionInfo, Manager_WatchDialServer) error

+ type Manager_TunnelClient interface

+ Recv func() (*TunnelMessage, error)

+ Send func(*TunnelMessage) error

+ type Manager_TunnelServer interface

+ Recv func() (*TunnelMessage, error)

+ Send func(*TunnelMessage) error

+ type Manager_WatchDialClient interface

+ Recv func() (*DialRequest, error)

+ type Manager_WatchDialServer interface

+ Send func(*DialRequest) error

+ type TunnelMessage struct

+ Payload []byte

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

+ func (*TunnelMessage) ProtoMessage()

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

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

+ func (x *TunnelMessage) Reset()

+ func (x *TunnelMessage) String() string

type UnimplementedManagerServer

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

+ func (UnimplementedManagerServer) Tunnel(Manager_TunnelServer) error

+ func (UnimplementedManagerServer) WatchDial(*SessionInfo, Manager_WatchDialServer) error

Sep 27, 2021

Changes in this version

+ type GetLogsRequest struct

+ Agents string

+ TrafficManager bool

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

+ func (*GetLogsRequest) ProtoMessage()

+ func (x *GetLogsRequest) GetAgents() string

+ func (x *GetLogsRequest) GetTrafficManager() bool

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

+ func (x *GetLogsRequest) Reset()

+ func (x *GetLogsRequest) String() string

+ type LogsResponse struct

+ ErrMsg string

+ PodLogs map[string]string

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

+ func (*LogsResponse) ProtoMessage()

+ func (x *LogsResponse) GetErrMsg() string

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

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

+ func (x *LogsResponse) Reset()

+ func (x *LogsResponse) String() string

type ManagerClient

+ GetLogs func(ctx context.Context, in *GetLogsRequest, opts ...grpc.CallOption) (*LogsResponse, error)

type ManagerServer

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

type UnimplementedManagerServer

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

Sep 15, 2021

Changes in this version

+ var ManagerProxy_ServiceDesc = grpc.ServiceDesc

+ var Manager_ServiceDesc = grpc.ServiceDesc

type ClusterInfo

+ ClusterDomain string

+ func (x *ClusterInfo) GetClusterDomain() string

Sep 1, 2021

Changes in this version

+ type LogLevelRequest struct

+ Duration *duration.Duration

+ LogLevel string

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

+ func (*LogLevelRequest) ProtoMessage()

+ func (x *LogLevelRequest) GetDuration() *duration.Duration

+ func (x *LogLevelRequest) GetLogLevel() string

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

+ func (x *LogLevelRequest) Reset()

+ func (x *LogLevelRequest) String() string

type ManagerClient

+ SetLogLevel func(ctx context.Context, in *LogLevelRequest, opts ...grpc.CallOption) (*empty.Empty, error)

+ WatchLogLevel func(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (Manager_WatchLogLevelClient, error)

type ManagerServer

+ SetLogLevel func(context.Context, *LogLevelRequest) (*empty.Empty, error)

+ WatchLogLevel func(*empty.Empty, Manager_WatchLogLevelServer) error

+ type Manager_WatchLogLevelClient interface

+ Recv func() (*LogLevelRequest, error)

+ type Manager_WatchLogLevelServer interface

+ Send func(*LogLevelRequest) error

type UnimplementedManagerServer

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

+ func (UnimplementedManagerServer) WatchLogLevel(*empty.Empty, Manager_WatchLogLevelServer) error

Jul 7, 2021

Changes in this version

type InterceptSpec

+ ExtraPorts []int32

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

Jun 18, 2021

Changes in this version

+ type ClusterInfo struct

+ KubeDnsIp []byte

+ PodSubnets []*IPNet

+ ServiceSubnet *IPNet

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

+ func (*ClusterInfo) ProtoMessage()

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

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

+ func (x *ClusterInfo) GetServiceSubnet() *IPNet

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

+ func (x *ClusterInfo) Reset()

+ func (x *ClusterInfo) String() string

+ type IPNet struct

+ Ip []byte

+ Mask int32

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

+ func (*IPNet) ProtoMessage()

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

+ func (x *IPNet) GetMask() int32

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

+ func (x *IPNet) Reset()

+ func (x *IPNet) String() string

type ManagerClient

+ AgentTunnel func(ctx context.Context, opts ...grpc.CallOption) (Manager_AgentTunnelClient, error)

+ ClientTunnel func(ctx context.Context, opts ...grpc.CallOption) (Manager_ClientTunnelClient, error)

+ WatchClusterInfo func(ctx context.Context, in *SessionInfo, opts ...grpc.CallOption) (Manager_WatchClusterInfoClient, error)

type ManagerServer

+ AgentTunnel func(Manager_AgentTunnelServer) error

+ ClientTunnel func(Manager_ClientTunnelServer) error

+ WatchClusterInfo func(*SessionInfo, Manager_WatchClusterInfoServer) error

+ type Manager_AgentTunnelClient interface

+ Recv func() (*ConnMessage, error)

+ Send func(*ConnMessage) error

+ type Manager_AgentTunnelServer interface

+ Recv func() (*ConnMessage, error)

+ Send func(*ConnMessage) error

+ type Manager_ClientTunnelClient interface

+ Recv func() (*ConnMessage, error)

+ Send func(*ConnMessage) error

+ type Manager_ClientTunnelServer interface

+ Recv func() (*ConnMessage, error)

+ Send func(*ConnMessage) error

+ type Manager_WatchClusterInfoClient interface

+ Recv func() (*ClusterInfo, error)

+ type Manager_WatchClusterInfoServer interface

+ Send func(*ClusterInfo) error

type UnimplementedManagerServer

+ func (UnimplementedManagerServer) AgentTunnel(Manager_AgentTunnelServer) error

+ func (UnimplementedManagerServer) ClientTunnel(Manager_ClientTunnelServer) error

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

Jun 1, 2021

Changes in this version

type AgentInfo

+ PodIp string

+ func (x *AgentInfo) GetPodIp() string

+ type ConnMessage struct

+ ConnId []byte

+ Payload []byte

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

+ func (*ConnMessage) ProtoMessage()

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

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

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

+ func (x *ConnMessage) Reset()

+ func (x *ConnMessage) String() string

type InterceptInfo

+ PodIp string

+ SftpPort int32

+ func (x *InterceptInfo) GetPodIp() string

+ func (x *InterceptInfo) GetSftpPort() int32

+ type LookupHostAgentResponse struct

+ Request *LookupHostRequest

+ Response *LookupHostResponse

+ Session *SessionInfo

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

+ func (*LookupHostAgentResponse) ProtoMessage()

+ func (x *LookupHostAgentResponse) GetRequest() *LookupHostRequest

+ func (x *LookupHostAgentResponse) GetResponse() *LookupHostResponse

+ func (x *LookupHostAgentResponse) GetSession() *SessionInfo

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

+ func (x *LookupHostAgentResponse) Reset()

+ func (x *LookupHostAgentResponse) String() string

+ type LookupHostRequest struct

+ Host string

+ Session *SessionInfo

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

+ func (*LookupHostRequest) ProtoMessage()

+ func (x *LookupHostRequest) GetHost() string

+ func (x *LookupHostRequest) GetSession() *SessionInfo

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

+ func (x *LookupHostRequest) Reset()

+ func (x *LookupHostRequest) String() string

+ type LookupHostResponse struct

+ Ips [][]byte

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

+ func (*LookupHostResponse) ProtoMessage()

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

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

+ func (x *LookupHostResponse) Reset()

+ func (x *LookupHostResponse) String() string

type ManagerClient

+ AgentLookupHostResponse func(ctx context.Context, in *LookupHostAgentResponse, opts ...grpc.CallOption) (*empty.Empty, error)

+ ConnTunnel func(ctx context.Context, opts ...grpc.CallOption) (Manager_ConnTunnelClient, error)

+ LookupHost func(ctx context.Context, in *LookupHostRequest, opts ...grpc.CallOption) (*LookupHostResponse, error)

+ WatchLookupHost func(ctx context.Context, in *SessionInfo, opts ...grpc.CallOption) (Manager_WatchLookupHostClient, error)

type ManagerServer

+ AgentLookupHostResponse func(context.Context, *LookupHostAgentResponse) (*empty.Empty, error)

+ ConnTunnel func(Manager_ConnTunnelServer) error

+ LookupHost func(context.Context, *LookupHostRequest) (*LookupHostResponse, error)

+ WatchLookupHost func(*SessionInfo, Manager_WatchLookupHostServer) error

+ type Manager_ConnTunnelClient interface

+ Recv func() (*ConnMessage, error)

+ Send func(*ConnMessage) error

+ type Manager_ConnTunnelServer interface

+ Recv func() (*ConnMessage, error)

+ Send func(*ConnMessage) error

+ type Manager_WatchLookupHostClient interface

+ Recv func() (*LookupHostRequest, error)

+ type Manager_WatchLookupHostServer interface

+ Send func(*LookupHostRequest) error

type ReviewInterceptRequest

+ PodIp string

+ SftpPort int32

+ func (x *ReviewInterceptRequest) GetPodIp() string

+ func (x *ReviewInterceptRequest) GetSftpPort() int32

type UnimplementedManagerServer

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

+ func (UnimplementedManagerServer) ConnTunnel(Manager_ConnTunnelServer) error

+ func (UnimplementedManagerServer) LookupHost(context.Context, *LookupHostRequest) (*LookupHostResponse, error)

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

May 17, 2021

Changes in this version

+ type AmbassadorCloudConfig struct

+ Host string

+ Port string

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

+ func (*AmbassadorCloudConfig) ProtoMessage()

+ func (x *AmbassadorCloudConfig) GetHost() string

+ func (x *AmbassadorCloudConfig) GetPort() string

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

+ func (x *AmbassadorCloudConfig) Reset()

+ func (x *AmbassadorCloudConfig) String() string

type CreateInterceptRequest

+ ApiKey string

+ func (x *CreateInterceptRequest) GetApiKey() string

type InterceptInfo

+ ApiKey string

+ func (x *InterceptInfo) GetApiKey() string

type License

+ ClusterId string

+ func (x *License) GetClusterId() string

type ManagerClient

+ GetCloudConfig func(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*AmbassadorCloudConfig, error)

type ManagerServer

+ GetCloudConfig func(context.Context, *empty.Empty) (*AmbassadorCloudConfig, error)

type UnimplementedManagerServer

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

Apr 19, 2021

Changes in this version

+ type AmbassadorCloudConnection struct

+ CanConnect bool

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

+ func (*AmbassadorCloudConnection) ProtoMessage()

+ func (x *AmbassadorCloudConnection) GetCanConnect() bool

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

+ func (x *AmbassadorCloudConnection) Reset()

+ func (x *AmbassadorCloudConnection) String() string

+ type License struct

+ Host string

+ License string

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

+ func (*License) ProtoMessage()

+ func (x *License) GetHost() string

+ func (x *License) GetLicense() string

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

+ func (x *License) Reset()

+ func (x *License) String() string

type ManagerClient

+ CanConnectAmbassadorCloud func(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*AmbassadorCloudConnection, error)

+ GetLicense func(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*License, error)

type ManagerServer

+ CanConnectAmbassadorCloud func(context.Context, *empty.Empty) (*AmbassadorCloudConnection, error)

+ GetLicense func(context.Context, *empty.Empty) (*License, error)

type UnimplementedManagerServer

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

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

Apr 12, 2021

Changes in this version

type InterceptSpec

+ ServicePortIdentifier string

+ func (x *InterceptSpec) GetServicePortIdentifier() string

Apr 5, 2021

Changes in this version

type ClientInfo

+ ApiKey string

+ func (x *ClientInfo) GetApiKey() string

type RemainRequest

+ ApiKey string

+ func (x *RemainRequest) GetApiKey() string

Mar 29, 2021

Changes in this version

type InterceptSpec

+ ServiceName string

+ WorkloadKind string

+ func (x *InterceptSpec) GetServiceName() string

+ func (x *InterceptSpec) GetWorkloadKind() string

Mar 19, 2021

Changes in this version

type InterceptSpec

+ ServiceUid string

+ func (x *InterceptSpec) GetServiceUid() string

Mar 12, 2021

Changes in this version

+ var File_rpc_manager_manager_proto protoreflect.FileDescriptor

+ var File_rpc_manager_systema_proto protoreflect.FileDescriptor

+ var InterceptDispositionType_name = map[int32]string

+ var InterceptDispositionType_value = map[string]int32

+ func RegisterManagerProxyServer(s grpc.ServiceRegistrar, srv ManagerProxyServer)

+ func RegisterManagerServer(s grpc.ServiceRegistrar, srv ManagerServer)

+ type AgentInfo struct

+ Environment map[string]string

+ Hostname string

+ Mechanisms []*AgentInfo_Mechanism

+ Name string

+ Namespace string

+ Product string

+ Version string

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

+ func (*AgentInfo) ProtoMessage()

+ func (x *AgentInfo) GetEnvironment() map[string]string

+ func (x *AgentInfo) GetHostname() string

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

+ func (x *AgentInfo) GetName() string

+ func (x *AgentInfo) GetNamespace() string

+ func (x *AgentInfo) GetProduct() string

+ func (x *AgentInfo) GetVersion() string

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

+ func (x *AgentInfo) Reset()

+ func (x *AgentInfo) String() string

+ type AgentInfoSnapshot struct

+ Agents []*AgentInfo

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

+ func (*AgentInfoSnapshot) ProtoMessage()

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

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

+ func (x *AgentInfoSnapshot) Reset()

+ func (x *AgentInfoSnapshot) String() string

+ type AgentInfo_Mechanism struct

+ Name string

+ Product string

+ Version string

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

+ func (*AgentInfo_Mechanism) ProtoMessage()

+ func (x *AgentInfo_Mechanism) GetName() string

+ func (x *AgentInfo_Mechanism) GetProduct() string

+ func (x *AgentInfo_Mechanism) GetVersion() string

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

+ func (x *AgentInfo_Mechanism) Reset()

+ func (x *AgentInfo_Mechanism) String() string

+ type ClientInfo struct

+ BearerToken string

+ InstallId string

+ Name string

+ Product string

+ Version string

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

+ func (*ClientInfo) ProtoMessage()

+ func (x *ClientInfo) GetBearerToken() string

+ func (x *ClientInfo) GetInstallId() string

+ func (x *ClientInfo) GetName() string

+ func (x *ClientInfo) GetProduct() string

+ func (x *ClientInfo) GetVersion() string

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

+ func (x *ClientInfo) Reset()

+ func (x *ClientInfo) String() string

+ type ConnectionChunk struct

+ Value isConnectionChunk_Value

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

+ func (*ConnectionChunk) ProtoMessage()

+ func (m *ConnectionChunk) GetValue() isConnectionChunk_Value

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

+ func (x *ConnectionChunk) GetError() string

+ func (x *ConnectionChunk) GetInterceptId() string

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

+ func (x *ConnectionChunk) Reset()

+ func (x *ConnectionChunk) String() string

+ type ConnectionChunk_Data struct

+ Data []byte

+ type ConnectionChunk_Error struct

+ Error string

+ type ConnectionChunk_InterceptId struct

+ InterceptId string

+ type CreateInterceptRequest struct

+ InterceptSpec *InterceptSpec

+ Session *SessionInfo

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

+ func (*CreateInterceptRequest) ProtoMessage()

+ func (x *CreateInterceptRequest) GetInterceptSpec() *InterceptSpec

+ func (x *CreateInterceptRequest) GetSession() *SessionInfo

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

+ func (x *CreateInterceptRequest) Reset()

+ func (x *CreateInterceptRequest) String() string

+ type IngressInfo struct

+ Host string

+ L5Host string

+ Port int32

+ UseTls bool

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

+ func (*IngressInfo) ProtoMessage()

+ func (x *IngressInfo) GetHost() string

+ func (x *IngressInfo) GetL5Host() string

+ func (x *IngressInfo) GetPort() int32

+ func (x *IngressInfo) GetUseTls() bool

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

+ func (x *IngressInfo) Reset()

+ func (x *IngressInfo) String() string

+ type InterceptDispositionType int32

+ const InterceptDispositionType_ACTIVE

+ const InterceptDispositionType_AGENT_ERROR

+ const InterceptDispositionType_BAD_ARGS

+ const InterceptDispositionType_NO_AGENT

+ const InterceptDispositionType_NO_CLIENT

+ const InterceptDispositionType_NO_MECHANISM

+ const InterceptDispositionType_NO_PORTS

+ const InterceptDispositionType_UNSPECIFIED

+ const InterceptDispositionType_WAITING

+ func (InterceptDispositionType) Descriptor() protoreflect.EnumDescriptor

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

+ func (InterceptDispositionType) Type() protoreflect.EnumType

+ func (x InterceptDispositionType) Enum() *InterceptDispositionType

+ func (x InterceptDispositionType) Number() protoreflect.EnumNumber

+ func (x InterceptDispositionType) String() string

+ type InterceptInfo struct

+ ClientSession *SessionInfo

+ Disposition InterceptDispositionType

+ Id string

+ ManagerPort int32

+ MechanismArgsDesc string

+ Message string

+ PodName string

+ PreviewDomain string

+ PreviewSpec *PreviewSpec

+ Spec *InterceptSpec

+ SshPort int32

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

+ func (*InterceptInfo) ProtoMessage()

+ func (x *InterceptInfo) GetClientSession() *SessionInfo

+ func (x *InterceptInfo) GetDisposition() InterceptDispositionType

+ func (x *InterceptInfo) GetId() string

+ func (x *InterceptInfo) GetManagerPort() int32

+ func (x *InterceptInfo) GetMechanismArgsDesc() string

+ func (x *InterceptInfo) GetMessage() string

+ func (x *InterceptInfo) GetPodName() string

+ func (x *InterceptInfo) GetPreviewDomain() string

+ func (x *InterceptInfo) GetPreviewSpec() *PreviewSpec

+ func (x *InterceptInfo) GetSpec() *InterceptSpec

+ func (x *InterceptInfo) GetSshPort() int32

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

+ func (x *InterceptInfo) Reset()

+ func (x *InterceptInfo) String() string

+ type InterceptInfoSnapshot struct

+ Intercepts []*InterceptInfo

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

+ func (*InterceptInfoSnapshot) ProtoMessage()

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

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

+ func (x *InterceptInfoSnapshot) Reset()

+ func (x *InterceptInfoSnapshot) String() string

+ type InterceptSpec struct

+ Agent string

+ Client string

+ Mechanism string

+ MechanismArgs []string

+ MountPoint string

+ Name string

+ Namespace string

+ ServicePortName string

+ TargetHost string

+ TargetPort int32

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

+ func (*InterceptSpec) ProtoMessage()

+ func (x *InterceptSpec) GetAgent() string

+ func (x *InterceptSpec) GetClient() string

+ func (x *InterceptSpec) GetMechanism() string

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

+ func (x *InterceptSpec) GetMountPoint() string

+ func (x *InterceptSpec) GetName() string

+ func (x *InterceptSpec) GetNamespace() string

+ func (x *InterceptSpec) GetServicePortName() string

+ func (x *InterceptSpec) GetTargetHost() string

+ func (x *InterceptSpec) GetTargetPort() int32

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

+ func (x *InterceptSpec) Reset()

+ func (x *InterceptSpec) String() string

+ type ManagerClient interface

+ ArriveAsAgent func(ctx context.Context, in *AgentInfo, opts ...grpc.CallOption) (*SessionInfo, error)

+ ArriveAsClient func(ctx context.Context, in *ClientInfo, opts ...grpc.CallOption) (*SessionInfo, error)

+ CreateIntercept func(ctx context.Context, in *CreateInterceptRequest, opts ...grpc.CallOption) (*InterceptInfo, error)

+ Depart func(ctx context.Context, in *SessionInfo, opts ...grpc.CallOption) (*empty.Empty, error)

+ Remain func(ctx context.Context, in *RemainRequest, opts ...grpc.CallOption) (*empty.Empty, error)

+ RemoveIntercept func(ctx context.Context, in *RemoveInterceptRequest2, opts ...grpc.CallOption) (*empty.Empty, error)

+ ReviewIntercept func(ctx context.Context, in *ReviewInterceptRequest, opts ...grpc.CallOption) (*empty.Empty, error)

+ UpdateIntercept func(ctx context.Context, in *UpdateInterceptRequest, opts ...grpc.CallOption) (*InterceptInfo, error)

+ Version func(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*VersionInfo2, error)

+ WatchAgents func(ctx context.Context, in *SessionInfo, opts ...grpc.CallOption) (Manager_WatchAgentsClient, error)

+ WatchIntercepts func(ctx context.Context, in *SessionInfo, opts ...grpc.CallOption) (Manager_WatchInterceptsClient, error)

+ func NewManagerClient(cc grpc.ClientConnInterface) ManagerClient

+ type ManagerProxyClient interface

+ HandleConnection func(ctx context.Context, opts ...grpc.CallOption) (ManagerProxy_HandleConnectionClient, error)

+ func NewManagerProxyClient(cc grpc.ClientConnInterface) ManagerProxyClient

+ type ManagerProxyServer interface

+ HandleConnection func(ManagerProxy_HandleConnectionServer) error

+ type ManagerProxy_HandleConnectionClient interface

+ Recv func() (*ConnectionChunk, error)

+ Send func(*ConnectionChunk) error

+ type ManagerProxy_HandleConnectionServer interface

+ Recv func() (*ConnectionChunk, error)

+ Send func(*ConnectionChunk) error

+ type ManagerServer interface

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

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

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

+ Depart func(context.Context, *SessionInfo) (*empty.Empty, error)

+ Remain func(context.Context, *RemainRequest) (*empty.Empty, error)

+ RemoveIntercept func(context.Context, *RemoveInterceptRequest2) (*empty.Empty, error)

+ ReviewIntercept func(context.Context, *ReviewInterceptRequest) (*empty.Empty, error)

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

+ Version func(context.Context, *empty.Empty) (*VersionInfo2, error)

+ WatchAgents func(*SessionInfo, Manager_WatchAgentsServer) error

+ WatchIntercepts func(*SessionInfo, Manager_WatchInterceptsServer) error

+ type Manager_WatchAgentsClient interface

+ Recv func() (*AgentInfoSnapshot, error)

+ type Manager_WatchAgentsServer interface

+ Send func(*AgentInfoSnapshot) error

+ type Manager_WatchInterceptsClient interface

+ Recv func() (*InterceptInfoSnapshot, error)

+ type Manager_WatchInterceptsServer interface

+ Send func(*InterceptInfoSnapshot) error

+ type PreviewSpec struct

+ DisplayBanner bool

+ Ingress *IngressInfo

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

+ func (*PreviewSpec) ProtoMessage()

+ func (x *PreviewSpec) GetDisplayBanner() bool

+ func (x *PreviewSpec) GetIngress() *IngressInfo

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

+ func (x *PreviewSpec) Reset()

+ func (x *PreviewSpec) String() string

+ type RemainRequest struct

+ BearerToken string

+ Session *SessionInfo

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

+ func (*RemainRequest) ProtoMessage()

+ func (x *RemainRequest) GetBearerToken() string

+ func (x *RemainRequest) GetSession() *SessionInfo

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

+ func (x *RemainRequest) Reset()

+ func (x *RemainRequest) String() string

+ type RemoveInterceptRequest2 struct

+ Name string

+ Session *SessionInfo

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

+ func (*RemoveInterceptRequest2) ProtoMessage()

+ func (x *RemoveInterceptRequest2) GetName() string

+ func (x *RemoveInterceptRequest2) GetSession() *SessionInfo

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

+ func (x *RemoveInterceptRequest2) Reset()

+ func (x *RemoveInterceptRequest2) String() string

+ type ReviewInterceptRequest struct

+ Disposition InterceptDispositionType

+ Id string

+ MechanismArgsDesc string

+ Message string

+ PodName string

+ Session *SessionInfo

+ SshPort int32

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

+ func (*ReviewInterceptRequest) ProtoMessage()

+ func (x *ReviewInterceptRequest) GetDisposition() InterceptDispositionType

+ func (x *ReviewInterceptRequest) GetId() string

+ func (x *ReviewInterceptRequest) GetMechanismArgsDesc() string

+ func (x *ReviewInterceptRequest) GetMessage() string

+ func (x *ReviewInterceptRequest) GetPodName() string

+ func (x *ReviewInterceptRequest) GetSession() *SessionInfo

+ func (x *ReviewInterceptRequest) GetSshPort() int32

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

+ func (x *ReviewInterceptRequest) Reset()

+ func (x *ReviewInterceptRequest) String() string

+ type SessionInfo struct

+ SessionId string

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

+ func (*SessionInfo) ProtoMessage()

+ func (x *SessionInfo) GetSessionId() string

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

+ func (x *SessionInfo) Reset()

+ func (x *SessionInfo) String() string

+ type UnimplementedManagerProxyServer struct

+ func (UnimplementedManagerProxyServer) HandleConnection(ManagerProxy_HandleConnectionServer) error

+ type UnimplementedManagerServer struct

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

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

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

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

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

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

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

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

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

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

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

+ type UnsafeManagerProxyServer interface

+ type UnsafeManagerServer interface

+ type UpdateInterceptRequest struct

+ Name string

+ PreviewDomainAction isUpdateInterceptRequest_PreviewDomainAction

+ Session *SessionInfo

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

+ func (*UpdateInterceptRequest) ProtoMessage()

+ func (m *UpdateInterceptRequest) GetPreviewDomainAction() isUpdateInterceptRequest_PreviewDomainAction

+ func (x *UpdateInterceptRequest) GetAddPreviewDomain() *PreviewSpec

+ func (x *UpdateInterceptRequest) GetName() string

+ func (x *UpdateInterceptRequest) GetRemovePreviewDomain() bool

+ func (x *UpdateInterceptRequest) GetSession() *SessionInfo

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

+ func (x *UpdateInterceptRequest) Reset()

+ func (x *UpdateInterceptRequest) String() string

+ type UpdateInterceptRequest_AddPreviewDomain struct

+ AddPreviewDomain *PreviewSpec

+ type UpdateInterceptRequest_RemovePreviewDomain struct

+ RemovePreviewDomain bool

+ type VersionInfo2 struct

+ Version string

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

+ func (*VersionInfo2) ProtoMessage()

+ func (x *VersionInfo2) GetVersion() string

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

+ func (x *VersionInfo2) Reset()

+ func (x *VersionInfo2) String() string