lifecycle

package

v1.0.0-beta.36 Latest Latest Go to latest Published: Mar 21, 2025 License: AGPL-3.0 Imports: 17 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/apecloud/kubeblocks

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func FileTemplateChanges(created, removed, updated string) map[string]string
func IgnoreNotDefined(err error) error
func SelectTargetPods(pods []*corev1.Pod, pod *corev1.Pod, spec *appsv1.Action) ([]*corev1.Pod, error)
func UDFActionName(name string) string
type Lifecycle
- func New(namespace, clusterName, compName string, ...) (Lifecycle, error)
type Options

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	ErrActionNotDefined     = errors.New("action is not defined")
	ErrActionNotImplemented = errors.New("action is not implemented")
	ErrPreconditionFailed   = errors.New("action precondition is not matched")
	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 FileTemplateChanges ¶

func FileTemplateChanges(created, removed, updated string) map[string]string

func IgnoreNotDefined ¶

func IgnoreNotDefined(err error) error

func SelectTargetPods ¶

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

func UDFActionName ¶

func UDFActionName(name string) string

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

	Reconfigure(ctx context.Context, cli client.Reader, opts *Options, args map[string]string) error

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

	UserDefined(ctx context.Context, cli client.Reader, opts *Options, name string, action *appsv1.Action, args map[string]string) error
}

func New ¶

func New(namespace, clusterName, compName string, lifecycleActions *appsv1.ComponentLifecycleActions,
	templateVars map[string]any, pod *corev1.Pod, pods ...*corev1.Pod) (Lifecycle, error)

type Options ¶

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

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL