Versions in this module Expand all Collapse all v11 v11.3.3 Dec 13, 2022 Changes in this version + type AccessRequest struct + URI uri.ResourceURI + type App struct + URI uri.ResourceURI + type Cluster struct + Features *proto.Features + Log *logrus.Entry + Name string + ProfileName string + URI uri.ResourceURI + func (c *Cluster) AssumeRole(ctx context.Context, req *api.AssumeRoleRequest) error + func (c *Cluster) Connected() bool + func (c *Cluster) CreateAccessRequest(ctx context.Context, req *api.CreateAccessRequestRequest) (*AccessRequest, error) + func (c *Cluster) CreateGateway(ctx context.Context, params CreateGatewayParams) (*gateway.Gateway, error) + func (c *Cluster) DeleteAccessRequest(ctx context.Context, req *api.DeleteAccessRequestRequest) error + func (c *Cluster) GetAccessRequests(ctx context.Context, req types.AccessRequestFilter) ([]AccessRequest, error) + func (c *Cluster) GetAllDatabases(ctx context.Context) ([]Database, error) + func (c *Cluster) GetAllKubes(ctx context.Context) ([]Kube, error) + func (c *Cluster) GetAllServers(ctx context.Context) ([]Server, error) + func (c *Cluster) GetAllowedDatabaseUsers(ctx context.Context, dbURI string) ([]string, error) + func (c *Cluster) GetApps(ctx context.Context) ([]App, error) + func (c *Cluster) GetClusterFeatures(ctx context.Context) (*proto.Features, error) + func (c *Cluster) GetDatabase(ctx context.Context, dbURI string) (*Database, error) + func (c *Cluster) GetDatabases(ctx context.Context, r *api.GetDatabasesRequest) (*GetDatabasesResponse, error) + func (c *Cluster) GetKubes(ctx context.Context, r *api.GetKubesRequest) (*GetKubesResponse, error) + func (c *Cluster) GetLeafClusters(ctx context.Context) ([]LeafCluster, error) + func (c *Cluster) GetLoggedInUser() LoggedInUser + func (c *Cluster) GetProxyHost() string + func (c *Cluster) GetRequestableRoles(ctx context.Context, req *api.GetRequestableRolesRequest) (*types.AccessCapabilities, error) + func (c *Cluster) GetRoles(ctx context.Context) ([]*types.Role, error) + func (c *Cluster) GetServers(ctx context.Context, r *api.GetServersRequest) (*GetServersResponse, error) + func (c *Cluster) LocalLogin(ctx context.Context, user, password, otpToken string) error + func (c *Cluster) Logout(ctx context.Context) error + func (c *Cluster) PasswordlessLogin(ctx context.Context, stream api.TerminalService_LoginPasswordlessServer) error + func (c *Cluster) ReissueDBCerts(ctx context.Context, routeToDatabase tlsca.RouteToDatabase) error + func (c *Cluster) ReviewAccessRequest(ctx context.Context, req *api.ReviewAccessRequestRequest) (*AccessRequest, error) + func (c *Cluster) SSOLogin(ctx context.Context, providerType, providerName string) error + func (c *Cluster) SyncAuthPreference(ctx context.Context) (*webclient.WebConfigAuthSettings, error) + func (c *Cluster) TransferFile(ctx context.Context, request *api.FileTransferRequest, ...) error + type Config struct + Clock clockwork.Clock + Dir string + InsecureSkipVerify bool + Log *logrus.Entry + func (c *Config) CheckAndSetDefaults() error + type CreateGatewayParams struct + CLICommandProvider gateway.CLICommandProvider + LocalPort string + OnExpiredCert gateway.OnExpiredCertFunc + TCPPortAllocator gateway.TCPPortAllocator + TargetSubresourceName string + TargetURI string + TargetUser string + type Database struct + URI uri.ResourceURI + type DbcmdCLICommandProvider struct + func NewDbcmdCLICommandProvider(storage StorageByResourceURI, execer dbcmd.Execer) DbcmdCLICommandProvider + func (d DbcmdCLICommandProvider) GetCommand(gateway *gateway.Gateway) (string, error) + type FileTransferProgressSender = func(progress *api.FileTransferProgress) error + type GatewayCreator struct + func NewGatewayCreator(resolver Resolver) GatewayCreator + func (g GatewayCreator) CreateGateway(ctx context.Context, params CreateGatewayParams) (*gateway.Gateway, error) + type GetDatabasesResponse struct + Databases []Database + StartKey string + TotalCount int + type GetKubesResponse struct + Kubes []Kube + StartKey string + TotalCount int + type GetServersResponse struct + Servers []Server + StartKey string + TotalCount int + type Kube struct + KubernetesCluster types.KubeCluster + URI uri.ResourceURI + type LeafCluster struct + Connected bool + LoggedInUser LoggedInUser + Name string + URI uri.ResourceURI + type LoggedInUser struct + ActiveRequests []string + Name string + Roles []string + SSHLogins []string + type Resolver interface + ResolveCluster func(string) (*Cluster, error) + type SSHLoginFunc func(context.Context, *keys.PrivateKey) (*auth.SSHLoginResponse, error) + type Server struct + URI uri.ResourceURI + type Storage struct + func NewStorage(cfg Config) (*Storage, error) + func (s *Storage) Add(ctx context.Context, webProxyAddress string) (*Cluster, error) + func (s *Storage) GetByResourceURI(resourceURI string) (*Cluster, error) + func (s *Storage) GetByURI(clusterURI string) (*Cluster, error) + func (s *Storage) ReadAll() ([]*Cluster, error) + func (s *Storage) Remove(ctx context.Context, profileName string) error + func (s *Storage) ResolveCluster(resourceURI string) (*Cluster, error) + type StorageByResourceURI interface + GetByResourceURI func(string) (*Cluster, error)
Go to main page