manager

package
v2.4.10-rc.2 Latest Latest
Warning

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

 Go to latest Published: Jan 12, 2022 License: Apache-2.0 Imports: 40 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Main 

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

Main starts up the traffic manager and blocks until it ends

func NewSystemAPool 

func NewSystemAPool(mgr *Manager) *systemaPool

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

func (*Manager) AgentLookupHostResponse added in v2.3.0 

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

func (*Manager) AgentTunnel added in v2.3.2 

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

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 rpc.Manager_ClientTunnelServer) error

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) 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(ctx context.Context, request *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

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

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

func (*Manager) Remain 

func (m *Manager) Remain(_ 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) 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) WatchLookupHost added in v2.3.0 

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

Source Files

View all Source files

Directories

Path Synopsis
internal
cluster
mutator
state
systema
Package system implements all of the yucky system-logic details for communicating with System A from the Telepresence manager.
 Package system implements all of the yucky system-logic details for communicating with System A from the Telepresence manager.
test
watchable

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.