Versions in this module Expand all Collapse all v11 v11.3.3 Dec 13, 2022 Changes in this version + type Config struct + CreateTshdEventsClientCredsFunc CreateTshdEventsClientCredsFunc + GatewayCertReissuer *GatewayCertReissuer + GatewayCreator GatewayCreator + Log *logrus.Entry + Storage *clusters.Storage + TCPPortAllocator gateway.TCPPortAllocator + func (c *Config) CheckAndSetDefaults() error + type CreateGatewayParams struct + LocalPort string + TargetSubresourceName string + TargetURI string + TargetUser string + type CreateTshdEventsClientCredsFunc func() (grpc.DialOption, error) + type DBCertReissuer interface + ReissueDBCerts func(context.Context, tlsca.RouteToDatabase) error + type GatewayCertReissuer struct + Log *logrus.Entry + TSHDEventsClient TSHDEventsClient + func (r *GatewayCertReissuer) ReissueCert(ctx context.Context, gateway *gateway.Gateway, dbCertReissuer DBCertReissuer) error + type GatewayCreator interface + CreateGateway func(context.Context, clusters.CreateGatewayParams) (*gateway.Gateway, error) + type Service struct + func New(cfg Config) (*Service, error) + func (s *Service) AddCluster(ctx context.Context, webProxyAddress string) (*clusters.Cluster, error) + func (s *Service) AssumeRole(ctx context.Context, req *api.AssumeRoleRequest) error + func (s *Service) ClusterLogout(ctx context.Context, uri string) error + func (s *Service) CreateAccessRequest(ctx context.Context, req *api.CreateAccessRequestRequest) (*clusters.AccessRequest, error) + func (s *Service) CreateGateway(ctx context.Context, params CreateGatewayParams) (*gateway.Gateway, error) + func (s *Service) DeleteAccessRequest(ctx context.Context, req *api.DeleteAccessRequestRequest) error + func (s *Service) GetAccessRequest(ctx context.Context, req *api.GetAccessRequestRequest) ([]clusters.AccessRequest, error) + func (s *Service) GetAccessRequests(ctx context.Context, req *api.GetAccessRequestsRequest) ([]clusters.AccessRequest, error) + func (s *Service) GetAllKubes(ctx context.Context, uri string) ([]clusters.Kube, error) + func (s *Service) GetAllServers(ctx context.Context, clusterURI string) ([]clusters.Server, error) + func (s *Service) GetCluster(ctx context.Context, uri string) (*clusters.Cluster, error) + func (s *Service) GetKubes(ctx context.Context, req *api.GetKubesRequest) (*clusters.GetKubesResponse, error) + func (s *Service) GetRequestableRoles(ctx context.Context, req *api.GetRequestableRolesRequest) (*api.GetRequestableRolesResponse, error) + func (s *Service) GetServers(ctx context.Context, req *api.GetServersRequest) (*clusters.GetServersResponse, error) + func (s *Service) ListApps(ctx context.Context, clusterURI string) ([]clusters.App, error) + func (s *Service) ListGateways() []gateway.Gateway + func (s *Service) ListLeafClusters(ctx context.Context, uri string) ([]clusters.LeafCluster, error) + func (s *Service) ListRootClusters(ctx context.Context) ([]*clusters.Cluster, error) + func (s *Service) RemoveCluster(ctx context.Context, uri string) error + func (s *Service) RemoveGateway(gatewayURI string) error + func (s *Service) ResolveCluster(uri string) (*clusters.Cluster, error) + func (s *Service) RestartGateway(ctx context.Context, gatewayURI string) error + func (s *Service) ReviewAccessRequest(ctx context.Context, req *api.ReviewAccessRequestRequest) (*clusters.AccessRequest, error) + func (s *Service) SetGatewayLocalPort(gatewayURI, localPort string) (*gateway.Gateway, error) + func (s *Service) SetGatewayTargetSubresourceName(gatewayURI, targetSubresourceName string) (*gateway.Gateway, error) + func (s *Service) Stop() + func (s *Service) TransferFile(ctx context.Context, request *api.FileTransferRequest, ...) error + func (s *Service) UpdateAndDialTshdEventsServerAddress(serverAddress string) error + type TSHDEventsClient interface + Relogin func(ctx context.Context, in *api.ReloginRequest, opts ...grpc.CallOption) (*api.ReloginResponse, error) + SendNotification func(ctx context.Context, in *api.SendNotificationRequest, opts ...grpc.CallOption) (*api.SendNotificationResponse, error)