db

package
v0.1.20 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 27, 2024 License: MIT Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func InitTables 

func InitTables(d *SQLDB, serverID dtypes.ServerID) error

InitTables initializes data tables.

Types

type SQLDB 

type SQLDB struct {
	// contains filtered or unexported fields
}

SQLDB represents a scheduler sql database.

func NewSQLDB 

func NewSQLDB(db *sqlx.DB) (*SQLDB, error)

NewSQLDB creates a new SQLDB instance.

func (*SQLDB) AddNodeProfit added in v0.1.19 

func (n *SQLDB) AddNodeProfit(profitInfo *types.ProfitDetails) error

func (*SQLDB) AssetExists 

func (n *SQLDB) AssetExists(hash string, serverID dtypes.ServerID) (bool, error)

AssetExists checks if an asset exists in the state machine table of the specified server.

func (*SQLDB) AssetExistsOfUser added in v0.1.11 

func (n *SQLDB) AssetExistsOfUser(hash, userID string) (bool, error)

AssetExistsOfUser checks if an asset exists

func (*SQLDB) AssetGroupExists added in v0.1.11 

func (n *SQLDB) AssetGroupExists(userID string, gid int) (bool, error)

AssetGroupExists is group exists

func (*SQLDB) CleanData added in v0.1.18 

func (n *SQLDB) CleanData() error

CleanData delete events

func (*SQLDB) CreateAssetGroup added in v0.1.11 

func (n *SQLDB) CreateAssetGroup(info *types.AssetGroup) (*types.AssetGroup, error)

CreateAssetGroup create a group

func (*SQLDB) DeleteAssetGroup added in v0.1.11 

func (n *SQLDB) DeleteAssetGroup(userID string, gid int) error

DeleteAssetGroup delete asset group

func (*SQLDB) DeleteAssetRecordsOfNode added in v0.1.11 

func (n *SQLDB) DeleteAssetRecordsOfNode(nodeID string) error

DeleteAssetRecordsOfNode clean asset records of node

func (*SQLDB) DeleteAssetReplica 

func (n *SQLDB) DeleteAssetReplica(hash, nodeID string) error

DeleteAssetReplica remove a replica associated with a given asset hash from the database.

func (*SQLDB) DeleteAssetUser added in v0.1.10 

func (n *SQLDB) DeleteAssetUser(hash, userID string) error

DeleteAssetUser delete asset and user info

func (*SQLDB) DeleteAssetsView 

func (n *SQLDB) DeleteAssetsView(nodeID string) error

DeleteAssetsView delete the asset view for node

func (*SQLDB) DeleteBucket 

func (n *SQLDB) DeleteBucket(bucketID string) error

DeleteBucket delete the bucket

func (*SQLDB) DeleteCandidateCodeInfo added in v0.1.19 

func (n *SQLDB) DeleteCandidateCodeInfo(code string) error

DeleteCandidateCodeInfo code info

func (*SQLDB) DeleteEdgeUpdateConfig 

func (n *SQLDB) DeleteEdgeUpdateConfig(nodeType int) error

DeleteEdgeUpdateConfig delete edge update info

func (*SQLDB) DeleteNodeInfo 

func (n *SQLDB) DeleteNodeInfo(nodeID string) error

DeleteNodeInfo delete Node info

func (*SQLDB) DeleteProjectInfo added in v0.1.19 

func (n *SQLDB) DeleteProjectInfo(serverID dtypes.ServerID, id string) error

DeleteProjectInfo deletes

func (*SQLDB) DeleteProjectReplica added in v0.1.19 

func (n *SQLDB) DeleteProjectReplica(id, nodeID string, event types.ProjectEvent) error

DeleteProjectReplica deletes

func (*SQLDB) DeleteReplenishBackup added in v0.1.11 

func (n *SQLDB) DeleteReplenishBackup(hash string) error

DeleteReplenishBackup delete

func (*SQLDB) DeleteReplicaOfTimeout added in v0.1.18 

func (n *SQLDB) DeleteReplicaOfTimeout(statuses, hs []string) error

func (*SQLDB) DeleteUnfinishedProjectReplicas added in v0.1.19 

func (n *SQLDB) DeleteUnfinishedProjectReplicas(id string) error

DeleteUnfinishedProjectReplicas deletes the incomplete replicas with the given hash from the database.

func (*SQLDB) DeleteUnfinishedReplicas 

func (n *SQLDB) DeleteUnfinishedReplicas(hash string) error

DeleteUnfinishedReplicas deletes the incomplete replicas with the given hash from the database.

func (*SQLDB) GetAssetCountsForUser added in v0.1.11 

func (n *SQLDB) GetAssetCountsForUser(user string, groupID int) (int, error)

GetAssetCountsForUser Get asset count

func (*SQLDB) GetAssetExpiration added in v0.1.11 

func (n *SQLDB) GetAssetExpiration(hash, userID string) (time.Time, error)

func (*SQLDB) GetAssetGroupCount added in v0.1.11 

func (n *SQLDB) GetAssetGroupCount(userID string) (int64, error)

GetAssetGroupCount get asset group count of user

func (*SQLDB) GetAssetGroupParent added in v0.1.11 

func (n *SQLDB) GetAssetGroupParent(gid int) (int, error)

GetAssetGroupParent get a group parent

func (*SQLDB) GetAssetName added in v0.1.11 

func (n *SQLDB) GetAssetName(hash, userID string) (string, error)

GetAssetName Get asset name of user

func (*SQLDB) GetAssetVisitCount added in v0.1.11 

func (n *SQLDB) GetAssetVisitCount(assetHash string) (int, error)

GetAssetVisitCount get asset visit count

func (*SQLDB) GetCandidateCodeInfo added in v0.1.19 

func (n *SQLDB) GetCandidateCodeInfo(code string) (*types.CandidateCodeInfo, error)

GetCandidateCodeInfo code info

func (*SQLDB) GetCandidateCodeInfoForNodeID added in v0.1.19 

func (n *SQLDB) GetCandidateCodeInfoForNodeID(nodeID string) (*types.CandidateCodeInfo, error)

GetCandidateCodeInfoForNodeID code info

func (*SQLDB) GetCandidateCodeInfos added in v0.1.19 

func (n *SQLDB) GetCandidateCodeInfos() ([]*types.CandidateCodeInfo, error)

GetCandidateCodeInfos code info

func (*SQLDB) GetNodePullingCount added in v0.1.15 

func (n *SQLDB) GetNodePullingCount(serverID dtypes.ServerID, nodeID string, statuses []string) (int64, error)

GetNodePullingCount

func (*SQLDB) GetOnlineCount added in v0.1.19 

func (n *SQLDB) GetOnlineCount(node string, date time.Time) (int, error)

GetOnlineCount

func (*SQLDB) GetSizeForUserAsset added in v0.1.11 

func (n *SQLDB) GetSizeForUserAsset(hash, userID string) (int64, error)

GetSizeForUserAsset Get asset size of user

func (*SQLDB) GetUserAssetCountByGroupID added in v0.1.11 

func (n *SQLDB) GetUserAssetCountByGroupID(user string, groupID int) (int, error)

GetUserAssetCountByGroupID Get count by group id

func (*SQLDB) GetUserStorageSize added in v0.1.10 

func (n *SQLDB) GetUserStorageSize(user string) (int64, error)

GetUserStorageSize Get the Storage Size already used by the user

func (*SQLDB) IsValidator 

func (n *SQLDB) IsValidator(nodeID string) (bool, error)

IsValidator Determine whether the node is a validator

func (*SQLDB) ListAWSData added in v0.1.13 

func (n *SQLDB) ListAWSData(limit, offset int, isDistribute bool) ([]*types.AWSDataInfo, error)

ListAWSData

func (*SQLDB) ListAssetGroupForUser added in v0.1.11 

func (n *SQLDB) ListAssetGroupForUser(user string, parent, limit, offset int) (*types.ListAssetGroupRsp, error)

ListAssetGroupForUser get asset group list

func (*SQLDB) ListAssetsForUser added in v0.1.10 

func (n *SQLDB) ListAssetsForUser(user string, limit, offset, groupID int) ([]*types.UserAssetDetail, error)

ListAssetsForUser Get a list of assets by user

func (*SQLDB) ListStorageStatsOfUsers added in v0.1.11 

func (n *SQLDB) ListStorageStatsOfUsers(limit, offset int) (*types.ListStorageStatsRsp, error)

ListStorageStatsOfUsers load users storage stats

func (*SQLDB) ListUsersForAsset added in v0.1.10 

func (n *SQLDB) ListUsersForAsset(hash string) ([]string, error)

ListUsersForAsset Get a list of users by asset

func (*SQLDB) LoadAWSData added in v0.1.13 

func (n *SQLDB) LoadAWSData(bucket string) (*types.AWSDataInfo, error)

LoadAWSData

func (*SQLDB) LoadAllAssetRecords 

func (n *SQLDB) LoadAllAssetRecords(serverID dtypes.ServerID, limit, offset int, statuses []string) (*sqlx.Rows, error)

LoadAllAssetRecords loads all asset records for a given server ID.

func (*SQLDB) LoadAllHashesOfNode added in v0.1.11 

func (n *SQLDB) LoadAllHashesOfNode(nodeID string) ([]string, error)

LoadAllHashesOfNode load asset replica information based on node.

func (*SQLDB) LoadAllProjectInfos added in v0.1.19 

func (n *SQLDB) LoadAllProjectInfos(serverID dtypes.ServerID, limit, offset int, statuses []string) (*sqlx.Rows, error)

LoadAllProjectInfos loads all project records for a given server ID.

func (*SQLDB) LoadAllReplicasByNodeID added in v0.1.16 

func (n *SQLDB) LoadAllReplicasByNodeID(nodeID string, limit, offset int, statues []types.ReplicaStatus) (*types.ListNodeReplicaRsp, error)

LoadAllReplicasByNodeID load replicas of node.

func (*SQLDB) LoadAssetCount 

func (n *SQLDB) LoadAssetCount(serverID dtypes.ServerID, filterState string) (int, error)

LoadAssetCount count asset

func (*SQLDB) LoadAssetRecord 

func (n *SQLDB) LoadAssetRecord(hash string) (*types.AssetRecord, error)

LoadAssetRecord load asset record information

func (*SQLDB) LoadAssetRecords 

func (n *SQLDB) LoadAssetRecords(statuses []string, limit, offset int, serverID dtypes.ServerID) (*sqlx.Rows, error)

LoadAssetRecords load the asset records from the incoming scheduler

func (*SQLDB) LoadAssetStateInfo added in v0.1.10 

func (n *SQLDB) LoadAssetStateInfo(hash string, serverID dtypes.ServerID) (*types.AssetStateInfo, error)

LoadAssetStateInfo loads the state of the asset for a given server ID.

func (*SQLDB) LoadBucket 

func (n *SQLDB) LoadBucket(bucketID string) ([]byte, error)

LoadBucket load assets ids from bucket return hashes of asset

func (*SQLDB) LoadBucketHashes 

func (n *SQLDB) LoadBucketHashes(nodeID string) ([]byte, error)

LoadBucketHashes load assets view buckets hashes

func (*SQLDB) LoadCreateValidationResultInfos added in v0.1.16 

func (n *SQLDB) LoadCreateValidationResultInfos() ([]*types.ValidationResultInfo, error)

LoadCreateValidationResultInfos load validation results.

func (*SQLDB) LoadDeactivateNodeTime added in v0.1.11 

func (n *SQLDB) LoadDeactivateNodeTime(nodeID string) (int64, error)

LoadDeactivateNodeTime Get node deactivate time

func (*SQLDB) LoadDeactivateNodes added in v0.1.11 

func (n *SQLDB) LoadDeactivateNodes(time int64) ([]string, error)

LoadDeactivateNodes load all deactivate node.

func (*SQLDB) LoadEdgeUpdateConfigs 

func (n *SQLDB) LoadEdgeUpdateConfigs() (map[int]*api.EdgeUpdateConfig, error)

LoadEdgeUpdateConfigs load edge update information.

func (*SQLDB) LoadExpiredAssetRecords 

func (n *SQLDB) LoadExpiredAssetRecords(serverID dtypes.ServerID, statuses []string) ([]*types.AssetRecord, error)

LoadExpiredAssetRecords load all expired asset records based on serverID.

func (*SQLDB) LoadFailedReplicas added in v0.1.16 

func (n *SQLDB) LoadFailedReplicas() ([]*types.ReplicaInfo, error)

LoadFailedReplicas load replicas .

func (*SQLDB) LoadFreeUpDiskTime added in v0.1.19 

func (n *SQLDB) LoadFreeUpDiskTime(nodeID string) (time.Time, error)

LoadFreeUpDiskTime Get free up disk time

func (*SQLDB) LoadNeedRefillAssetRecords added in v0.1.13 

func (n *SQLDB) LoadNeedRefillAssetRecords(serverID dtypes.ServerID, replicas int64, status string) (*types.AssetRecord, error)

LoadNeedRefillAssetRecords loads

func (*SQLDB) LoadNodeActivationKey added in v0.1.10 

func (n *SQLDB) LoadNodeActivationKey(nodeID string) (string, error)

LoadNodeActivationKey load activation key of node.

func (*SQLDB) LoadNodeInfo 

func (n *SQLDB) LoadNodeInfo(nodeID string) (*types.NodeInfo, error)

LoadNodeInfo load node information.

func (*SQLDB) LoadNodeInfos 

func (n *SQLDB) LoadNodeInfos(limit, offset int) (*sqlx.Rows, int64, error)

LoadNodeInfos load nodes information.

func (*SQLDB) LoadNodeInfosOfType added in v0.1.19 

func (n *SQLDB) LoadNodeInfosOfType(nodeType int) ([]*types.NodeInfo, error)

LoadNodeInfosOfType load node infos

func (*SQLDB) LoadNodeLastSeenTime 

func (n *SQLDB) LoadNodeLastSeenTime(nodeID string) (time.Time, error)

LoadNodeLastSeenTime loads the last seen time of a node

func (*SQLDB) LoadNodeProfits added in v0.1.18 

func (n *SQLDB) LoadNodeProfits(nodeID string, limit, offset int, ts []int) (*types.ListNodeProfitDetailsRsp, error)

LoadNodeProfits load profit info.

func (*SQLDB) LoadNodePublicKey 

func (n *SQLDB) LoadNodePublicKey(nodeID string) (string, error)

LoadNodePublicKey load public key of node.

func (*SQLDB) LoadNodeType 

func (n *SQLDB) LoadNodeType(nodeID string) (types.NodeType, error)

LoadNodeType load type of node.

func (*SQLDB) LoadNodeValidationInfo 

func (n *SQLDB) LoadNodeValidationInfo(roundID, nodeID string) (*types.ValidationResultInfo, error)

LoadNodeValidationInfo load the cid of a validation result.

func (*SQLDB) LoadNodesOfPullingReplica added in v0.1.16 

func (n *SQLDB) LoadNodesOfPullingReplica(hash string) ([]string, error)

LoadNodesOfPullingReplica

func (*SQLDB) LoadNodesOfStartingReplica added in v0.1.19 

func (n *SQLDB) LoadNodesOfStartingReplica(id string) ([]string, error)

LoadNodesOfStartingReplica

func (*SQLDB) LoadProjectCount added in v0.1.19 

func (n *SQLDB) LoadProjectCount(serverID dtypes.ServerID, filterState string) (int, error)

LoadProjectCount count project

func (*SQLDB) LoadProjectInfo added in v0.1.19 

func (n *SQLDB) LoadProjectInfo(id string) (*types.ProjectInfo, error)

LoadProjectInfo load project record information

func (*SQLDB) LoadProjectInfos added in v0.1.19 

func (n *SQLDB) LoadProjectInfos(serverID dtypes.ServerID, userID string, limit, offset int) ([]*types.ProjectInfo, error)

LoadProjectInfos load project record information

func (*SQLDB) LoadProjectReplicasForNode added in v0.1.19 

func (n *SQLDB) LoadProjectReplicasForNode(nodeID string) ([]*types.ProjectReplicas, error)

LoadProjectReplicasForNode load project replica information based on node

func (*SQLDB) LoadProjectReplicasInfos added in v0.1.19 

func (n *SQLDB) LoadProjectReplicasInfos(id string) ([]*types.ProjectReplicas, error)

LoadProjectReplicasInfos load project replica information based on id

func (*SQLDB) LoadProjectStateInfo added in v0.1.19 

func (n *SQLDB) LoadProjectStateInfo(id string, serverID dtypes.ServerID) (*types.ProjectStateInfo, error)

LoadProjectStateInfo loads the state of the project for a given server ID.

func (*SQLDB) LoadRecords added in v0.1.18 

func (n *SQLDB) LoadRecords(statuses []string, serverID dtypes.ServerID) ([]*types.AssetRecord, error)

LoadRecords load the asset records from the incoming scheduler

func (*SQLDB) LoadReplenishBackups added in v0.1.11 

func (n *SQLDB) LoadReplenishBackups(limit int) ([]string, error)

LoadReplenishBackups load asset replica information

func (*SQLDB) LoadReplicaEvents added in v0.1.10 

func (n *SQLDB) LoadReplicaEvents(start, end time.Time, limit, offset int) (*types.ListReplicaEventRsp, error)

LoadReplicaEvents Load replica event

func (*SQLDB) LoadReplicaEventsOfNode added in v0.1.11 

func (n *SQLDB) LoadReplicaEventsOfNode(nodeID string, limit, offset int) (*types.ListReplicaEventRsp, error)

LoadReplicaEventsOfNode Load replica event

func (*SQLDB) LoadReplicaSizeByNodeID added in v0.1.13 

func (n *SQLDB) LoadReplicaSizeByNodeID(nodeID string) (int64, error)

LoadReplicaSizeByNodeID load size of node.

func (*SQLDB) LoadReplicasByHash 

func (n *SQLDB) LoadReplicasByHash(hash string, limit, offset int) (*types.ListReplicaRsp, error)

LoadReplicasByHash load replicas of asset hash.

func (*SQLDB) LoadReplicasByStatus added in v0.1.10 

func (n *SQLDB) LoadReplicasByStatus(hash string, statuses []types.ReplicaStatus) ([]*types.ReplicaInfo, error)

LoadReplicasByStatus load asset replica information based on hash and statuses.

func (*SQLDB) LoadRetrieveEvent added in v0.1.11 

func (n *SQLDB) LoadRetrieveEvent(tokenID string) (*types.RetrieveEvent, error)

LoadRetrieveEvent load retrieve event

func (*SQLDB) LoadRetrieveEventRecords added in v0.1.11 

func (n *SQLDB) LoadRetrieveEventRecords(nodeID string, limit, offset int) (*types.ListRetrieveEventRsp, error)

LoadRetrieveEventRecords Load retrieve events

func (*SQLDB) LoadStorageStatsOfUser added in v0.1.11 

func (n *SQLDB) LoadStorageStatsOfUser(userID string) (*types.StorageStats, error)

LoadStorageStatsOfUser load user storage stats

func (*SQLDB) LoadSucceedReplicasByNodeID added in v0.1.16 

func (n *SQLDB) LoadSucceedReplicasByNodeID(nodeID string, limit, offset int) (*types.ListNodeAssetRsp, error)

LoadSucceedReplicasByNodeID load replicas of node.

func (*SQLDB) LoadSyncTime added in v0.1.10 

func (n *SQLDB) LoadSyncTime(nodeID string) (time.Time, error)

LoadSyncTime load assets view sync time

func (*SQLDB) LoadTodayProfitsForNode added in v0.1.19 

func (n *SQLDB) LoadTodayProfitsForNode(nodeID string, startTime, endTime time.Time) (float64, error)

func (*SQLDB) LoadTopHash 

func (n *SQLDB) LoadTopHash(nodeID string) (string, error)

LoadTopHash load assets view top hash

func (*SQLDB) LoadUnCalculatedValidationResults added in v0.1.10 

func (n *SQLDB) LoadUnCalculatedValidationResults(maxTime time.Time, limit int) (*sqlx.Rows, error)

LoadUnCalculatedValidationResults Load not calculated profit validation results

func (*SQLDB) LoadUnSavedValidationResults added in v0.1.10 

func (n *SQLDB) LoadUnSavedValidationResults(limit int) (*sqlx.Rows, error)

LoadUnSavedValidationResults Load not save to file validation results

func (*SQLDB) LoadUserAPIKeys added in v0.1.10 

func (n *SQLDB) LoadUserAPIKeys(userID string) ([]byte, error)

LoadUserAPIKeys load user api keys

func (*SQLDB) LoadUserInfo added in v0.1.11 

func (n *SQLDB) LoadUserInfo(userID string) (*types.UserInfo, error)

LoadUserInfo load user info

func (*SQLDB) LoadValidationResultInfos 

func (n *SQLDB) LoadValidationResultInfos(nodeID string, limit, offset int) (*types.ListValidationResultRsp, error)

LoadValidationResultInfos load validation results.

func (*SQLDB) LoadValidators 

func (n *SQLDB) LoadValidators(serverID dtypes.ServerID) ([]string, error)

LoadValidators load validators information.

func (*SQLDB) LoadWSServerID added in v0.1.19 

func (n *SQLDB) LoadWSServerID(nodeID string) (string, error)

LoadWSServerID

func (*SQLDB) LoadWorkloadRecord added in v0.1.10 

func (n *SQLDB) LoadWorkloadRecord(workload *types.WorkloadRecord) ([]*types.WorkloadRecord, error)

LoadWorkloadRecord load workload record

func (*SQLDB) LoadWorkloadRecordOfID added in v0.1.18 

func (n *SQLDB) LoadWorkloadRecordOfID(workloadID string) (*types.WorkloadRecord, error)

LoadWorkloadRecordOfID load workload record

func (*SQLDB) LoadWorkloadRecords added in v0.1.10 

func (n *SQLDB) LoadWorkloadRecords(nodeID string, limit, offset int) (*types.ListWorkloadRecordRsp, error)

LoadWorkloadRecords Load workload records

func (*SQLDB) NodeExists 

func (n *SQLDB) NodeExists(nodeID string, nodeType types.NodeType) error

NodeExists is node exists

func (*SQLDB) ProjectExists added in v0.1.19 

func (n *SQLDB) ProjectExists(id string, serverID dtypes.ServerID) (bool, error)

ProjectExists checks if an project exists in the state machine table of the specified server.

func (*SQLDB) RegisterCount added in v0.1.13 

func (n *SQLDB) RegisterCount(ip string) (int, error)

TodayRegisterCount get the number of registrations for this ip today

func (*SQLDB) RemoveInvalidValidationResult added in v0.1.11 

func (n *SQLDB) RemoveInvalidValidationResult(sIDs []int) error

RemoveInvalidValidationResult Remove invalid validation results

func (*SQLDB) SaveAWSData added in v0.1.13 

func (n *SQLDB) SaveAWSData(infos []types.AWSDataInfo) error

SaveAWSData save data

func (*SQLDB) SaveAssetRecord 

func (n *SQLDB) SaveAssetRecord(rInfo *types.AssetRecord) error

SaveAssetRecord saves an asset record into the database.

func (*SQLDB) SaveAssetUser added in v0.1.10 

func (n *SQLDB) SaveAssetUser(hash, userID, assetName, assetType string, size int64, expiration time.Time, password string, groupID int) error

SaveAssetUser save asset and user info

func (*SQLDB) SaveAssetsView 

func (n *SQLDB) SaveAssetsView(nodeID string, topHash string, bucketHashes []byte) error

SaveAssetsView update or insert top hash and buckets hashes to assets view bucketHashes key is number of bucket, value is bucket hash TODO save bucketHashes as array

func (*SQLDB) SaveBucket 

func (n *SQLDB) SaveBucket(bucketID string, assetHashes []byte) error

SaveBucket update or insert assets ids to bucket

func (*SQLDB) SaveCandidateCodeInfo added in v0.1.19 

func (n *SQLDB) SaveCandidateCodeInfo(infos []*types.CandidateCodeInfo) error

SaveCandidateCodeInfo Insert Node code info

func (*SQLDB) SaveDeactivateNode added in v0.1.11 

func (n *SQLDB) SaveDeactivateNode(nodeID string, time int64, penaltyPoint float64) error

SaveDeactivateNode save deactivate node time

func (*SQLDB) SaveEdgeUpdateConfig 

func (n *SQLDB) SaveEdgeUpdateConfig(info *api.EdgeUpdateConfig) error

SaveEdgeUpdateConfig inserts edge update information.

func (*SQLDB) SaveFreeUpDiskTime added in v0.1.19 

func (n *SQLDB) SaveFreeUpDiskTime(nodeID string, time time.Time) error

SaveFreeUpDiskTime save free up disk time

func (*SQLDB) SaveNodeInfo 

func (n *SQLDB) SaveNodeInfo(info *types.NodeInfo) error

SaveNodeInfo Insert or update node info

func (*SQLDB) SaveNodePublicKey added in v0.1.10 

func (n *SQLDB) SaveNodePublicKey(pKey, nodeID string) error

SaveNodePublicKey update node public key

func (*SQLDB) SaveNodeRegisterInfos added in v0.1.10 

func (n *SQLDB) SaveNodeRegisterInfos(details []*types.ActivationDetail) error

SaveNodeRegisterInfos Insert Node register info

func (*SQLDB) SaveProjectInfo added in v0.1.19 

func (n *SQLDB) SaveProjectInfo(info *types.ProjectInfo) error

SaveProjectInfo inserts

func (*SQLDB) SaveProjectReplicasInfo added in v0.1.19 

func (n *SQLDB) SaveProjectReplicasInfo(info *types.ProjectReplicas) error

SaveProjectReplicasInfo inserts

func (*SQLDB) SaveReplenishBackup added in v0.1.11 

func (n *SQLDB) SaveReplenishBackup(hashes []string) error

SaveReplenishBackup Save assets that require replenish backups

func (*SQLDB) SaveReplicaEvent added in v0.1.11 

func (n *SQLDB) SaveReplicaEvent(hash, cid, nodeID string, size int64, expiration time.Time, event types.ReplicaEvent, source int64) error

func (*SQLDB) SaveReplicaStatus added in v0.1.18 

func (n *SQLDB) SaveReplicaStatus(info *types.ReplicaInfo) error

SaveReplicaStatus inserts or updates replicas status

func (*SQLDB) SaveReplicasStatus added in v0.1.10 

func (n *SQLDB) SaveReplicasStatus(infos []*types.ReplicaInfo) error

SaveReplicasStatus inserts or updates replicas status

func (*SQLDB) SaveRetrieveEventInfo added in v0.1.11 

func (n *SQLDB) SaveRetrieveEventInfo(cInfo *types.RetrieveEvent) error

SaveRetrieveEventInfo save retrieve event and update node info

func (*SQLDB) SaveUserAPIKeys added in v0.1.10 

func (n *SQLDB) SaveUserAPIKeys(userID string, apiKeys []byte) error

SaveUserAPIKeys save user api keys, apiKeys is map[string]UsetAPIKeysInfo encode by gob

func (*SQLDB) SaveUserTotalStorageSize added in v0.1.10 

func (n *SQLDB) SaveUserTotalStorageSize(userID string, totalSize int64) error

SaveUserTotalStorageSize save user storage size

func (*SQLDB) SaveValidationResultInfos 

func (n *SQLDB) SaveValidationResultInfos(infos []*types.ValidationResultInfo) error

SaveValidationResultInfos inserts validation result information.

func (*SQLDB) SaveWSServerID added in v0.1.19 

func (n *SQLDB) SaveWSServerID(nodeID, wID string) error

SaveWSServerID save id

func (*SQLDB) SaveWorkloadRecord added in v0.1.10 

func (n *SQLDB) SaveWorkloadRecord(records []*types.WorkloadRecord) error

SaveWorkloadRecord save workload record

func (*SQLDB) UpdateAWSData added in v0.1.13 

func (n *SQLDB) UpdateAWSData(info *types.AWSDataInfo) error

UpdateAWSData update aws info

func (*SQLDB) UpdateAssetGroup added in v0.1.11 

func (n *SQLDB) UpdateAssetGroup(hash, userID string, groupID int) error

UpdateAssetGroup update user asset group

func (*SQLDB) UpdateAssetGroupName added in v0.1.11 

func (n *SQLDB) UpdateAssetGroupName(userID, rename string, groupID int) error

UpdateAssetGroupName update user asset group name

func (*SQLDB) UpdateAssetGroupParent added in v0.1.11 

func (n *SQLDB) UpdateAssetGroupParent(userID string, groupID, parent int) error

UpdateAssetGroupParent update user asset group parent

func (*SQLDB) UpdateAssetInfo added in v0.1.10 

func (n *SQLDB) UpdateAssetInfo(hash, state string, totalBlock, totalSize, retryCount, replenishReplicas int64, serverID dtypes.ServerID) error

UpdateAssetInfo update asset information

func (*SQLDB) UpdateAssetRecordExpiration added in v0.1.10 

func (n *SQLDB) UpdateAssetRecordExpiration(hash string, eTime time.Time) error

UpdateAssetRecordExpiration resets asset record expiration time based on hash and eTime

func (*SQLDB) UpdateAssetRecordReplicaCount added in v0.1.14 

func (n *SQLDB) UpdateAssetRecordReplicaCount(cid string, count int) error

UpdateAssetRecordReplicaCount

func (*SQLDB) UpdateAssetShareStatus added in v0.1.11 

func (n *SQLDB) UpdateAssetShareStatus(hash, userID string, status int64) error

UpdateAssetShareStatus save share status

func (*SQLDB) UpdateAssetVisitCount added in v0.1.11 

func (n *SQLDB) UpdateAssetVisitCount(assetHash string) error

UpdateAssetVisitCount update asset visit count

func (*SQLDB) UpdateCandidateCodeInfo added in v0.1.19 

func (n *SQLDB) UpdateCandidateCodeInfo(code, nodeID string) error

UpdateCandidateCodeInfo code info

func (*SQLDB) UpdateFileSavedStatus added in v0.1.10 

func (n *SQLDB) UpdateFileSavedStatus(ids []int) error

UpdateFileSavedStatus update the file saved in validation result

func (*SQLDB) UpdateNodeDynamicInfo added in v0.1.19 

func (n *SQLDB) UpdateNodeDynamicInfo(infos []*types.NodeDynamicInfo) ([]string, error)

UpdateNodeDynamicInfo update node online time , last time , disk usage ...

func (*SQLDB) UpdateNodePenalty added in v0.1.19 

func (n *SQLDB) UpdateNodePenalty(nodePns map[string]float64) error

UpdateNodePenalty

func (*SQLDB) UpdateOnlineCount added in v0.1.19 

func (n *SQLDB) UpdateOnlineCount(nodes []string, countIncr int, date time.Time) error

func (*SQLDB) UpdatePortMapping 

func (n *SQLDB) UpdatePortMapping(nodeID, port string) error

UpdatePortMapping sets the node's mapping port.

func (*SQLDB) UpdateProjectInfo added in v0.1.19 

func (n *SQLDB) UpdateProjectInfo(info *types.ProjectInfo) error

func (*SQLDB) UpdateProjectReplicaStatusFromNode added in v0.1.19 

func (n *SQLDB) UpdateProjectReplicaStatusFromNode(nodeID string, uuids []string, status types.ProjectReplicaStatus) error

UpdateProjectReplicaStatusFromNode

func (*SQLDB) UpdateProjectReplicaStatusToFailed added in v0.1.19 

func (n *SQLDB) UpdateProjectReplicaStatusToFailed(id string, nodes []string) error

UpdateProjectReplicaStatusToFailed

func (*SQLDB) UpdateProjectReplicasStatusToFailed added in v0.1.19 

func (n *SQLDB) UpdateProjectReplicasStatusToFailed(id string) error

UpdateProjectReplicasStatusToFailed updates the status of unfinished project replicas

func (*SQLDB) UpdateProjectStateInfo added in v0.1.19 

func (n *SQLDB) UpdateProjectStateInfo(id, state string, retryCount, replenishReplicas int64, serverID dtypes.ServerID) error

UpdateProjectStateInfo update project information

func (*SQLDB) UpdateReplicaInfo added in v0.1.10 

func (n *SQLDB) UpdateReplicaInfo(cInfo *types.ReplicaInfo) error

UpdateReplicaInfo update unfinished replica info , return an error if the replica is finished

func (*SQLDB) UpdateReplicasStatusToFailed 

func (n *SQLDB) UpdateReplicasStatusToFailed(hash string) error

UpdateReplicasStatusToFailed updates the status of unfinished asset replicas

func (*SQLDB) UpdateSyncTime added in v0.1.10 

func (n *SQLDB) UpdateSyncTime(nodeID string) error

UpdateSyncTime update assets view sync time

func (*SQLDB) UpdateUserInfo added in v0.1.11 

func (n *SQLDB) UpdateUserInfo(userID string, incSize, incCount int64) error

UpdateUserInfo update user info

func (*SQLDB) UpdateUserPeakSize added in v0.1.11 

func (n *SQLDB) UpdateUserPeakSize(userID string, peakSize int64) error

UpdateUserPeakSize update user peakSize

func (*SQLDB) UpdateUserVIPAndStorageSize added in v0.1.11 

func (n *SQLDB) UpdateUserVIPAndStorageSize(userID string, enableVIP bool, storageSize int64) error

UpdateUserVIPAndStorageSize update user info

func (*SQLDB) UpdateValidationResultInfo 

func (n *SQLDB) UpdateValidationResultInfo(info *types.ValidationResultInfo) error

UpdateValidationResultInfo updates the validation result information.

func (*SQLDB) UpdateValidationResultStatus added in v0.1.16 

func (n *SQLDB) UpdateValidationResultStatus(roundID, nodeID string, status types.ValidationStatus) error

UpdateValidationResultsTimeout sets the validation results' status as timeout.

func (*SQLDB) UpdateValidatorInfo 

func (n *SQLDB) UpdateValidatorInfo(serverID dtypes.ServerID, nodeID string) error

UpdateValidatorInfo reset scheduler server id for validator

func (*SQLDB) UpdateValidators 

func (n *SQLDB) UpdateValidators(nodeIDs []string, serverID dtypes.ServerID, cleanOld bool) error

UpdateValidators update validators

func (*SQLDB) UpdateWorkloadRecord added in v0.1.10 

func (n *SQLDB) UpdateWorkloadRecord(record *types.WorkloadRecord, status types.WorkloadStatus) error

UpdateWorkloadRecord update workload record

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.