use new k8s deploy watcher

Author: BSick7

app/container/aws-eks-service/provider.go

@@ -19,7 +19,7 @@ var Provider = app.Provider{
 	CanDeployImmediate: false,
 	NewPusher:          ecr.NewPusher,
 	NewDeployer:        eks.NewDeployer,
-	NewDeployWatcher:   app.NewPollingDeployWatcher(eks.NewDeployStatusGetter),
+	NewDeployWatcher:   eks.NewDeployWatcher,
 	NewStatuser:        nil,
 	NewLogStreamer:     eks.NewLogStreamer,
 }

aws/eks/deploy_status_getter.go

@@ -37,6 +37,8 @@ type DeployStatusGetter struct {
 	numDesired      int
 }
 
+func (d *DeployStatusGetter) Close() {}
+
 func (d *DeployStatusGetter) initialize(ctx context.Context, reference string) error {
 	return nil
 }

aws/eks/deploy_watcher.go

@@ -0,0 +1,27 @@
+package eks
+
+import (
+	"context"
+	"github.com/nullstone-io/deployment-sdk/app"
+	"github.com/nullstone-io/deployment-sdk/k8s"
+	"github.com/nullstone-io/deployment-sdk/logging"
+	"github.com/nullstone-io/deployment-sdk/outputs"
+	"k8s.io/client-go/rest"
+)
+
+func NewDeployWatcher(ctx context.Context, osWriters logging.OsWriters, source outputs.RetrieverSource, appDetails app.Details) (app.DeployWatcher, error) {
+	outs, err := outputs.Retrieve[Outputs](ctx, source, appDetails.Workspace, appDetails.WorkspaceConfig)
+	if err != nil {
+		return nil, err
+	}
+
+	return &k8s.DeployWatcher{
+		OsWriters:    osWriters,
+		Details:      appDetails,
+		AppNamespace: outs.ServiceNamespace,
+		AppName:      outs.ServiceName,
+		NewConfigFn: func(ctx context.Context) (*rest.Config, error) {
+			return CreateKubeConfig(ctx, outs.Region, outs.ClusterNamespace, outs.Deployer)
+		},
+	}, nil
+}