Function tryStart

etl/transform.go:220–279

Returns: * errCtx - gathered information about ETL context * podName - non-empty if at least one attempt of creating pod was executed * svcName - non-empty if at least one attempt of creating service was executed * err - any error occurred which should be passed further.

(t cluster.Target, msg InitSpecMsg, opts StartOpts)

// * svcName - non-empty if at least one attempt of creating service was executed
// * err - any error occurred which should be passed further.
func tryStart(t cluster.Target, msg InitSpecMsg, opts StartOpts) (errCtx *cmn.ETLErrorContext,
	podName, svcName string, err error) {
	cos.Assert(k8s.NodeName != "") // Corresponding 'if' done at the beginning of the request.

	errCtx = &cmn.ETLErrorContext{
		TID:  t.SID(),
		UUID: msg.IDX,
	}

	b := &etlBootstraper{
		errCtx: errCtx,
		t:      t,
		msg:    msg,
		env:    opts.Env,
	}

	// Parse spec template and fill Pod object with necessary fields.
	if err = b.createPodSpec(); err != nil {
		return
	}

	b.createServiceSpec()

	// 1. Cleanup previously started entities (if any).
	errCleanup := cleanupEntities(errCtx, b.pod.Name, b.svc.Name)
	debug.AssertNoErr(errCleanup)

	// 2. Creating service.
	svcName = b.svc.GetName()
	if err = b.createEntity(k8s.Svc); err != nil {
		return
	}

	// 3. Creating pod.
	podName = b.pod.GetName()
	if err = b.createEntity(k8s.Pod); err != nil {
		return
	}

	if err = b.waitPodReady(); err != nil {
		return
	}

	if err = b.setupConnection(); err != nil {
		return
	}

	b.setupXaction()

	c := makeCommunicator(commArgs{
		listener:    newAborter(t, msg.IDX),
		bootstraper: b,
	})
	// NOTE: Communicator is put to registry only if the whole tryStart was successful.
	if err = reg.put(msg.IDX, c); err != nil {
		return
	}
	t.Sowner().Listeners().Reg(c)