Documentation ¶
Index ¶
- func NewGRPCService(callbacks Callbacks, sharedState *sharedstate.State) rpc.ConnectorServer
- type Callbacks
- type MgrProxy
- func (p *MgrProxy) AgentLookupHostResponse(ctx context.Context, arg *managerrpc.LookupHostAgentResponse) (*empty.Empty, error)
- func (p *MgrProxy) AgentTunnel(server managerrpc.Manager_AgentTunnelServer) error
- func (p *MgrProxy) ArriveAsAgent(ctx context.Context, arg *managerrpc.AgentInfo) (*managerrpc.SessionInfo, error)
- func (p *MgrProxy) ArriveAsClient(ctx context.Context, arg *managerrpc.ClientInfo) (*managerrpc.SessionInfo, error)
- func (p *MgrProxy) CanConnectAmbassadorCloud(ctx context.Context, arg *empty.Empty) (*managerrpc.AmbassadorCloudConnection, error)
- func (p *MgrProxy) ClientTunnel(fhDaemon managerrpc.Manager_ClientTunnelServer) error
- func (p *MgrProxy) CreateIntercept(ctx context.Context, arg *managerrpc.CreateInterceptRequest) (*managerrpc.InterceptInfo, error)
- func (p *MgrProxy) Depart(ctx context.Context, arg *managerrpc.SessionInfo) (*empty.Empty, error)
- func (p *MgrProxy) GetCloudConfig(ctx context.Context, arg *empty.Empty) (*managerrpc.AmbassadorCloudConfig, error)
- func (p *MgrProxy) GetLicense(ctx context.Context, arg *empty.Empty) (*managerrpc.License, error)
- func (p *MgrProxy) LookupHost(ctx context.Context, arg *managerrpc.LookupHostRequest) (*managerrpc.LookupHostResponse, error)
- func (p *MgrProxy) Remain(ctx context.Context, arg *managerrpc.RemainRequest) (*empty.Empty, error)
- func (p *MgrProxy) RemoveIntercept(ctx context.Context, arg *managerrpc.RemoveInterceptRequest2) (*empty.Empty, error)
- func (p *MgrProxy) ReviewIntercept(ctx context.Context, arg *managerrpc.ReviewInterceptRequest) (*empty.Empty, error)
- func (p *MgrProxy) SetClient(client managerrpc.ManagerClient, callOptions ...grpc.CallOption)
- func (p *MgrProxy) SetLogLevel(ctx context.Context, request *managerrpc.LogLevelRequest) (*empty.Empty, error)
- func (p *MgrProxy) UpdateIntercept(ctx context.Context, arg *managerrpc.UpdateInterceptRequest) (*managerrpc.InterceptInfo, error)
- func (p *MgrProxy) Version(ctx context.Context, arg *empty.Empty) (*managerrpc.VersionInfo2, error)
- func (p *MgrProxy) WatchAgents(arg *managerrpc.SessionInfo, srv managerrpc.Manager_WatchAgentsServer) error
- func (p *MgrProxy) WatchClusterInfo(arg *managerrpc.SessionInfo, srv managerrpc.Manager_WatchClusterInfoServer) error
- func (p *MgrProxy) WatchIntercepts(arg *managerrpc.SessionInfo, srv managerrpc.Manager_WatchInterceptsServer) error
- func (p *MgrProxy) WatchLogLevel(e *empty.Empty, server managerrpc.Manager_WatchLogLevelServer) error
- func (p *MgrProxy) WatchLookupHost(_ *managerrpc.SessionInfo, server managerrpc.Manager_WatchLookupHostServer) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewGRPCService ¶
func NewGRPCService( callbacks Callbacks, sharedState *sharedstate.State, ) rpc.ConnectorServer
Types ¶
type Callbacks ¶
type Callbacks struct { InterceptStatus func() *rpc.InterceptResult Cancel func() Connect func(c context.Context, cr *rpc.ConnectRequest, dryRun bool) *rpc.ConnectInfo }
type MgrProxy ¶
type MgrProxy struct { managerrpc.UnsafeManagerServer // contains filtered or unexported fields }
MgrProxy implements rpc.ManagerServer, but just proxies all requests through a rpc.ManagerClient. Use the `SetClient` method safely adjust the client at runtime. MgrProxy does not need initialized; the zero value works fine.
func (*MgrProxy) AgentLookupHostResponse ¶
func (p *MgrProxy) AgentLookupHostResponse(ctx context.Context, arg *managerrpc.LookupHostAgentResponse) (*empty.Empty, error)
func (*MgrProxy) AgentTunnel ¶
func (p *MgrProxy) AgentTunnel(server managerrpc.Manager_AgentTunnelServer) error
func (*MgrProxy) ArriveAsAgent ¶
func (p *MgrProxy) ArriveAsAgent(ctx context.Context, arg *managerrpc.AgentInfo) (*managerrpc.SessionInfo, error)
func (*MgrProxy) ArriveAsClient ¶
func (p *MgrProxy) ArriveAsClient(ctx context.Context, arg *managerrpc.ClientInfo) (*managerrpc.SessionInfo, error)
func (*MgrProxy) CanConnectAmbassadorCloud ¶
func (p *MgrProxy) CanConnectAmbassadorCloud(ctx context.Context, arg *empty.Empty) (*managerrpc.AmbassadorCloudConnection, error)
func (*MgrProxy) ClientTunnel ¶
func (p *MgrProxy) ClientTunnel(fhDaemon managerrpc.Manager_ClientTunnelServer) error
func (*MgrProxy) CreateIntercept ¶
func (p *MgrProxy) CreateIntercept(ctx context.Context, arg *managerrpc.CreateInterceptRequest) (*managerrpc.InterceptInfo, error)
func (*MgrProxy) Depart ¶
func (p *MgrProxy) Depart(ctx context.Context, arg *managerrpc.SessionInfo) (*empty.Empty, error)
func (*MgrProxy) GetCloudConfig ¶
func (p *MgrProxy) GetCloudConfig(ctx context.Context, arg *empty.Empty) (*managerrpc.AmbassadorCloudConfig, error)
func (*MgrProxy) GetLicense ¶
func (*MgrProxy) LookupHost ¶
func (p *MgrProxy) LookupHost(ctx context.Context, arg *managerrpc.LookupHostRequest) (*managerrpc.LookupHostResponse, error)
func (*MgrProxy) Remain ¶
func (p *MgrProxy) Remain(ctx context.Context, arg *managerrpc.RemainRequest) (*empty.Empty, error)
func (*MgrProxy) RemoveIntercept ¶
func (p *MgrProxy) RemoveIntercept(ctx context.Context, arg *managerrpc.RemoveInterceptRequest2) (*empty.Empty, error)
func (*MgrProxy) ReviewIntercept ¶
func (p *MgrProxy) ReviewIntercept(ctx context.Context, arg *managerrpc.ReviewInterceptRequest) (*empty.Empty, error)
func (*MgrProxy) SetClient ¶
func (p *MgrProxy) SetClient(client managerrpc.ManagerClient, callOptions ...grpc.CallOption)
func (*MgrProxy) SetLogLevel ¶ added in v2.4.2
func (p *MgrProxy) SetLogLevel(ctx context.Context, request *managerrpc.LogLevelRequest) (*empty.Empty, error)
func (*MgrProxy) UpdateIntercept ¶
func (p *MgrProxy) UpdateIntercept(ctx context.Context, arg *managerrpc.UpdateInterceptRequest) (*managerrpc.InterceptInfo, error)
func (*MgrProxy) Version ¶
func (p *MgrProxy) Version(ctx context.Context, arg *empty.Empty) (*managerrpc.VersionInfo2, error)
func (*MgrProxy) WatchAgents ¶
func (p *MgrProxy) WatchAgents(arg *managerrpc.SessionInfo, srv managerrpc.Manager_WatchAgentsServer) error
func (*MgrProxy) WatchClusterInfo ¶
func (p *MgrProxy) WatchClusterInfo(arg *managerrpc.SessionInfo, srv managerrpc.Manager_WatchClusterInfoServer) error
func (*MgrProxy) WatchIntercepts ¶
func (p *MgrProxy) WatchIntercepts(arg *managerrpc.SessionInfo, srv managerrpc.Manager_WatchInterceptsServer) error
func (*MgrProxy) WatchLogLevel ¶ added in v2.4.2
func (p *MgrProxy) WatchLogLevel(e *empty.Empty, server managerrpc.Manager_WatchLogLevelServer) error
func (*MgrProxy) WatchLookupHost ¶
func (p *MgrProxy) WatchLookupHost(_ *managerrpc.SessionInfo, server managerrpc.Manager_WatchLookupHostServer) error
Click to show internal directories.
Click to hide internal directories.