userd_grpc

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

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 (p *MgrProxy) GetLicense(ctx context.Context, arg *empty.Empty) (*managerrpc.License, error)

func (*MgrProxy) GetLogs

func (p *MgrProxy) GetLogs(ctx context.Context, request *managerrpc.GetLogsRequest) (*managerrpc.LogsResponse, error)

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

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

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