Documentation
¶
Index ¶
- func CreateAndWriteExecConfigForTask(task *admin.Task, fileName string) error
- func CreateAndWriteExecConfigForWorkflow(wlp *admin.LaunchPlan, fileName string) error
- func CreateGetCommand() *cobra.Command
- func ExecutionToProtoMessages(l []*admin.Execution) []proto.Message
- func FetchAndUnDecorateMatchableAttr(ctx context.Context, project, domain, workflowName string, ...) error
- func FetchLPForName(ctx context.Context, fetcher ext.AdminFetcherExtInterface, ...) ([]*admin.LaunchPlan, error)
- func FetchTaskForName(ctx context.Context, fetcher ext.AdminFetcherExtInterface, ...) ([]*admin.Task, error)
- func FetchWorkflowForName(ctx context.Context, fetcher ext.AdminFetcherExtInterface, ...) ([]*admin.Workflow, error)
- func LaunchplanToProtoMessages(l []*admin.LaunchPlan) []proto.Message
- func ParamMapForTask(task *admin.Task) (map[string]interface{}, error)
- func ParamMapForWorkflow(lp *admin.LaunchPlan) (map[string]interface{}, error)
- func ProjectToProtoMessages(l []*admin.Project) []proto.Message
- func TaskInputs(task *admin.Task) map[string]*core.Variable
- func TaskToProtoMessages(l []*admin.Task) []proto.Message
- func WorkflowParams(lp *admin.LaunchPlan) map[string]*core.Parameter
- func WorkflowToProtoMessages(l []*admin.Workflow) []proto.Message
- func WriteExecConfigToFile(executionConfig ExecutionConfig, fileName string) error
- type ExecutionConfig
- type NodeExecution
- type NodeExecutionClosure
- type TaskExecution
- type TaskExecutionClosure
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CreateAndWriteExecConfigForWorkflow ¶
func CreateAndWriteExecConfigForWorkflow(wlp *admin.LaunchPlan, fileName string) error
func CreateGetCommand ¶
CreateGetCommand will return get command
func FetchAndUnDecorateMatchableAttr ¶ added in v0.1.7
func FetchAndUnDecorateMatchableAttr(ctx context.Context, project, domain, workflowName string, fetcher ext.AdminFetcherExtInterface, unDecorator sconfig.MatchableAttributeUnDecorator, rsType admin.MatchableResource) error
func FetchLPForName ¶
func FetchLPForName(ctx context.Context, fetcher ext.AdminFetcherExtInterface, name, project, domain string) ([]*admin.LaunchPlan, error)
FetchLPForName fetches the launchplan give it name.
func FetchTaskForName ¶
func FetchTaskForName(ctx context.Context, fetcher ext.AdminFetcherExtInterface, name, project, domain string) ([]*admin.Task, error)
FetchTaskForName Reads the task config to drive fetching the correct tasks.
func FetchWorkflowForName ¶ added in v0.1.7
func FetchWorkflowForName(ctx context.Context, fetcher ext.AdminFetcherExtInterface, name, project, domain string) ([]*admin.Workflow, error)
FetchWorkflowForName fetches the workflow give it name.
func LaunchplanToProtoMessages ¶
func LaunchplanToProtoMessages(l []*admin.LaunchPlan) []proto.Message
func ParamMapForWorkflow ¶
func ParamMapForWorkflow(lp *admin.LaunchPlan) (map[string]interface{}, error)
func WorkflowParams ¶
func WorkflowParams(lp *admin.LaunchPlan) map[string]*core.Parameter
func WriteExecConfigToFile ¶
func WriteExecConfigToFile(executionConfig ExecutionConfig, fileName string) error
Types ¶
type ExecutionConfig ¶
type ExecutionConfig struct {
TargetDomain string `json:"targetDomain"`
TargetProject string `json:"targetProject"`
KubeServiceAcct string `json:"kubeServiceAcct"`
IamRoleARN string `json:"iamRoleARN"`
Workflow string `json:"workflow,omitempty"`
Task string `json:"task,omitempty"`
Version string `json:"version"`
Inputs map[string]interface{} `json:"inputs"`
}
ExecutionConfig is duplicated struct from create with the same structure. This is to avoid the circular dependency. TODO : replace this with a cleaner design
type NodeExecution ¶ added in v0.2.13
type NodeExecution struct {
*admin.NodeExecution
}
func (*NodeExecution) MarshalJSON ¶ added in v0.2.13
func (in *NodeExecution) MarshalJSON() ([]byte, error)
MarshalJSON overridden method to json marshalling to use jsonpb
func (*NodeExecution) UnmarshalJSON ¶ added in v0.2.13
func (in *NodeExecution) UnmarshalJSON(b []byte) error
UnmarshalJSON overridden method to json unmarshalling to use jsonpb
type NodeExecutionClosure ¶ added in v0.2.13
type NodeExecutionClosure struct {
NodeExec *NodeExecution `json:"node_exec,omitempty"`
ChildNodes []*NodeExecutionClosure `json:"child_nodes,omitempty"`
TaskExecutions []*TaskExecutionClosure `json:"task_execs,omitempty"`
// Inputs for the node
Inputs map[string]interface{} `json:"inputs,omitempty"`
// Outputs for the node
Outputs map[string]interface{} `json:"outputs,omitempty"`
}
NodeExecutionClosure forms a wrapper around admin.NodeExecution and also fetches the childnodes , task execs and input/output on the node executions from the admin api's.
type TaskExecution ¶ added in v0.2.13
type TaskExecution struct {
*admin.TaskExecution
}
TaskExecution wrapper around admin.TaskExecution
func (*TaskExecution) MarshalJSON ¶ added in v0.2.13
func (in *TaskExecution) MarshalJSON() ([]byte, error)
MarshalJSON overridden method to json marshalling to use jsonpb
func (*TaskExecution) UnmarshalJSON ¶ added in v0.2.13
func (in *TaskExecution) UnmarshalJSON(b []byte) error
UnmarshalJSON overridden method to json unmarshalling to use jsonpb
type TaskExecutionClosure ¶ added in v0.2.13
type TaskExecutionClosure struct {
*TaskExecution
}
TaskExecutionClosure wrapper around TaskExecution
Source Files
¶
Click to show internal directories.
Click to hide internal directories.