testutils

Documentation

Overview

Provides sample closures for use in tests.

Index

• Constants
• Variables
• func GetApplicationConfigWithDefaultDomains() runtimeInterfaces.ApplicationConfiguration
• func GetExecutionRequest() admin.ExecutionCreateRequest
• func GetLaunchPlanRequest() admin.LaunchPlanCreateRequest
• func GetLaunchPlanRequestWithCronSchedule(testCronExpr string) admin.LaunchPlanCreateRequest
• func GetLaunchPlanRequestWithFixedRateSchedule(testRateValue uint32, testRateUnit admin.FixedRateUnit) admin.LaunchPlanCreateRequest
• func GetRepoWithDefaultProject() repositoryInterfaces.Repository
• func GetRepoWithDefaultProjectAndErr(err error) repositoryInterfaces.Repository
• func GetSampleLpSpecForTest() admin.LaunchPlanSpec
• func GetSampleWorkflowSpecForTest() admin.WorkflowSpec
• func GetTaskClosure() *admin.TaskClosure
• func GetTaskClosureBytes() []byte
• func GetValidTaskRequest() admin.TaskCreateRequest
• func GetValidTaskRequestWithOverrides(project string, domain string, name string, version string) admin.TaskCreateRequest
• func GetValidTaskSpecBytes() []byte
• func GetWorkflowClosure() *admin.WorkflowClosure
• func GetWorkflowClosureBytes() []byte
• func GetWorkflowRequest() admin.WorkflowCreateRequest
• func GetWorkflowRequestInterface() *core.TypedInterface
• func GetWorkflowRequestInterfaceBytes() []byte
• func MakeStringLiteral(value string) *core.Literal

Constants

const (
	ProjectQueryPattern = "project = ?"
	DomainQueryPattern  = "domain = ?"
	NameQueryPattern    = "name = ?"
	StateQueryPattern   = "state = ?"
)

Variables

var ExecutionQueueAttributes = &admin.MatchingAttributes{
	Target: &admin.MatchingAttributes_ExecutionQueueAttributes{
		ExecutionQueueAttributes: &admin.ExecutionQueueAttributes{
			Tags: []string{
				"foo", "bar", "baz",
			},
		},
	},
}

var MockCreatedAtProto, _ = ptypes.TimestampProto(MockCreatedAtValue)

var MockCreatedAtValue = time.Date(2018, time.February, 17, 00, 00, 00, 00, time.UTC).UTC()

var WorkflowExecutionConfigSample = &admin.MatchingAttributes{
	Target: &admin.MatchingAttributes_WorkflowExecutionConfig{
		WorkflowExecutionConfig: &admin.WorkflowExecutionConfig{
			MaxParallelism: 5,
			RawOutputDataConfig: &admin.RawOutputDataConfig{
				OutputLocationPrefix: "s3://test-bucket",
			},
			Labels: &admin.Labels{
				Values: map[string]string{"lab1": "val1"},
			},
			Annotations: nil,
		},
	},
}

Functions

func GetApplicationConfigWithDefaultDomains

func GetApplicationConfigWithDefaultDomains() runtimeInterfaces.ApplicationConfiguration

func GetExecutionRequest

func GetExecutionRequest() admin.ExecutionCreateRequest

func GetLaunchPlanRequest

func GetLaunchPlanRequest() admin.LaunchPlanCreateRequest

func GetLaunchPlanRequestWithCronSchedule

func GetLaunchPlanRequestWithCronSchedule(testCronExpr string) admin.LaunchPlanCreateRequest

func GetLaunchPlanRequestWithFixedRateSchedule

func GetLaunchPlanRequestWithFixedRateSchedule(testRateValue uint32, testRateUnit admin.FixedRateUnit) admin.LaunchPlanCreateRequest

func GetRepoWithDefaultProject

func GetRepoWithDefaultProject() repositoryInterfaces.Repository

func GetRepoWithDefaultProjectAndErr

func GetRepoWithDefaultProjectAndErr(err error) repositoryInterfaces.Repository

func GetSampleLpSpecForTest

func GetSampleLpSpecForTest() admin.LaunchPlanSpec

func GetSampleWorkflowSpecForTest

func GetSampleWorkflowSpecForTest() admin.WorkflowSpec

func GetTaskClosure

func GetTaskClosure() *admin.TaskClosure

func GetTaskClosureBytes

func GetTaskClosureBytes() []byte

func GetValidTaskRequest

func GetValidTaskRequest() admin.TaskCreateRequest

func GetValidTaskRequestWithOverrides

func GetValidTaskRequestWithOverrides(project string, domain string, name string, version string) admin.TaskCreateRequest

func GetValidTaskSpecBytes

func GetValidTaskSpecBytes() []byte

func GetWorkflowClosure

func GetWorkflowClosure() *admin.WorkflowClosure

func GetWorkflowClosureBytes

func GetWorkflowClosureBytes() []byte

func GetWorkflowRequest

func GetWorkflowRequest() admin.WorkflowCreateRequest

func GetWorkflowRequestInterface

func GetWorkflowRequestInterface() *core.TypedInterface

func GetWorkflowRequestInterfaceBytes

func GetWorkflowRequestInterfaceBytes() []byte

func MakeStringLiteral

func MakeStringLiteral(value string) *core.Literal