lifecycle

Documentation

Index

• Variables
• func IgnoreNotDefined(err error) error
• func SelectTargetPods(pods []*corev1.Pod, pod *corev1.Pod, spec *appsv1.Action) ([]*corev1.Pod, error)
• type Lifecycle
  • func New(synthesizedComp *component.SynthesizedComponent, pod *corev1.Pod, ...) (Lifecycle, error)
• type Options

Variables

var (
	ErrActionNotDefined     = errors.New("action is not defined")
	ErrActionNotImplemented = errors.New("action is not implemented")
	ErrActionInProgress     = errors.New("action is in progress")
	ErrActionBusy           = errors.New("action is busy")
	ErrActionTimedOut       = errors.New("action timed-out")
	ErrActionFailed         = errors.New("action failed")
	ErrActionInternalError  = errors.New("action internal error")
)

Functions

func IgnoreNotDefined

func IgnoreNotDefined(err error) error

func SelectTargetPods

func SelectTargetPods(pods []*corev1.Pod, pod *corev1.Pod, spec *appsv1.Action) ([]*corev1.Pod, error)

Types

type Lifecycle

type Lifecycle interface {
	PostProvision(ctx context.Context, cli client.Reader, opts *Options) error

	PreTerminate(ctx context.Context, cli client.Reader, opts *Options) error

	RoleProbe(ctx context.Context, cli client.Reader, opts *Options) ([]byte, error)

	Switchover(ctx context.Context, cli client.Reader, opts *Options, candidate string) error

	MemberJoin(ctx context.Context, cli client.Reader, opts *Options) error

	MemberLeave(ctx context.Context, cli client.Reader, opts *Options) error

	AccountProvision(ctx context.Context, cli client.Reader, opts *Options, statement, user, password string) error
}

func New

func New(synthesizedComp *component.SynthesizedComponent, pod *corev1.Pod, pods ...*corev1.Pod) (Lifecycle, error)

type Options

type Options struct {
	NonBlocking    *bool
	TimeoutSeconds *int32
	RetryPolicy    *appsv1.RetryPolicy
}