chart

Documentation

Index

• func AdjustDockerRegToClusterPVCSize(ctx context.Context, c client.Client, obj unstructured.Unstructured) (unstructured.Unstructured, error)
• func AppendContainersFlags(flags map[string]interface{}, ...) map[string]interface{}
• func AppendDefaultPresetFlags(flags map[string]interface{}, ...) map[string]interface{}
• func AppendExistingInternalRegistryCredentialsFlags(flags map[string]interface{}, username, password, registryHttpSecret string) map[string]interface{}
• func AppendExternalRegistryFlags(flags map[string]interface{}, enableInternal bool, ...) map[string]interface{}
• func AppendInternalRegistryFlags(flags map[string]interface{}, enableInternal bool) map[string]interface{}
• func AppendK3dRegistryFlags(flags map[string]interface{}, enableInternal bool, ...) map[string]interface{}
• func AppendNodePortFlag(flags map[string]interface{}, nodePort int64) map[string]interface{}
• func CheckCRDOrphanResources(config *Config) error
• func EmptyFlags() map[string]interface{}
• func Install(config *Config) error
• func IsPVC(objKind schema.GroupVersionKind) bool
• func NewInMemoryManifestCache() *inMemoryManifestCache
• func NewSecretManifestCache(client client.Client) *secretManifestCache
• func Uninstall(config *Config, filterFunc ...FilterFunc) error
• func Verify(config *Config) (bool, error)
• func WithoutCRDFilter(u unstructured.Unstructured) bool
• type Cluster
• type Config
• type FilterFunc
• type ManifestCache
• type Release
• type ServerlessSpecManifest

Functions

func AdjustDockerRegToClusterPVCSize

func AdjustDockerRegToClusterPVCSize(ctx context.Context, c client.Client, obj unstructured.Unstructured) (unstructured.Unstructured, error)

func AppendContainersFlags

func AppendContainersFlags(flags map[string]interface{}, publisherURL, traceCollectorURL, CPUUtilizationPercentage, requeueDuration, buildExecutorArgs, maxSimultaneousJobs, healthzLivenessTimeout, requestBodyLimitMb, timeoutSec string) map[string]interface{}

func AppendDefaultPresetFlags

func AppendDefaultPresetFlags(flags map[string]interface{}, defaultBuildJobPreset, defaultRuntimePodPreset string) map[string]interface{}

func AppendExistingInternalRegistryCredentialsFlags

func AppendExistingInternalRegistryCredentialsFlags(flags map[string]interface{}, username, password, registryHttpSecret string) map[string]interface{}

func AppendExternalRegistryFlags

func AppendExternalRegistryFlags(flags map[string]interface{}, enableInternal bool, username, password, registryAddress, serverAddress string) map[string]interface{}

func AppendInternalRegistryFlags

func AppendInternalRegistryFlags(flags map[string]interface{}, enableInternal bool) map[string]interface{}

func AppendK3dRegistryFlags

func AppendK3dRegistryFlags(flags map[string]interface{}, enableInternal bool, registryAddress, serverAddress string) map[string]interface{}

func AppendNodePortFlag

func AppendNodePortFlag(flags map[string]interface{}, nodePort int64) map[string]interface{}

AppendNodePortFlag nodePort must be int64, because when we compare old Flags with new flags, by default all integers are int64

func CheckCRDOrphanResources

func CheckCRDOrphanResources(config *Config) error

func EmptyFlags

func EmptyFlags() map[string]interface{}

func Install

func Install(config *Config) error

func IsPVC

func IsPVC(objKind schema.GroupVersionKind) bool

func NewInMemoryManifestCache

func NewInMemoryManifestCache() *inMemoryManifestCache

NewInMemoryManifestCache returns a new instance of inMemoryManifestCache.

func NewSecretManifestCache

func NewSecretManifestCache(client client.Client) *secretManifestCache

NewSecretManifestCache - returns a new instance of SecretManifestCache.

func Uninstall

func Uninstall(config *Config, filterFunc ...FilterFunc) error

func Verify

func Verify(config *Config) (bool, error)

func WithoutCRDFilter

func WithoutCRDFilter(u unstructured.Unstructured) bool

Types

type Cluster

type Cluster struct {
	Client client.Client
	Config *rest.Config
}

type Config

type Config struct {
	Ctx        context.Context
	Log        *zap.SugaredLogger
	Cache      ManifestCache
	CacheKey   types.NamespacedName
	ManagerUID string
	Cluster    Cluster
	Release    Release
}

type FilterFunc

type FilterFunc func(unstructured.Unstructured) bool

type ManifestCache

type ManifestCache interface {
	Set(context.Context, client.ObjectKey, ServerlessSpecManifest) error
	Get(context.Context, client.ObjectKey) (ServerlessSpecManifest, error)
	Delete(context.Context, client.ObjectKey) error
}

type Release

type Release struct {
	Flags     map[string]interface{}
	ChartPath string
	Name      string
	Namespace string
}

type ServerlessSpecManifest

type ServerlessSpecManifest struct {
	ManagerUID  string
	CustomFlags map[string]interface{}
	Manifest    string
}