handlers

Documentation

Index

• Constants
• func ApplyFlags(commandLineInput *common.CopyCmdArgsAndFlags, ...)
• func HandleCopyCommand(commandLineInput common.CopyCmdArgsAndFlags) string
• func HandleDownloadFromWastoreToLocal(commandLineInput *common.CopyCmdArgsAndFlags, ...)
• func HandleListCommand(commandLineInput common.ListCmdArgsAndFlags)
• func HandleUploadFromLocalToWastore(commandLineInput *common.CopyCmdArgsAndFlags, ...)
• func PrintExistingJobIds(data []byte)
• func PrintJobProgressSummary(summaryData []byte, jobId string) (status common.Status)
• func PrintJobTransfers(data []byte, jobId string)

Constants

const (
	NumOfFilesPerUploadJobPart = 2
)

Functions

func ApplyFlags

func ApplyFlags(commandLineInput *common.CopyCmdArgsAndFlags, jobPartOrderToFill *common.CopyJobPartOrder)

func HandleCopyCommand

func HandleCopyCommand(commandLineInput common.CopyCmdArgsAndFlags) string

handles the copy command dispatches the job order (in parts) to the storage engine

func HandleDownloadFromWastoreToLocal

func HandleDownloadFromWastoreToLocal(
	commandLineInput *common.CopyCmdArgsAndFlags,
	jobPartOrderToFill *common.CopyJobPartOrder,
	dispatchJobPartOrderFunc func(jobPartOrder *common.CopyJobPartOrder))

func HandleListCommand

func HandleListCommand(commandLineInput common.ListCmdArgsAndFlags)

handles the list command dispatches the list order to the storage engine

func HandleUploadFromLocalToWastore

func HandleUploadFromLocalToWastore(commandLineInput *common.CopyCmdArgsAndFlags,
	jobPartOrderToFill *common.CopyJobPartOrder,
	dispatchJobPartOrderFunc func(jobPartOrder *common.CopyJobPartOrder))

func PrintExistingJobIds

func PrintExistingJobIds(data []byte)

PrintExistingJobIds prints the response of listOrder command when listOrder command requested the list of existing jobs

func PrintJobProgressSummary

func PrintJobProgressSummary(summaryData []byte, jobId string) (status common.Status)

PrintJobProgressSummary prints the response of listOrder command when listOrder command requested the progress summary of an existing job

func PrintJobTransfers

func PrintJobTransfers(data []byte, jobId string)

PrintJobTransfers prints the response of listOrder command when list Order command requested the list of specific transfer of an existing job