dload

type AdminBody struct {
	ID         string `json:"id"`
	Regex      string `json:"regex"`
	OnlyActive bool   `json:"only_active_tasks"` // Skips detailed info about tasks finished/errored
}

type BackendBody struct {
	Base
	Prefix string `json:"prefix"`
	Suffix string `json:"suffix"`
	Sync   bool   `json:"sync"`
}

type BackendResource struct {
	ObjName string
}

type Base struct {
	Description      string  `json:"description"`
	Bck              cmn.Bck `json:"bucket"`
	Timeout          string  `json:"timeout"`
	ProgressInterval string  `json:"progress_interval"`
	Limits           Limits  `json:"limits"`
}

type Body struct {
	Type Type `json:"type"`
	json.RawMessage
}

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

type DiffResolverCtx interface {
	CompareObjects(*cluster.LOM, *DstElement) (bool, error)
	IsObjFromRemote(*cluster.LOM) (bool, error)
}

type DiffResolverResult struct {
	Action uint8
	Src    *cluster.LOM
	Dst    *DstElement
	Err    error
}

type DlPostResp struct {
	ID string `json:"id"`
}

type DstElement struct {
	ObjName string
	Version string
	Link    string
}

type Job struct {
	ID            string    `json:"id"`
	XactID        string    `json:"xaction_id"`
	Description   string    `json:"description"`
	StartedTime   time.Time `json:"started_time"`
	FinishedTime  time.Time `json:"finished_time"`
	FinishedCnt   int       `json:"finished_cnt"`
	ScheduledCnt  int       `json:"scheduled_cnt"` // tasks being processed or already processed by dispatched
	SkippedCnt    int       `json:"skipped_cnt"`   // number of tasks skipped
	ErrorCnt      int       `json:"error_cnt"`
	Total         int       `json:"total"`          // total number of tasks, negative if unknown
	AllDispatched bool      `json:"all_dispatched"` // if true, dispatcher has already scheduled all tasks for given job
	Aborted       bool      `json:"aborted"`
}

type JobInfos []*Job

type Limits struct {
	Connections  int `json:"connections"`
	BytesPerHour int `json:"bytes_per_hour"`
}

type MultiBody struct {
	Base
	ObjectsPayload any `json:"objects"`
}

type NotifDownload struct {
	nl.Base
	// contains filtered or unexported fields
}

type NotifDownloadListerner struct {
	nl.ListenerBase
}

type RangeBody struct {
	Base
	Template string `json:"template"`
	Subdir   string `json:"subdir"`
}

type SingleBody struct {
	Base
	SingleObj
}

type SingleObj struct {
	ObjName    string `json:"object_name"`
	Link       string `json:"link"`
	FromRemote bool   `json:"from_remote"`
}

type StatusResp struct {
	Job
	CurrentTasks  []TaskDlInfo  `json:"current_tasks,omitempty"`
	FinishedTasks []TaskDlInfo  `json:"finished_tasks,omitempty"`
	Errs          []TaskErrInfo `json:"download_errors,omitempty"`
}

type TaskDlInfo struct {
	Name       string    `json:"name"`
	Downloaded int64     `json:"downloaded,string"`
	Total      int64     `json:"total,string,omitempty"`
	StartTime  time.Time `json:"start_time,omitempty"`
	EndTime    time.Time `json:"end_time,omitempty"`
	Running    bool      `json:"running"`
}

type TaskErrByName []TaskErrInfo

type TaskErrInfo struct {
	Name string `json:"name"`
	Err  string `json:"error"`
}

type TaskInfoByName []TaskDlInfo

type Type string

type WebResource struct {
	ObjName string
	Link    string
}

type Xact struct {
	xact.DemandBase
	// contains filtered or unexported fields
}