hook

Jul 4, 2024

Changes in this version

+ func CheckErr(err error)

+ func GetKubeBlocksDeploy(ctx context.Context, client *kubernetes.Clientset, ns string, ...) (*appsv1.Deployment, error)

+ func Log(format string, a ...any)

+ func PrepareFor(ctx *UpgradeContext) (err error)

+ func RegisterCRDConversion(gvr schema.GroupVersionResource, newVersion Version, handler ConversionHandler, ...)

+ type Addon struct

+ KeepAddons bool

+ func (p *Addon) Handle(ctx *UpgradeContext) (err error)

+ func (p *Addon) IsSkip(*UpgradeContext) (bool, error)

+ type BasedHandler struct

+ func (b *BasedHandler) IsSkip(*UpgradeContext) (bool, error)

+ type CRClient struct

+ CRDClient *clientset.Clientset

+ K8sClient *kubernetes.Clientset

+ KBClient *versioned.Clientset

+ type ContextHandler interface

+ Handle func(*UpgradeContext) error

+ IsSkip func(*UpgradeContext) (bool, error)

+ type ContextHandlerFunc func(ctx *UpgradeContext) error

+ func (f ContextHandlerFunc) Handle(ctx *UpgradeContext) error

+ type Conversion struct

+ func (p *Conversion) Handle(ctx *UpgradeContext) (err error)

+ type ConversionHandler interface

+ Convert func(context.Context, CRClient) ([]client.Object, error)

+ type ConversionMeta struct

+ FromVersion []Version

+ ToVersion Version

+ type StopOperator struct

+ func (p *StopOperator) Handle(ctx *UpgradeContext) error

+ type UpdateCR struct

+ func (u *UpdateCR) Handle(context *UpgradeContext) error

+ type UpdateCRD struct

+ func (p *UpdateCRD) Handle(ctx *UpgradeContext) (err error)

+ type UpgradeContext struct

+ From *Version

+ To Version

+ UpdatedObjects map[schema.GroupVersionResource][]client.Object

+ func NewUpgradeContext(ctx context.Context, config *restclient.Config, version string, crd string, ...) *UpgradeContext

+ type UpgradeMetaContext struct

+ CRDPath string

+ Namespace string

+ Version string

+ type Version struct

+ Major int32

+ Minor int32

+ func NewNoVersion(major, minor int32) Version

+ func NewVersion(version string) (*Version, error)

+ func (v Version) String() string

+ type Workflow []ContextHandlerFunc

+ func NewUpgradeWorkflow() Workflow

+ func (w Workflow) AddStage(stage ContextHandler) Workflow

+ func (w Workflow) Do(ctx *UpgradeContext) error

+ func (w Workflow) WrapStage(stageFn ContextHandlerFunc) Workflow