testruntime

Documentation

Index

• func ClickhouseCluster(t TestingT) (string, string)
• func DeleteFiles(t testing.TB, rt *runtime.Runtime, id string, files ...string)
• func DumpResources(t testing.TB, rt *runtime.Runtime, id string)
• func GetResource(t testing.TB, rt *runtime.Runtime, id, kind, name string) *runtimev1.Resource
• func Must[T any](v T, err error) T
• func New(t TestingT) *runtime.Runtime
• func NewInstance(t TestingT) (*runtime.Runtime, string)
• func NewInstanceForDruidProject(t *testing.T) (*runtime.Runtime, string, error)
• func NewInstanceForProject(t TestingT, name string) (*runtime.Runtime, string)
• func NewInstanceForResolvers(t *testing.T, opts InstanceOptionsForResolvers) (*runtime.Runtime, string)
• func NewInstanceWithClickhouseProject(t TestingT, withCluster bool) (*runtime.Runtime, string)
• func NewInstanceWithModel(t TestingT, name, sql string) (*runtime.Runtime, string)
• func NewInstanceWithOptions(t TestingT, opts InstanceOptions) (*runtime.Runtime, string)
• func PutFiles(t testing.TB, rt *runtime.Runtime, id string, files map[string]string)
• func ReconcileAndWait(t testing.TB, rt *runtime.Runtime, id string, n *runtimev1.ResourceName)
• func ReconcileParserAndWait(t testing.TB, rt *runtime.Runtime, id string)
• func RefreshAndWait(t testing.TB, rt *runtime.Runtime, id string, n *runtimev1.ResourceName)
• func RenameFile(t testing.TB, rt *runtime.Runtime, id, from, to string)
• func RequireIsView(t testing.TB, olap drivers.OLAPStore, tableName string, isView bool)
• func RequireNoOLAPTable(t testing.TB, rt *runtime.Runtime, id, name string)
• func RequireOLAPTable(t testing.TB, rt *runtime.Runtime, id, name string)
• func RequireOLAPTableCount(t testing.TB, rt *runtime.Runtime, id, name string, count int)
• func RequireParseErrors(t testing.TB, rt *runtime.Runtime, id string, ...)
• func RequireReconcileState(t testing.TB, rt *runtime.Runtime, id string, ...)
• func RequireResource(t testing.TB, rt *runtime.Runtime, id string, a *runtimev1.Resource)
• type InstanceOptions
• type InstanceOptionsForResolvers
• type TestingT

Functions

func ClickhouseCluster

func ClickhouseCluster(t TestingT) (string, string)

func DeleteFiles

func DeleteFiles(t testing.TB, rt *runtime.Runtime, id string, files ...string)

func DumpResources

func DumpResources(t testing.TB, rt *runtime.Runtime, id string)

func GetResource

func GetResource(t testing.TB, rt *runtime.Runtime, id, kind, name string) *runtimev1.Resource

func Must

func Must[T any](v T, err error) T

func New

func New(t TestingT) *runtime.Runtime

New returns a runtime configured for use in tests.

func NewInstance

func NewInstance(t TestingT) (*runtime.Runtime, string)

NewInstance is a convenience wrapper around NewInstanceWithOptions, using defaults sensible for most tests.

func NewInstanceForDruidProject

func NewInstanceForDruidProject(t *testing.T) (*runtime.Runtime, string, error)

func NewInstanceForProject

func NewInstanceForProject(t TestingT, name string) (*runtime.Runtime, string)

NewInstanceForProject creates a runtime and an instance for use in tests. The passed name should match a test project in the testdata folder. You should not do mutable repo operations on the returned instance.

func NewInstanceForResolvers

func NewInstanceForResolvers(t *testing.T, opts InstanceOptionsForResolvers) (*runtime.Runtime, string)

func NewInstanceWithClickhouseProject

func NewInstanceWithClickhouseProject(t TestingT, withCluster bool) (*runtime.Runtime, string)

func NewInstanceWithModel

func NewInstanceWithModel(t TestingT, name, sql string) (*runtime.Runtime, string)

NewInstanceWithModel creates a runtime and an instance for use in tests. The passed model name and SQL SELECT statement will be loaded into the instance.

func NewInstanceWithOptions

func NewInstanceWithOptions(t TestingT, opts InstanceOptions) (*runtime.Runtime, string)

NewInstanceWithOptions creates a runtime and an instance for use in tests. The instance's repo is a temp directory that will be cleared when the tests finish.

func PutFiles

func PutFiles(t testing.TB, rt *runtime.Runtime, id string, files map[string]string)

func ReconcileAndWait

func ReconcileAndWait(t testing.TB, rt *runtime.Runtime, id string, n *runtimev1.ResourceName)

func ReconcileParserAndWait

func ReconcileParserAndWait(t testing.TB, rt *runtime.Runtime, id string)

func RefreshAndWait

func RefreshAndWait(t testing.TB, rt *runtime.Runtime, id string, n *runtimev1.ResourceName)

func RenameFile

func RenameFile(t testing.TB, rt *runtime.Runtime, id, from, to string)

func RequireIsView

func RequireIsView(t testing.TB, olap drivers.OLAPStore, tableName string, isView bool)

func RequireNoOLAPTable

func RequireNoOLAPTable(t testing.TB, rt *runtime.Runtime, id, name string)

func RequireOLAPTable

func RequireOLAPTable(t testing.TB, rt *runtime.Runtime, id, name string)

func RequireOLAPTableCount

func RequireOLAPTableCount(t testing.TB, rt *runtime.Runtime, id, name string, count int)

func RequireParseErrors

func RequireParseErrors(t testing.TB, rt *runtime.Runtime, id string, expectedParseErrors map[string]string)

func RequireReconcileState

func RequireReconcileState(t testing.TB, rt *runtime.Runtime, id string, lenResources, lenReconcileErrs, lenParseErrs int)

func RequireResource

func RequireResource(t testing.TB, rt *runtime.Runtime, id string, a *runtimev1.Resource)

Types

type InstanceOptions

type InstanceOptions struct {
	Files        map[string]string
	Variables    map[string]string
	WatchRepo    bool
	StageChanges bool
}

InstanceOptions enables configuration of the instance options that are configurable in tests.

type InstanceOptionsForResolvers

type InstanceOptionsForResolvers struct {
	InstanceOptions
	OLAPDriver string
	OLAPDSN    string
}

type TestingT

type TestingT interface {
	Name() string
	TempDir() string
	FailNow()
	Errorf(format string, args ...interface{})
	Cleanup(f func())
}

TestingT satisfies both *testing.T and *testing.B.