db

package
v0.1.10 Latest Latest
Warning

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

 Go to latest Published: Jun 28, 2023 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) 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) 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, size int64) 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) 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) DeleteUnfinishedReplicas 

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

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

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) ListAssetsForUser added in v0.1.10 

func (n *SQLDB) ListAssetsForUser(user string, limit, offset int) (*sqlx.Rows, error)

ListAssetsForUser Get a list of assets by user

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) 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) 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) 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) 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) LoadNodeLastSeenTime 

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

LoadNodeLastSeenTime loads the last seen time of a node

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) LoadReplicaEvents added in v0.1.10 

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

LoadReplicaEvents Load replica event

func (*SQLDB) LoadReplicas 

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

LoadReplicas load replicas of node.

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) LoadReplicasOfNode added in v0.1.10 

func (n *SQLDB) LoadReplicasOfNode(nodeID string) ([]*types.ReplicaInfo, error)

LoadReplicasOfNode load asset replica information based on 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) 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) LoadUnprocessedWorkloadResults added in v0.1.10 

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

LoadUnprocessedWorkloadResults Load unprocessed workload results

func (*SQLDB) LoadUserAPIKeys added in v0.1.10 

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

LoadUserAPIKeys load user api keys

func (*SQLDB) LoadUserStorageSize added in v0.1.10 

func (n *SQLDB) LoadUserStorageSize(userID string) (*types.StorageSize, error)

LoadUserStorageSize load user storage size

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) LoadWorkloadRecord added in v0.1.10 

func (n *SQLDB) LoadWorkloadRecord(tokenID string) (*types.WorkloadRecord, error)

LoadWorkloadRecord 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) RemoveInvalidWorkloadResult added in v0.1.10 

func (n *SQLDB) RemoveInvalidWorkloadResult(sIDs []string) error

RemoveInvalidWorkloadResult Remove invalid workload certificates

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 string, size int64) 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) SaveEdgeUpdateConfig 

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

SaveEdgeUpdateConfig inserts edge update information.

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) SaveReplicasStatus added in v0.1.10 

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

SaveReplicasStatus inserts or updates replicas status

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]string 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) SaveWorkloadRecord added in v0.1.10 

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

SaveWorkloadRecord save workload record

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) UpdateFileSavedStatus added in v0.1.10 

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

UpdateFileSavedStatus update the file saved in validation result

func (*SQLDB) UpdateNodeInfosByValidationResult added in v0.1.10 

func (n *SQLDB) UpdateNodeInfosByValidationResult(infos []*types.ValidationResultInfo, nodeProfits map[string]float64) error

UpdateNodeInfosByValidationResult Update the info value of the node, and set the calculated flag to the validation record

func (*SQLDB) UpdateNodeInfosByWorkloadResult added in v0.1.10 

func (n *SQLDB) UpdateNodeInfosByWorkloadResult(sIDs map[string]types.WorkloadStatus, nodeInfos map[string]*types.NodeDynamicInfo) error

UpdateNodeInfosByWorkloadResult Update the info value of the node, and set the processed flag to the workload record

func (*SQLDB) UpdateOnlineDuration added in v0.1.10 

func (n *SQLDB) UpdateOnlineDuration(infos []*types.NodeDynamicInfo) error

UpdateOnlineDuration update node online time , last time , disk usage

func (*SQLDB) UpdatePortMapping 

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

UpdatePortMapping sets the node's mapping port.

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) UpdateValidationResultInfo 

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

UpdateValidationResultInfo updates the validation result information.

func (*SQLDB) UpdateValidationResultsTimeout 

func (n *SQLDB) UpdateValidationResultsTimeout(roundID string) 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) error

UpdateValidators update validators

func (*SQLDB) UpdateWorkloadRecord added in v0.1.10 

func (n *SQLDB) UpdateWorkloadRecord(record *types.WorkloadRecord) 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.