installer

Documentation

Index

• func Install(ctx context.Context, isbSvc *dfv1.InterStepBufferService, client client.Client, ...) error
• func Uninstall(ctx context.Context, isbSvc *dfv1.InterStepBufferService, client client.Client, ...) error
• type Installer
  • func NewExternalRedisInstaller(isbSvc *dfv1.InterStepBufferService, logger *zap.SugaredLogger) Installer
  • func NewJetStreamInstaller(client client.Client, kubeClient kubernetes.Interface, ...) Installer
  • func NewNativeRedisInstaller(client client.Client, kubeClient kubernetes.Interface, ...) Installer

Functions

func Install

func Install(ctx context.Context, isbSvc *dfv1.InterStepBufferService, client client.Client, kubeClient kubernetes.Interface, config *reconciler.GlobalConfig, logger *zap.SugaredLogger, recorder record.EventRecorder) error

Install function installs the ISBS

func Uninstall

func Uninstall(ctx context.Context, isbSvc *dfv1.InterStepBufferService, client client.Client, kubeClient kubernetes.Interface, config *reconciler.GlobalConfig, logger *zap.SugaredLogger, recorder record.EventRecorder) error

Uninstall function will be run before the ISBS object is deleted, usually it could be used to uninstall the extra resources who would not be cleaned up when an ISBS is deleted. Most of the time this is not needed as all the dependency resources should have been deleted by owner references cascade deletion, but things like PVC created by StatefulSet need to be cleaned up separately.

It could also be used to check if the ISB Service object can be safely deleted.

Types

type Installer

type Installer interface {
	Install(ctx context.Context) (*dfv1.BufferServiceConfig, error)
	// Uninstall only needs to handle those resources not cascade deleted.
	// For example, undeleted PVCs not automatically deleted when deleting a StatefulSet
	Uninstall(ctx context.Context) error
}

Installer is an interface for ISBS installation

func NewExternalRedisInstaller

func NewExternalRedisInstaller(isbSvc *dfv1.InterStepBufferService, logger *zap.SugaredLogger) Installer

func NewJetStreamInstaller

func NewJetStreamInstaller(client client.Client, kubeClient kubernetes.Interface, isbSvc *dfv1.InterStepBufferService, config *reconciler.GlobalConfig, labels map[string]string, logger *zap.SugaredLogger, recorder record.EventRecorder) Installer

func NewNativeRedisInstaller

func NewNativeRedisInstaller(client client.Client, kubeClient kubernetes.Interface, isbSvc *dfv1.InterStepBufferService, config *reconciler.GlobalConfig, labels map[string]string, logger *zap.SugaredLogger, recorder record.EventRecorder) Installer