helmworkload

Documentation

Index

• Constants
• func HelmWorkloadDefinitionReconciler(r *controller.Reconciler)
• func HelmWorkloadInstanceReconciler(r *controller.Reconciler)
• func MergeHelmValuesGo(base, override string) (map[string]interface{}, error)
• func MergeHelmValuesPtrs(base, override *string) (string, error)
• func MergeHelmValuesString(base, override string) (string, error)
• func UnmarshalHelmValues(helmValues string) (map[string]interface{}, error)
• type CustomRESTClientGetter
  • func (c *CustomRESTClientGetter) ToDiscoveryClient() (discovery.CachedDiscoveryInterface, error)
  • func (c *CustomRESTClientGetter) ToRESTConfig() (*rest.Config, error)
  • func (c *CustomRESTClientGetter) ToRESTMapper() (meta.RESTMapper, error)
  • func (c *CustomRESTClientGetter) ToRawKubeConfigLoader() clientcmd.ClientConfig
• type Locater
• type ThreeportPostRenderer
  • func (p *ThreeportPostRenderer) AppendAdditionalResources(manifests string, additionalResources *datatypes.JSONSlice[datatypes.JSON]) (string, error)
  • func (p *ThreeportPostRenderer) Run(renderedManifests *bytes.Buffer) (*bytes.Buffer, error)

Constants

const (
	TempValuesFilePath   = "/tmp/values.yaml"
	TempOverriedFilePath = "/tmp/override-values.yaml"
)

const (
	LockBucketName  = "helmWorkloadLock"
	LockBucketDescr = "contains locks on helm workload objects"
)

The name and description of the NATS bucket used for helm workload object locks

const (
	HelmRepoConfigFile = "/root/repository.yaml"
	HelmValuesDir      = "/tmp/helm"
)

Functions

func HelmWorkloadDefinitionReconciler

func HelmWorkloadDefinitionReconciler(r *controller.Reconciler)

HelmWorkloadDefinitionReconciler reconciles system state when a HelmWorkloadDefinition is created, updated or deleted.

func HelmWorkloadInstanceReconciler

func HelmWorkloadInstanceReconciler(r *controller.Reconciler)

HelmWorkloadInstanceReconciler reconciles system state when a HelmWorkloadInstance is created, updated or deleted.

func MergeHelmValuesGo

func MergeHelmValuesGo(base, override string) (map[string]interface{}, error)

MergeHelmValuesGo merges two helm values documents and returns the result as a map[string]interface{}.

func MergeHelmValuesPtrs

func MergeHelmValuesPtrs(base, override *string) (string, error)

MergeHelmValuesPtrs merges two helm values documents that are referred to by string pointers.

func MergeHelmValuesString

func MergeHelmValuesString(base, override string) (string, error)

MergeHelmValuesString merges two helm values documents and returns the result as a string.

func UnmarshalHelmValues

func UnmarshalHelmValues(helmValues string) (map[string]interface{}, error)

UnmarshalHelmValues unmarshals a helm values document.

Types

type CustomRESTClientGetter

type CustomRESTClientGetter struct {
	KubernetesRuntimeInstance *v0.KubernetesRuntimeInstance
	ApiClient                 *http.Client
	ApiServer                 string
	EncryptionKey             string
}

CustomRESTClientGetter implements the genericclioptions.RESTClientGetter interface.

func (*CustomRESTClientGetter) ToDiscoveryClient

func (c *CustomRESTClientGetter) ToDiscoveryClient() (discovery.CachedDiscoveryInterface, error)

ToDiscoveryClient returns a cached discover interface for a Kubernetes runtime.

func (*CustomRESTClientGetter) ToRESTConfig

func (c *CustomRESTClientGetter) ToRESTConfig() (*rest.Config, error)

ToRESTConfig returns a REST config for a Kubernetes runtime.

func (*CustomRESTClientGetter) ToRESTMapper

func (c *CustomRESTClientGetter) ToRESTMapper() (meta.RESTMapper, error)

ToRESTMapper returns a REST mapper for a Kubernetes runtime.

func (*CustomRESTClientGetter) ToRawKubeConfigLoader

func (c *CustomRESTClientGetter) ToRawKubeConfigLoader() clientcmd.ClientConfig

ToRawKubeConfigLoader returns a raw default client config for a Kubernetes runtime.

type Locater

type Locater interface {
	LocateChart(name string, settings *cli.EnvSettings) (string, error)
}

Locater is an interface for locating helm charts.

type ThreeportPostRenderer

type ThreeportPostRenderer struct {
	HelmWorkloadDefinition *v0.HelmWorkloadDefinition
	HelmWorkloadInstance   *v0.HelmWorkloadInstance
}

ThreeportPostRenderer implements the postrender.PostRenderer interface for Threeport purposes.

func (*ThreeportPostRenderer) AppendAdditionalResources

func (p *ThreeportPostRenderer) AppendAdditionalResources(
	manifests string,
	additionalResources *datatypes.JSONSlice[datatypes.JSON],
) (string, error)

AppendAdditionalResources appends additional resources to the given manifests.

func (*ThreeportPostRenderer) Run

func (p *ThreeportPostRenderer) Run(renderedManifests *bytes.Buffer) (*bytes.Buffer, error)

Run modifies the redndered manifests to add threeport labels that allow the threeport agent to monitor the workload.