wait

Documentation

Index

• Constants
• func CompleteCredentialsRotationWaitHandler(ctx context.Context, a APIClientClusterInterface, ...) *wait.AsyncActionHandler[ske.Cluster]
• func CreateOrUpdateClusterWaitHandler(ctx context.Context, a APIClientClusterInterface, projectId, name string) *wait.AsyncActionHandler[ske.Cluster]
• func DeleteClusterWaitHandler(ctx context.Context, a APIClientClusterInterface, projectId, name string) *wait.AsyncActionHandler[ske.ListClustersResponse]
• func DisableServiceWaitHandler(ctx context.Context, a APIClientProjectInterface, projectId string) *wait.AsyncActionHandler[struct{}]
• func EnableServiceWaitHandler(ctx context.Context, a APIClientProjectInterface, projectId string) *wait.AsyncActionHandler[ske.ProjectResponse]
• func RotateCredentialsWaitHandler(ctx context.Context, a APIClientClusterInterface, ...) *wait.AsyncActionHandler[ske.Cluster]
• func StartCredentialsRotationWaitHandler(ctx context.Context, a APIClientClusterInterface, ...) *wait.AsyncActionHandler[ske.Cluster]
• type APIClientClusterInterface
• type APIClientProjectInterface

Constants

const (
	StateHealthy                       = "STATE_HEALTHY"
	StateHibernated                    = "STATE_HIBERNATED"
	StateFailed                        = "STATE_FAILED"
	StateDeleting                      = "STATE_DELETING"
	StateCreated                       = "STATE_CREATED"
	StateUnhealthy                     = "STATE_UNHEALTHY"
	StateReconciling                   = "STATE_RECONCILING"
	CredentialsRotationStatePreparing  = "PREPARING"
	CredentialsRotationStatePrepared   = "PREPARED"
	CredentialsRotationStateCompleting = "COMPLETING"
	CredentialsRotationStateCompleted  = "COMPLETED"
	InvalidArgusInstanceErrorCode      = "SKE_ARGUS_INSTANCE_NOT_FOUND"
)

Functions

func CompleteCredentialsRotationWaitHandler

func CompleteCredentialsRotationWaitHandler(ctx context.Context, a APIClientClusterInterface, projectId, clusterName string) *wait.AsyncActionHandler[ske.Cluster]

CompleteCredentialsRotationWaitHandler will wait for credentials rotation

func CreateOrUpdateClusterWaitHandler

func CreateOrUpdateClusterWaitHandler(ctx context.Context, a APIClientClusterInterface, projectId, name string) *wait.AsyncActionHandler[ske.Cluster]

CreateOrUpdateClusterWaitHandler will wait for cluster creation or update

func DeleteClusterWaitHandler

func DeleteClusterWaitHandler(ctx context.Context, a APIClientClusterInterface, projectId, name string) *wait.AsyncActionHandler[ske.ListClustersResponse]

DeleteClusterWaitHandler will wait for cluster deletion

func DisableServiceWaitHandler

func DisableServiceWaitHandler(ctx context.Context, a APIClientProjectInterface, projectId string) *wait.AsyncActionHandler[struct{}]

DisableServiceWaitHandler will wait for service disablement

func EnableServiceWaitHandler

func EnableServiceWaitHandler(ctx context.Context, a APIClientProjectInterface, projectId string) *wait.AsyncActionHandler[ske.ProjectResponse]

EnableServiceWaitHandler will wait for service enablement

func RotateCredentialsWaitHandler

func RotateCredentialsWaitHandler(ctx context.Context, a APIClientClusterInterface, projectId, clusterName string) *wait.AsyncActionHandler[ske.Cluster]

RotateCredentialsWaitHandler will wait for credentials rotation

func StartCredentialsRotationWaitHandler

func StartCredentialsRotationWaitHandler(ctx context.Context, a APIClientClusterInterface, projectId, clusterName string) *wait.AsyncActionHandler[ske.Cluster]

StartCredentialsRotationWaitHandler will wait for credentials rotation

Types

type APIClientClusterInterface

type APIClientClusterInterface interface {
	GetClusterExecute(ctx context.Context, projectId, name string) (*ske.Cluster, error)
	ListClustersExecute(ctx context.Context, projectId string) (*ske.ListClustersResponse, error)
}

type APIClientProjectInterface

type APIClientProjectInterface interface {
	GetServiceStatusExecute(ctx context.Context, projectId string) (*ske.ProjectResponse, error)
}