es_size

type Context interface {
	QueueIdScanFolder() string

	New(sessionId string, path es_filesystem.Path, stg eq_sequence.Stage, fs es_filesystem.FileSystem, folder, sum kv_storage.Storage, meta interface{}) Session
	StartSession(sessionId string, stg eq_sequence.Stage) error

	Get(sessionId string) (Session, error)

	Log() esl.Logger

	ListEach(depth int, h func(sessionId string, meta interface{}, size FolderSize)) error
}

type FolderSize struct {
	Path                  string     `json:"path"`
	Depth                 int        `json:"depth"`
	Size                  int64      `json:"size"`
	NumFile               int64      `json:"num_file"`
	NumFolder             int64      `json:"num_folder"`
	ModTimeEarliest       *time.Time `json:"mod_time_earliest"`
	ModTimeLatest         *time.Time `json:"mod_time_latest"`
	OperationalComplexity int64      `json:"operational_complexity"`
}

type Session interface {
	// Session Id of this scan
	SessionId() string

	// Logger
	Log() esl.Logger

	// Queue stage
	Stage() eq_sequence.Stage

	// Target file system
	FileSystem() es_filesystem.FileSystem

	// Storage for folder tree (path -> descendant paths)
	Folder() kv_storage.Storage

	// Storage for sum (path -> *FolderSize)
	Sum() kv_storage.Storage

	// List each results. This function must call after stage finish.
	// depth == 0 for the root folder.
	ListEach(depth int, h func(size FolderSize)) error

	// Session metadata
	Metadata() interface{}

	// Open session
	Open() error

	// Enqueue
	Enqueue(path es_filesystem.Path, depth int)
}

type TaskScanFolder struct {
	SessionId string                 `json:"session_id"`
	Path      es_filesystem.PathData `json:"path"`
	Depth     int                    `json:"depth"`
}

type TaskScanFolderDescendants struct {
	Folders []string `json:"folders"`
}