manager

package
v2.9.0 Latest Latest
Warning

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

 Go to latest Published: Nov 15, 2022 License: Apache-2.0 Imports: 51 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Main 

func Main(ctx context.Context, _ ...string) error

Main starts up the traffic manager and blocks until it ends.

Types

type Clock 

type Clock interface {
	Now() time.Time
}

Clock is the mechanism used by the Manager state to get the current time.

type HealthChecker 

type HealthChecker struct{}

func (*HealthChecker) Check 

func (s *HealthChecker) Check(ctx context.Context, _ *grpc_health_v1.HealthCheckRequest) (*grpc_health_v1.HealthCheckResponse, error)

func (*HealthChecker) Watch 

func (s *HealthChecker) Watch(_ *grpc_health_v1.HealthCheckRequest, stream grpc_health_v1.Health_WatchServer) error

type Manager 

type Manager struct {
	ID string

	rpc.UnsafeManagerServer
	// contains filtered or unexported fields
}

func NewManager 

func NewManager(ctx context.Context) (*Manager, context.Context, error)

func (*Manager) AgentLookupDNSResponse added in v2.8.0 

func (m *Manager) AgentLookupDNSResponse(ctx context.Context, response *rpc.DNSAgentResponse) (*empty.Empty, error)

func (*Manager) AgentLookupHostResponse added in v2.3.0 

func (m *Manager) AgentLookupHostResponse(ctx context.Context, response *rpc.LookupHostAgentResponse) (*empty.Empty, error)

AgentLookupHostResponse Deprecated: More recent clients will use LookupDNS

func (*Manager) AgentTunnel added in v2.3.2 

func (m *Manager) AgentTunnel(server manager.Manager_AgentTunnelServer) error

AgentTunnel just reports that the version of this traffic-manager. Mux tunnels are no longer supported but still used by for version exchange by clients prior to 2.5.0 Deprecated.

func (*Manager) ArriveAsAgent 

func (m *Manager) ArriveAsAgent(ctx context.Context, agent *rpc.AgentInfo) (*rpc.SessionInfo, error)

ArriveAsAgent establishes a session between an agent and the Manager.

func (*Manager) ArriveAsClient 

func (m *Manager) ArriveAsClient(ctx context.Context, client *rpc.ClientInfo) (*rpc.SessionInfo, error)

ArriveAsClient establishes a session between a client and the Manager.

func (*Manager) CanConnectAmbassadorCloud added in v2.2.0 

func (m *Manager) CanConnectAmbassadorCloud(ctx context.Context, _ *empty.Empty) (*rpc.AmbassadorCloudConnection, error)

CanConnectAmbassadorCloud checks if Ambassador Cloud is resolvable from within a cluster.

func (*Manager) ClientTunnel added in v2.3.2 

func (m *Manager) ClientTunnel(server manager.Manager_ClientTunnelServer) error

ClientTunnel just reports that the version of this traffic-manager. Mux tunnels are no longer supported but still used by for version exchange by clients prior to 2.5.0 Deprecated.

func (*Manager) CreateIntercept 

func (m *Manager) CreateIntercept(ctx context.Context, ciReq *rpc.CreateInterceptRequest) (*rpc.InterceptInfo, error)

CreateIntercept lets a client create an intercept.

func (*Manager) Depart 

func (m *Manager) Depart(ctx context.Context, session *rpc.SessionInfo) (*empty.Empty, error)

Depart terminates a session.

func (*Manager) DialIntercept 

func (m *Manager) DialIntercept(ctx context.Context, interceptID string) (net.Conn, error)

func (*Manager) GetClientConfig added in v2.9.0 

func (m *Manager) GetClientConfig(ctx context.Context, _ *empty.Empty) (*rpc.CLIConfig, error)

func (*Manager) GetCloudConfig added in v2.2.2 

func (m *Manager) GetCloudConfig(ctx context.Context, _ *empty.Empty) (*rpc.AmbassadorCloudConfig, error)

GetCloudConfig returns the SystemA Host and Port to the caller (currently just used by the agents).

func (*Manager) GetIntercept added in v2.4.5 

func (m *Manager) GetIntercept(ctx context.Context, request *rpc.GetInterceptRequest) (*rpc.InterceptInfo, error)

GetIntercept gets an intercept info from intercept name.

func (*Manager) GetLicense added in v2.2.0 

func (m *Manager) GetLicense(ctx context.Context, _ *empty.Empty) (*rpc.License, error)

GetLicense returns the license for the cluster. This directory is mounted via the connector if it detects the presence of a systema license secret when installing the traffic-manager.

func (*Manager) GetLogs added in v2.4.4 

func (m *Manager) GetLogs(_ context.Context, _ *rpc.GetLogsRequest) (*rpc.LogsResponse, error)

GetLogs acquires the logs for the traffic-manager and/or traffic-agents specified by the GetLogsRequest and returns them to the caller Deprecated: Clients should use the user daemon's GatherLogs method.

func (*Manager) GetTelepresenceAPI added in v2.4.8 

func (m *Manager) GetTelepresenceAPI(ctx context.Context, e *empty.Empty) (*rpc.TelepresenceAPIInfo, error)

GetTelepresenceAPI returns information about the TelepresenceAPI server.

func (*Manager) LookupDNS added in v2.8.0 

func (m *Manager) LookupDNS(ctx context.Context, request *rpc.DNSRequest) (*rpc.DNSResponse, error)

func (*Manager) LookupHost added in v2.3.0 

func (m *Manager) LookupHost(ctx context.Context, request *rpc.LookupHostRequest) (*rpc.LookupHostResponse, error)

LookupHost Deprecated: Use LookupDNS

func (*Manager) MaybeAddToken added in v2.9.0 

func (m *Manager) MaybeAddToken(ctx context.Context, apikey string)

MaybeAddToken maybe adds apikey to the cluster so that the ambassador agent can login.

func (*Manager) PrepareIntercept added in v2.6.0 

func (m *Manager) PrepareIntercept(ctx context.Context, request *rpc.CreateInterceptRequest) (*rpc.PreparedIntercept, error)

func (*Manager) Remain 

func (m *Manager) Remain(ctx context.Context, req *rpc.RemainRequest) (*empty.Empty, error)

Remain indicates that the session is still valid.

func (*Manager) RemoveIntercept 

func (m *Manager) RemoveIntercept(ctx context.Context, riReq *rpc.RemoveInterceptRequest2) (*empty.Empty, error)

RemoveIntercept lets a client remove an intercept.

func (*Manager) ReviewIntercept 

func (m *Manager) ReviewIntercept(ctx context.Context, rIReq *rpc.ReviewInterceptRequest) (*empty.Empty, error)

ReviewIntercept lets an agent approve or reject an intercept.

func (*Manager) SetLogLevel added in v2.4.2 

func (m *Manager) SetLogLevel(ctx context.Context, request *rpc.LogLevelRequest) (*empty.Empty, error)

func (*Manager) Tunnel added in v2.4.5 

func (m *Manager) Tunnel(server rpc.Manager_TunnelServer) error

func (*Manager) UpdateIntercept 

func (m *Manager) UpdateIntercept(ctx context.Context, req *rpc.UpdateInterceptRequest) (*rpc.InterceptInfo, error)

func (*Manager) Version 

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

Version returns the version information of the Manager.

func (*Manager) WatchAgents 

func (m *Manager) WatchAgents(session *rpc.SessionInfo, stream rpc.Manager_WatchAgentsServer) error

WatchAgents notifies a client of the set of known Agents.

func (*Manager) WatchAgentsNS added in v2.5.5 

func (m *Manager) WatchAgentsNS(request *rpc.AgentsRequest, stream rpc.Manager_WatchAgentsNSServer) error

WatchAgentsNS notifies a client of the set of known Agents.

func (*Manager) WatchClusterInfo added in v2.3.2 

func (m *Manager) WatchClusterInfo(session *rpc.SessionInfo, stream rpc.Manager_WatchClusterInfoServer) error

func (*Manager) WatchDial added in v2.4.5 

func (m *Manager) WatchDial(session *rpc.SessionInfo, stream rpc.Manager_WatchDialServer) error

func (*Manager) WatchIntercepts 

func (m *Manager) WatchIntercepts(session *rpc.SessionInfo, stream rpc.Manager_WatchInterceptsServer) error

WatchIntercepts notifies a client or agent of the set of intercepts relevant to that client or agent.

func (*Manager) WatchLogLevel added in v2.4.2 

func (m *Manager) WatchLogLevel(_ *empty.Empty, stream rpc.Manager_WatchLogLevelServer) error

func (*Manager) WatchLookupDNS added in v2.8.0 

func (m *Manager) WatchLookupDNS(session *rpc.SessionInfo, stream rpc.Manager_WatchLookupDNSServer) error

func (*Manager) WatchLookupHost added in v2.3.0 

func (m *Manager) WatchLookupHost(session *rpc.SessionInfo, stream rpc.Manager_WatchLookupHostServer) error

WatchLookupHost Deprecated: retained for backward compatibility. More recent clients will use LookupDNS.

type ReverseConnProvider added in v2.6.0 

type ReverseConnProvider struct {
	// contains filtered or unexported fields
}

func (*ReverseConnProvider) BuildClient added in v2.6.0 

func (p *ReverseConnProvider) BuildClient(ctx context.Context, conn *grpc.ClientConn) (managerutil.SystemaCRUDClient, error)

func (*ReverseConnProvider) GetAPIKey added in v2.6.0 

func (p *ReverseConnProvider) GetAPIKey(ctx context.Context) (string, error)

func (*ReverseConnProvider) GetCloudConfig added in v2.6.5 

func (p *ReverseConnProvider) GetCloudConfig(ctx context.Context) (*manager.AmbassadorCloudConfig, error)

func (*ReverseConnProvider) GetExtraHeaders added in v2.6.0 

func (p *ReverseConnProvider) GetExtraHeaders(ctx context.Context) (map[string]string, error)

func (*ReverseConnProvider) GetInstallID added in v2.6.0 

func (p *ReverseConnProvider) GetInstallID(ctx context.Context) (string, error)

Source Files

View all Source files

Directories

Path Synopsis
internal
ambassadoragent/cloudtoken
cliconfig
cluster
mutator
mutator/v25uninstall
state
systema
Package systema implements all the yucky system-logic details for communicating with System A from the Telepresence manager.
 Package systema implements all the yucky system-logic details for communicating with System A from the Telepresence manager.
test
watchable
mocks
Package mockmanagerutil is a generated GoMock package.
 Package mockmanagerutil is a generated GoMock package.

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.