Function Stop

etl/transform.go:364–391

Stop deletes all occupied by the ETL resources, including Pods and Services. It unregisters ETL smap listener.

(t cluster.Target, id string, errCause error)

// Stop deletes all occupied by the ETL resources, including Pods and Services.
// It unregisters ETL smap listener.
func Stop(t cluster.Target, id string, errCause error) error {
	errCtx := &cmn.ETLErrorContext{
		TID:  t.SID(),
		UUID: id,
	}

	// Abort any running offline ETLs.
	xreg.AbortAll(errCause, apc.ActETLBck)

	c, err := GetCommunicator(id, t.Snode())
	if err != nil {
		return cmn.NewErrETL(errCtx, err.Error())
	}
	errCtx.PodName = c.PodName()
	errCtx.SvcName = c.SvcName()

	if err := cleanupEntities(errCtx, c.PodName(), c.SvcName()); err != nil {
		return err
	}

	if c := reg.removeByUUID(id); c != nil {
		t.Sowner().Listeners().Unreg(c)
	}

	c.Stop()

	return nil
}

// StopAll terminates all running ETLs.
func StopAll(t cluster.Target) {