helmapp

Documentation

Index

• type App
  • func NewApp(ctx context.Context, kubeClient clientset.Interface, ...) (*App, error)
  • func (a *App) Chart() string
  • func (a *App) Detect() error
  • func (a *App) InstallOrUpdate() error
  • func (a *App) LoadChart() error
  • func (a *App) NeedDetect() bool
  • func (a *App) NeedSetup() bool
  • func (a *App) NeedUpdate() bool
  • func (a *App) PreInstall() error
  • func (a *App) Setup() error
  • func (a *App) Status() (*release.Release, error)
  • func (a *App) Uninstall() error
  • func (a *App) Update() error
  • func (a *App) UpdateRunningStatus()
  • func (a *App) UpdateSpec() error
  • func (a *App) UpdateStatus() error
• type ControlLoop
  • func NewControlLoop(ctx context.Context, kubeClient clientset.Interface, ...) *ControlLoop
  • func (c *ControlLoop) Reconcile(helmApp *v1alpha1.HelmApp) error
  • func (c *ControlLoop) Run()
  • func (c *ControlLoop) Stop()
• type Controller
  • func NewController(ctx context.Context, stopCh chan struct{}, kubeClient clientset.Interface, ...) *Controller
  • func (c *Controller) Start()
  • func (c *Controller) Stop()
• type Detector
  • func NewDetector(helmApp *v1alpha1.HelmApp, app *App, repo *helm.Repo) *Detector
  • func (d *Detector) Detect() error
• type Finalizer
  • func NewFinalizer(ctx context.Context, kubeClient clientset.Interface, ...) *Finalizer
  • func (c *Finalizer) Run()
  • func (c *Finalizer) Stop()
• type Status
  • func NewStatus(ctx context.Context, app *v1alpha1.HelmApp, katoClient versioned.Interface) *Status
  • func (s *Status) Update() error
• type Storer
  • func NewStorer(informer cache.SharedIndexInformer, lister v1alpha1.HelmAppLister, ...) Storer

Types

type App

type App struct {
	// contains filtered or unexported fields
}

App represents a helm app.

func NewApp

func NewApp(ctx context.Context, kubeClient clientset.Interface, katoClient versioned.Interface, helmApp *v1alpha1.HelmApp, repoFile, repoCache, chartCache string) (*App, error)

NewApp creates a new app.

func (*App) Chart

func (a *App) Chart() string

Chart returns the chart.

func (*App) Detect

func (a *App) Detect() error

Detect detect the helm app.

func (*App) InstallOrUpdate

func (a *App) InstallOrUpdate() error

InstallOrUpdate will install or update the helm app.

func (*App) LoadChart

func (a *App) LoadChart() error

LoadChart loads the chart from repository.

func (*App) NeedDetect

func (a *App) NeedDetect() bool

NeedDetect checks if necessary to detect the helm app.

func (*App) NeedSetup

func (a *App) NeedSetup() bool

NeedSetup checks if necessary to setup default values for the helm app.

func (*App) NeedUpdate

func (a *App) NeedUpdate() bool

NeedUpdate check if the helmApp needed to update.

func (*App) PreInstall

func (a *App) PreInstall() error

PreInstall will check if we can intall the helm app.

func (*App) Setup

func (a *App) Setup() error

Setup setups the default values of the helm app.

func (*App) Status

func (a *App) Status() (*release.Release, error)

Status returns the status.

func (*App) Uninstall

func (a *App) Uninstall() error

Uninstall uninstalls the helm app.

func (*App) Update

func (a *App) Update() error

Update updates the helm app.

func (*App) UpdateRunningStatus

func (a *App) UpdateRunningStatus()

UpdateRunningStatus updates the running status of the helm app.

func (*App) UpdateSpec

func (a *App) UpdateSpec() error

UpdateSpec updates the helm app spec.

func (*App) UpdateStatus

func (a *App) UpdateStatus() error

UpdateStatus updates the status of the helm app.

type ControlLoop

type ControlLoop struct {
	// contains filtered or unexported fields
}

ControlLoop is a control loop to get helm app and reconcile it.

func NewControlLoop

func NewControlLoop(ctx context.Context,
	kubeClient clientset.Interface,
	clientset versioned.Interface,
	storer Storer,
	workQueue workqueue.Interface,
	repoFile string,
	repoCache string,
	chartCache string,
) *ControlLoop

NewControlLoop -

func (*ControlLoop) Reconcile

func (c *ControlLoop) Reconcile(helmApp *v1alpha1.HelmApp) error

Reconcile -

func (*ControlLoop) Run

func (c *ControlLoop) Run()

Run runs the control loop.

func (*ControlLoop) Stop

func (c *ControlLoop) Stop()

Stop stops the control loop.

type Controller

type Controller struct {
	// contains filtered or unexported fields
}

Controller -

func NewController

func NewController(ctx context.Context,
	stopCh chan struct{},
	kubeClient clientset.Interface,
	clientset versioned.Interface,
	informer cache.SharedIndexInformer,
	lister v1alpha1.HelmAppLister,
	repoFile, repoCache, chartCache string) *Controller

NewController creates a new helm app controller.

func (*Controller) Start

func (c *Controller) Start()

Start starts the controller.

func (*Controller) Stop

func (c *Controller) Stop()

Stop stops the controller.

type Detector

type Detector struct {
	// contains filtered or unexported fields
}

Detector is responsible for detecting the helm app.

func NewDetector

func NewDetector(helmApp *v1alpha1.HelmApp, app *App, repo *helm.Repo) *Detector

NewDetector creates a new Detector.

func (*Detector) Detect

func (d *Detector) Detect() error

Detect detects the helm app.

type Finalizer

type Finalizer struct {
	// contains filtered or unexported fields
}

Finalizer does some cleanup work when helmApp is deleted

func NewFinalizer

func NewFinalizer(ctx context.Context,
	kubeClient clientset.Interface,
	clientset versioned.Interface,
	workQueue workqueue.Interface,
	repoFile string,
	repoCache string,
	chartCache string,
) *Finalizer

NewFinalizer creates a new finalizer.

func (*Finalizer) Run

func (c *Finalizer) Run()

Run runs the finalizer.

func (*Finalizer) Stop

func (c *Finalizer) Stop()

Stop stops the finalizer.

type Status

type Status struct {
	// contains filtered or unexported fields
}

Status represents the status of helm app.

func NewStatus

func NewStatus(ctx context.Context, app *v1alpha1.HelmApp, katoClient versioned.Interface) *Status

NewStatus creates a new helm app status.

func (*Status) Update

func (s *Status) Update() error

Update updates helm app status.

type Storer

type Storer interface {
	Run(stopCh <-chan struct{})
	GetHelmApp(ns, name string) (*katov1alpha1.HelmApp, error)
}

Storer -

func NewStorer

func NewStorer(informer cache.SharedIndexInformer,
	lister v1alpha1.HelmAppLister,
	workqueue workqueue.Interface,
	finalizerQueue workqueue.Interface) Storer

NewStorer creates a new storer.