Function GetCommunicator

etl/transform.go:405–411

(transformID string, lsnode *cluster.Snode)

}

func GetCommunicator(transformID string, lsnode *cluster.Snode) (Communicator, error) {
	c, exists := reg.getByUUID(transformID)
	if !exists {
		return nil, cmn.NewErrNotFound("%s: ETL %q", lsnode, transformID)
	}
	return c, nil
}

func List() []Info { return reg.list() }