[WIP] Run chaincode using jobs

See #119

Signed-off-by: James Taylor <[email protected]>

internal/builder/run.go

@@ -64,12 +64,12 @@ func (r *Run) Run(ctx context.Context) error {
 		)
 	}
 
-	podsClient := clientset.CoreV1().Pods(r.KubeNamespace)
+	jobsClient := clientset.BatchV1().Jobs(r.KubeNamespace)
 
-	pod, err := util.CreateChaincodePod(
+	job, err := util.CreateChaincodeJob(
 		ctx,
 		logger,
-		podsClient,
+		jobsClient,
 		kubeObjectName,
 		r.KubeNamespace,
 		r.KubeServiceAccount,
@@ -82,11 +82,13 @@ func (r *Run) Run(ctx context.Context) error {
 	}
 
 	logger.Printf(
-		"Running chaincode ID %s in kubernetes pod %s/%s",
+		"Running chaincode ID %s with kubernetes job %s/%s",
 		chaincodeData.ChaincodeID,
-		pod.Namespace,
-		pod.Name,
+		job.Namespace,
+		job.Name,
 	)
 
-	return util.WaitForChaincodePod(ctx, logger, podsClient, pod, chaincodeData.ChaincodeID)
+	batchClient := clientset.BatchV1().RESTClient()
+
+	return util.WaitForChaincodeJob(ctx, logger, batchClient, job, chaincodeData.ChaincodeID)
 }