daemon

Documentation

Index

• func Command() *cobra.Command
• func ManageSessions(c context.Context, si userd.Service) error
• func NewService(ctx context.Context, _ *dgroup.Group, sr *scout.Reporter, cfg *client.Config, ...) (userd.Service, error)
• type Service
  • func (s *Service) AddInterceptor(ctx context.Context, interceptor *rpc.Interceptor) (*empty.Empty, error)
  • func (s *Service) As(ptr any)
  • func (s *Service) CanIntercept(c context.Context, ir *rpc.CreateInterceptRequest) (result *rpc.InterceptResult, err error)
  • func (s *Service) Connect(ctx context.Context, cr *rpc.ConnectRequest) (result *rpc.ConnectInfo, err error)
  • func (s *Service) CreateIntercept(c context.Context, ir *rpc.CreateInterceptRequest) (result *rpc.InterceptResult, err error)
  • func (s *Service) Disconnect(ctx context.Context, ex *empty.Empty) (*empty.Empty, error)
  • func (s *Service) FuseFTPError() error
  • func (s *Service) FuseFTPMgr() remotefs.FuseFTPManager
  • func (s *Service) GatherLogs(ctx context.Context, request *rpc.LogsRequest) (result *rpc.LogsResponse, err error)
  • func (s *Service) GatherTraces(ctx context.Context, request *rpc.TracesRequest) (result *common.Result, err error)
  • func (s *Service) GetAPIKey(_ context.Context) (string, error)
  • func (s *Service) GetCloudAPIKey(context.Context, *rpc.KeyRequest) (result *rpc.KeyData, err error)
  • func (s *Service) GetCloudLicense(ctx context.Context, req *rpc.LicenseRequest) (result *rpc.LicenseData, err error)
  • func (s *Service) GetCloudUserInfo(context.Context, *rpc.UserInfoRequest) (result *rpc.UserInfo, err error)
  • func (s *Service) GetClusterSubnets(ctx context.Context, _ *empty.Empty) (cs *rpc.ClusterSubnets, err error)
  • func (s *Service) GetConfig(ctx context.Context, empty *empty.Empty) (cfg *rpc.ClientConfig, err error)
  • func (s *Service) GetIntercept(ctx context.Context, request *manager.GetInterceptRequest) (ii *manager.InterceptInfo, err error)
  • func (s *Service) GetNamespaces(ctx context.Context, req *rpc.GetNamespacesRequest) (*rpc.GetNamespacesResponse, error)
  • func (s *Service) Helm(ctx context.Context, req *rpc.HelmRequest) (*common.Result, error)
  • func (s *Service) List(c context.Context, lr *rpc.ListRequest) (result *rpc.WorkloadInfoSnapshot, err error)
  • func (s *Service) Login(context.Context, *rpc.LoginRequest) (result *rpc.LoginResult, err error)
  • func (s *Service) Logout(context.Context, *empty.Empty) (result *empty.Empty, err error)
  • func (s *Service) Quit(ctx context.Context, ex *empty.Empty) (*empty.Empty, error)
  • func (s *Service) RemoteMountAvailability(ctx context.Context, _ *empty.Empty) (*common.Result, error)
  • func (s *Service) RemoveIntercept(c context.Context, rr *manager.RemoveInterceptRequest2) (result *rpc.InterceptResult, err error)
  • func (s *Service) RemoveInterceptor(ctx context.Context, interceptor *rpc.Interceptor) (*empty.Empty, error)
  • func (s *Service) Reporter() *scout.Reporter
  • func (s *Service) RootDaemonVersion(ctx context.Context, empty *empty.Empty) (vi *common.VersionInfo, err error)
  • func (s *Service) RootSessionInProcess() bool
  • func (s *Service) Server() *grpc.Server
  • func (s *Service) SetLogLevel(ctx context.Context, request *rpc.LogLevelRequest) (result *empty.Empty, err error)
  • func (s *Service) SetManagerClient(managerClient manager.ManagerClient, callOptions ...grpc.CallOption)
  • func (s *Service) Status(ctx context.Context, ex *empty.Empty) (result *rpc.ConnectInfo, err error)
  • func (s *Service) TrafficManagerVersion(ctx context.Context, _ *empty.Empty) (vi *common.VersionInfo, err error)
  • func (s *Service) Uninstall(c context.Context, ur *rpc.UninstallRequest) (result *common.Result, err error)
  • func (s *Service) UpdateIntercept(c context.Context, rr *manager.UpdateInterceptRequest) (result *manager.InterceptInfo, err error)
  • func (s *Service) Version(_ context.Context, _ *empty.Empty) (*common.VersionInfo, error)
  • func (s *Service) WatchWorkloads(wr *rpc.WatchWorkloadsRequest, server rpc.Connector_WatchWorkloadsServer) error
  • func (s *Service) WithSession(c context.Context, callName string, ...) (err error)

Functions

func Command

func Command() *cobra.Command

Command returns the CLI sub-command for "connector-foreground".

func ManageSessions

func ManageSessions(c context.Context, si userd.Service) error

ManageSessions is the counterpart to the Connect method. It reads the connectCh, creates a session and writes a reply to the connectErrCh. The session is then started if it was successfully created.

func NewService

func NewService(ctx context.Context, _ *dgroup.Group, sr *scout.Reporter, cfg *client.Config, srv *grpc.Server) (userd.Service, error)

Types

type Service

type Service struct {
	rpc.UnsafeConnectorServer
	// contains filtered or unexported fields
}

Service represents the long-running state of the Telepresence User Daemon.

func (*Service) AddInterceptor

func (s *Service) AddInterceptor(ctx context.Context, interceptor *rpc.Interceptor) (*empty.Empty, error)

func (*Service) As

func (s *Service) As(ptr any)

func (*Service) CanIntercept

func (s *Service) CanIntercept(c context.Context, ir *rpc.CreateInterceptRequest) (result *rpc.InterceptResult, err error)

func (*Service) Connect

func (s *Service) Connect(ctx context.Context, cr *rpc.ConnectRequest) (result *rpc.ConnectInfo, err error)

func (*Service) CreateIntercept

func (s *Service) CreateIntercept(c context.Context, ir *rpc.CreateInterceptRequest) (result *rpc.InterceptResult, err error)

func (*Service) Disconnect

func (s *Service) Disconnect(ctx context.Context, ex *empty.Empty) (*empty.Empty, error)

func (*Service) FuseFTPError

func (s *Service) FuseFTPError() error

func (*Service) FuseFTPMgr

func (s *Service) FuseFTPMgr() remotefs.FuseFTPManager

func (*Service) GatherLogs

func (s *Service) GatherLogs(ctx context.Context, request *rpc.LogsRequest) (result *rpc.LogsResponse, err error)

func (*Service) GatherTraces

func (s *Service) GatherTraces(ctx context.Context, request *rpc.TracesRequest) (result *common.Result, err error)

func (*Service) GetAPIKey

func (s *Service) GetAPIKey(_ context.Context) (string, error)

func (*Service) GetCloudAPIKey

func (s *Service) GetCloudAPIKey(context.Context, *rpc.KeyRequest) (result *rpc.KeyData, err error)

func (*Service) GetCloudLicense

func (s *Service) GetCloudLicense(ctx context.Context, req *rpc.LicenseRequest) (result *rpc.LicenseData, err error)

func (*Service) GetCloudUserInfo

func (s *Service) GetCloudUserInfo(context.Context, *rpc.UserInfoRequest) (result *rpc.UserInfo, err error)

func (*Service) GetClusterSubnets

func (s *Service) GetClusterSubnets(ctx context.Context, _ *empty.Empty) (cs *rpc.ClusterSubnets, err error)

func (*Service) GetConfig

func (s *Service) GetConfig(ctx context.Context, empty *empty.Empty) (cfg *rpc.ClientConfig, err error)

func (*Service) GetIntercept

func (s *Service) GetIntercept(ctx context.Context, request *manager.GetInterceptRequest) (ii *manager.InterceptInfo, err error)

func (*Service) GetNamespaces

func (s *Service) GetNamespaces(ctx context.Context, req *rpc.GetNamespacesRequest) (*rpc.GetNamespacesResponse, error)

func (*Service) Helm

func (s *Service) Helm(ctx context.Context, req *rpc.HelmRequest) (*common.Result, error)

func (*Service) List

func (s *Service) List(c context.Context, lr *rpc.ListRequest) (result *rpc.WorkloadInfoSnapshot, err error)

func (*Service) Login

func (s *Service) Login(context.Context, *rpc.LoginRequest) (result *rpc.LoginResult, err error)

func (*Service) Logout

func (s *Service) Logout(context.Context, *empty.Empty) (result *empty.Empty, err error)

func (*Service) Quit

func (s *Service) Quit(ctx context.Context, ex *empty.Empty) (*empty.Empty, error)

func (*Service) RemoteMountAvailability

func (s *Service) RemoteMountAvailability(ctx context.Context, _ *empty.Empty) (*common.Result, error)

func (*Service) RemoveIntercept

func (s *Service) RemoveIntercept(c context.Context, rr *manager.RemoveInterceptRequest2) (result *rpc.InterceptResult, err error)

func (*Service) RemoveInterceptor

func (s *Service) RemoveInterceptor(ctx context.Context, interceptor *rpc.Interceptor) (*empty.Empty, error)

func (*Service) Reporter

func (s *Service) Reporter() *scout.Reporter

func (*Service) RootDaemonVersion

func (s *Service) RootDaemonVersion(ctx context.Context, empty *empty.Empty) (vi *common.VersionInfo, err error)

func (*Service) RootSessionInProcess

func (s *Service) RootSessionInProcess() bool

func (*Service) Server

func (s *Service) Server() *grpc.Server

func (*Service) SetLogLevel

func (s *Service) SetLogLevel(ctx context.Context, request *rpc.LogLevelRequest) (result *empty.Empty, err error)

func (*Service) SetManagerClient

func (s *Service) SetManagerClient(managerClient manager.ManagerClient, callOptions ...grpc.CallOption)

func (*Service) Status

func (s *Service) Status(ctx context.Context, ex *empty.Empty) (result *rpc.ConnectInfo, err error)

func (*Service) TrafficManagerVersion

func (s *Service) TrafficManagerVersion(ctx context.Context, _ *empty.Empty) (vi *common.VersionInfo, err error)

func (*Service) Uninstall

func (s *Service) Uninstall(c context.Context, ur *rpc.UninstallRequest) (result *common.Result, err error)

func (*Service) UpdateIntercept

func (s *Service) UpdateIntercept(c context.Context, rr *manager.UpdateInterceptRequest) (result *manager.InterceptInfo, err error)

func (*Service) Version

func (s *Service) Version(_ context.Context, _ *empty.Empty) (*common.VersionInfo, error)

func (*Service) WatchWorkloads

func (s *Service) WatchWorkloads(wr *rpc.WatchWorkloadsRequest, server rpc.Connector_WatchWorkloadsServer) error

func (*Service) WithSession

func (s *Service) WithSession(c context.Context, callName string, f func(context.Context, userd.Session) error) (err error)