coordinator: add transit engine

edgelesssys · Feb 4, 2025 · eed6fd3 · eed6fd3
1 parent 17b276b
commit eed6fd3
Show file tree

Hide file tree

Showing 2 changed files with 17 additions and 0 deletions.
diff --git a/coordinator/main.go b/coordinator/main.go
@@ -15,6 +15,7 @@ import (
 
 	"github.com/edgelesssys/contrast/coordinator/history"
 	"github.com/edgelesssys/contrast/coordinator/internal/authority"
+	"github.com/edgelesssys/contrast/coordinator/internal/transitengine"
 	"github.com/edgelesssys/contrast/internal/atls"
 	"github.com/edgelesssys/contrast/internal/atls/issuer"
 	"github.com/edgelesssys/contrast/internal/grpc/atlscredentials"
@@ -129,6 +130,19 @@ func run() (retErr error) {
 		return nil
 	})
 
+	eg.Go(func() error {
+		logger.Info("Creating transit engine API")
+		if err != nil {
+			logger.Error("Serving transit engine API", "err", err)
+			return fmt.Errorf("getting seed engine: %w", err)
+		}
+		if err := transitengine.NewTransitEngineAPI(8200, nil, logger); err != nil {
+			logger.Error("Serving transit engine API", "err", err)
+			return fmt.Errorf("serving transit engine API: %w", err)
+		}
+		return nil
+	})
+
 	eg.Go(func() error {
 		<-ctx.Done()
 		logger.Info("Error detected, shutting down")

diff --git a/internal/kuberesource/parts.go b/internal/kuberesource/parts.go
@@ -373,6 +373,9 @@ func Coordinator(namespace string) *CoordinatorConfig {
 								ContainerPort().
 									WithName("meshapi").
 									WithContainerPort(7777),
+								ContainerPort().
+									WithName("transitapi").
+									WithContainerPort(8200),
 							).
 							WithReadinessProbe(Probe().
 								WithInitialDelaySeconds(1).