installer

Documentation

Index

• func Install(eventBus *v1alpha1.EventBus, client client.Client, ...) error
• func Uninstall(eventBus *v1alpha1.EventBus, client client.Client, ...) error
• type Installer
  • func NewExoticNATSInstaller(eventBus *v1alpha1.EventBus, logger *zap.SugaredLogger) Installer
  • func NewNATSInstaller(client client.Client, eventBus *v1alpha1.EventBus, ...) Installer

Functions

func Install

func Install(eventBus *v1alpha1.EventBus, client client.Client, natsStreamingImage, natsMetricsImage string, logger *zap.SugaredLogger) error

Install function installs the event bus

func Uninstall

func Uninstall(eventBus *v1alpha1.EventBus, client client.Client, natsStreamingImage, natsMetricsImage string, logger *zap.SugaredLogger) error

Uninstall function uninstalls the extra resources who were not cleaned up when an eventbus was 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.

Types

type Installer

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

Installer is an interface for event bus installation

func NewExoticNATSInstaller

func NewExoticNATSInstaller(eventBus *v1alpha1.EventBus, logger *zap.SugaredLogger) Installer

NewExoticNATSInstaller return a new exoticNATSInstaller

func NewNATSInstaller

func NewNATSInstaller(client client.Client, eventBus *v1alpha1.EventBus, streamingImage, metricsImage string, labels map[string]string, logger *zap.SugaredLogger) Installer

NewNATSInstaller returns a new NATS installer