drainerinitializer

Documentation

Index

• Constants
• func IsInvalidConfig(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

Constants

const (
	Name = "drainerinitializer"
)

Functions

func IsInvalidConfig

func IsInvalidConfig(err error) bool

IsInvalidConfig asserts invalidConfigError.

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

func (*Resource) EnsureDeleted

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

func (*Resource) Name

func (r *Resource) Name() string

type ResourceConfig

type ResourceConfig struct {
	ASG        asg.Interface
	CtrlClient ctrlClient.Client
	Logger     micrologger.Logger

	LabelMapFunc      func(cr metav1.Object) map[string]string
	LifeCycleHookName string
	ToClusterFunc     func(ctx context.Context, v interface{}) (infrastructurev1alpha3.AWSCluster, error)
}