testutils

package
v1.1.88 Latest Latest
Warning

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

Go to latest
Published: Mar 29, 2023 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Overview

Provides sample closures for use in tests.

Index

Constants

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

Variables

View Source
var ExecutionQueueAttributes = &admin.MatchingAttributes{
	Target: &admin.MatchingAttributes_ExecutionQueueAttributes{
		ExecutionQueueAttributes: &admin.ExecutionQueueAttributes{
			Tags: []string{
				"foo", "bar", "baz",
			},
		},
	},
}
View Source
var MockCreatedAtProto, _ = ptypes.TimestampProto(MockCreatedAtValue)
View Source
var MockCreatedAtValue = time.Date(2018, time.February, 17, 00, 00, 00, 00, time.UTC).UTC()
View Source
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 added in v0.3.38

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 GetWorkflowRequestInterfaceBytes

func GetWorkflowRequestInterfaceBytes() []byte

func MakeStringLiteral added in v0.3.38

func MakeStringLiteral(value string) *core.Literal

Types

This section is empty.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL