Documentation
¶
Overview ¶
Package tetl provides helpers for ETL.
- Copyright (c) 2018-2021, NVIDIA CORPORATION. All rights reserved.
Index ¶
- Constants
- func CheckNoRunningETLContainers(t *testing.T, params api.BaseParams)
- func ETLBucket(t *testing.T, baseParams api.BaseParams, fromBck, toBck cmn.Bck, ...) string
- func ETLShouldBeRunning(t *testing.T, params api.BaseParams, etlID string)
- func ETLShouldNotBeRunning(t *testing.T, params api.BaseParams, etlID string)
- func GetTransformYaml(name string) ([]byte, error)
- func Init(t *testing.T, baseParams api.BaseParams, name, comm string) string
- func InitCode(t *testing.T, baseParams api.BaseParams, msg etl.InitCodeMsg) string
- func ReportXactionStatus(baseParams api.BaseParams, xactID string, stopCh *cos.StopCh, ...)
- func SpecToInitMsg(spec []byte) (msg *etl.InitSpecMsg, err error)
- func StopAndDeleteETL(t *testing.T, baseParams api.BaseParams, etlID string)
- func WaitForAborted(baseParams api.BaseParams, xactID string, timeout time.Duration) error
- func WaitForContainersStopped(t *testing.T, baseParams api.BaseParams)
- func WaitForFinished(baseParams api.BaseParams, xactID string, timeout time.Duration) error
Constants ¶
View Source
const ( Tar2TF = "tar2tf" Echo = "transformer-echo" EchoGolang = "echo-go" MD5 = "transformer-md5" Tar2tfFilters = "tar2tf-filters" )
Variables ¶
This section is empty.
Functions ¶
func CheckNoRunningETLContainers ¶
func CheckNoRunningETLContainers(t *testing.T, params api.BaseParams)
func ETLShouldBeRunning ¶
func ETLShouldBeRunning(t *testing.T, params api.BaseParams, etlID string)
func ETLShouldNotBeRunning ¶
func ETLShouldNotBeRunning(t *testing.T, params api.BaseParams, etlID string)
func GetTransformYaml ¶
func InitCode ¶
func InitCode(t *testing.T, baseParams api.BaseParams, msg etl.InitCodeMsg) string
func ReportXactionStatus ¶
func SpecToInitMsg ¶
func SpecToInitMsg(spec []byte) (msg *etl.InitSpecMsg, err error)
func StopAndDeleteETL ¶
func StopAndDeleteETL(t *testing.T, baseParams api.BaseParams, etlID string)
func WaitForAborted ¶
func WaitForContainersStopped ¶
func WaitForContainersStopped(t *testing.T, baseParams api.BaseParams)
func WaitForFinished ¶
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.