driver

type DMRequest struct {
	ComputeName string `json:"computeName"`

	// Source file or directory
	SourcePath string `json:"sourcePath"`
	// Destination file or directory
	DestinationPath string `json:"destinationPath"`
	// If True, the data movement command runs `/bin/true` rather than perform actual data movement
	Dryrun bool `json:"dryrun"`
	// Extra options to pass to `dcp` if present in the Data Movement command.
	DcpOptions string `json:"dcpOptions"`
	// If true, enable server-side logging of stdout when the command is successful. Failure output is always logged.
	LogStdout bool `json:"logStdout"`
	// If true, store stdout in DataMovementStatusResponse.Message when the command is successful. Failure output is always contained in the message.
	StoreStdout bool `json:"storeStdout"`
	// The number of slots specified in the MPI hostfile. A value of 0 disables the use of slots in
	// the hostfile. -1 will defer to the server side configuration.
	Slots int32 `json:"slots"`
	// The number of max_slots specified in the MPI hostfile. A value of 0 disables the use of
	// max_slots in the hostfile. -1 will defer to the server side configuration.
	MaxSlots int32 `json:"maxSlots"`
	// The name of the data movement configuration profile to use. The above parameters (e.g. slots,
	// logStdout) will override the settings defined by the profile. This profile must exist on the
	// server otherwise the data movement operation will be invalid. Empty will default to the
	// default profile.
	DMProfile string `json:"dmProfile"`
	// Extra options to pass to `mpirun` if present in the Data Movement command.
	MpirunOptions string `json:"mpirunOptions"`
}

type DataMovementCommandStatus struct {
	// Command used to perform Data Movement
	Command string `json:"command,omitempty"`
	// Progress percentage (0-100%) of the data movement based on the output of `dcp`. `dcp` must be present in the command.
	Progress int32 `json:"progress,omitempty"`
	// Duration of how long the operation has been running (e.g. 1m30s)
	ElapsedTime string `json:"elapsedTime,omitempty"`
	// The most recent line of output from the data movement command
	LastMessage string `json:"lastMessage,omitempty"`
	// The time (local) of lastMessage
	LastMessageTime string `json:"lastMessageTime,omitempty"`
}

type DataMovementStatusResponse_State string

type DataMovementStatusResponse_Status string

type DataMovementStatusResponse_v1_0 struct {
	// Current state of the Data Movement Request
	State DataMovementStatusResponse_State `json:"state,omitempty"`
	// Current status of the Data Movement Request
	Status DataMovementStatusResponse_Status `json:"status,omitempty"`
	// Any extra information supplied with the state/status
	Message string `json:"message,omitempty"`
	// Current state/progress of the Data Movement command
	CommandStatus *DataMovementCommandStatus `json:"commandStatus,omitempty"`
	// The start time (local) of the data movement operation
	StartTime string `json:"startTime,omitempty"`
	// The end time (local) of the data movement operation
	EndTime string `json:"endTime,omitempty"`
}

type Driver struct {
	Client client.Client
	Log    logr.Logger

	Mock      bool
	MockCount int

	WorkflowName      string
	WorkflowNamespace string
	// contains filtered or unexported fields
}

type DriverRequest struct {
	Drvr *Driver

	// Rabbit node targeted for data movement. This is the local node attach to the requesting
	// compute node.
	RabbitName string
	// contains filtered or unexported fields
}

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

type StatusRequest struct {
	// Name of the copy request.
	RequestName string `json:"requestName"`
	// Max number of seconds to wait for the completion of the copy request.
	// A negative number results in an indefinite wait.
	MaxWaitSecs int `json:"maxWaitSecs"`
}