cmd

Documentation

Index

• Constants
• Variables
• func Execute(azsAppPathFolder string)
• func GetUserOAuthTokenManagerInstance() *common.UserOAuthTokenManager
• func HandleListContainerCommand(source string, outputFormat common.OutputFormat) (err error)
• func HandleListJobsCommand() error
• func HandlePauseCommand(jobIdString string)
• func HandleShowCommand(listRequest common.ListRequest) error
• func PrintExistingJobIds(listJobResponse common.ListJobsResponse) error
• func PrintJobProgressSummary(outputFormat common.OutputFormat, summary common.ListJobSummaryResponse)
• func PrintJobTransfers(outputForamt common.OutputFormat, ...)
• type HTTPClient
  • func NewHttpClient(url string) *HTTPClient
• type ListReq
• type ListResponse

Constants

const (
	NumOfFilesPerDispatchJobPart = 10000
)

Variables

var Rpc = func(cmd common.RpcCmd, request interface{}, response interface{}) {
	err := inprocSend(cmd, request, response)

	common.PanicIfErr(err)
}

Global singleton for sending RPC requests from the frontend to the STE

Functions

func Execute

func Execute(azsAppPathFolder string)

Execute adds all child commands to the root command and sets flags appropriately. This is called by main.main(). It only needs to happen once to the rootCmd.

func GetUserOAuthTokenManagerInstance

func GetUserOAuthTokenManagerInstance() *common.UserOAuthTokenManager

GetUserOAuthTokenManagerInstance gets or creates OAuthTokenManager for current user. Note: Currently, only support to have TokenManager for one user mapping to one tenantID.

func HandleListContainerCommand

func HandleListContainerCommand(source string, outputFormat common.OutputFormat) (err error)

HandleListContainerCommand handles the list container command

func HandleListJobsCommand

func HandleListJobsCommand() error

HandleListJobsCommand sends the ListJobs request to transfer engine Print the Jobs in the history of Azcopy

func HandlePauseCommand

func HandlePauseCommand(jobIdString string)

handles the pause command dispatches the pause Job order to the storage engine

func HandleShowCommand

func HandleShowCommand(listRequest common.ListRequest) error

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

func PrintExistingJobIds

func PrintExistingJobIds(listJobResponse common.ListJobsResponse) error

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

func PrintJobProgressSummary

func PrintJobProgressSummary(outputFormat common.OutputFormat, summary common.ListJobSummaryResponse)

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

func PrintJobTransfers

func PrintJobTransfers(outputForamt common.OutputFormat, listTransfersResponse common.ListJobTransfersResponse)

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

Types

type HTTPClient

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

todo : use url in case of string

func NewHttpClient

func NewHttpClient(url string) *HTTPClient

NewHttpClient returns the instance of struct containing an instance of http.client and url

type ListReq

type ListReq struct {
	JobID    common.JobID
	OfStatus string
	Output   string
}

type ListResponse

type ListResponse struct {
	ErrorMsg string
}