Versions in this module Expand all Collapse all v1 v1.0.1 Aug 15, 2024 Changes in this version + var TaskCleanDurationTimestamp int64 = 7 * 24 * 60 * 60 + func InternalReverseHandler(handler func(context.Context, *http.Request, map[string]string) error) http.Handler + func ProxyMetrics(ctx context.Context, r *http.Request, vars map[string]string) error + type Endpoints struct + Addons *addons.Addons + CachedJS jsonstore.JsonStore + CloudAccount *cloud_account.CloudAccount + ClusterSvc clusterpb.ClusterServiceServer + Credential tokenpb.TokenServiceServer + CronService cronpb.CronServiceServer + Ess *ess.Ess + JS jsonstore.JsonStore + Mns *mns.Mns + PipelineSvc pipelinepb.PipelineServiceServer + Resource *resource.Resource + SteveAggregator *steve.Aggregator + SteveCacheConfig *steveCacheConfig + func New(ctx context.Context, db *dbclient.DBClient, js jsonstore.JsonStore, ...) *Endpoints + func (e *Endpoints) AddCloudClusters(ctx context.Context, r *http.Request, vars map[string]string) (resp httpserver.Responser, err error) + func (e *Endpoints) AddCloudNodes(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error) + func (e *Endpoints) AddNodes(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error) + func (e *Endpoints) AddonScale(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error) + func (e *Endpoints) AutoRenewECS(ctx context.Context, r *http.Request, vars map[string]string) (resp httpserver.Responser, err error) + func (e *Endpoints) BatchOfflineEdgeCluster(ctx context.Context, r *http.Request, vars map[string]string) (resp httpserver.Responser, err error) + func (e *Endpoints) BatchUpgradeEdgeCluster(ctx context.Context, r *http.Request, vars map[string]string) (resp httpserver.Responser, err error) + func (e *Endpoints) CetOnsDetailInfo(ctx context.Context, r *http.Request, vars map[string]string) (resp httpserver.Responser, err error) + func (e *Endpoints) CetRedisDetailInfo(ctx context.Context, r *http.Request, vars map[string]string) (resp httpserver.Responser, err error) + func (e *Endpoints) CloudResourceOverview(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error) + func (e *Endpoints) CloudResourcePermissionCheck(ctx context.Context, userId, orgId, clusterName, action string) error + func (e *Endpoints) CloudResourceSetTag(ctx context.Context, r *http.Request, vars map[string]string) (resp httpserver.Responser, err error) + func (e *Endpoints) ClusterHook(ctx context.Context, r *http.Request, vars map[string]string) (resp httpserver.Responser, err error) + func (e *Endpoints) ClusterInfo(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error) + func (e *Endpoints) ClusterPreview(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error) + func (e *Endpoints) ClusterUpdate(ctx context.Context, r *http.Request, vars map[string]string) (resp httpserver.Responser, err error) + func (e *Endpoints) CreateAccessKey(ctx context.Context, r *http.Request, vars map[string]string) (resp httpserver.Responser, err error) + func (e *Endpoints) CreateAccount(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error) + func (e *Endpoints) CreateAddonCheck(req apistructs.CreateCloudResourceBaseInfo) error + func (e *Endpoints) CreateGatewayVpcGrant(ctx context.Context, r *http.Request, vars map[string]string) (resp httpserver.Responser, err error) + func (e *Endpoints) CreateMysqlAccount(ctx context.Context, r *http.Request, vars map[string]string) (resp httpserver.Responser, err error) + func (e *Endpoints) CreateMysqlDatabase(ctx context.Context, r *http.Request, vars map[string]string) (resp httpserver.Responser, err error) + func (e *Endpoints) CreateMysqlInstance(ctx context.Context, r *http.Request, vars map[string]string) (resp httpserver.Responser, err error) + func (e *Endpoints) CreateOSS(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error) + func (e *Endpoints) CreateOnsGroup(ctx context.Context, r *http.Request, vars map[string]string) (resp httpserver.Responser, err error) + func (e *Endpoints) CreateOnsInstance(ctx context.Context, r *http.Request, vars map[string]string) (resp httpserver.Responser, err error) + func (e *Endpoints) CreateOnsTopic(ctx context.Context, r *http.Request, vars map[string]string) (resp httpserver.Responser, err error) + func (e *Endpoints) CreateRedis(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error) + func (e *Endpoints) CreateVPC(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error) + func (e *Endpoints) CreateVSW(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error) + func (e *Endpoints) DealTaskEvent(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error) + func (e *Endpoints) DeleteAccount(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error) + func (e *Endpoints) DeleteGateway(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error) + func (e *Endpoints) DeleteMysql(ctx context.Context, r *http.Request, vars map[string]string) (resp httpserver.Responser, err error) + func (e *Endpoints) DeleteMysqlDatabase(ctx context.Context, r *http.Request, vars map[string]string) (resp httpserver.Responser, err error) + func (e *Endpoints) DeleteOSSResource(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error) + func (e *Endpoints) DeleteOns(ctx context.Context, r *http.Request, vars map[string]string) (resp httpserver.Responser, err error) + func (e *Endpoints) DeleteOnsTopic(ctx context.Context, r *http.Request, vars map[string]string) (resp httpserver.Responser, err error) + func (e *Endpoints) DeleteRedisResource(ctx context.Context, r *http.Request, vars map[string]string) (resp httpserver.Responser, err error) + func (e *Endpoints) DoRemoteAction(ctx context.Context, w http.ResponseWriter, r *http.Request, ...) error + func (e *Endpoints) ECSTrending(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error) + func (e *Endpoints) GetAccessKey(ctx context.Context, r *http.Request, vars map[string]string) (resp httpserver.Responser, err error) + func (e *Endpoints) GetAddonConfig(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error) + func (e *Endpoints) GetAddonStatus(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error) + func (e *Endpoints) GetCloudAccount(ctx context.Context, r *http.Request, vars map[string]string) (resp httpserver.Responser, err error) + func (e *Endpoints) GetCluster() *clusters.Clusters + func (e *Endpoints) GetIdentity(r *http.Request) (apistructs.Identity, httpserver.Responser) + func (e *Endpoints) GetMysqlDetailInfo(ctx context.Context, r *http.Request, vars map[string]string) (resp httpserver.Responser, err error) + func (e *Endpoints) GetResourceClass(ctx context.Context, r *http.Request, vars map[string]string) (resp httpserver.Responser, err error) + func (e *Endpoints) GetResourceClusterTrend(ctx context.Context, r *http.Request, vars map[string]string) (resp httpserver.Responser, err error) + func (e *Endpoints) GetResourceGauge(ctx context.Context, r *http.Request, vars map[string]string) (resp httpserver.Responser, err error) + func (e *Endpoints) GetResourceProjectTrend(ctx context.Context, r *http.Request, vars map[string]string) (resp httpserver.Responser, err error) + func (e *Endpoints) GetScriptInfo(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error) + func (e *Endpoints) GetVpcInfoByCluster(ak_ctx aliyun_resources.Context, r *http.Request, cluster string) (libvpc.Vpc, httpserver.Responser) + func (e *Endpoints) GrantMysqlAccountPrivilege(ctx context.Context, r *http.Request, vars map[string]string) (resp httpserver.Responser, err error) + func (e *Endpoints) ImportCluster(ctx context.Context, r *http.Request, vars map[string]string) (resp httpserver.Responser, err error) + func (e *Endpoints) Info(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error) + func (e *Endpoints) InitCluster(ctx context.Context, w http.ResponseWriter, r *http.Request, ...) error + func (e *Endpoints) InitClusterRetry(ctx context.Context, r *http.Request, vars map[string]string) (resp httpserver.Responser, err error) + func (e *Endpoints) InitRecord(r dbclient.Record) (*dbclient.Record, httpserver.Responser) + func (e *Endpoints) IsManager(userID string, scopeType apistructs.ScopeType, scopeID string) error + func (e *Endpoints) ListAccount(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error) + func (e *Endpoints) ListAliyunResources(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error) + func (e *Endpoints) ListECS(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error) + func (e *Endpoints) ListGatewayAndVpc(ctx context.Context, r *http.Request, vars map[string]string) (resp httpserver.Responser, err error) + func (e *Endpoints) ListK8SClusters(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error) + func (e *Endpoints) ListLabels(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error) + func (e *Endpoints) ListMysql(ctx context.Context, r *http.Request, vars map[string]string) (resp httpserver.Responser, err error) + func (e *Endpoints) ListMysqlAccount(ctx context.Context, r *http.Request, vars map[string]string) (resp httpserver.Responser, err error) + func (e *Endpoints) ListMysqlDatabase(ctx context.Context, r *http.Request, vars map[string]string) (resp httpserver.Responser, err error) + func (e *Endpoints) ListOSS(ctx context.Context, r *http.Request, vars map[string]string) (resp httpserver.Responser, err error) + func (e *Endpoints) ListOns(ctx context.Context, r *http.Request, vars map[string]string) (resp httpserver.Responser, err error) + func (e *Endpoints) ListOnsGroup(ctx context.Context, r *http.Request, vars map[string]string) (resp httpserver.Responser, err error) + func (e *Endpoints) ListOnsTopic(ctx context.Context, r *http.Request, vars map[string]string) (resp httpserver.Responser, err error) + func (e *Endpoints) ListOrgRunningTasks(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error) + func (e *Endpoints) ListRedis(ctx context.Context, r *http.Request, vars map[string]string) (resp httpserver.Responser, err error) + func (e *Endpoints) ListRegion(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error) + func (e *Endpoints) ListVPC(ctx context.Context, r *http.Request, vars map[string]string) (resp httpserver.Responser, err error) + func (e *Endpoints) ListVSW(ctx context.Context, r *http.Request, vars map[string]string) (resp httpserver.Responser, err error) + func (e *Endpoints) ListZone(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error) + func (e *Endpoints) LockCluster(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error) + func (e *Endpoints) Logs(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error) + func (e *Endpoints) MetricsQuery(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error) + func (e *Endpoints) OfflineEdgeCluster(ctx context.Context, r *http.Request, vars map[string]string) (resp httpserver.Responser, err error) + func (e *Endpoints) OrgClusterInfo(ctx context.Context, r *http.Request, vars map[string]string) (resp httpserver.Responser, err error) + func (e *Endpoints) OrgPermCheck(userID, orgID, action string) error + func (e *Endpoints) PermissionCheck(userID, orgID, projectID, action string) error + func (e *Endpoints) Query(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error) + func (e *Endpoints) QueryCloudResourceDetail(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error) + func (e *Endpoints) RecordTypeList(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error) + func (e *Endpoints) RegistryReadonly(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error) + func (e *Endpoints) RegistryRemoveLayers(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error) + func (e *Endpoints) RegistryRemoveManifests(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error) + func (e *Endpoints) ResetAccessKey(ctx context.Context, r *http.Request, vars map[string]string) (resp httpserver.Responser, err error) + func (e *Endpoints) ResetMysqlAccountPassword(ctx context.Context, r *http.Request, vars map[string]string) (resp httpserver.Responser, err error) + func (e *Endpoints) ResourceOverviewReport(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error) + func (e *Endpoints) RestartECS(ctx context.Context, r *http.Request, vars map[string]string) (resp httpserver.Responser, err error) + func (e *Endpoints) RmNodes(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error) + func (e *Endpoints) Routes() []httpserver.Endpoint + func (e *Endpoints) ServeScript(ctx context.Context, w http.ResponseWriter, r *http.Request, ...) error + func (e *Endpoints) StartECS(ctx context.Context, r *http.Request, vars map[string]string) (resp httpserver.Responser, err error) + func (e *Endpoints) StopECS(ctx context.Context, r *http.Request, vars map[string]string) (resp httpserver.Responser, err error) + func (e *Endpoints) SyncTaskStatus(interval time.Duration) + func (e *Endpoints) TagResources(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error) + func (e *Endpoints) TaskClean(interval time.Duration) + func (e *Endpoints) UnlockCluster(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error) + func (e *Endpoints) UpdateAddonConfig(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error) + func (e *Endpoints) UpdateLabels(ctx context.Context, r *http.Request, vars map[string]string) (resp httpserver.Responser, err error) + func (e *Endpoints) UpgradeEdgeCluster(ctx context.Context, r *http.Request, vars map[string]string) (resp httpserver.Responser, err error) + func (e *Endpoints) VPCTagCluster(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error) + type Option func(*Endpoints) + func WithBundle(bdl *bundle.Bundle) Option + func WithClusterServiceServer(clusterSvc clusterpb.ClusterServiceServer) Option + func WithCredential(c tokenpb.TokenServiceServer) Option + func WithCronServiceServer(cronService cronpb.CronServiceServer) Option + func WithOrg(org org.Interface) Option + func WithOrgResource(o *org_resource.OrgResource) Option + func WithPipelineSvc(pipelineSvc pipelinepb.PipelineServiceServer) Option + func WithResourceTable(reportTable *resource.ReportTable) Option + func WithSteveCacheConfig(size int) Option
Go to main page