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) GatherLogs(ctx context.Context, request *rpc.LogsRequest) (result *rpc.LogsResponse, err error)
- func (s *Service) GatherTraces(ctx context.Context, request *rpc.TracesRequest) (result *rpc.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.Empty) (cs *daemon.ClusterSubnets, err error)
- func (s *Service) GetConfig(ctx context.Context, empty *empty.Empty) (cfg *rpc.ClientConfig, err error)
- func (s *Service) GetFuseFTPClient(ctx context.Context) rpc.FuseFTPClient
- 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) (*rpc.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) (*rpc.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) Server() *grpc.Server
- func (s *Service) SetLogLevel(ctx context.Context, request *rpc.LogLevelRequest) (result *empty.Empty, err error)
- func (s *Service) Status(c 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 *rpc.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)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ManageSessions ¶
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.
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 (*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 (*Service) FuseFTPError ¶
func (*Service) GatherLogs ¶
func (s *Service) GatherLogs(ctx context.Context, request *rpc.LogsRequest) (result *rpc.LogsResponse, err error)
func (*Service) GatherTraces ¶
func (*Service) GetCloudAPIKey ¶
func (*Service) GetCloudLicense ¶
func (s *Service) GetCloudLicense(ctx context.Context, req *rpc.LicenseRequest) (result *rpc.LicenseData, err error)
func (*Service) GetCloudUserInfo ¶
func (*Service) GetClusterSubnets ¶
func (*Service) GetFuseFTPClient ¶ added in v2.9.4
func (s *Service) GetFuseFTPClient(ctx context.Context) rpc.FuseFTPClient
func (*Service) GetIntercept ¶ added in v2.9.3
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) 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) RemoteMountAvailability ¶
func (*Service) RemoveIntercept ¶
func (s *Service) RemoveIntercept(c context.Context, rr *manager.RemoveInterceptRequest2) (result *rpc.InterceptResult, err error)
func (*Service) RemoveInterceptor ¶
func (*Service) RootDaemonVersion ¶
func (*Service) SetLogLevel ¶
func (*Service) TrafficManagerVersion ¶ added in v2.9.3
func (*Service) UpdateIntercept ¶ added in v2.9.3
func (s *Service) UpdateIntercept(c context.Context, rr *manager.UpdateInterceptRequest) (result *manager.InterceptInfo, err error)
func (*Service) WatchWorkloads ¶
func (s *Service) WatchWorkloads(wr *rpc.WatchWorkloadsRequest, server rpc.Connector_WatchWorkloadsServer) error
Click to show internal directories.
Click to hide internal directories.