Versions in this module Expand all Collapse all v1 v1.3.19 Jun 6, 2023 v1.3.18 Jun 6, 2023 Changes in this version + const Echo + const EchoGolang + const MD5 + const Tar2TF + const Tar2tfFilters + func CheckNoRunningETLContainers(t *testing.T, params api.BaseParams) + func ETLBucketWithCleanup(t *testing.T, bp api.BaseParams, bckFrom, bckTo cmn.Bck, msg *apc.TCBMsg) string + func ETLShouldBeRunning(t *testing.T, params api.BaseParams, etlName string) + func ETLShouldNotBeRunning(t *testing.T, params api.BaseParams, etlName string) + func GetTransformYaml(etlName string) ([]byte, error) + func InitCode(t *testing.T, bp api.BaseParams, msg etl.InitCodeMsg) (xid string) + func InitSpec(t *testing.T, bp api.BaseParams, etlName, comm string) (xid string) + func ReportXactionStatus(bp api.BaseParams, xid string, stopCh *cos.StopCh, interval time.Duration, ...) + func SpecToInitMsg(spec []byte) (msg *etl.InitSpecMsg, err error) + func StopAndDeleteETL(t *testing.T, bp api.BaseParams, etlName string) + func WaitForAborted(bp api.BaseParams, xid, kind string, timeout time.Duration) error + func WaitForContainersStopped(t *testing.T, bp api.BaseParams) + func WaitForFinished(bp api.BaseParams, xid, kind string, timeout time.Duration) (err error)
Go to main page