wait

Documentation

Overview

Package wait contains the functions to wait for resource events.

Index

• type Waiter
  • func NewWaiterFromFactory(f *factory.Factory) *Waiter
  • func (w *Waiter) ForConfiguration(ctx context.Context, remoteClusterID liqov1beta1.ClusterID) error
  • func (w *Waiter) ForConnection(ctx context.Context, namespace string, remoteCluster liqov1beta1.ClusterID) (*networkingv1beta1.Connection, error)
  • func (w *Waiter) ForConnectionEstablished(ctx context.Context, conn *networkingv1beta1.Connection) error
  • func (w *Waiter) ForGatewayClientSecretRef(ctx context.Context, gwClient *networkingv1beta1.GatewayClient) error
  • func (w *Waiter) ForGatewayPodReady(ctx context.Context, gateway client.Object) error
  • func (w *Waiter) ForGatewayServerSecretRef(ctx context.Context, gwServer *networkingv1beta1.GatewayServer) error
  • func (w *Waiter) ForGatewayServerStatusEndpoint(ctx context.Context, gwServer *networkingv1beta1.GatewayServer) error
  • func (w *Waiter) ForIdentityStatus(ctx context.Context, remoteClusterID liqov1beta1.ClusterID) error
  • func (w *Waiter) ForNetwork(ctx context.Context, remoteClusterID liqov1beta1.ClusterID) error
  • func (w *Waiter) ForNodeReady(ctx context.Context, nodeName string) error
  • func (w *Waiter) ForNonce(ctx context.Context, remoteClusterID liqov1beta1.ClusterID, silent bool) error
  • func (w *Waiter) ForOffloading(ctx context.Context, namespace string) error
  • func (w *Waiter) ForResourceSliceAuthentication(ctx context.Context, resourceSlice *authv1beta1.ResourceSlice) error
  • func (w *Waiter) ForResourceSlicesAbsence(ctx context.Context, namespace string, selector labels.Selector) error
  • func (w *Waiter) ForSignedNonce(ctx context.Context, remoteClusterID liqov1beta1.ClusterID, silent bool) error
  • func (w *Waiter) ForTenantNamespaceAbsence(ctx context.Context, remoteClusterID liqov1beta1.ClusterID) error
  • func (w *Waiter) ForTenantStatus(ctx context.Context, remoteClusterID liqov1beta1.ClusterID) error
  • func (w *Waiter) ForUnoffloading(ctx context.Context, namespace string) error
  • func (w *Waiter) ForVirtualNodesAbsence(ctx context.Context, remoteClusterID liqov1beta1.ClusterID) error

Types

type Waiter

type Waiter struct {
	// Printer is the object used to output messages in the appropriate format.
	Printer *output.Printer
	// crClient is the controller runtime client.
	CRClient client.Client
	// kubeClient is a Kubernetes clientset for interacting with the base Kubernetes APIs.
	KubeClient kubernetes.Interface
}

Waiter is a struct that contains the necessary information to wait for resource events.

func NewWaiterFromFactory

func NewWaiterFromFactory(f *factory.Factory) *Waiter

NewWaiterFromFactory creates a new Waiter object from the given factory.

func (*Waiter) ForConfiguration

func (w *Waiter) ForConfiguration(ctx context.Context, remoteClusterID liqov1beta1.ClusterID) error

ForConfiguration waits until the status on the Configuration resource states that the configuration has been successfully applied.

func (*Waiter) ForConnection

func (w *Waiter) ForConnection(ctx context.Context, namespace string,
	remoteCluster liqov1beta1.ClusterID) (*networkingv1beta1.Connection, error)

ForConnection waits until the Connection resource has been created.

func (*Waiter) ForConnectionEstablished

func (w *Waiter) ForConnectionEstablished(ctx context.Context, conn *networkingv1beta1.Connection) error

ForConnectionEstablished waits until the status of the Connection is established.

func (*Waiter) ForGatewayClientSecretRef

func (w *Waiter) ForGatewayClientSecretRef(ctx context.Context, gwClient *networkingv1beta1.GatewayClient) error

ForGatewayClientSecretRef waits until the secret containing the public key of a gateway client has been created (i.e., until its secret reference status is not set).

func (*Waiter) ForGatewayPodReady

func (w *Waiter) ForGatewayPodReady(ctx context.Context, gateway client.Object) error

ForGatewayPodReady waits until the pod of a Gateway resource has been created and is ready.

func (*Waiter) ForGatewayServerSecretRef

func (w *Waiter) ForGatewayServerSecretRef(ctx context.Context, gwServer *networkingv1beta1.GatewayServer) error

ForGatewayServerSecretRef waits until the secret containing the public key of a gateway server has been created (i.e., until its secret reference status is not set).

func (*Waiter) ForGatewayServerStatusEndpoint

func (w *Waiter) ForGatewayServerStatusEndpoint(ctx context.Context, gwServer *networkingv1beta1.GatewayServer) error

ForGatewayServerStatusEndpoint waits until the service of a Gateway resource has been created (i.e., until its endpoint status is not set).

func (*Waiter) ForIdentityStatus

func (w *Waiter) ForIdentityStatus(ctx context.Context, remoteClusterID liqov1beta1.ClusterID) error

ForIdentityStatus waits until the identity status has been updated or the timeout expires.

func (*Waiter) ForNetwork

func (w *Waiter) ForNetwork(ctx context.Context, remoteClusterID liqov1beta1.ClusterID) error

ForNetwork waits until the networking has been established with the remote cluster or the timeout expires.

func (*Waiter) ForNodeReady

func (w *Waiter) ForNodeReady(ctx context.Context, nodeName string) error

ForNodeReady waits until the node has been added to the cluster and is Ready, or the timeout expires.

func (*Waiter) ForNonce

func (w *Waiter) ForNonce(ctx context.Context, remoteClusterID liqov1beta1.ClusterID, silent bool) error

ForNonce waits until the secret containing the nonce has been created or the timeout expires.

func (*Waiter) ForOffloading

func (w *Waiter) ForOffloading(ctx context.Context, namespace string) error

ForOffloading waits until the status on the NamespaceOffloading resource states that the offloading has been successfully established or the timeout expires.

func (*Waiter) ForResourceSliceAuthentication

func (w *Waiter) ForResourceSliceAuthentication(ctx context.Context, resourceSlice *authv1beta1.ResourceSlice) error

ForResourceSliceAuthentication waits until the ResourceSlice authentication has been accepted or the timeout expires.

func (*Waiter) ForResourceSlicesAbsence

func (w *Waiter) ForResourceSlicesAbsence(ctx context.Context, namespace string, selector labels.Selector) error

ForResourceSlicesAbsence waits until the resource slices with the given selector have been deleted or the timeout expires.

func (*Waiter) ForSignedNonce

func (w *Waiter) ForSignedNonce(ctx context.Context, remoteClusterID liqov1beta1.ClusterID, silent bool) error

ForSignedNonce waits until the signed nonce secret has been signed and returns the signature.

func (*Waiter) ForTenantNamespaceAbsence

func (w *Waiter) ForTenantNamespaceAbsence(ctx context.Context, remoteClusterID liqov1beta1.ClusterID) error

ForTenantNamespaceAbsence waits until the tenant namespace has been deleted or the timeout expires.

func (*Waiter) ForTenantStatus

func (w *Waiter) ForTenantStatus(ctx context.Context, remoteClusterID liqov1beta1.ClusterID) error

ForTenantStatus waits until the tenant status has been updated or the timeout expires.

func (*Waiter) ForUnoffloading

func (w *Waiter) ForUnoffloading(ctx context.Context, namespace string) error

ForUnoffloading waits until the status on the NamespaceOffloading resource states that the offloading has been successfully removed or the timeout expires.

func (*Waiter) ForVirtualNodesAbsence

func (w *Waiter) ForVirtualNodesAbsence(ctx context.Context, remoteClusterID liqov1beta1.ClusterID) error

ForVirtualNodesAbsence waits until the virtual nodes with the given selector have been deleted or the timeout expires.