get

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 NodeExecutionToProtoMessages(l []*admin.NodeExecution) []proto.Message
• func NodeTaskExecutionToProtoMessages(l []*admin.TaskExecution) []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

Functions

func CreateAndWriteExecConfigForTask

func CreateAndWriteExecConfigForTask(task *admin.Task, fileName string) error

func CreateAndWriteExecConfigForWorkflow

func CreateAndWriteExecConfigForWorkflow(wlp *admin.LaunchPlan, fileName string) error

func CreateGetCommand

func CreateGetCommand() *cobra.Command

CreateGetCommand will return get command

func ExecutionToProtoMessages

func ExecutionToProtoMessages(l []*admin.Execution) []proto.Message

func FetchAndUnDecorateMatchableAttr

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

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 NodeExecutionToProtoMessages

func NodeExecutionToProtoMessages(l []*admin.NodeExecution) []proto.Message

func NodeTaskExecutionToProtoMessages

func NodeTaskExecutionToProtoMessages(l []*admin.TaskExecution) []proto.Message

func ParamMapForTask

func ParamMapForTask(task *admin.Task) (map[string]interface{}, error)

func ParamMapForWorkflow

func ParamMapForWorkflow(lp *admin.LaunchPlan) (map[string]interface{}, error)

func ProjectToProtoMessages

func ProjectToProtoMessages(l []*admin.Project) []proto.Message

func TaskInputs

func TaskInputs(task *admin.Task) map[string]*core.Variable

func TaskToProtoMessages

func TaskToProtoMessages(l []*admin.Task) []proto.Message

func WorkflowParams

func WorkflowParams(lp *admin.LaunchPlan) map[string]*core.Parameter

func WorkflowToProtoMessages

func WorkflowToProtoMessages(l []*admin.Workflow) []proto.Message

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