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 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 LaunchPlanConfig
  • func (cfg LaunchPlanConfig) GetPFlagSet(prefix string) *pflag.FlagSet
• type TaskConfig
  • func (cfg TaskConfig) GetPFlagSet(prefix string) *pflag.FlagSet

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 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

type LaunchPlanConfig

type LaunchPlanConfig struct {
	ExecFile string `json:"execFile" pflag:",execution file name to be used for generating execution spec of a single launchplan."`
	Version  string `json:"version" pflag:",version of the launchplan to be fetched."`
	Latest   bool   `json:"latest" pflag:", flag to indicate to fetch the latest version, version flag will be ignored in this case"`
}

LaunchPlanConfig

func (LaunchPlanConfig) GetPFlagSet

func (cfg LaunchPlanConfig) GetPFlagSet(prefix string) *pflag.FlagSet

GetPFlagSet will return strongly types pflags for all fields in LaunchPlanConfig and its nested types. The format of the flags is json-name.json-sub-name... etc.

type TaskConfig

type TaskConfig struct {
	ExecFile string `json:"execFile" pflag:",execution file name to be used for generating execution spec of a single task."`
	Version  string `json:"version" pflag:",version of the task to be fetched."`
	Latest   bool   `json:"latest" pflag:", flag to indicate to fetch the latest version, version flag will be ignored in this case"`
}

FilesConfig

func (TaskConfig) GetPFlagSet

func (cfg TaskConfig) GetPFlagSet(prefix string) *pflag.FlagSet

GetPFlagSet will return strongly types pflags for all fields in TaskConfig and its nested types. The format of the flags is json-name.json-sub-name... etc.