TelemetryRouter service waiters and examples

CHANGELOG.md

@@ -424,6 +424,8 @@
     - **Dependencies:** Bump STACKIT SDK core module from `v0.25.0` to `v0.26.0`
   - [v0.2.0](services/telemetryrouter/CHANGELOG.md#v020)
     - **Feature:** Added `_UNKNOWN_DEFAULT_OPEN_API` fallback value to all enums to handle unknown API values gracefully.
+  - [v0.2.1](services/telemetryrouter/CHANGELOG.md#v021)
+    - **Improvement**: Use new `WaiterHandler` struct in the DNS WaitHandler
 - `vpn`:
   - [v0.4.2](services/vpn/CHANGELOG.md#v042) 
     - **Dependencies:** Bump STACKIT SDK core module from `v0.24.0` to `v0.24.1`

examples/telemetryrouter/go.mod

@@ -0,0 +1,16 @@
+module github.com/stackitcloud/stackit-sdk-go/examples/telemetryrouter
+
+go 1.25
+
+// This is not needed in production. This is only here to point the golangci linter to the local version instead of the last release on GitHub.
+replace github.com/stackitcloud/stackit-sdk-go/services/telemetryrouter => ../../services/telemetryrouter
+
+require (
+	github.com/stackitcloud/stackit-sdk-go/core v0.26.0
+	github.com/stackitcloud/stackit-sdk-go/services/telemetryrouter v0.2.1
+)
+
+require (
+	github.com/golang-jwt/jwt/v5 v5.3.1 // indirect
+	github.com/google/uuid v1.6.0 // indirect
+)

examples/telemetryrouter/go.sum

@@ -0,0 +1,8 @@
+github.com/golang-jwt/jwt/v5 v5.3.1 h1:kYf81DTWFe7t+1VvL7eS+jKFVWaUnK9cB1qbwn63YCY=
+github.com/golang-jwt/jwt/v5 v5.3.1/go.mod h1:fxCRLWMO43lRc8nhHWY6LGqRcf+1gQWArsqaEUEa5bE=
+github.com/google/go-cmp v0.7.0 h1:wk8382ETsv4JYUZwIsn6YpYiWiBsYLSJiTsyBybVuN8=
+github.com/google/go-cmp v0.7.0/go.mod h1:pXiqmnSA92OHEEa9HXL2W4E7lf9JzCmGVUdgjX3N/iU=
+github.com/google/uuid v1.6.0 h1:NIvaJDMOsjHA8n1jAhLSgzrAzy1Hgr+hNrb57e+94F0=
+github.com/google/uuid v1.6.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo=
+github.com/stackitcloud/stackit-sdk-go/core v0.26.0 h1:jQEb9gkehfp6VCP6TcYk7BI10cz4l0KM2L6hqYBH2QA=
+github.com/stackitcloud/stackit-sdk-go/core v0.26.0/go.mod h1:WU1hhxnjXw2EV7CYa1nlEvNpMiRY6CvmIOaHuL3pOaA=

go.work

@@ -34,6 +34,7 @@ use (
 	./examples/sfs
 	./examples/ske
 	./examples/sqlserverflex
+	./examples/telemetryrouter
 	./examples/waiter
 	./services/alb
 	./services/albwaf

services/telemetryrouter/CHANGELOG.md

@@ -1,3 +1,6 @@
+## v0.2.1
+- **Improvement**: Use new `WaiterHandler` struct in the DNS WaitHandler
+
 ## v0.2.0
 - **Feature:** Added `_UNKNOWN_DEFAULT_OPEN_API` fallback value to all enums to handle unknown API values gracefully.
 

services/telemetryrouter/VERSION

@@ -1 +1 @@
-v0.2.0
+v0.2.1

services/telemetryrouter/go.mod

@@ -2,7 +2,10 @@ module github.com/stackitcloud/stackit-sdk-go/services/telemetryrouter
 
 go 1.25
 
-require github.com/stackitcloud/stackit-sdk-go/core v0.26.0
+require (
+	github.com/google/go-cmp v0.7.0
+	github.com/stackitcloud/stackit-sdk-go/core v0.26.0
+)
 
 require (
 	github.com/golang-jwt/jwt/v5 v5.3.1 // indirect

services/telemetryrouter/v1betaapi/wait/wait.go

@@ -0,0 +1,179 @@
+package wait
+
+import (
+	"context"
+	"errors"
+	"net/http"
+	"time"
+
+	"github.com/stackitcloud/stackit-sdk-go/core/wait"
+	telemetryrouter "github.com/stackitcloud/stackit-sdk-go/services/telemetryrouter/v1betaapi"
+)
+
+const (
+	TELEMETRYROUTER_ACTIVE = "active"
+	DESTINATION_ACTIVE     = "active"
+	ACCESSTOKEN_ACTIVE     = "active"
+)
+
+// CreateTelemetryRouterWaitHandler will wait for TelemetryRouter creation
+func CreateTelemetryRouterWaitHandler(ctx context.Context, a telemetryrouter.DefaultAPI, projectId, regionId, instanceId string) *wait.AsyncActionHandler[telemetryrouter.TelemetryRouterResponse] {
+	waitConfig := wait.WaiterHelper[telemetryrouter.TelemetryRouterResponse, string]{
+		FetchInstance: a.GetTelemetryRouter(ctx, projectId, regionId, instanceId).Execute,
+		GetState: func(d *telemetryrouter.TelemetryRouterResponse) (string, error) {
+			if d == nil {
+				return "", errors.New("empty response")
+			}
+			return d.Status, nil
+		},
+		ActiveState: []string{TELEMETRYROUTER_ACTIVE},
+	}
+
+	handler := wait.New(waitConfig.Wait())
+	handler.SetTimeout(10 * time.Minute)
+	return handler
+}
+
+// UpdateTelemetryRouterWaitHandler will wait for TelemetryRouter update
+func UpdateTelemetryRouterWaitHandler(ctx context.Context, a telemetryrouter.DefaultAPI, projectId, regionId, instanceId string) *wait.AsyncActionHandler[telemetryrouter.TelemetryRouterResponse] {
+	waitConfig := wait.WaiterHelper[telemetryrouter.TelemetryRouterResponse, string]{
+		FetchInstance: a.GetTelemetryRouter(ctx, projectId, regionId, instanceId).Execute,
+		GetState: func(d *telemetryrouter.TelemetryRouterResponse) (string, error) {
+			if d == nil {
+				return "", errors.New("empty response")
+			}
+			return d.Status, nil
+		},
+		ActiveState: []string{TELEMETRYROUTER_ACTIVE},
+	}
+
+	handler := wait.New(waitConfig.Wait())
+	handler.SetTimeout(10 * time.Minute)
+	return handler
+}
+
+// DeleteTelemetryRouterWaitHandler will wait for TelemetryRouter deletion
+func DeleteTelemetryRouterWaitHandler(ctx context.Context, a telemetryrouter.DefaultAPI, projectId, regionId, instanceId string) *wait.AsyncActionHandler[telemetryrouter.TelemetryRouterResponse] {
+	waitConfig := wait.WaiterHelper[telemetryrouter.TelemetryRouterResponse, string]{
+		FetchInstance: a.GetTelemetryRouter(ctx, projectId, regionId, instanceId).Execute,
+		GetState: func(d *telemetryrouter.TelemetryRouterResponse) (string, error) {
+			if d == nil {
+				return "", errors.New("empty response")
+			}
+			return d.Status, nil
+		},
+		DeleteHttpErrorStatusCodes: []int{http.StatusNotFound},
+	}
+
+	handler := wait.New(waitConfig.Wait())
+	handler.SetTimeout(10 * time.Minute)
+	return handler
+}
+
+// CreateDestinationWaitHandler will wait for Destination creation
+func CreateDestinationWaitHandler(ctx context.Context, a telemetryrouter.DefaultAPI, projectId, regionId, instanceId, destinationId string) *wait.AsyncActionHandler[telemetryrouter.DestinationResponse] {
+	waitConfig := wait.WaiterHelper[telemetryrouter.DestinationResponse, string]{
+		FetchInstance: a.GetDestination(ctx, projectId, regionId, instanceId, destinationId).Execute,
+		GetState: func(d *telemetryrouter.DestinationResponse) (string, error) {
+			if d == nil {
+				return "", errors.New("empty response")
+			}
+			return d.Status, nil
+		},
+		ActiveState: []string{DESTINATION_ACTIVE},
+	}
+
+	handler := wait.New(waitConfig.Wait())
+	handler.SetTimeout(10 * time.Minute)
+	return handler
+}
+
+// UpdateDestinationWaitHandler will wait for Destination update
+func UpdateDestinationWaitHandler(ctx context.Context, a telemetryrouter.DefaultAPI, projectId, regionId, instanceId, destinationId string) *wait.AsyncActionHandler[telemetryrouter.DestinationResponse] {
+	waitConfig := wait.WaiterHelper[telemetryrouter.DestinationResponse, string]{
+		FetchInstance: a.GetDestination(ctx, projectId, regionId, instanceId, destinationId).Execute,
+		GetState: func(d *telemetryrouter.DestinationResponse) (string, error) {
+			if d == nil {
+				return "", errors.New("empty response")
+			}
+			return d.Status, nil
+		},
+		ActiveState: []string{DESTINATION_ACTIVE},
+	}
+
+	handler := wait.New(waitConfig.Wait())
+	handler.SetTimeout(10 * time.Minute)
+	return handler
+}
+
+// DeleteDestinationWaitHandler will wait for Destination deletion
+func DeleteDestinationWaitHandler(ctx context.Context, a telemetryrouter.DefaultAPI, projectId, regionId, instanceId, destinationId string) *wait.AsyncActionHandler[telemetryrouter.DestinationResponse] {
+	waitConfig := wait.WaiterHelper[telemetryrouter.DestinationResponse, string]{
+		FetchInstance: a.GetDestination(ctx, projectId, regionId, instanceId, destinationId).Execute,
+		GetState: func(d *telemetryrouter.DestinationResponse) (string, error) {
+			if d == nil {
+				return "", errors.New("empty response")
+			}
+			return d.Status, nil
+		},
+		DeleteHttpErrorStatusCodes: []int{http.StatusNotFound},
+	}
+
+	handler := wait.New(waitConfig.Wait())
+	handler.SetTimeout(10 * time.Minute)
+	return handler
+}
+
+// CreateAccessTokenWaitHandler will wait for AccessToken creation
+func CreateAccessTokenWaitHandler(ctx context.Context, a telemetryrouter.DefaultAPI, projectId, regionId, instanceId, accessTokenId string) *wait.AsyncActionHandler[telemetryrouter.GetAccessTokenResponse] {
+	waitConfig := wait.WaiterHelper[telemetryrouter.GetAccessTokenResponse, string]{
+		FetchInstance: a.GetAccessToken(ctx, projectId, regionId, instanceId, accessTokenId).Execute,
+		GetState: func(d *telemetryrouter.GetAccessTokenResponse) (string, error) {
+			if d == nil {
+				return "", errors.New("empty response")
+			}
+			return d.Status, nil
+		},
+		ActiveState: []string{ACCESSTOKEN_ACTIVE},
+	}
+
+	handler := wait.New(waitConfig.Wait())
+	handler.SetTimeout(10 * time.Minute)
+	return handler
+}
+
+// UpdateAccessTokenWaitHandler will wait for AccessToken update
+func UpdateAccessTokenWaitHandler(ctx context.Context, a telemetryrouter.DefaultAPI, projectId, regionId, instanceId, accessTokenId string) *wait.AsyncActionHandler[telemetryrouter.GetAccessTokenResponse] {
+	waitConfig := wait.WaiterHelper[telemetryrouter.GetAccessTokenResponse, string]{
+		FetchInstance: a.GetAccessToken(ctx, projectId, regionId, instanceId, accessTokenId).Execute,
+		GetState: func(d *telemetryrouter.GetAccessTokenResponse) (string, error) {
+			if d == nil {
+				return "", errors.New("empty response")
+			}
+			return d.Status, nil
+		},
+		ActiveState: []string{ACCESSTOKEN_ACTIVE},
+	}
+
+	handler := wait.New(waitConfig.Wait())
+	handler.SetTimeout(10 * time.Minute)
+	return handler
+}
+
+// DeleteAccessTokenWaitHandler will wait for AccessToken deletion
+func DeleteAccessTokenWaitHandler(ctx context.Context, a telemetryrouter.DefaultAPI, projectId, regionId, instanceId, accessTokenId string) *wait.AsyncActionHandler[telemetryrouter.GetAccessTokenResponse] {
+	waitConfig := wait.WaiterHelper[telemetryrouter.GetAccessTokenResponse, string]{
+		FetchInstance: a.GetAccessToken(ctx, projectId, regionId, instanceId, accessTokenId).Execute,
+		GetState: func(d *telemetryrouter.GetAccessTokenResponse) (string, error) {
+			if d == nil {
+				return "", errors.New("empty response")
+			}
+			return d.Status, nil
+		},
+		DeleteHttpErrorStatusCodes: []int{http.StatusNotFound},
+	}
+
+	handler := wait.New(waitConfig.Wait())
+	handler.SetTimeout(10 * time.Minute)
+	return handler
+}