jobsAdmin

Documentation

Index

• Constants
• Variables
• func CancelPauseJobOrder(jobID common.JobID, desiredJobStatus common.JobStatus) common.CancelPauseResumeResponse
• func ExecuteNewCopyJobPartOrder(order common.CopyJobPartOrderRequest) common.CopyJobPartOrderResponse
• func GetJobFromTo(r common.GetJobFromToRequest) common.GetJobFromToResponse
• func GetJobLCMWrapper(jobID common.JobID) common.LifecycleMgr
• func GetJobSummary(jobID common.JobID) common.ListJobSummaryResponse
• func ListJobTransfers(r common.ListJobTransfersRequest) common.ListJobTransfersResponse
• func ListJobs(givenStatus common.JobStatus) common.ListJobsResponse
• func MainSTE(concurrency ste.ConcurrencySettings, targetRateInMegaBitsPerSec float64, ...) error
• func ResumeJobOrder(req common.ResumeJobRequest) common.CancelPauseResumeResponse
• func ToFixed(num float64, precision int) float64

Constants

const EMPTY_SAS_STRING = ""

Variables

var JobsAdmin interface {
	NewJobPartPlanFileName(jobID common.JobID, partNumber common.PartNumber) ste.JobPartPlanFileName

	// JobIDDetails returns point-in-time list of JobIDDetails
	JobIDs() []common.JobID

	// JobMgr returns the specified JobID's JobMgr
	JobMgr(jobID common.JobID) (ste.IJobMgr, bool)
	JobMgrEnsureExists(jobID common.JobID, level common.LogLevel, commandString string) ste.IJobMgr

	// AddJobPartMgr associates the specified JobPartMgr with the Jobs Administrator
	//AddJobPartMgr(appContext context.Context, planFile JobPartPlanFileName) IJobPartMgr
	/*ScheduleTransfer(jptm IJobPartTransferMgr)*/
	ResurrectJob(jobId common.JobID, sourceSAS string, destinationSAS string, srcServiceClient *common.ServiceClient, dstServiceClient *common.ServiceClient, srcIsOAuth bool) bool

	ResurrectJobParts()

	// AppPathFolder returns the Azcopy application path folder.
	// JobPartPlanFile will be created inside this folder.
	AppPathFolder() string

	// returns the current value of bytesOverWire.
	BytesOverWire() int64

	LogToJobLog(msg string, level common.LogLevel)

	//DeleteJob(jobID common.JobID)
	common.ILoggerCloser

	CurrentMainPoolSize() int

	TryGetPerformanceAdvice(bytesInJob uint64, filesInJob uint32, fromTo common.FromTo, dir common.TransferDirection, p *ste.PipelineNetworkStats) []common.PerformanceAdvice

	SetConcurrencySettingsToAuto()

	// JobMgrCleanUp do the JobMgr cleanup.
	JobMgrCleanUp(jobId common.JobID)
	ListJobs(givenStatus common.JobStatus) common.ListJobsResponse
}

JobAdmin is the singleton that manages ALL running Jobs, their parts, & their transfers

Functions

func CancelPauseJobOrder

func CancelPauseJobOrder(jobID common.JobID, desiredJobStatus common.JobStatus) common.CancelPauseResumeResponse

func ExecuteNewCopyJobPartOrder

func ExecuteNewCopyJobPartOrder(order common.CopyJobPartOrderRequest) common.CopyJobPartOrderResponse

ExecuteNewCopyJobPartOrder api executes a new job part order

func GetJobFromTo

func GetJobFromTo(r common.GetJobFromToRequest) common.GetJobFromToResponse

GetJobFromTo api returns the job FromTo info.

func GetJobLCMWrapper

func GetJobLCMWrapper(jobID common.JobID) common.LifecycleMgr

func GetJobSummary

func GetJobSummary(jobID common.JobID) common.ListJobSummaryResponse

GetJobSummary api returns the job progress summary of an active job

* Return following Properties in Job Progress Summary * CompleteJobOrdered - determines whether final part of job has been ordered or not * TotalTransfers - total number of transfers available for the given job * TotalNumberOfTransfersCompleted - total number of transfers in the job completed * NumberOfTransfersCompletedAfterCheckpoint - number of transfers completed after the last checkpoint * NumberOfTransferFailedAfterCheckpoint - number of transfers failed after last checkpoint timestamp * PercentageProgress - job progress reported in terms of percentage * FailedTransfers - list of transfer after last checkpoint timestamp that failed.

func ListJobTransfers

func ListJobTransfers(r common.ListJobTransfersRequest) common.ListJobTransfersResponse

ListJobTransfers api returns the list of transfer with specific status for given jobId in http response

func ListJobs

func ListJobs(givenStatus common.JobStatus) common.ListJobsResponse

ListJobs returns the jobId of all the jobs existing in the current instance of azcopy

func MainSTE

func MainSTE(concurrency ste.ConcurrencySettings, targetRateInMegaBitsPerSec float64, azcopyJobPlanFolder, azcopyLogPathFolder string, providePerfAdvice bool) error

MainSTE initializes the Storage Transfer Engine

func ResumeJobOrder

func ResumeJobOrder(req common.ResumeJobRequest) common.CancelPauseResumeResponse

func ToFixed

func ToFixed(num float64, precision int) float64

ToFixed api returns the float number precised up to given decimal places.