db

package
v0.1.9 Latest Latest
Warning

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

 Go to latest Published: Jun 5, 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) BatchInitReplicas 

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

BatchInitReplicas inserts or updates replica information in batch

func (*SQLDB) DeleteAssetRecord 

func (n *SQLDB) DeleteAssetRecord(hash string, serverID dtypes.ServerID, info *types.AssetEventInfo) error

DeleteAssetRecord removes all records associated with a given asset hash from the database.

func (*SQLDB) DeleteAssetReplica 

func (n *SQLDB) DeleteAssetReplica(hash, nodeID string, info *types.AssetEventInfo) error

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

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

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

IsValidator Determine whether the node is a validator

func (*SQLDB) LoadAllAssetRecords 

func (n *SQLDB) LoadAllAssetRecords(serverID dtypes.ServerID) (*sqlx.Rows, error)

LoadAllAssetRecords loads all asset records for a given server ID.

func (*SQLDB) LoadAssetCount 

func (n *SQLDB) LoadAssetCount(serverID dtypes.ServerID) (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) LoadAssetReplicas 

func (n *SQLDB) LoadAssetReplicas(hash string) ([]*types.ReplicaInfo, error)

LoadAssetReplicas load asset replica information based on hash.

func (*SQLDB) LoadAssetState 

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

LoadAssetState 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) ([]*types.AssetRecord, error)

LoadExpiredAssetRecords load all expired asset records based on serverID.

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

func (n *SQLDB) LoadNodeOnlineDuration(nodeID string) (int, error)

LoadNodeOnlineDuration load online duration of 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) LoadPortMapping 

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

LoadPortMapping load the mapping port of a node.

func (*SQLDB) LoadReplicas 

func (n *SQLDB) LoadReplicas(startTime time.Time, endTime time.Time, cursor, count int) (*types.ListReplicaInfosRsp, error)

LoadReplicas load information about all replicas whose end_time is between startTime and endTime, limited to "count" results and starting from "cursor".

func (*SQLDB) LoadReplicasByHash 

func (n *SQLDB) LoadReplicasByHash(hash string, statuses []types.ReplicaStatus) (*sqlx.Rows, error)

LoadReplicasByHash load asset replica information based on hash and statuses.

func (*SQLDB) LoadSucceededReplicaCount 

func (n *SQLDB) LoadSucceededReplicaCount() (int, error)

LoadSucceededReplicaCount retrieves the succeeded replica count

func (*SQLDB) LoadTokenPayloadAndWorkloads 

func (n *SQLDB) LoadTokenPayloadAndWorkloads(tokenID string, isClient bool) (*types.TokenPayload, []byte, error)

func (*SQLDB) LoadTopHash 

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

LoadTopHash load assets view top hash

func (*SQLDB) LoadUnfinishedPullAssetNodes 

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

LoadUnfinishedPullAssetNodes retrieves the node IDs for all nodes that have not yet finished pulling an asset for a given asset hash.

func (*SQLDB) LoadValidationResultInfos 

func (n *SQLDB) LoadValidationResultInfos(startTime, endTime time.Time, pageNumber, pageSize int) (*types.ListValidationResultRsp, error)

LoadValidationResultInfos load validation results.

func (*SQLDB) LoadValidationResults 

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

LoadValidationResults Load unprocessed validation results

func (*SQLDB) LoadValidators 

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

LoadValidators load validators information.

func (*SQLDB) NodeExists 

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

NodeExists is node exists

func (*SQLDB) SaveAssetRecord 

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

SaveAssetRecord saves an asset record into the database.

func (*SQLDB) SaveAssetsView 

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

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

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

func (n *SQLDB) SaveNodeProfit(nodeID string, cProfit float64) (oldProfit, newValue float64, err error)

SaveNodeProfit Modify and return the node profit value

func (*SQLDB) SaveNodeRegisterInfo 

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

SaveNodeRegisterInfo Insert Node register info

func (*SQLDB) SaveTokenPayload 

func (n *SQLDB) SaveTokenPayload(tks []*types.TokenPayload) error

func (*SQLDB) SaveValidationResultInfos 

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

SaveValidationResultInfos inserts validation result information.

func (*SQLDB) UpdateAssetRecordExpiry 

func (n *SQLDB) UpdateAssetRecordExpiry(hash string, eTime time.Time, serverID dtypes.ServerID) error

UpdateAssetRecordExpiry resets asset record expiration time based on hash and eTime

func (*SQLDB) UpdateNodeOnlineTime 

func (n *SQLDB) UpdateNodeOnlineTime(nodeID string, onlineTime int) error

UpdateNodeOnlineTime update node online time and last time

func (*SQLDB) UpdateNodeProfitsByValidationResult 

func (n *SQLDB) UpdateNodeProfitsByValidationResult(vIDs []int, nodeProfits map[string]float64) error

UpdateNodeProfitsByValidationResult Update the gain value of the node, and set the processed flag to the validation record

func (*SQLDB) UpdatePortMapping 

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

UpdatePortMapping sets the node's mapping port.

func (*SQLDB) UpdateReplicasStatusToFailed 

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

UpdateReplicasStatusToFailed updates the status of unfinished asset replicas

func (*SQLDB) UpdateStateOfAsset 

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

UpdateStateOfAsset update asset state information

func (*SQLDB) UpdateUnfinishedReplica 

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

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

func (*SQLDB) UpdateValidationResultInfo 

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

UpdateValidationResultInfo updates the validation result information.

func (*SQLDB) UpdateValidationResultProfit 

func (n *SQLDB) UpdateValidationResultProfit(id int, profit float64) error

UpdateValidationResultProfit update profit for node validation

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

func (n *SQLDB) UpdateWorkloadReport(tokenID string, isClient bool, workloads []byte) error

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.