scheduler

package

Go to main page

Versions in this module

v0

v0.1.21

Jul 31, 2024

Changes in this version

+ const StateInvalid

+ const StateOk

+ var ErrDeploymentNotFound = errors.New("deployment not found")

+ var ErrDomainAlreadyExist = errors.New("domain already exist")

+ var ErrInvalidAnnotations = errors.New("invalid annotations")

+ var ErrInvalidDomain = errors.New("invalid domain")

type Scheduler

+ ContainerManager *container.Manager

+ func (s *Scheduler) AddDeploymentDomain(ctx context.Context, id types.DeploymentID, cert *types.Certificate) error

+ func (s *Scheduler) CloseDeployment(ctx context.Context, deployment *types.Deployment, force bool) error

+ func (s *Scheduler) CreateDeployment(ctx context.Context, deployment *types.Deployment) error

+ func (s *Scheduler) CreateSyncAsset(ctx context.Context, req *types.CreateSyncAssetReq) error

+ func (s *Scheduler) CreateTunnel(ctx context.Context, req *types.CreateTunnelReq) error

+ func (s *Scheduler) DeleteDeploymentDomain(ctx context.Context, id types.DeploymentID, domain string) error

+ func (s *Scheduler) GenerateCandidateCodes(ctx context.Context, count int, nodeType types.NodeType, isTest bool) ([]string, error)

+ func (s *Scheduler) GenerateTokenForDownloadSource(ctx context.Context, nodeID string, cid string) (*types.SourceDownloadInfo, error)

+ func (s *Scheduler) GetDeploymentDomains(ctx context.Context, id types.DeploymentID) ([]*types.DeploymentDomain, error)

+ func (s *Scheduler) GetDeploymentList(ctx context.Context, opt *types.GetDeploymentOption) (*types.GetDeploymentListResp, error)

+ func (s *Scheduler) GetDeploymentProviderIP(ctx context.Context, id types.DeploymentID) (string, error)

+ func (s *Scheduler) GetDownloadInfos(cid string, needCandidate bool) (*types.AssetSourceDownloadInfoRsp, int64, error)

+ func (s *Scheduler) GetEvents(ctx context.Context, deployment *types.Deployment) ([]*types.ServiceEvent, error)

+ func (s *Scheduler) GetIngress(ctx context.Context, id types.DeploymentID) (*types.Ingress, error)

+ func (s *Scheduler) GetLeaseShellEndpoint(ctx context.Context, id types.DeploymentID) (*types.LeaseEndpoint, error)

+ func (s *Scheduler) GetLogs(ctx context.Context, deployment *types.Deployment) ([]*types.ServiceLog, error)

+ func (s *Scheduler) GetProviderList(ctx context.Context, opt *types.GetProviderOption) ([]*types.Provider, error)

+ func (s *Scheduler) GetRemoteAddress(ctx context.Context) (string, error)

+ func (s *Scheduler) GetStatistics(ctx context.Context, id string) (*types.ResourcesStatistics, error)

+ func (s *Scheduler) GetTunserverURLFromUser(ctx context.Context, req *types.TunserverReq) (*types.TunserverRsp, error)

+ func (s *Scheduler) L5Connect(ctx context.Context, opts *types.ConnectOptions) error

+ func (s *Scheduler) ReimburseNodeProfit(ctx context.Context, nodeID, note string, profit float64) error

+ func (s *Scheduler) RemoveCandidateCode(ctx context.Context, code string) error

+ func (s *Scheduler) ResetCandidateCode(ctx context.Context, nodeID, code string) error

+ func (s *Scheduler) SetProperties(ctx context.Context, properties *types.Properties) error

+ func (s *Scheduler) SetTunserverURL(ctx context.Context, nodeID, wsNodeID string) error

+ func (s *Scheduler) SubmitProjectReport(ctx context.Context, req *types.ProjectRecordReq) error

+ func (s *Scheduler) UpdateDeployment(ctx context.Context, deployment *types.Deployment) error

+ func (s *Scheduler) UpdateIngress(ctx context.Context, id types.DeploymentID, annotations map[string]string) error

v0.1.20

Jun 27, 2024

v0.1.19

Jun 27, 2024

Changes in this version

+ var FreeUpDayInterval = 1

type Scheduler

+ ProjectManager *projects.Manager

+ func (s *Scheduler) AssignTunserverURL(ctx context.Context) (*types.TunserverRsp, error)

+ func (s *Scheduler) CalculateExitProfit(ctx context.Context, nodeID string) (types.ExitProfitRsp, error)

+ func (s *Scheduler) CandidateCodeExist(ctx context.Context, code string) (bool, error)

+ func (s *Scheduler) DeleteProject(ctx context.Context, req *types.ProjectReq) error

+ func (s *Scheduler) DeployProject(ctx context.Context, req *types.DeployProjectReq) error

+ func (s *Scheduler) FreeUpDiskSpace(ctx context.Context, nodeID string, size int64) (*types.FreeUpDiskResp, error)

+ func (s *Scheduler) GenerateCandidateCode(ctx context.Context, count int, nodeType types.NodeType, isTest bool) ([]string, error)

+ func (s *Scheduler) GetCandidateCodeInfos(ctx context.Context, nodeID, code string) ([]*types.CandidateCodeInfo, error)

+ func (s *Scheduler) GetCurrentRegionInfos(ctx context.Context, areaID string) (map[string]int, error)

+ func (s *Scheduler) GetNextFreeTime(ctx context.Context, nodeID string) (int64, error)

+ func (s *Scheduler) GetNodeUploadInfo(ctx context.Context, userID string) (*types.UploadInfo, error)

+ func (s *Scheduler) GetNodesFromRegion(ctx context.Context, areaID string) ([]*types.NodeInfo, error)

+ func (s *Scheduler) GetProjectInfo(ctx context.Context, uuid string) (*types.ProjectInfo, error)

+ func (s *Scheduler) GetProjectInfos(ctx context.Context, userID string, limit, offset int) ([]*types.ProjectInfo, error)

+ func (s *Scheduler) GetProjectsForNode(ctx context.Context, nodeID string) ([]*types.ProjectReplicas, error)

+ func (s *Scheduler) ReDetermineNodeNATType(ctx context.Context, nodeID string) error

+ func (s *Scheduler) RedeployFailedProjects(ctx context.Context, ids []string) error

+ func (s *Scheduler) RegisterCandidateNode(ctx context.Context, nodeID, publicKey, code string) (*types.ActivationDetail, error)

+ func (s *Scheduler) StartProject(ctx context.Context, req *types.ProjectReq) error

+ func (s *Scheduler) UpdateNetFlows(ctx context.Context, total, up, down int64) error

+ func (s *Scheduler) UpdateNodeDynamicInfo(ctx context.Context, info *types.NodeDynamicInfo) error

+ func (s *Scheduler) UpdateProject(ctx context.Context, req *types.ProjectReq) error

+ func (s *Scheduler) UpdateProjectStatus(ctx context.Context, list []*types.Project) error

+ func (s *Scheduler) UpdateTunserverURL(ctx context.Context, nodeID string) error

v0.1.19-b

Jun 27, 2024

v0.1.18

Apr 29, 2024

Changes in this version

type Scheduler

+ func (s *Scheduler) AddProfits(ctx context.Context, nodes []string, profit float64) error

+ func (s *Scheduler) GetAssetSourceDownloadInfo(ctx context.Context, cid string) (*types.AssetSourceDownloadInfoRsp, error)

+ func (s *Scheduler) GetProfitDetailsForNode(ctx context.Context, nodeID string, limit, offset int, ts []int) (*types.ListNodeProfitDetailsRsp, error)

+ func (s *Scheduler) PerformSyncData(ctx context.Context, nodeID string) error

+ func (s *Scheduler) SubmitWorkloadReport(ctx context.Context, workload *types.WorkloadRecordReq) error

+ func (s *Scheduler) SubmitWorkloadReportV2(ctx context.Context, workload *types.WorkloadRecordReq) error

v0.1.16

Mar 29, 2024

Changes in this version

type Scheduler

+ func (s *Scheduler) GetReplicasForNode(ctx context.Context, nodeID string, limit, offset int, ...) (*types.ListNodeReplicaRsp, error)

+ func (s *Scheduler) RemoveNodeFailedReplica(ctx context.Context) error

v0.1.15

Mar 26, 2024

Changes in this version

type Scheduler

+ func (s *Scheduler) GetNodeOfIP(ctx context.Context, ip string) ([]string, error)

v0.1.14

Mar 21, 2024

Changes in this version

type Scheduler

+ func (s *Scheduler) CheckIpUsage(ctx context.Context, ip string) (bool, error)

+ func (s *Scheduler) GetAssetView(ctx context.Context, nodeID string, isFromNode bool) (*types.AssetView, error)

+ func (s *Scheduler) GetAssetsInBucket(ctx context.Context, nodeID string, bucketID int, isFromNode bool) ([]string, error)

+ func (s *Scheduler) LoadAWSData(ctx context.Context, limit, offset int, isDistribute bool) ([]*types.AWSDataInfo, error)

+ func (s *Scheduler) StopAssetRecord(ctx context.Context, cids []string) error

v0.1.13

Mar 15, 2024

Changes in this version

type Scheduler

+ func (s *Scheduler) AddAWSData(ctx context.Context, list []types.AWSDataInfo) error

+ func (s *Scheduler) DownloadDataResult(ctx context.Context, bucket, cid string, size int64) error

+ func (s *Scheduler) ElectValidators(ctx context.Context, nodeIDs []string) error

+ func (s *Scheduler) GetNodeOnlineState(ctx context.Context) (bool, error)

+ func (s *Scheduler) GetNodeToken(ctx context.Context, nodeID string) (string, error)

+ func (s *Scheduler) SwitchFillDiskTimer(ctx context.Context, open bool) error

v0.1.11

Mar 1, 2024

Changes in this version

type Scheduler

+ Transport *quic.Transport

+ func (s *Scheduler) CreateAssetGroup(ctx context.Context, userID, name string, parent int) (*types.AssetGroup, error)

+ func (s *Scheduler) DeactivateNode(ctx context.Context, nodeID string, hours int) error

+ func (s *Scheduler) DeleteAssetGroup(ctx context.Context, userID string, gid int) error

+ func (s *Scheduler) GetAPPKeyPermissions(ctx context.Context, userID string, keyName string) ([]string, error)

+ func (s *Scheduler) GetAssetStatus(ctx context.Context, userID, assetCID string) (*types.AssetStatus, error)

+ func (s *Scheduler) GetCandidateIPs(ctx context.Context) ([]*types.NodeIPInfo, error)

+ func (s *Scheduler) GetCandidateNodeIP(ctx context.Context, nodeID string) (string, error)

+ func (s *Scheduler) GetMinioConfigFromCandidate(ctx context.Context, nodeID string) (*types.MinioConfig, error)

+ func (s *Scheduler) GetNodePublicKey(ctx context.Context, nodeID string) (string, error)

+ func (s *Scheduler) GetReplicaEvents(ctx context.Context, start, end time.Time, limit, offset int) (*types.ListReplicaEventRsp, error)

+ func (s *Scheduler) GetReplicas(ctx context.Context, cid string, limit, offset int) (*types.ListReplicaRsp, error)

+ func (s *Scheduler) GetRetrieveEventRecords(ctx context.Context, nodeID string, limit, offset int) (*types.ListRetrieveEventRsp, error)

+ func (s *Scheduler) GetUserAccessToken(ctx context.Context, userID string) (string, error)

+ func (s *Scheduler) GetUserInfo(ctx context.Context, userID string) (*types.UserInfo, error)

+ func (s *Scheduler) GetUserInfos(ctx context.Context, userIDs []string) (map[string]*types.UserInfo, error)

+ func (s *Scheduler) GetUserStorageStats(ctx context.Context, userID string) (*types.StorageStats, error)

+ func (s *Scheduler) ListAssetGroup(ctx context.Context, userID string, parent, limit int, offset int) (*types.ListAssetGroupRsp, error)

+ func (s *Scheduler) ListAssetSummary(ctx context.Context, userID string, parent, limit, offset int) (*types.ListAssetSummaryRsp, error)

+ func (s *Scheduler) ListUserStorageStats(ctx context.Context, limit, offset int) (*types.ListStorageStatsRsp, error)

+ func (s *Scheduler) MinioUploadFileEvent(ctx context.Context, event *types.MinioUploadFileEvent) error

+ func (s *Scheduler) MoveAssetGroup(ctx context.Context, userID string, groupID, targetGroupID int) error

+ func (s *Scheduler) MoveAssetToGroup(ctx context.Context, userID, cid string, groupID int) error

+ func (s *Scheduler) NodeKeepaliveV2(ctx context.Context) (uuid.UUID, error)

+ func (s *Scheduler) RegisterEdgeNode(ctx context.Context, nodeID, publicKey string) (*types.ActivationDetail, error)

+ func (s *Scheduler) RenameAssetGroup(ctx context.Context, userID, newName string, groupID int) error

+ func (s *Scheduler) SetUserVIP(ctx context.Context, userID string, enableVIP bool) error

+ func (s *Scheduler) UndoNodeDeactivation(ctx context.Context, nodeID string) error

+ func (s *Scheduler) UpdateBandwidths(ctx context.Context, bandwidthDown, bandwidthUp int64) error

+ func (s *Scheduler) UpdateShareStatus(ctx context.Context, userID, assetCID string) error

+ func (s *Scheduler) UserAssetDownloadResult(ctx context.Context, userID, cid string, totalTraffic, peakBandwidth int64) error

+ func (s *Scheduler) VerifyTokenWithLimitCount(ctx context.Context, token string) (*types.JWTPayload, error)

v0.1.10

Jun 28, 2023

Changes in this version

type Scheduler

+ WorkloadManager *workload.Manager

+ func (s *Scheduler) AllocateStorage(ctx context.Context, userID string) (*types.StorageSize, error)

+ func (s *Scheduler) CreateAPIKey(ctx context.Context, userID, keyName string) (string, error)

+ func (s *Scheduler) CreateAsset(ctx context.Context, req *types.CreateAssetReq) (*types.CreateAssetRsp, error)

+ func (s *Scheduler) CreateUserAsset(ctx context.Context, assetCID, assetName string, assetSize int64) (*types.CreateAssetRsp, error)

+ func (s *Scheduler) DeleteAPIKey(ctx context.Context, userID, name string) error

+ func (s *Scheduler) DeleteAsset(ctx context.Context, userID, assetCID string) error

+ func (s *Scheduler) DeleteUserAsset(ctx context.Context, assetCID string) error

+ func (s *Scheduler) GetAPIKeys(ctx context.Context, userID string) (map[string]string, error)

+ func (s *Scheduler) GetAssetCount(ctx context.Context) (int, error)

+ func (s *Scheduler) GetAssetsForNode(ctx context.Context, nodeID string, limit, offset int) (*types.ListNodeAssetRsp, error)

+ func (s *Scheduler) GetReplicaEventsForNode(ctx context.Context, nodeID string, limit, offset int) (*types.ListReplicaEventRsp, error)

+ func (s *Scheduler) GetStorageSize(ctx context.Context, userID string) (*types.StorageSize, error)

+ func (s *Scheduler) GetWorkloadRecord(ctx context.Context, tokenID string) (*types.WorkloadRecord, error)

+ func (s *Scheduler) GetWorkloadRecords(ctx context.Context, nodeID string, limit, offset int) (*types.ListWorkloadRecordRsp, error)

+ func (s *Scheduler) ListAssets(ctx context.Context, userID string, limit, offset int) ([]*types.AssetRecord, error)

+ func (s *Scheduler) ListUserAssets(ctx context.Context, limit, offset int) ([]*types.AssetRecord, error)

+ func (s *Scheduler) RequestActivationCodes(ctx context.Context, nodeType types.NodeType, count int) ([]*types.NodeActivation, error)

+ func (s *Scheduler) ShareAssets(ctx context.Context, userID string, assetCIDs []string) (map[string]string, error)

+ func (s *Scheduler) ShareUserAssets(ctx context.Context, assetCID []string) (map[string]string, error)

+ func (s *Scheduler) UserAPIKeysExists(ctx context.Context, userID string) error

v0.1.9

Jun 5, 2023

Changes in this version

+ type EdgeUpdateManager struct

+ func NewEdgeUpdateManager(db *db.SQLDB) (*EdgeUpdateManager, error)

+ func (eu *EdgeUpdateManager) DeleteEdgeUpdateConfig(ctx context.Context, nodeType int) error

+ func (eu *EdgeUpdateManager) GetEdgeUpdateConfigs(ctx context.Context) (map[int]*api.EdgeUpdateConfig, error)

+ func (eu *EdgeUpdateManager) SetEdgeUpdateConfig(ctx context.Context, info *api.EdgeUpdateConfig) error

+ type Scheduler struct

+ AssetManager *assets.Manager

+ DataSync *sync.DataSync

+ GetSchedulerConfigFunc dtypes.GetSchedulerConfigFunc

+ NatManager *nat.Manager

+ NodeManager *node.Manager

+ PrivateKey *rsa.PrivateKey

+ SchedulerCfg *config.SchedulerCfg

+ SetSchedulerConfigFunc dtypes.SetSchedulerConfigFunc

+ ValidationMgr *validation.Manager

+ func (s *Scheduler) CandidateConnect(ctx context.Context, opts *types.ConnectOptions) error

+ func (s *Scheduler) EdgeConnect(ctx context.Context, opts *types.ConnectOptions) error

+ func (s *Scheduler) GetAssetListForBucket(ctx context.Context, bucketID uint32) ([]string, error)

+ func (s *Scheduler) GetAssetRecord(ctx context.Context, cid string) (*types.AssetRecord, error)

+ func (s *Scheduler) GetAssetRecords(ctx context.Context, limit, offset int, statuses []string, ...) ([]*types.AssetRecord, error)

+ func (s *Scheduler) GetAssetReplicaInfos(ctx context.Context, req types.ListReplicaInfosReq) (*types.ListReplicaInfosRsp, error)

+ func (s *Scheduler) GetAssetStatistics(ctx context.Context) (*types.AssetStatistics, error)

+ func (s *Scheduler) GetCandidateDownloadInfos(ctx context.Context, cid string) ([]*types.CandidateDownloadInfo, error)

+ func (s *Scheduler) GetCandidateURLsForDetectNat(ctx context.Context) ([]string, error)

+ func (s *Scheduler) GetEdgeDownloadInfos(ctx context.Context, cid string) (*types.EdgeDownloadInfoList, error)

+ func (s *Scheduler) GetEdgeExternalServiceAddress(ctx context.Context, nodeID, candidateURL string) (string, error)

+ func (s *Scheduler) GetExternalAddress(ctx context.Context) (string, error)

+ func (s *Scheduler) GetNodeInfo(ctx context.Context, nodeID string) (types.NodeInfo, error)

+ func (s *Scheduler) GetNodeList(ctx context.Context, offset int, limit int) (*types.ListNodesRsp, error)

+ func (s *Scheduler) GetOnlineNodeCount(ctx context.Context, nodeType types.NodeType) (int, error)

+ func (s *Scheduler) GetSchedulerPublicKey(ctx context.Context) (string, error)

+ func (s *Scheduler) GetValidationInfo(ctx context.Context) (*types.ValidationInfo, error)

+ func (s *Scheduler) GetValidationResults(ctx context.Context, startTime, endTime time.Time, pageNumber, pageSize int) (*types.ListValidationResultRsp, error)

+ func (s *Scheduler) NatPunch(ctx context.Context, target *types.NatPunchReq) error

+ func (s *Scheduler) NodeExists(ctx context.Context, nodeID string) error

+ func (s *Scheduler) NodeKeepalive(ctx context.Context) (uuid.UUID, error)

+ func (s *Scheduler) NodeLogin(ctx context.Context, nodeID, sign string) (string, error)

+ func (s *Scheduler) NodeRemoveAssetResult(ctx context.Context, resultInfo types.RemoveAssetResult) error

+ func (s *Scheduler) NodeValidationResult(ctx context.Context, result api.ValidationResult, sign string) error

+ func (s *Scheduler) PullAsset(ctx context.Context, info *types.PullAssetReq) error

+ func (s *Scheduler) RePullFailedAssets(ctx context.Context, hashes []types.AssetHash) error

+ func (s *Scheduler) RegisterNode(ctx context.Context, pKey string, nodeType types.NodeType) (nodeID string, err error)

+ func (s *Scheduler) RemoveAssetRecord(ctx context.Context, cid string) error

+ func (s *Scheduler) RemoveAssetReplica(ctx context.Context, cid, nodeID string) error

+ func (s *Scheduler) SubmitNodeWorkloadReport(ctx context.Context, r io.Reader) error

+ func (s *Scheduler) SubmitUserWorkloadReport(ctx context.Context, r io.Reader) error

+ func (s *Scheduler) TriggerElection(ctx context.Context) error

+ func (s *Scheduler) UnregisterNode(ctx context.Context, nodeID string) error

+ func (s *Scheduler) UpdateAssetExpiration(ctx context.Context, cid string, t time.Time) error

+ func (s *Scheduler) UpdateNodePort(ctx context.Context, nodeID, port string) error

+ func (s *Scheduler) VerifyNodeAuthToken(ctx context.Context, token string) ([]auth.Permission, error)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL