Documentation ¶
Overview ¶
Package wait_v2 implements cluster waiter.
Index ¶
- func IsDeleted(err error) bool
- func Poll(ctx context.Context, stopc chan struct{}, lg *zap.Logger, logWriter io.Writer, ...) <-chan ClusterStatus
- func PollUpdate(ctx context.Context, stopc chan struct{}, lg *zap.Logger, logWriter io.Writer, ...) <-chan UpdateStatus
- type ClusterStatus
- type Op
- type OpOption
- type UpdateStatus
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func IsDeleted ¶
IsDeleted returns true if error from EKS API indicates that the EKS cluster has already been deleted.
func Poll ¶
func Poll( ctx context.Context, stopc chan struct{}, lg *zap.Logger, logWriter io.Writer, eksAPIV2 *aws_eks_v2.Client, clusterName string, desiredClusterStatus string, initialWait time.Duration, pollInterval time.Duration, opts ...OpOption) <-chan ClusterStatus
Poll periodically fetches the cluster status until the cluster becomes the desired state.
func PollUpdate ¶
func PollUpdate( ctx context.Context, stopc chan struct{}, lg *zap.Logger, logWriter io.Writer, eksAPIV2 *aws_eks_v2.Client, clusterName string, requestID string, desiredUpdateStatus string, initialWait time.Duration, pollInterval time.Duration, opts ...OpOption) <-chan UpdateStatus
PollUpdate periodically fetches the cluster update status until the cluster update becomes the desired state. ref. https://docs.aws.amazon.com/eks/latest/APIReference/API_DescribeUpdate.html
Types ¶
type ClusterStatus ¶
type ClusterStatus struct { Cluster *aws_eks_v2_types.Cluster Error error }
ClusterStatus represents the EKS cluster status.
type Op ¶
type Op struct {
// contains filtered or unexported fields
}
Op represents a MNG operation.
type OpOption ¶
type OpOption func(*Op)
OpOption configures archiver operations.
func WithQueryFunc ¶
func WithQueryFunc(f func()) OpOption
WithQueryFunc configures query function to be called in retry func.
type UpdateStatus ¶
type UpdateStatus struct { Update *aws_eks_v2_types.Update Error error }
UpdateStatus represents the CloudFormation status.