Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetAAIClient ¶ added in v1.0.6
func GetAAIClient(deploymentID string, locationProps config.DynamicMap) yorcoidc.Client
GetAAIClient returns the AAI client for a given location
Types ¶
type ActionOperator ¶
type ActionOperator struct {
}
ActionOperator holds function allowing to execute an action
func (*ActionOperator) ExecAction ¶
func (o *ActionOperator) ExecAction(ctx context.Context, cfg config.Configuration, taskID, deploymentID string, action *prov.Action) (bool, error)
ExecAction allows to execute and action
type DatasetTransferExecution ¶
type DatasetTransferExecution struct {
KV *api.KV
Cfg config.Configuration
DeploymentID string
TaskID string
NodeName string
User string
Operation prov.Operation
OverlayPath string
Artifacts map[string]string
MonitoringTimeInterval time.Duration
EnvInputs []*operations.EnvInput
VarInputsNames []string
}
DatasetTransferExecution holds properties of a data transfer operation
func (*DatasetTransferExecution) Execute ¶
func (e *DatasetTransferExecution) Execute(ctx context.Context) error
Execute executes a synchronous operation
func (*DatasetTransferExecution) ExecuteAsync ¶
func (e *DatasetTransferExecution) ExecuteAsync(ctx context.Context) (*prov.Action, time.Duration, error)
ExecuteAsync executes an asynchronous operation - supported to wait for a file and get its content
func (*DatasetTransferExecution) ResolveExecution ¶
func (e *DatasetTransferExecution) ResolveExecution(ctx context.Context) error
ResolveExecution resolves inputs and artifacts before the execution of an operation
type Execution ¶
type Execution struct {
KV *api.KV
Cfg config.Configuration
DeploymentID string
TaskID string
NodeName string
User string
ListFilesWhileRunning bool
Operation prov.Operation
MonitoringTimeInterval time.Duration
EnvInputs []*operations.EnvInput
VarInputsNames []string
}
Execution holds job Execution properties
func (*Execution) ExecuteAsync ¶
ExecuteAsync executes an asynchronous operation
type UrgentComputingExecution ¶ added in v1.0.8
type UrgentComputingExecution struct {
KV *api.KV
Cfg config.Configuration
DeploymentID string
TaskID string
NodeName string
User string
CancelRemainingJobs bool
Operation prov.Operation
MonitoringTimeInterval time.Duration
}
UrgentComputingExecution holds urgent computing job xecution properties
func (*UrgentComputingExecution) Execute ¶ added in v1.0.8
func (u *UrgentComputingExecution) Execute(ctx context.Context) error
Execute executes a synchronous operation
func (*UrgentComputingExecution) ExecuteAsync ¶ added in v1.0.8
func (u *UrgentComputingExecution) ExecuteAsync(ctx context.Context) (*prov.Action, time.Duration, error)
ExecuteAsync executes an asynchronous operation
func (*UrgentComputingExecution) ResolveExecution ¶ added in v1.0.8
func (u *UrgentComputingExecution) ResolveExecution(ctx context.Context) error
ResolveExecution resolves inputs and artifacts before the execution of an operation
Source Files