prov

type Action struct {
	ID             string
	ActionType     string
	AsyncOperation AsyncOperation
	Data           map[string]string
}

type ActionOperator interface {
	ExecAction(ctx context.Context, conf config.Configuration, taskID, deploymentID string, action *Action) (deregister bool, err error)
}

type AsyncOperation struct {
	DeploymentID     string                   `json:"deployment_id,omitempty"`
	TaskID           string                   `json:"task_id,omitempty"`
	ExecutionID      string                   `json:"execution_id,omitempty"`
	WorkflowName     string                   `json:"workflow_name,omitempty"`
	StepName         string                   `json:"step_name,omitempty"`
	NodeName         string                   `json:"node_name,omitempty"`
	Operation        Operation                `json:"operation,omitempty"`
	WorkflowStepInfo *events.WorkflowStepInfo `json:"workflow_step_info,omitempty"`
}

type DelegateExecutor interface {
	ExecDelegate(ctx context.Context, conf config.Configuration, taskID, deploymentID, nodeName, delegateOperation string) error
}

type InfraUsageCollector interface {
	GetUsageInfo(ctx context.Context, cfg config.Configuration, taskID, infraName string) (map[string]interface{}, error)
}

type Operation struct {
	// The operation name
	Name string `json:"name,omitempty"`
	// Name of the type implementing this operation if implemented by node type
	ImplementedInType string `json:"implemented_in_type,omitempty"`
	// Name of the node template implementing this operation if implemented by a node template
	ImplementedInNodeTemplate string `json:"implemented_in_node_template,omitempty"`
	// Artifact type of the operation implementation
	ImplementationArtifact string `json:"implementation_artifact,omitempty"`
	// Additional information for relationship operation
	RelOp RelationshipOperation `json:"rel_op,omitempty"`
	// Node on which operation should be executed
	OperationHost string `json:"operation_host,omitempty"`
}

type OperationExecutor interface {
	ExecOperation(ctx context.Context, conf config.Configuration, taskID, deploymentID, nodeName string, operation Operation) error
	ExecAsyncOperation(ctx context.Context, conf config.Configuration, taskID, deploymentID, nodeName string, operation Operation, stepName string) (*Action, time.Duration, error)
}

type RelationshipOperation struct {
	// If this is set to true then other struct fields could be considered.
	IsRelationshipOperation bool `json:"is_relationship_operation,omitempty"`
	// Requirement index of the relationship in the source node
	RequirementIndex string `json:"requirement_index,omitempty"`
	// Name of the target node of the relationship
	TargetNodeName string `json:"target_node_name,omitempty"`
	// Requirement name in case of relationship
	TargetRelationship string `json:"target_relationship,omitempty"`
}