api

type APIVersion struct {
	Version string

	// APIVersion is a binary encoded semver version of the remote implementing
	// this api
	//
	// See APIVersion in build/version.go
	APIVersion Version

	// Seconds
	BlockDelay uint64
}

type AccessPoint struct {
	AreaID        string
	SchedulerURLs []string
}

type Asset interface {
	// PullAsset pull the asset with given assetCID from specified sources
	PullAsset(ctx context.Context, assetCID string, sources []*types.CandidateDownloadInfo) error //perm:admin
	// PullAssetV2 pull the asset by scheduler
	PullAssetV2(ctx context.Context, req *types.AssetPullRequest) error //perm:admin
	// DeleteAsset deletes the asset with given assetCID
	DeleteAsset(ctx context.Context, assetCID string) error //perm:admin
	// GetAssetStats retrieves the statistics of assets
	GetAssetStats(ctx context.Context) (*types.AssetStats, error) //perm:admin
	// GetCachingAssetInfo retrieves the information of assets that are currently being pulled
	GetPullingAssetInfo(ctx context.Context) (*types.InProgressAsset, error) //perm:admin
	// GetAssetProgresses retrieves the progress of assets with specified assetCIDs
	GetAssetProgresses(ctx context.Context, assetCIDs []string) (*types.PullResult, error) //perm:admin
	// CreateAsset notify candidate that user upload asset, return auth token of candidate
	CreateAsset(ctx context.Context, tokenPayload *types.AuthUserUploadDownloadAsset) (string, error) //perm:admin
	// PullAssetWithURL download the file locally from the url and save it as car file
	PullAssetFromAWS(ctx context.Context, bucket, key string) error //perm:admin
	// GetAssetView get asset view
	GetAssetView(ctx context.Context) (*types.AssetView, error) //perm:admin
	// AddAssetView add asset to view
	AddAssetView(ctx context.Context, assetCIDs []string) error //perm:admin
	// GetAssetsInBucket get assets in bucket
	GetAssetsInBucket(ctx context.Context, bucketID int) ([]string, error) //perm:admin
	// SyncAssetViewAndData sync assetView and local car
	SyncAssetViewAndData(ctx context.Context) error //perm:admin
	// RequestFreeUpDisk Initiate a request to free up disk space with a certain size, size unit GiB
	RequestFreeUpDisk(ctx context.Context, size float64) error //perm:admin
	// StateFreeUpDisk shows the result of last free task is done, return nil means done
	StateFreeUpDisk(ctx context.Context) (*types.FreeUpDiskStateResp, error) //perm:admin
	// ClearFreeUpDisk clear the previous failed task
	ClearFreeUpDisk(ctx context.Context) error //perm:admin
}

type AssetAPI interface {
	// Asset-related methods
	// PullAsset Pull an asset based on the provided PullAssetReq structure.
	PullAsset(ctx context.Context, info *types.PullAssetReq) error //perm:web,admin
	// RemoveAssetRecord removes the asset record with the specified CID from the scheduler
	RemoveAssetRecord(ctx context.Context, cid string) error //perm:admin,web
	// RemoveAssetRecords removes the asset record with the specified CID from the scheduler
	RemoveAssetRecords(ctx context.Context, cids []string) error //perm:admin,web
	// StopAssetRecord stop asset
	StopAssetRecord(ctx context.Context, cids []string) error //perm:admin
	// RemoveAssetReplica deletes an asset replica with the specified CID and node from the scheduler
	RemoveAssetReplica(ctx context.Context, cid, nodeID string) error //perm:admin
	// GetAssetRecord retrieves the asset record with the specified CID
	GetAssetRecord(ctx context.Context, cid string) (*types.AssetRecord, error) //perm:web,admin
	// GetAssetRecords retrieves a list of asset records with pagination using the specified limit, offset, and states
	GetAssetRecords(ctx context.Context, limit, offset int, states []string, serverID dtypes.ServerID) ([]*types.AssetRecord, error) //perm:web,admin
	// GetAssetRecordsWithCIDs retrieves a list of asset records with cid
	GetAssetRecordsWithCIDs(ctx context.Context, cids []string) ([]*types.AssetRecord, error) //perm:web,admin
	// GetReplicas retrieves a list of asset replicas with pagination using the specified limit, offset
	GetReplicas(ctx context.Context, cid string, limit, offset int) (*types.ListReplicaRsp, error) //perm:web,admin
	// RePullFailedAssets retries the pull process for a list of failed assets
	RePullFailedAssets(ctx context.Context, hashes []types.AssetHash) error //perm:admin
	// UpdateAssetExpiration updates the expiration time for an asset with the specified CID
	UpdateAssetExpiration(ctx context.Context, cid string, time time.Time) error //perm:web,admin
	// ResetAssetReplicaCount updates the replica count for an asset with the specified CID
	ResetAssetReplicaCount(ctx context.Context, cid string, count int) error //perm:web,admin
	// NodeRemoveAssetResult the result of an asset removal operation
	NodeRemoveAssetResult(ctx context.Context, resultInfo types.RemoveAssetResult) error //perm:edge,candidate
	// GetAssetListForBucket retrieves a list of asset hashes for a bucket associated with the specified bucket ID (bucketID is hash code)
	GetAssetListForBucket(ctx context.Context, bucketID uint32) ([]string, error) //perm:edge,candidate
	// GetAssetCount retrieves a count of asset
	GetAssetCount(ctx context.Context) (int, error) //perm:web,admin
	// GetAssetsForNode retrieves a asset list of node
	GetAssetsForNode(ctx context.Context, nodeID string, limit, offset int) (*types.ListNodeAssetRsp, error) //perm:web,admin
	// GetReplicasForNode retrieves a replica list of node
	GetReplicasForNode(ctx context.Context, nodeID string, limit, offset int, statuses []types.ReplicaStatus) (*types.ListNodeReplicaRsp, error) //perm:web,admin
	// GetReplicaEventsForNode retrieves a replica event list of node
	GetReplicaEventsForNode(ctx context.Context, nodeID string, limit, offset int) (*types.ListAssetReplicaEventRsp, error) //perm:web,admin
	// GetAssetDownloadResults retrieves a asset download list
	GetAssetDownloadResults(ctx context.Context, hash string, start, end time.Time) (*types.ListAssetDownloadRsp, error) //perm:web,admin
	// GetDownloadResultsFromAssets
	GetDownloadResultsFromAssets(ctx context.Context, hashes []string, start, end time.Time) ([]*types.AssetDownloadResultRsp, error) //perm:web,admin
	// CreateAsset creates an asset with car CID, car name, and car size.
	CreateAsset(ctx context.Context, req *types.CreateAssetReq) (*types.UploadInfo, error) //perm:web,admin,user
	// CreateSyncAsset Synchronizing assets from other schedulers
	CreateSyncAsset(ctx context.Context, req *types.CreateSyncAssetReq) error //perm:web,admin,user
	// GenerateTokenForDownloadSource Generate Token For Download Source
	GenerateTokenForDownloadSource(ctx context.Context, nodeID string, cid string) (*types.SourceDownloadInfo, error) //perm:web,admin,user
	// GenerateTokenForDownloadSources Generate Token For Download Source
	GenerateTokenForDownloadSources(ctx context.Context, cid string) ([]*types.SourceDownloadInfo, error) //perm:web,admin,user
	// ShareAssets shares the assets of the user.
	// ShareAssets(ctx context.Context, userID string, assetCID []string, expireTime time.Time) (map[string][]string, error) //perm:web,admin,user
	// ShareEncryptedAsset shares the encrypted file
	// ShareEncryptedAsset(ctx context.Context, userID, assetCID, filePass string, expireTime time.Time) ([]string, error) // perm:web,admin,user
	// ShareAssetV2 shares the assets of the user.
	ShareAssetV2(ctx context.Context, info *types.ShareAssetReq) (*types.ShareAssetRsp, error) //perm:web,admin,user
	// MinioUploadFileEvent the event of minio upload file
	MinioUploadFileEvent(ctx context.Context, event *types.MinioUploadFileEvent) error //perm:candidate
	// AddAWSData add aws resource information
	AddAWSData(ctx context.Context, list []types.AWSDataInfo) error //perm:web,admin
	// SwitchFillDiskTimer  switches the timer between ON and OFF states
	SwitchFillDiskTimer(ctx context.Context, open bool) error //perm:web,admin
	// LoadAWSData load data
	LoadAWSData(ctx context.Context, limit, offset int, isDistribute bool) ([]*types.AWSDataInfo, error) //perm:web,admin
	// RemoveNodeFailedReplica
	RemoveNodeFailedReplica(ctx context.Context) error //perm:web,admin
	// GetActiveAssetRecords
	GetActiveAssetRecords(ctx context.Context, offset int, limit int) (*types.ListAssetRecordRsp, error) //perm:web,admin
	// GetAssetRecordsByDateRange
	GetAssetRecordsByDateRange(ctx context.Context, offset int, limit int, start time.Time, end time.Time) (*types.ListAssetRecordRsp, error) //perm:web,admin
	// GetSucceededReplicaByCID
	GetSucceededReplicaByCID(ctx context.Context, cid string, limit, offset int) (*types.ListReplicaRsp, error) //perm:web,admin
	// GetFailedReplicaByCID
	GetFailedReplicaByCID(ctx context.Context, cid string, limit, offset int) (*types.ListAssetReplicaEventRsp, error) //perm:web,admin
	// GetSucceededReplicaByNode
	GetSucceededReplicaByNode(ctx context.Context, nodeID string, limit, offset int) (*types.ListReplicaRsp, error) //perm:web,admin
	// GetFailedReplicaByNode
	GetFailedReplicaByNode(ctx context.Context, nodeID string, limit, offset int) (*types.ListAssetReplicaEventRsp, error) //perm:web,admin
	// GetNodeAssetReplicasByHashes
	GetNodeAssetReplicasByHashes(ctx context.Context, nodeID string, hashes []string) ([]*types.ReplicaInfo, error) //perm:web,admin
}

type AssetAPIStruct struct {
	Internal struct {
		AddAWSData func(p0 context.Context, p1 []types.AWSDataInfo) error `perm:"web,admin"`

		CreateAsset func(p0 context.Context, p1 *types.CreateAssetReq) (*types.UploadInfo, error) `perm:"web,admin,user"`

		CreateSyncAsset func(p0 context.Context, p1 *types.CreateSyncAssetReq) error `perm:"web,admin,user"`

		GenerateTokenForDownloadSource func(p0 context.Context, p1 string, p2 string) (*types.SourceDownloadInfo, error) `perm:"web,admin,user"`

		GenerateTokenForDownloadSources func(p0 context.Context, p1 string) ([]*types.SourceDownloadInfo, error) `perm:"web,admin,user"`

		GetActiveAssetRecords func(p0 context.Context, p1 int, p2 int) (*types.ListAssetRecordRsp, error) `perm:"web,admin"`

		GetAssetCount func(p0 context.Context) (int, error) `perm:"web,admin"`

		GetAssetDownloadResults func(p0 context.Context, p1 string, p2 time.Time, p3 time.Time) (*types.ListAssetDownloadRsp, error) `perm:"web,admin"`

		GetAssetListForBucket func(p0 context.Context, p1 uint32) ([]string, error) `perm:"edge,candidate"`

		GetAssetRecord func(p0 context.Context, p1 string) (*types.AssetRecord, error) `perm:"web,admin"`

		GetAssetRecords func(p0 context.Context, p1 int, p2 int, p3 []string, p4 dtypes.ServerID) ([]*types.AssetRecord, error) `perm:"web,admin"`

		GetAssetRecordsByDateRange func(p0 context.Context, p1 int, p2 int, p3 time.Time, p4 time.Time) (*types.ListAssetRecordRsp, error) `perm:"web,admin"`

		GetAssetRecordsWithCIDs func(p0 context.Context, p1 []string) ([]*types.AssetRecord, error) `perm:"web,admin"`

		GetAssetsForNode func(p0 context.Context, p1 string, p2 int, p3 int) (*types.ListNodeAssetRsp, error) `perm:"web,admin"`

		GetDownloadResultsFromAssets func(p0 context.Context, p1 []string, p2 time.Time, p3 time.Time) ([]*types.AssetDownloadResultRsp, error) `perm:"web,admin"`

		GetFailedReplicaByCID func(p0 context.Context, p1 string, p2 int, p3 int) (*types.ListAssetReplicaEventRsp, error) `perm:"web,admin"`

		GetFailedReplicaByNode func(p0 context.Context, p1 string, p2 int, p3 int) (*types.ListAssetReplicaEventRsp, error) `perm:"web,admin"`

		GetNodeAssetReplicasByHashes func(p0 context.Context, p1 string, p2 []string) ([]*types.ReplicaInfo, error) `perm:"web,admin"`

		GetReplicaEventsForNode func(p0 context.Context, p1 string, p2 int, p3 int) (*types.ListAssetReplicaEventRsp, error) `perm:"web,admin"`

		GetReplicas func(p0 context.Context, p1 string, p2 int, p3 int) (*types.ListReplicaRsp, error) `perm:"web,admin"`

		GetReplicasForNode func(p0 context.Context, p1 string, p2 int, p3 int, p4 []types.ReplicaStatus) (*types.ListNodeReplicaRsp, error) `perm:"web,admin"`

		GetSucceededReplicaByCID func(p0 context.Context, p1 string, p2 int, p3 int) (*types.ListReplicaRsp, error) `perm:"web,admin"`

		GetSucceededReplicaByNode func(p0 context.Context, p1 string, p2 int, p3 int) (*types.ListReplicaRsp, error) `perm:"web,admin"`

		LoadAWSData func(p0 context.Context, p1 int, p2 int, p3 bool) ([]*types.AWSDataInfo, error) `perm:"web,admin"`

		MinioUploadFileEvent func(p0 context.Context, p1 *types.MinioUploadFileEvent) error `perm:"candidate"`

		NodeRemoveAssetResult func(p0 context.Context, p1 types.RemoveAssetResult) error `perm:"edge,candidate"`

		PullAsset func(p0 context.Context, p1 *types.PullAssetReq) error `perm:"web,admin"`

		RePullFailedAssets func(p0 context.Context, p1 []types.AssetHash) error `perm:"admin"`

		RemoveAssetRecord func(p0 context.Context, p1 string) error `perm:"admin,web"`

		RemoveAssetRecords func(p0 context.Context, p1 []string) error `perm:"admin,web"`

		RemoveAssetReplica func(p0 context.Context, p1 string, p2 string) error `perm:"admin"`

		RemoveNodeFailedReplica func(p0 context.Context) error `perm:"web,admin"`

		ResetAssetReplicaCount func(p0 context.Context, p1 string, p2 int) error `perm:"web,admin"`

		ShareAssetV2 func(p0 context.Context, p1 *types.ShareAssetReq) (*types.ShareAssetRsp, error) `perm:"web,admin,user"`

		StopAssetRecord func(p0 context.Context, p1 []string) error `perm:"admin"`

		SwitchFillDiskTimer func(p0 context.Context, p1 bool) error `perm:"web,admin"`

		UpdateAssetExpiration func(p0 context.Context, p1 string, p2 time.Time) error `perm:"web,admin"`
	}
}

type AssetAPIStub struct {
}

type AssetStruct struct {
	Internal struct {
		AddAssetView func(p0 context.Context, p1 []string) error `perm:"admin"`

		ClearFreeUpDisk func(p0 context.Context) error `perm:"admin"`

		CreateAsset func(p0 context.Context, p1 *types.AuthUserUploadDownloadAsset) (string, error) `perm:"admin"`

		DeleteAsset func(p0 context.Context, p1 string) error `perm:"admin"`

		GetAssetProgresses func(p0 context.Context, p1 []string) (*types.PullResult, error) `perm:"admin"`

		GetAssetStats func(p0 context.Context) (*types.AssetStats, error) `perm:"admin"`

		GetAssetView func(p0 context.Context) (*types.AssetView, error) `perm:"admin"`

		GetAssetsInBucket func(p0 context.Context, p1 int) ([]string, error) `perm:"admin"`

		GetPullingAssetInfo func(p0 context.Context) (*types.InProgressAsset, error) `perm:"admin"`

		PullAsset func(p0 context.Context, p1 string, p2 []*types.CandidateDownloadInfo) error `perm:"admin"`

		PullAssetFromAWS func(p0 context.Context, p1 string, p2 string) error `perm:"admin"`

		PullAssetV2 func(p0 context.Context, p1 *types.AssetPullRequest) error `perm:"admin"`

		RequestFreeUpDisk func(p0 context.Context, p1 float64) error `perm:"admin"`

		StateFreeUpDisk func(p0 context.Context) (*types.FreeUpDiskStateResp, error) `perm:"admin"`

		SyncAssetViewAndData func(p0 context.Context) error `perm:"admin"`
	}
}

type AssetStub struct {
}

type Candidate interface {
	Common
	Device
	Validation
	DataSync
	Asset

	WaitQuiet(ctx context.Context) error                                                                             //perm:admin
	GetBlocksWithAssetCID(ctx context.Context, assetCID string, randomSeed int64, randomCount int) ([]string, error) //perm:admin
	// GetExternalAddress retrieves the external address of the caller.
	GetExternalAddress(ctx context.Context) (string, error) //perm:default
	// CheckNetworkConnectivity deprecated
	CheckNetworkConnectivity(ctx context.Context, network, targetURL string) error //perm:default
	// CheckNetworkConnectable check network if connectable
	CheckNetworkConnectable(ctx context.Context, network, targetURL string) (bool, error) //perm:admin
	GetMinioConfig(ctx context.Context) (*types.MinioConfig, error)                       //perm:admin

	DeactivateNode(ctx context.Context) error                             //perm:default
	CalculateExitProfit(ctx context.Context) (types.ExitProfitRsp, error) //perm:default
}

type CandidateStruct struct {
	CommonStruct

	DeviceStruct

	ValidationStruct

	DataSyncStruct

	AssetStruct

	Internal struct {
		CalculateExitProfit func(p0 context.Context) (types.ExitProfitRsp, error) `perm:"default"`

		CheckNetworkConnectable func(p0 context.Context, p1 string, p2 string) (bool, error) `perm:"admin"`

		CheckNetworkConnectivity func(p0 context.Context, p1 string, p2 string) error `perm:"default"`

		DeactivateNode func(p0 context.Context) error `perm:"default"`

		GetBlocksWithAssetCID func(p0 context.Context, p1 string, p2 int64, p3 int) ([]string, error) `perm:"admin"`

		GetExternalAddress func(p0 context.Context) (string, error) `perm:"default"`

		GetMinioConfig func(p0 context.Context) (*types.MinioConfig, error) `perm:"admin"`

		WaitQuiet func(p0 context.Context) error `perm:"admin"`
	}
}

type CandidateStub struct {
	CommonStub

	DeviceStub

	ValidationStub

	DataSyncStub

	AssetStub
}

type Common interface {

	// AuthVerify checks whether the specified token is valid and returns the list of permissions associated with it.
	AuthVerify(ctx context.Context, token string) (*types.JWTPayload, error) //perm:default
	// AuthNew creates a new token with the specified list of permissions.
	AuthNew(ctx context.Context, payload *types.JWTPayload) (string, error) //perm:admin

	// LogList returns a list of all logs in the system.
	LogList(context.Context) ([]string, error) //perm:admin
	// LogSetLevel sets the log level of the specified logger.
	LogSetLevel(context.Context, string, string) error //perm:admin
	// LogAlerts returns list of all, active and inactive alerts tracked by the
	LogAlerts(ctx context.Context) ([]alerting.Alert, error) //perm:admin

	// Version provides information about API provider
	Version(context.Context) (APIVersion, error) //perm:default
	// Discover returns an OpenRPC document describing an RPC API.
	Discover(ctx context.Context) (types.OpenRPCDocument, error) //perm:admin
	// Shutdown trigger graceful shutdown
	Shutdown(context.Context) error //perm:admin
	// Session returns a UUID of api provider session
	Session(ctx context.Context) (uuid.UUID, error) //perm:edge,candidate,l5

	// Closing jsonrpc closing
	Closing(context.Context) (<-chan struct{}, error) //perm:admin

	// ExternalServiceAddress check service address with different candidate
	// if behind nat, service address maybe different
	ExternalServiceAddress(ctx context.Context, rpcURL string) (string, error) //perm:admin
}

type CommonStruct struct {
	Internal struct {
		AuthNew func(p0 context.Context, p1 *types.JWTPayload) (string, error) `perm:"admin"`

		AuthVerify func(p0 context.Context, p1 string) (*types.JWTPayload, error) `perm:"default"`

		Closing func(p0 context.Context) (<-chan struct{}, error) `perm:"admin"`

		Discover func(p0 context.Context) (types.OpenRPCDocument, error) `perm:"admin"`

		ExternalServiceAddress func(p0 context.Context, p1 string) (string, error) `perm:"admin"`

		LogAlerts func(p0 context.Context) ([]alerting.Alert, error) `perm:"admin"`

		LogList func(p0 context.Context) ([]string, error) `perm:"admin"`

		LogSetLevel func(p0 context.Context, p1 string, p2 string) error `perm:"admin"`

		Session func(p0 context.Context) (uuid.UUID, error) `perm:"edge,candidate,l5"`

		Shutdown func(p0 context.Context) error `perm:"admin"`

		Version func(p0 context.Context) (APIVersion, error) `perm:"default"`
	}
}

type CommonStub struct {
}

type DataSync interface {
	// CompareTopHash check asset if same as scheduler.
	// topHash is hash of all buckets
	CompareTopHash(ctx context.Context, topHash string) (bool, error) //perm:admin
	// CompareBucketHashes group asset in bucket, and compare single bucket hash
	// hashes are map of bucket, key is number of bucket, value is hash
	// return mismatch bucket number
	CompareBucketHashes(ctx context.Context, hashes map[uint32]string) ([]uint32, error) //perm:admin
}

type DataSyncStruct struct {
	Internal struct {
		CompareBucketHashes func(p0 context.Context, p1 map[uint32]string) ([]uint32, error) `perm:"admin"`

		CompareTopHash func(p0 context.Context, p1 string) (bool, error) `perm:"admin"`
	}
}

type DataSyncStub struct {
}

type Device interface {
	GetNodeInfo(ctx context.Context) (types.NodeInfo, error)                    //perm:admin
	GetNodeID(ctx context.Context) (string, error)                              //perm:admin
	GetDeviceRunningStat(ctx context.Context) (*types.DeviceRunningStat, error) //perm:admin
}

type DeviceStruct struct {
	Internal struct {
		GetDeviceRunningStat func(p0 context.Context) (*types.DeviceRunningStat, error) `perm:"admin"`

		GetNodeID func(p0 context.Context) (string, error) `perm:"admin"`

		GetNodeInfo func(p0 context.Context) (types.NodeInfo, error) `perm:"admin"`
	}
}

type DeviceStub struct {
}

type Edge interface {
	Common
	Device
	Validation
	DataSync
	Asset
	Workerd
	WaitQuiet(ctx context.Context) error //perm:admin
	// UserNATTravel build connection for user
	UserNATPunch(ctx context.Context, userServiceAddress string, req *types.NatPunchReq) error //perm:admin
	// GetEdgeOnlineStateFromScheduler this online state is get from scheduler
	GetEdgeOnlineStateFromScheduler(ctx context.Context) (bool, error) //perm:default
	// Restart trigger graceful restart of edge node
	Restart(ctx context.Context) error // perm:admin

	// CreateTunnel create a tunnel for workerd communication
	CreateTunnel(ctx context.Context, req *types.CreateTunnelReq) error // perm:admin
}

type EdgeStruct struct {
	CommonStruct

	DeviceStruct

	ValidationStruct

	DataSyncStruct

	AssetStruct

	WorkerdStruct

	Internal struct {
		CreateTunnel func(p0 context.Context, p1 *types.CreateTunnelReq) error `perm:"admin"`

		GetEdgeOnlineStateFromScheduler func(p0 context.Context) (bool, error) `perm:"default"`

		Restart func(p0 context.Context) error `perm:"admin"`

		UserNATPunch func(p0 context.Context, p1 string, p2 *types.NatPunchReq) error `perm:"admin"`

		WaitQuiet func(p0 context.Context) error `perm:"admin"`
	}
}

type EdgeStub struct {
	CommonStub

	DeviceStub

	ValidationStub

	DataSyncStub

	AssetStub

	WorkerdStub
}

type EdgeUpdateConfig struct {
	NodeType    int       `db:"node_type"`
	AppName     string    `db:"app_name"`
	Version     Version   `db:"version"`
	DownloadURL string    `db:"download_url"`
	Hash        string    `db:"hash"`
	UpdateTime  time.Time `db:"update_time"`
}

type ErrNode = ErrWeb

type ErrUnknown struct{}

type ErrWeb struct {
	Code    int
	Message string
}

type L5 interface {
	Common
	WaitQuiet(ctx context.Context) error //perm:admin
}

type L5Struct struct {
	CommonStruct

	Internal struct {
		WaitQuiet func(p0 context.Context) error `perm:"admin"`
	}
}

type L5Stub struct {
	CommonStub
}

type Locator interface {
	Common
	// GetAccessPoints retrieves all access points associated with a node.
	GetAccessPoints(ctx context.Context, nodeID, areaID string) ([]string, error) //perm:default
	// GetAccessPointsV2 retrieves all access points associated with a node.
	GetAccessPointsV2(ctx context.Context, nodeID, areaID string) (*types.AccessPointRsp, error) //perm:default
	// user api
	// EdgeDownloadInfos retrieves download information for a content identifier (CID).
	EdgeDownloadInfos(ctx context.Context, cid string) ([]*types.EdgeDownloadInfoList, error) //perm:default
	// GetUserAccessPoint retrieves an access point for a user with a specified IP address.
	GetUserAccessPoint(ctx context.Context, userIP string) (*AccessPoint, error) //perm:default
	// CandidateDownloadInfos retrieves information about candidate's download interface
	CandidateDownloadInfos(ctx context.Context, cid string) ([]*types.CandidateDownloadInfo, error) //perm:default
	// GetAssetSourceDownloadInfo
	GetAssetSourceDownloadInfos(ctx context.Context, cid string) ([]*types.AssetSourceDownloadInfoRsp, error) //perm:default
	// GetCandidateIP retrieves ip of candidate, used in the locator dns
	GetCandidateIP(ctx context.Context, nodeID string) (string, error) //perm:admin
	// GetSchedulerWithNode get the scheduler that the node is already connected to
	GetSchedulerWithNode(ctx context.Context, nodeID string) (string, error) //perm:default
	// // GetSchedulerWithAPIKey get the scheduler that the user create the api key
	// GetSchedulerWithAPIKey(ctx context.Context, apiKey string) (string, error)                          //perm:default
	AllocateSchedulerForNode(ctx context.Context, nodeType types.NodeType, code string) (string, error) //perm:default
	GetDeploymentCandidateIP(ctx context.Context, deploymentID string) (string, error)                  //perm:default
}

type LocatorStruct struct {
	CommonStruct

	Internal struct {
		AllocateSchedulerForNode func(p0 context.Context, p1 types.NodeType, p2 string) (string, error) `perm:"default"`

		CandidateDownloadInfos func(p0 context.Context, p1 string) ([]*types.CandidateDownloadInfo, error) `perm:"default"`

		EdgeDownloadInfos func(p0 context.Context, p1 string) ([]*types.EdgeDownloadInfoList, error) `perm:"default"`

		GetAccessPoints func(p0 context.Context, p1 string, p2 string) ([]string, error) `perm:"default"`

		GetAccessPointsV2 func(p0 context.Context, p1 string, p2 string) (*types.AccessPointRsp, error) `perm:"default"`

		GetAssetSourceDownloadInfos func(p0 context.Context, p1 string) ([]*types.AssetSourceDownloadInfoRsp, error) `perm:"default"`

		GetCandidateIP func(p0 context.Context, p1 string) (string, error) `perm:"admin"`

		GetDeploymentCandidateIP func(p0 context.Context, p1 string) (string, error) `perm:"default"`

		GetSchedulerWithNode func(p0 context.Context, p1 string) (string, error) `perm:"default"`

		GetUserAccessPoint func(p0 context.Context, p1 string) (*AccessPoint, error) `perm:"default"`
	}
}

type LocatorStub struct {
	CommonStub
}

type LogFile struct {
	Name string
	Size int64
}

type NodeAPI interface {
	// Node-related methods
	// GetOnlineNodeCount returns the count of online nodes for a given node type
	GetOnlineNodeCount(ctx context.Context, nodeType types.NodeType) (int, error) //perm:web,admin
	// RegisterNode adds new node to the scheduler
	RegisterNode(ctx context.Context, nodeID, publicKey string, nodeType types.NodeType) (*types.ActivationDetail, error) //perm:default
	// RegisterEdgeNode adds new edge node to the scheduler
	RegisterEdgeNode(ctx context.Context, nodeID, publicKey string) (*types.ActivationDetail, error) //perm:default
	// RegisterCandidateNode adds new node to the scheduler
	RegisterCandidateNode(ctx context.Context, nodeID, publicKey, code string) (*types.ActivationDetail, error) //perm:default
	// RegisterNodeV2 adds new edge node to the scheduler
	RegisterNodeV2(ctx context.Context, info types.NodeRegister) (*types.ActivationDetail, error) //perm:default
	// DeactivateNode is used to deactivate a node in the titan server.
	// It stops the node from serving any requests and marks it as inactive.
	// - nodeID: The ID of the node to deactivate.
	// - hours: The deactivation countdown time in hours. It specifies the duration
	// before the deactivation is executed. If the deactivation is canceled within
	// this period, the node will remain active.
	DeactivateNode(ctx context.Context, nodeID string, hours int) error                          //perm:web,admin,candidate
	DeactivateNodeV2(ctx context.Context, nodeID string, hours int, reductionRate float64) error //perm:web,admin,candidate
	// ForceNodeOffline changes the online status of a node identified by nodeID.
	// If the status is true, it forces the node offline. If the status is false, it brings the node back online.
	ForceNodeOffline(ctx context.Context, nodeID string, forceOffline bool) error //perm:web,admin
	// MigrateNodeOut Migrate out the node
	MigrateNodeOut(ctx context.Context, nodeID string) (*types.NodeMigrateInfo, error) //perm:web,admin
	// MigrateNodeIn Migrate in the node
	MigrateNodeIn(ctx context.Context, info *types.NodeMigrateInfo) error //perm:web,admin
	// CleanupNode removes residual data from the source server after a node has been migrated.
	CleanupNode(ctx context.Context, nodeID, key string) error //perm:web,admin
	// CalculateExitProfit please use CalculateDowntimePenalty
	CalculateExitProfit(ctx context.Context, nodeID string) (types.ExitProfitRsp, error) //perm:web,admin,candidate
	// CalculateDowntimePenalty calculates the penalty points to be deducted for a node's requested downtime.
	CalculateDowntimePenalty(ctx context.Context, nodeID string) (types.ExitProfitRsp, error) //perm:web,admin,candidate
	// UndoNodeDeactivation is used to undo the deactivation of a node in the titan server.
	// It allows the previously deactivated node to start serving requests again.
	UndoNodeDeactivation(ctx context.Context, nodeID string) error //perm:web,admin
	// UpdateNodePort updates the port for the node with the specified node
	UpdateNodePort(ctx context.Context, nodeID, port string) error //perm:web,admin
	// EdgeConnect edge node login to the scheduler
	EdgeConnect(ctx context.Context, opts *types.ConnectOptions) error //perm:edge
	// CandidateConnect candidate node login to the scheduler
	CandidateConnect(ctx context.Context, opts *types.ConnectOptions) error //perm:candidate
	// L5Connect l5 node login to the scheduler
	L5Connect(ctx context.Context, opts *types.ConnectOptions) error //perm:l5
	// L3Connect l3 node login to the scheduler
	L3Connect(ctx context.Context, opts *types.ConnectOptions) error //perm:edge
	// GetExternalAddress retrieves the external address of the caller.
	GetExternalAddress(ctx context.Context) (string, error) //perm:default
	// NodeLogin generates an authentication token for a node with the specified node ID and signature
	NodeLogin(ctx context.Context, nodeID, sign string) (string, error) //perm:default
	// GetNodeInfo get information for node
	GetNodeInfo(ctx context.Context, nodeID string) (*types.NodeInfo, error) //perm:web,admin
	// GetNodeList retrieves a list of nodes with pagination using the specified cursor and count
	GetNodeList(ctx context.Context, cursor int, count int) (*types.ListNodesRsp, error) //perm:web,admin
	// GetNodesFromRegion retrieves a list of nodes with pagination using the specified cursor and count
	GetNodesFromRegion(ctx context.Context, areaID string) ([]*types.NodeInfo, error) //perm:web,admin
	// GetCurrentRegionInfos retrieves a list of nodes with pagination using the specified cursor and count
	GetCurrentRegionInfos(ctx context.Context, areaID string) (map[string]int, error) //perm:web,admin
	// GetCandidateURLsForDetectNat Get the rpc url of the specified number of candidate nodes
	GetCandidateURLsForDetectNat(ctx context.Context) ([]string, error) //perm:default
	// GetEdgeExternalServiceAddress nat travel, get edge external addr with different candidate
	GetEdgeExternalServiceAddress(ctx context.Context, nodeID, candidateURL string) (string, error) //perm:admin
	// NatPunch nat punch between user and node
	NatPunch(ctx context.Context, target *types.NatPunchReq) error //perm:default
	// GetEdgeDownloadInfos retrieves download information for the edge with the asset with the specified CID.
	GetEdgeDownloadInfos(ctx context.Context, cid string) (*types.EdgeDownloadInfoList, error) //perm:default
	// GetCandidateDownloadInfos retrieves download information for the candidate with the asset with the specified CID.
	GetCandidateDownloadInfos(ctx context.Context, cid string) ([]*types.CandidateDownloadInfo, error) //perm:edge,candidate,web,locator
	// GetAssetSourceDownloadInfo retrieves the download details for a specified asset.
	GetAssetSourceDownloadInfo(ctx context.Context, cid string) (*types.AssetSourceDownloadInfoRsp, error) //perm:edge,candidate,web,locator
	// NodeExists checks if the node with the specified ID exists.
	NodeExists(ctx context.Context, nodeID string) error //perm:web
	// NodeKeepalive
	NodeKeepalive(ctx context.Context) (*types.KeepaliveRsp, error) //perm:edge,candidate
	// NodeKeepaliveV2 fix the problem of NodeKeepalive, Maintaining old device connections
	NodeKeepaliveV2(ctx context.Context) (uuid.UUID, error) //perm:edge,candidate,l5
	// NodeKeepaliveV3
	NodeKeepaliveV3(ctx context.Context, req *types.KeepaliveReq) (*types.KeepaliveRsp, error) //perm:edge,candidate,l5
	// RequestActivationCodes Get the device's encrypted activation code
	RequestActivationCodes(ctx context.Context, nodeType types.NodeType, count int) ([]*types.NodeActivation, error) //perm:web,admin
	// VerifyTokenWithLimitCount verify token in limit count
	VerifyTokenWithLimitCount(ctx context.Context, token string) (*types.JWTPayload, error) //perm:edge,candidate
	// UpdateBandwidths update node bandwidthDown and bandwidthUp
	UpdateBandwidths(ctx context.Context, bandwidthDown, bandwidthUp int64) error //perm:edge,candidate
	// GetCandidateNodeIP get candidate ip for locator
	GetCandidateNodeIP(ctx context.Context, nodeID string) (string, error) //perm:web,admin
	// GetMinioConfigFromCandidate get minio config from candidate
	GetMinioConfigFromCandidate(ctx context.Context, nodeID string) (*types.MinioConfig, error) //perm:default
	// GetCandidateIPs get candidate ips
	GetCandidateIPs(ctx context.Context) ([]*types.NodeIPInfo, error) //perm:web,user,admin
	// GetNodeOnlineState get node online state
	GetNodeOnlineState(ctx context.Context) (bool, error) //perm:edge
	// DownloadDataResult node download data from AWS result
	DownloadDataResult(ctx context.Context, bucket, cid string, size int64) error //perm:edge,candidate
	// GetNodeToken get node token
	GetNodeToken(ctx context.Context, nodeID string) (string, error) //perm:admin
	// CheckIpUsage  checks if a specific IP address is present on the server.
	CheckIpUsage(ctx context.Context, ip string) (bool, error) //perm:admin,web,locator
	// GetAssetView get the asset view of node
	GetAssetView(ctx context.Context, nodeID string, isFromNode bool) (*types.AssetView, error) //perm:admin
	// GetAssetInBucket get the assets of the bucket
	GetAssetsInBucket(ctx context.Context, nodeID string, bucketID int, isFromNode bool) ([]string, error) //perm:admin
	// GetNodeOfIP get nodes
	GetNodeOfIP(ctx context.Context, ip string) ([]string, error) //perm:admin,web,locator
	// PerformSyncData sync the assetView of scheduler and node
	PerformSyncData(ctx context.Context, nodeID string) error //perm:admin
	// GetProfitDetailsForNode retrieves a profit list of node
	GetProfitDetailsForNode(ctx context.Context, nodeID string, limit, offset int, ts []int) (*types.ListNodeProfitDetailsRsp, error) //perm:web,admin
	// FreeUpDiskSpace  Request to free up disk space, returns free hashes and next time
	FreeUpDiskSpace(ctx context.Context, nodeID string, size int64) (*types.FreeUpDiskResp, error) //perm:edge,candidate,admin
	// GetNextFreeTime returns the next free up time
	GetNextFreeTime(ctx context.Context, nodeID string) (int64, error) //perm:edge,candidate,admin

	// ReDetermineNodeNATType
	ReDetermineNodeNATType(ctx context.Context, nodeID string) error //perm:admin,web,locator
	// SetTunserverURL
	SetTunserverURL(ctx context.Context, nodeID, wsNodeID string) error //perm:admin,web,locator
	// RecompenseNodeProfit
	RecompenseNodeProfit(ctx context.Context, nodeID, note string, profit float64) error //perm:admin,web,locator
	// GetTunserverURLFromUser
	GetTunserverURLFromUser(ctx context.Context, req *types.TunserverReq) (*types.TunserverRsp, error) //perm:admin,web,locator
	// CreateTunnel create tunnel for workerd communication
	CreateTunnel(ctx context.Context, req *types.CreateTunnelReq) error // perm:candidate
	// UserAssetDownloadResult After a user downloads a resource from a candidate node, the candidate node reports the download result
	UserAssetDownloadResultV2(ctx context.Context, info *types.RetrieveEvent) error //perm:candidate
	// LoadNodeBandwidthScores
	LoadNodeBandwidthScores(ctx context.Context, nodeID string, start, end time.Time, limit int, offset int) (*types.ListBandwidthScoreRsp, error) //perm:user,web,admin
}

type NodeAPIStruct struct {
	Internal struct {
		CalculateDowntimePenalty func(p0 context.Context, p1 string) (types.ExitProfitRsp, error) `perm:"web,admin,candidate"`

		CalculateExitProfit func(p0 context.Context, p1 string) (types.ExitProfitRsp, error) `perm:"web,admin,candidate"`

		CandidateConnect func(p0 context.Context, p1 *types.ConnectOptions) error `perm:"candidate"`

		CheckIpUsage func(p0 context.Context, p1 string) (bool, error) `perm:"admin,web,locator"`

		CleanupNode func(p0 context.Context, p1 string, p2 string) error `perm:"web,admin"`

		CreateTunnel func(p0 context.Context, p1 *types.CreateTunnelReq) error `perm:"candidate"`

		DeactivateNode func(p0 context.Context, p1 string, p2 int) error `perm:"web,admin,candidate"`

		DeactivateNodeV2 func(p0 context.Context, p1 string, p2 int, p3 float64) error `perm:"web,admin,candidate"`

		DownloadDataResult func(p0 context.Context, p1 string, p2 string, p3 int64) error `perm:"edge,candidate"`

		EdgeConnect func(p0 context.Context, p1 *types.ConnectOptions) error `perm:"edge"`

		ForceNodeOffline func(p0 context.Context, p1 string, p2 bool) error `perm:"web,admin"`

		FreeUpDiskSpace func(p0 context.Context, p1 string, p2 int64) (*types.FreeUpDiskResp, error) `perm:"edge,candidate,admin"`

		GetAssetSourceDownloadInfo func(p0 context.Context, p1 string) (*types.AssetSourceDownloadInfoRsp, error) `perm:"edge,candidate,web,locator"`

		GetAssetView func(p0 context.Context, p1 string, p2 bool) (*types.AssetView, error) `perm:"admin"`

		GetAssetsInBucket func(p0 context.Context, p1 string, p2 int, p3 bool) ([]string, error) `perm:"admin"`

		GetCandidateDownloadInfos func(p0 context.Context, p1 string) ([]*types.CandidateDownloadInfo, error) `perm:"edge,candidate,web,locator"`

		GetCandidateIPs func(p0 context.Context) ([]*types.NodeIPInfo, error) `perm:"web,user,admin"`

		GetCandidateNodeIP func(p0 context.Context, p1 string) (string, error) `perm:"web,admin"`

		GetCandidateURLsForDetectNat func(p0 context.Context) ([]string, error) `perm:"default"`

		GetCurrentRegionInfos func(p0 context.Context, p1 string) (map[string]int, error) `perm:"web,admin"`

		GetEdgeDownloadInfos func(p0 context.Context, p1 string) (*types.EdgeDownloadInfoList, error) `perm:"default"`

		GetEdgeExternalServiceAddress func(p0 context.Context, p1 string, p2 string) (string, error) `perm:"admin"`

		GetExternalAddress func(p0 context.Context) (string, error) `perm:"default"`

		GetMinioConfigFromCandidate func(p0 context.Context, p1 string) (*types.MinioConfig, error) `perm:"default"`

		GetNextFreeTime func(p0 context.Context, p1 string) (int64, error) `perm:"edge,candidate,admin"`

		GetNodeInfo func(p0 context.Context, p1 string) (*types.NodeInfo, error) `perm:"web,admin"`

		GetNodeList func(p0 context.Context, p1 int, p2 int) (*types.ListNodesRsp, error) `perm:"web,admin"`

		GetNodeOfIP func(p0 context.Context, p1 string) ([]string, error) `perm:"admin,web,locator"`

		GetNodeOnlineState func(p0 context.Context) (bool, error) `perm:"edge"`

		GetNodeToken func(p0 context.Context, p1 string) (string, error) `perm:"admin"`

		GetNodesFromRegion func(p0 context.Context, p1 string) ([]*types.NodeInfo, error) `perm:"web,admin"`

		GetOnlineNodeCount func(p0 context.Context, p1 types.NodeType) (int, error) `perm:"web,admin"`

		GetProfitDetailsForNode func(p0 context.Context, p1 string, p2 int, p3 int, p4 []int) (*types.ListNodeProfitDetailsRsp, error) `perm:"web,admin"`

		GetTunserverURLFromUser func(p0 context.Context, p1 *types.TunserverReq) (*types.TunserverRsp, error) `perm:"admin,web,locator"`

		L3Connect func(p0 context.Context, p1 *types.ConnectOptions) error `perm:"edge"`

		L5Connect func(p0 context.Context, p1 *types.ConnectOptions) error `perm:"l5"`

		LoadNodeBandwidthScores func(p0 context.Context, p1 string, p2 time.Time, p3 time.Time, p4 int, p5 int) (*types.ListBandwidthScoreRsp, error) `perm:"user,web,admin"`

		MigrateNodeIn func(p0 context.Context, p1 *types.NodeMigrateInfo) error `perm:"web,admin"`

		MigrateNodeOut func(p0 context.Context, p1 string) (*types.NodeMigrateInfo, error) `perm:"web,admin"`

		NatPunch func(p0 context.Context, p1 *types.NatPunchReq) error `perm:"default"`

		NodeExists func(p0 context.Context, p1 string) error `perm:"web"`

		NodeKeepalive func(p0 context.Context) (*types.KeepaliveRsp, error) `perm:"edge,candidate"`

		NodeKeepaliveV2 func(p0 context.Context) (uuid.UUID, error) `perm:"edge,candidate,l5"`

		NodeKeepaliveV3 func(p0 context.Context, p1 *types.KeepaliveReq) (*types.KeepaliveRsp, error) `perm:"edge,candidate,l5"`

		NodeLogin func(p0 context.Context, p1 string, p2 string) (string, error) `perm:"default"`

		PerformSyncData func(p0 context.Context, p1 string) error `perm:"admin"`

		ReDetermineNodeNATType func(p0 context.Context, p1 string) error `perm:"admin,web,locator"`

		RecompenseNodeProfit func(p0 context.Context, p1 string, p2 string, p3 float64) error `perm:"admin,web,locator"`

		RegisterCandidateNode func(p0 context.Context, p1 string, p2 string, p3 string) (*types.ActivationDetail, error) `perm:"default"`

		RegisterEdgeNode func(p0 context.Context, p1 string, p2 string) (*types.ActivationDetail, error) `perm:"default"`

		RegisterNode func(p0 context.Context, p1 string, p2 string, p3 types.NodeType) (*types.ActivationDetail, error) `perm:"default"`

		RegisterNodeV2 func(p0 context.Context, p1 types.NodeRegister) (*types.ActivationDetail, error) `perm:"default"`

		RequestActivationCodes func(p0 context.Context, p1 types.NodeType, p2 int) ([]*types.NodeActivation, error) `perm:"web,admin"`

		SetTunserverURL func(p0 context.Context, p1 string, p2 string) error `perm:"admin,web,locator"`

		UndoNodeDeactivation func(p0 context.Context, p1 string) error `perm:"web,admin"`

		UpdateBandwidths func(p0 context.Context, p1 int64, p2 int64) error `perm:"edge,candidate"`

		UpdateNodePort func(p0 context.Context, p1 string, p2 string) error `perm:"web,admin"`

		UserAssetDownloadResultV2 func(p0 context.Context, p1 *types.RetrieveEvent) error `perm:"candidate"`

		VerifyTokenWithLimitCount func(p0 context.Context, p1 string) (*types.JWTPayload, error) `perm:"edge,candidate"`
	}
}

type NodeAPIStub struct {
}