get

package
v0.8.18 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 1, 2024 License: Apache-2.0 Imports: 39 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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 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) (workflows []*admin.Workflow, isList bool, err error)

FetchWorkflowForName fetches the workflow give it name.

func LaunchplanToProtoMessages 

func LaunchplanToProtoMessages(l []*admin.LaunchPlan) []proto.Message

func LaunchplanToTableProtoMessages added in v0.2.26 

func LaunchplanToTableProtoMessages(l []*admin.LaunchPlan) []proto.Message

func NamedEntityToProtoMessages added in v0.5.12 

func NamedEntityToProtoMessages(l []*admin.NamedEntity) []proto.Message

func ParamMapForTask 

func ParamMapForTask(task *admin.Task) (map[string]yaml.Node, error)

func ParamMapForWorkflow 

func ParamMapForWorkflow(lp *admin.LaunchPlan) (map[string]yaml.Node, 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 TaskToTableProtoMessages added in v0.2.26 

func TaskToTableProtoMessages(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 WorkflowToTableProtoMessages added in v0.2.26 

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

func WriteExecConfigToFile 

func WriteExecConfigToFile(executionConfig ExecutionConfig, fileName string) error

Types

type ExecutionConfig 

type ExecutionConfig struct {
	IamRoleARN      string               `yaml:"iamRoleARN"`
	Inputs          map[string]yaml.Node `yaml:"inputs"`
	Envs            map[string]string    `yaml:"envs"`
	KubeServiceAcct string               `yaml:"kubeServiceAcct"`
	TargetDomain    string               `yaml:"targetDomain"`
	TargetProject   string               `yaml:"targetProject"`
	Task            string               `yaml:"task,omitempty"`
	Version         string               `yaml:"version"`
	Workflow        string               `yaml:"workflow,omitempty"`
}

ExecutionConfig is duplicated struct from create with the same structure. This is to avoid the circular dependency. Only works with go-yaml. 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

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.