userd

Dec 13, 2024

Changes in this version

type Service

+ InitFTPServer func(context.Context) error

type Session

+ ClearIngestsAndIntercepts func(context.Context) error

+ GetIngest func(*rpc.IngestIdentifier) (*rpc.IngestInfo, error)

+ Ingest func(context.Context, *rpc.IngestRequest) (*rpc.IngestInfo, error)

+ LeaveIngest func(context.Context, *rpc.IngestIdentifier) (*rpc.IngestInfo, error)

Oct 3, 2024

Changes in this version

type Session

+ WithJoinedClientSetInterface func(context.Context) context.Context

Jul 12, 2024

Changes in this version

+ type ConnectRequest interface

+ Request func() *rpc.ConnectRequest

type Service

+ LogCall func(context.Context, string, func(context.Context))

+ PostConnectRequest func(context.Context, ConnectRequest) error

+ ReadConnectResponse func(context.Context) (*rpc.ConnectInfo, error)

Nov 14, 2023

Changes in this version

type Service

+ ListenerAddress func(ctx context.Context) string

Aug 29, 2023

Changes in this version

type WatchWorkloadsStream

+ Context func() context.Context

Jul 7, 2023

Changes in this version

type Service

+ WithSession func(context.Context, string, func(context.Context, Session) error) error

type Session

+ AddIntercept func(context.Context, *rpc.CreateInterceptRequest) *rpc.InterceptResult

+ CanIntercept func(context.Context, *rpc.CreateInterceptRequest) (InterceptInfo, *rpc.InterceptResult)

+ NewCreateInterceptRequest func(*manager.InterceptSpec) *manager.CreateInterceptRequest

+ NewRemainRequest func() *manager.RemainRequest

+ Remain func(ctx context.Context) error

+ RunSession func(c context.Context) error

Jun 12, 2023

Changes in this version

type Session

+ RootDaemon func() rootdRpc.DaemonClient

Mar 20, 2023

Changes in this version

type KubeConfig

+ GetContext func() string

Feb 22, 2023

Changes in this version

type Service

+ FuseFTPMgr func() remotefs.FuseFTPManager

+ RootSessionInProcess func() bool

type Session

+ func GetSession(ctx context.Context) Session

Jan 11, 2023

Changes in this version

type Session

+ ManagerName func() string

Dec 5, 2022

Changes in this version

+ func WithService(ctx context.Context, s Service) context.Context

type Service

+ func GetService(ctx context.Context) Service

+ GetFuseFTPClient func(ctx context.Context) rpc.FuseFTPClient

Nov 23, 2022

Changes in this version

type Session

+ GetInterceptInfo func(string) *manager.InterceptInfo

Nov 15, 2022

Changes in this version

+ func RunSession(c context.Context, s Session) error

+ func WithNewServiceFunc(ctx context.Context, f NewServiceFunc) context.Context

+ func WithNewSessionFunc(ctx context.Context, f NewSessionFunc) context.Context

+ type InterceptInfo interface

+ APIKey func() string

+ InterceptResult func() *rpc.InterceptResult

+ PortIdentifier func() (agentconfig.PortIdentifier, error)

+ PreparedIntercept func() *manager.PreparedIntercept

+ type KubeConfig interface

+ GetManagerNamespace func() string

+ GetRestConfig func() *rest.Config

+ type NamespaceListener func(context.Context)

+ type NewServiceFunc func(context.Context, *dgroup.Group, *scout.Reporter, *client.Config, *grpc.Server) (Service, error)

+ func GetNewServiceFunc(ctx context.Context) NewServiceFunc

+ type NewSessionFunc func(context.Context, *scout.Reporter, *rpc.ConnectRequest, Service, ...) (context.Context, Session, *connector.ConnectInfo)

+ func GetNewSessionFunc(ctx context.Context) NewSessionFunc

type Service

+ As func(ptr any)

+ GetAPIKey func(context.Context) (string, error)

+ Reporter func() *scout.Reporter

+ Server func() *grpc.Server

+ type Session interface

+ ActualNamespace func(string) string

+ AddInterceptor func(string, int) error

+ AddNamespaceListener func(context.Context, NamespaceListener)

+ ApplyConfig func(context.Context) error

+ As func(ptr any)

+ ClearIntercepts func(context.Context) error

+ Done func() <-chan struct{}

+ Epilog func(ctx context.Context)

+ ForeachAgentPod func(ctx context.Context, fn func(context.Context, typed.PodInterface, *core.Pod), ...) error

+ GatherLogs func(context.Context, *connector.LogsRequest) (*connector.LogsResponse, error)

+ GatherTraces func(ctx context.Context, tr *connector.TracesRequest) *connector.Result

+ GetConfig func(context.Context) (*client.SessionConfig, error)

+ GetCurrentNamespaces func(forClientAccess bool) []string

+ GetInterceptSpec func(string) *manager.InterceptSpec

+ InterceptEpilog func(context.Context, *rpc.CreateInterceptRequest, *rpc.InterceptResult) *rpc.InterceptResult

+ InterceptProlog func(context.Context, *manager.CreateInterceptRequest) *rpc.InterceptResult

+ InterceptsForWorkload func(string, string) []*manager.InterceptSpec

+ ManagerClient func() manager.ManagerClient

+ ManagerConn func() *grpc.ClientConn

+ ManagerVersion func() semver.Version

+ RemoveIntercept func(context.Context, string) error

+ RemoveInterceptor func(string) error

+ Reporter func() *scout.Reporter

+ SessionInfo func() *manager.SessionInfo

+ StartServices func(g *dgroup.Group)

+ Status func(context.Context) *rpc.ConnectInfo

+ Uninstall func(context.Context, *rpc.UninstallRequest) (*rpc.Result, error)

+ UpdateStatus func(context.Context, *rpc.ConnectRequest) *rpc.ConnectInfo

+ WatchWorkloads func(context.Context, *rpc.WatchWorkloadsRequest, WatchWorkloadsStream) error

+ WithK8sInterface func(context.Context) context.Context

+ WorkloadInfoSnapshot func(context.Context, []string, rpc.ListRequest_Filter, bool) (*rpc.WorkloadInfoSnapshot, error)

+ type WatchWorkloadsStream interface

+ Send func(*rpc.WorkloadInfoSnapshot) error

Oct 14, 2022

Changes in this version

type Service

+ func (s *Service) FuseFTPError() error

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

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

Aug 25, 2022

Changes in this version

type Service

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

+ func (s *Service) ValidArgsForCommand(ctx context.Context, req *rpc.ValidArgsForCommandRequest) (*rpc.ValidArgsForCommandResponse, error)

Aug 10, 2022

Changes in this version

type Service

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

Aug 8, 2022

Changes in this version

+ type Service struct

+ ManagerProxy trafficmgr.ManagerProxy

+ func GetPoddService(sc *scout.Reporter, cfg client.Config, login auth.LoginExecutor) Service

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

+ 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(c context.Context, _ *empty.Empty) (*empty.Empty, error)

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

+ func (s *Service) GetCloudAPIKey(ctx context.Context, req *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(ctx context.Context, req *rpc.UserInfoRequest) (result *rpc.UserInfo, err error)

+ func (s *Service) GetIngressInfos(c context.Context, _ *empty.Empty) (result *rpc.IngressInfos, err error)

+ func (s *Service) Install(ctx context.Context, req *rpc.InstallRequest) (*rpc.InstallResult, error)

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

+ func (s *Service) ListCommands(ctx context.Context, _ *empty.Empty) (groups *rpc.CommandGroups, err error)

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

+ func (s *Service) LoginExecutor() auth.LoginExecutor

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

+ func (s *Service) ManageSessions(c context.Context, sessionServices []trafficmgr.SessionService) error

+ func (s *Service) Quit(ctx context.Context, _ *empty.Empty) (*empty.Empty, 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) ResolveIngressInfo(ctx context.Context, req *userdaemon.IngressInfoRequest) (resp *userdaemon.IngressInfoResponse, err error)

+ func (s *Service) RootDaemonClient(c context.Context) (daemon.DaemonClient, error)

+ func (s *Service) RunCommand(ctx context.Context, req *rpc.RunCommandRequest) (result *rpc.RunCommandResponse, err error)

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

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

+ func (s *Service) Status(c context.Context, _ *empty.Empty) (result *rpc.ConnectInfo, err error)

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

+ func (s *Service) UserNotifications(_ *empty.Empty, stream rpc.Connector_UserNotificationsServer) (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

Jun 3, 2022

Changes in this version

type SessionClientProvider

+ func (p *SessionClientProvider) GetCloudConfig(ctx context.Context) (*manager.AmbassadorCloudConfig, error)

May 13, 2022

Changes in this version

+ type SessionClient struct

+ func (c *SessionClient) Close(ctx context.Context) error

+ type SessionClientProvider struct

+ func (p *SessionClientProvider) BuildClient(ctx context.Context, conn *grpc.ClientConn) (*SessionClient, error)

+ func (p *SessionClientProvider) GetAPIKey(ctx context.Context) (string, error)

+ func (p *SessionClientProvider) GetExtraHeaders(ctx context.Context) (map[string]string, error)

+ func (p *SessionClientProvider) GetInstallID(ctx context.Context) (string, error)

+ func (p *SessionClientProvider) GetSystemaAddress(ctx context.Context) (string, error)

Feb 19, 2022

Changes in this version

+ const ProcessName

+ func Command(getCommands CommandFactory, daemonServices []DaemonService, ...) *cobra.Command

+ func ConnectSessionToSystemA(ctx context.Context, session trafficmgr.Session) (*grpc.ClientConn, error)

+ func ConnectSystemA(ctx context.Context, systemaURL, apiKey string) (*grpc.ClientConn, error)

+ func Notify(c context.Context, message string)

+ type CommandFactory func() cliutil.CommandGroups

+ type DaemonService interface

+ Name func() string

+ Start func(ctx context.Context, scout *scout.Reporter, grpcServer *grpc.Server, ...) error

+ type WithSession func(c context.Context, callName string, ...) (err error)