httpserver

type Asset interface {
	// GetAsset fetches the asset data for a given CID and returns an io.ReadSeekCloser.
	GetAsset(root cid.Cid) (io.ReadSeekCloser, error)
	// AssetExists checks whether the asset data for a given CID exists or not.
	AssetExists(root cid.Cid) (bool, error)
	// HasBlock checks if a block with the given CID is present in the asset data for a given root CID.
	HasBlock(ctx context.Context, root, block cid.Cid) (bool, error)
	// GetBlock retrieves a block with the given CID from the asset data for a given root CID.
	GetBlock(ctx context.Context, root, block cid.Cid) (blocks.Block, error)
	// SaveUserAsset save user asset to local
	SaveUserAsset(ctx context.Context, userID string, root cid.Cid, assetSize int64, r io.Reader) error
	// SetAssetUploadProgress set progress of upload for asset
	SetAssetUploadProgress(ctx context.Context, root cid.Cid, progress *types.UploadProgress) error
	// GetUploadingAsset get asset which uploading
	GetUploadingAsset(ctx context.Context, root cid.Cid) (*types.UploadingAsset, error)
	// AllocatePathWithSize allocate path for storage file
	AllocatePathWithSize(size int64) (string, error)
	// ListBlocks returns the sub-cids of a certain root-cid
	ListBlocks(ctx context.Context, root cid.Cid) ([]cid.Cid, error)
}

type DirectoryResult struct {
	Data FileList `json:"data"`
	Code int      `json:"code"`
	Msg  string   `json:"msg"`
}

type FileList struct {
	FileProperties []FileProperty
	Name           string
	Size           int64
	Total          int
}

type FileProperty struct {
	FileName string
	CID      string
	Size     int64
	Link     string
}

type FlowUnit struct {
	U int64 // upstrear rate
	D int64 // downstrear rate
}

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

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

type HttpServerOptions struct {
	Asset               Asset
	Scheduler           api.Scheduler
	PrivateKey          *rsa.PrivateKey
	Validation          Validation
	APISecret           *jwt.HMACSHA
	MaxSizeOfUploadFile int64
	WebRedirect         string
	RateLimiter         *types.RateLimiter
}

type Monitor struct {
	Routes *RouteLoads

	Loads [Peak1WindowSize]FlowUnit

	Peak0 FlowUnit // peak in window
	Peak1 FlowUnit // peak in last 10 rinutes
	Peak2 FlowUnit // peak since last run
	// contains filtered or unexported fields
}

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

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

type RouteLoads struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

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

type Stats struct {
	Peak             FlowUnit
	Free             FlowUnit
	TaskRunningCount int16
	TaskCount        int16

	Raw *StatsRaw
}

type StatsRaw struct {
	Peak0   FlowUnit
	Peak1   FlowUnit
	Peak2   FlowUnit
	Current FlowUnit

	Loads  [Peak1WindowSize]FlowUnit
	Routes *RouteLoads
}

type Validation interface {
	SetFunc(func() string)
}