Documentation ¶
Overview ¶
Package wait 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, eksAPI eksiface.EKSAPI, 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 ¶ added in v1.4.6
func PollUpdate( ctx context.Context, stopc chan struct{}, lg *zap.Logger, logWriter io.Writer, eksAPI eksiface.EKSAPI, 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 ¶
ClusterStatus represents the EKS cluster status.
type Op ¶ added in v1.4.6
type Op struct {
// contains filtered or unexported fields
}
Op represents a MNG operation.
type OpOption ¶ added in v1.4.6
type OpOption func(*Op)
OpOption configures archiver operations.
func WithQueryFunc ¶ added in v1.4.6
func WithQueryFunc(f func()) OpOption
WithQueryFunc configures query function to be called in retry func.
type UpdateStatus ¶ added in v1.4.6
UpdateStatus represents the CloudFormation status.