sync

type Checkpoint struct {
	sync.RWMutex
	PrefixState      map[string]*PrefixState          `json:"prefix_state"`
	MultipartUploads map[string]*multipartUploadState `json:"multipart_uploads,omitempty"`
	Config           *Config                          `json:"config"`
	Stats            CheckpointStats                  `json:"stats"`
	SrcDelayDel      []string                         `json:"src_delay_del,omitempty"`
	DstDelayDel      []string                         `json:"dst_delay_del,omitempty"`
	UpdatedAt        time.Time                        `json:"updated_at"`
}

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

type CheckpointStats struct {
	Copied       int64 `json:"copied"`
	CopiedBytes  int64 `json:"copied_bytes"`
	Checked      int64 `json:"checked"`
	CheckedBytes int64 `json:"checked_bytes"`
	Deleted      int64 `json:"deleted"`
	Skipped      int64 `json:"skipped"`
	SkippedBytes int64 `json:"skipped_bytes"`
	Failed       int64 `json:"failed"`
	Handled      int64 `json:"handled"`
}

type Config struct {
	StorageClass      string
	Start             string
	End               string
	Threads           int
	Update            bool
	ForceUpdate       bool
	Perms             bool
	MaxFailure        int64
	Dry               bool
	DeleteSrc         bool
	DeleteSrcAfter    bool
	DeleteDst         bool
	MatchFullPath     bool
	Dirs              bool
	Exclude           []string
	Include           []string
	Existing          bool
	IgnoreExisting    bool
	Links             bool
	Inplace           bool
	Limit             int64
	Manager           string
	Workers           []string
	ManagerAddr       string
	ListThreads       int
	ListDepth         int
	BWLimit           int64
	TrafficControlURL string
	NoHTTPS           bool
	Verbose           bool
	Quiet             bool
	CheckAll          bool
	CheckNew          bool
	CheckChange       bool
	MaxSize           int64
	MinSize           int64
	MaxAge            time.Duration
	MinAge            time.Duration
	StartTime         time.Time
	EndTime           time.Time
	Env               map[string]string `json:"-"`

	FilesFrom string

	EnableCheckpoint     bool
	CheckpointInterval   time.Duration
	CheckpointForceReset bool

	Registerer prometheus.Registerer `json:"-"`
	// contains filtered or unexported fields
}

type PrefixState struct {
	sync.RWMutex
	ListDone      bool                     `json:"list_done"`
	LastListedKey string                   `json:"last_listed_key"`
	ListDepth     int                      `json:"list_depth"`
	PendingKeys   map[string]object.Object `json:"-"`
	FailedKeys    map[string]object.Object `json:"-"`
	// contains filtered or unexported fields
}

type Stat struct {
	Copied           int64                            // the number of copied files
	CopiedBytes      int64                            // total amount of copied data in bytes
	Checked          int64                            // the number of checked files
	CheckedBytes     int64                            // total amount of checked data in bytes
	Deleted          int64                            // the number of deleted files
	Skipped          int64                            // the number of files skipped
	SkippedBytes     int64                            // total amount of skipped data in bytes
	Failed           int64                            // the number of files that fail to copy
	DelayDelDir      []string                         // the directories that need to be deleted
	CompletedKeys    []string                         `json:"completed_keys,omitempty"` // checkpoint: keys completed by this worker
	FailedKeys       []string                         `json:"failed_keys,omitempty"`    // checkpoint: keys failed by this worker
	MultipartUploads map[string]*multipartUploadState `json:"multipart_uploads,omitempty"`
}