@Test public void testExecute_WithVariousSGM_ExpectCorrectTaskGraph() throws Exception { UpdateK8sSecurityGroupMemberLabelMetaTask task = this.factoryTask.create(this.sgm, this.k8sPodApi); task.labelPodCreateTask = new CreateK8sLabelPodTask(); task.labelPodDeleteTask = new DeleteK8sLabelPodTask(); task.execute(); TaskGraphHelper.validateTaskGraph(task, this.expectedGraph); }
UpdateK8sSecurityGroupMemberLabelMetaTask create(SecurityGroupMember sgm, KubernetesPodApi k8sPodApi) { UpdateK8sSecurityGroupMemberLabelMetaTask task = new UpdateK8sSecurityGroupMemberLabelMetaTask(); task.sgm = sgm; task.labelPodCreateTask = this.labelPodCreateTask; task.labelPodDeleteTask = this.labelPodDeleteTask; task.dbConnectionManager = this.dbConnectionManager; task.txBroadcastUtil = this.txBroadcastUtil; task.k8sPodApi = this.k8sPodApi; return task; }
UpdateK8sSecurityGroupMemberLabelMetaTask extends TransactionalMetaTask { UpdateK8sSecurityGroupMemberLabelMetaTask create(SecurityGroupMember sgm, KubernetesPodApi k8sPodApi) { UpdateK8sSecurityGroupMemberLabelMetaTask task = new UpdateK8sSecurityGroupMemberLabelMetaTask(); task.sgm = sgm; task.labelPodCreateTask = this.labelPodCreateTask; task.labelPodDeleteTask = this.labelPodDeleteTask; task.dbConnectionManager = this.dbConnectionManager; task.txBroadcastUtil = this.txBroadcastUtil; task.k8sPodApi = this.k8sPodApi; return task; } }
UpdateK8sSecurityGroupMemberLabelMetaTask extends TransactionalMetaTask { UpdateK8sSecurityGroupMemberLabelMetaTask create(SecurityGroupMember sgm, KubernetesPodApi k8sPodApi) { UpdateK8sSecurityGroupMemberLabelMetaTask task = new UpdateK8sSecurityGroupMemberLabelMetaTask(); task.sgm = sgm; task.labelPodCreateTask = this.labelPodCreateTask; task.labelPodDeleteTask = this.labelPodDeleteTask; task.dbConnectionManager = this.dbConnectionManager; task.txBroadcastUtil = this.txBroadcastUtil; task.k8sPodApi = this.k8sPodApi; return task; }  }
UpdateK8sSecurityGroupMemberLabelMetaTask extends TransactionalMetaTask { UpdateK8sSecurityGroupMemberLabelMetaTask create(SecurityGroupMember sgm, KubernetesPodApi k8sPodApi) { UpdateK8sSecurityGroupMemberLabelMetaTask task = new UpdateK8sSecurityGroupMemberLabelMetaTask(); task.sgm = sgm; task.labelPodCreateTask = this.labelPodCreateTask; task.labelPodDeleteTask = this.labelPodDeleteTask; task.dbConnectionManager = this.dbConnectionManager; task.txBroadcastUtil = this.txBroadcastUtil; task.k8sPodApi = this.k8sPodApi; return task; }  @Override TaskGraph getTaskGraph(); @Override String getName(); @Override void executeTransaction(EntityManager em); @Override Set<LockObjectReference> getObjects(); }
UpdateK8sSecurityGroupMemberLabelMetaTask extends TransactionalMetaTask { UpdateK8sSecurityGroupMemberLabelMetaTask create(SecurityGroupMember sgm, KubernetesPodApi k8sPodApi) { UpdateK8sSecurityGroupMemberLabelMetaTask task = new UpdateK8sSecurityGroupMemberLabelMetaTask(); task.sgm = sgm; task.labelPodCreateTask = this.labelPodCreateTask; task.labelPodDeleteTask = this.labelPodDeleteTask; task.dbConnectionManager = this.dbConnectionManager; task.txBroadcastUtil = this.txBroadcastUtil; task.k8sPodApi = this.k8sPodApi; return task; }  @Override TaskGraph getTaskGraph(); @Override String getName(); @Override void executeTransaction(EntityManager em); @Override Set<LockObjectReference> getObjects();  }