drainfinisher

Documentation

Index

• Constants
• func IsInvalidConfig(err error) bool
• func IsMissingAnnotationError(err error) bool
• func IsNoActiveLifecycleAction(err error) bool
• type Resource
  • func NewResource(config ResourceConfig) (*Resource, error)
  • func (r *Resource) EnsureCreated(ctx context.Context, obj interface{}) error
  • func (r *Resource) EnsureDeleted(ctx context.Context, obj interface{}) error
  • func (r *Resource) Name() string
• type ResourceConfig
• type StackState

Constants

const (
	Name = "drainfinisher"
)

Functions

func IsInvalidConfig

func IsInvalidConfig(err error) bool

IsInvalidConfig asserts invalidConfigError.

func IsMissingAnnotationError

func IsMissingAnnotationError(err error) bool

func IsNoActiveLifecycleAction

func IsNoActiveLifecycleAction(err error) bool

IsNoActiveLifecycleAction asserts noActiveLifecycleActionError. It also checks for some string matching in the error message to figure if the AWS API gives the error we expect.

Types

type Resource

type Resource struct {
	// contains filtered or unexported fields
}

func NewResource

func NewResource(config ResourceConfig) (*Resource, error)

func (*Resource) EnsureCreated

func (r *Resource) EnsureCreated(ctx context.Context, obj interface{}) error

EnsureCreated completes ASG lifecycle hooks for nodes drained by node-operator, and then deletes drained DrainerConfigs.

func (*Resource) EnsureDeleted

func (r *Resource) EnsureDeleted(ctx context.Context, obj interface{}) error

EnsureDeleted is a no-op, because the lifecycle resource only has to act on create and update events in order to drain guest cluster nodes.

func (*Resource) Name

func (r *Resource) Name() string

type ResourceConfig

type ResourceConfig struct {
	G8sClient versioned.Interface
	Logger    micrologger.Logger
}

type StackState

type StackState struct {
	Instances     []*autoscaling.Instance
	WorkerASGName string
}