workers

Documentation

Index

• func CreateObjectWorker(jt *jobtracker.JobTracker, f string, context jobtracker.Context)
• func DownloadWorker(jt *jobtracker.JobTracker, file string, context jobtracker.Context)
• func FindObjectsWorker(jt *jobtracker.JobTracker, obj string, context jobtracker.Context)
• func FindRefWorker(jt *jobtracker.JobTracker, path string, context jobtracker.Context)
• func RecursiveDownloadWorker(jt *jobtracker.JobTracker, f string, context jobtracker.Context)
• type CreateObjectContext
• type DownloadContext
• type FindObjectsContext
• type FindRefContext
• type RecursiveDownloadContext

Functions

func CreateObjectWorker

func CreateObjectWorker(jt *jobtracker.JobTracker, f string, context jobtracker.Context)

func DownloadWorker

func DownloadWorker(jt *jobtracker.JobTracker, file string, context jobtracker.Context)

func FindObjectsWorker

func FindObjectsWorker(jt *jobtracker.JobTracker, obj string, context jobtracker.Context)

func FindRefWorker

func FindRefWorker(jt *jobtracker.JobTracker, path string, context jobtracker.Context)

func RecursiveDownloadWorker

func RecursiveDownloadWorker(jt *jobtracker.JobTracker, f string, context jobtracker.Context)

Types

type CreateObjectContext

type CreateObjectContext struct {
	BaseDir string
	Storage *filesystem.ObjectStorage
	Index   *index.Index
}

type DownloadContext

type DownloadContext struct {
	C           *fasthttp.Client
	BaseUrl     string
	BaseDir     string
	AllowHtml   bool
	AlllowEmpty bool
}

type FindObjectsContext

type FindObjectsContext struct {
	C       *fasthttp.Client
	BaseUrl string
	BaseDir string
	Storage *filesystem.ObjectStorage
}

type FindRefContext

type FindRefContext struct {
	C       *fasthttp.Client
	BaseUrl string
	BaseDir string
}

type RecursiveDownloadContext

type RecursiveDownloadContext struct {
	C       *fasthttp.Client
	BaseUrl string
	BaseDir string
}