envfuncsext

package
v1.8.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 5, 2024 License: Apache-2.0 Imports: 34 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CreateObject 

func CreateObject(obj k8s.Object) env.Func

func DefaultNebulaClusterReadyFunc 

func DefaultNebulaClusterReadyFunc(ctx context.Context, cfg *envconf.Config, nc *appsv1alpha1.NebulaCluster) (bool, error)

func DeleteObject 

func DeleteObject(obj k8s.Object) env.Func

func HelmInstall 

func HelmInstall(opts ...HelmOption) env.Func

func HelmUninstall 

func HelmUninstall(opts ...HelmOption) env.Func

func HelmUpgrade 

func HelmUpgrade(opts ...HelmOption) env.Func

func IgnoreAlreadyExists 

func IgnoreAlreadyExists(ctx context.Context, err error) env.Func

func IgnoreErrors 

func IgnoreErrors(ctx context.Context, err error, isErrors ...func(error) bool) env.Func

func IgnoreNotFound 

func IgnoreNotFound(ctx context.Context, err error) env.Func

func ImportData 

func ImportData(opts ...ImporterOption) env.Func

func ImportLDBC 

func ImportLDBC(opts ...ImporterOption) env.Func

func InstallCluster 

func InstallCluster(opts ...ClusterOption) env.Func

func InstallNebulaCluster 

func InstallNebulaCluster(opts ...NebulaClusterOption) env.Func

func InstallOperator 

func InstallOperator(opts ...OperatorOption) env.Func

func UninstallCluster 

func UninstallCluster(opts ...ClusterOption) env.Func

func UninstallNebulaCluster 

func UninstallNebulaCluster(opts ...NebulaClusterOption) env.Func

func UninstallOperator 

func UninstallOperator(opts ...OperatorOption) env.Func

func UpgradeNebulaCluster 

func UpgradeNebulaCluster(opts ...NebulaClusterOption) env.Func

func WaitNebulaClusterReady 

func WaitNebulaClusterReady(opts ...NebulaClusterOption) env.Func

Types

type ClusterCtxValue 

type ClusterCtxValue struct {
	Name string
}

func GetClusterCtxValue 

func GetClusterCtxValue(ctx context.Context) *ClusterCtxValue

type ClusterOption 

type ClusterOption func(*ClusterOptions)

func WithClusterKindConfigPath 

func WithClusterKindConfigPath(kindConfigPath string) ClusterOption

func WithClusterNamePrefix 

func WithClusterNamePrefix(namePrefix string) ClusterOption

type ClusterOptions 

type ClusterOptions struct {
	Name           string
	NamePrefix     string
	KindConfigPath string
}

func (*ClusterOptions) WithOptions 

func (o *ClusterOptions) WithOptions(opts ...ClusterOption) *ClusterOptions

type HelmOption 

type HelmOption func(*HelmOptions)

func WithHelmOptions 

func WithHelmOptions(opts ...helm.Option) HelmOption

type HelmOptions 

type HelmOptions struct {
	HelmOptions []helm.Option
}

func (*HelmOptions) RawHelmOpts 

func (o *HelmOptions) RawHelmOpts() *helm.Opts

func (*HelmOptions) WithOptions 

func (o *HelmOptions) WithOptions(opts ...HelmOption) *HelmOptions

type ImporterOption 

type ImporterOption func(*ImporterOptions)

func WithImporterClientAddress 

func WithImporterClientAddress(address string) ImporterOption

func WithImporterClientUserPassword 

func WithImporterClientUserPassword(user, password string) ImporterOption

func WithImporterConfig 

func WithImporterConfig(importerConfig importerconfig.Configurator) ImporterOption

func WithImporterConfigUpdate 

func WithImporterConfigUpdate(fns ...func(importerconfig.Configurator)) ImporterOption

func WithImporterInitContainers 

func WithImporterInitContainers(initContainers ...corev1.Container) ImporterOption

func WithImporterName 

func WithImporterName(name string) ImporterOption

func WithImporterNamespace 

func WithImporterNamespace(namespace string) ImporterOption

func WithImporterWaitOptions 

func WithImporterWaitOptions(opts ...wait.Option) ImporterOption

type ImporterOptions 

type ImporterOptions struct {
	Name              string
	Namespace         string
	Image             string
	Config            importerconfig.Configurator
	ConfigUpdateFuncs []func(importerconfig.Configurator)
	DataDir           string
	InitContainers    []corev1.Container
	WaitOptions       []wait.Option
}

func DefaultImporterOptions 

func DefaultImporterOptions() *ImporterOptions

func (*ImporterOptions) WithOptions 

func (o *ImporterOptions) WithOptions(opts ...ImporterOption) *ImporterOptions

type NebulaClusterCtxValue 

type NebulaClusterCtxValue struct {
	Name      string
	Namespace string
}

func GetNebulaClusterCtxValue 

func GetNebulaClusterCtxValue(ctx context.Context) *NebulaClusterCtxValue

type NebulaClusterOption 

type NebulaClusterOption func(*NebulaClusterOptions)

func WithNebulaClusterHelmOptions 

func WithNebulaClusterHelmOptions(opts ...HelmOption) NebulaClusterOption

func WithNebulaClusterHelmRawOptions 

func WithNebulaClusterHelmRawOptions(opts ...helm.Option) NebulaClusterOption

func WithNebulaClusterReadyFuncs 

func WithNebulaClusterReadyFuncs(fns ...NebulaClusterReadyFunc) NebulaClusterOption

func WithNebulaClusterWaitOptions 

func WithNebulaClusterWaitOptions(opts ...wait.Option) NebulaClusterOption

type NebulaClusterOptions 

type NebulaClusterOptions struct {
	HelmOptions []HelmOption
	ReadyFuncs  []NebulaClusterReadyFunc
	WaitOptions []wait.Option
}

func (*NebulaClusterOptions) WithOptions 

func (o *NebulaClusterOptions) WithOptions(opts ...NebulaClusterOption) *NebulaClusterOptions

type NebulaClusterReadyFunc 

type NebulaClusterReadyFunc func(context.Context, *envconf.Config, *appsv1alpha1.NebulaCluster) (bool, error)

func NebulaClusterReadyFuncForFields 

func NebulaClusterReadyFuncForFields(ignoreValidationErrors bool, matchersMapping map[string]any) NebulaClusterReadyFunc

type ObjectOption 

type ObjectOption func(*ObjectOptions)

func WithObjectCreateOptions 

func WithObjectCreateOptions(opts ...resources.CreateOption) ObjectOption

func WithObjectDeleteOptions 

func WithObjectDeleteOptions(opts ...resources.DeleteOption) ObjectOption

type ObjectOptions 

type ObjectOptions struct {
	CreateOptions []resources.CreateOption
	DeleteOptions []resources.DeleteOption
}

func (*ObjectOptions) WithOptions 

func (o *ObjectOptions) WithOptions(opts ...ObjectOption) *ObjectOptions

type OperatorCtxValue 

type OperatorCtxValue struct {
	Name      string
	Namespace string
}

func GetOperatorCtxValue 

func GetOperatorCtxValue(ctx context.Context) *OperatorCtxValue

type OperatorOption 

type OperatorOption func(*OperatorOptions)

func WithOperatorHelmOptions 

func WithOperatorHelmOptions(opts ...HelmOption) OperatorOption

func WithOperatorHelmRawOptions 

func WithOperatorHelmRawOptions(opts ...helm.Option) OperatorOption

type OperatorOptions 

type OperatorOptions struct {
	HelmOptions []HelmOption
}

func (*OperatorOptions) WithOptions 

func (o *OperatorOptions) WithOptions(opts ...OperatorOption) *OperatorOptions

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.