initfx

package
v3.29.0 Latest Latest
Warning

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

 Go to latest Published: Sep 3, 2026 License: AGPL-3.0 Imports: 49 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var GetArgs = getArgs
View Source 
var GetWebhookServer = getWebhookServer
View Source 
var NewAuthRegistrationClientSet = newAuthRegistrationClientSet
View Source 
var NewCommandExecutor = exec.NewCommandExecutor
View Source 
var NewDoguClientset = newDoguClientset
View Source 
var NewExpositionClientSet = newExpositionClientSet
View Source 
var NewImageRegistry = imageregistry.NewCraneContainerImageRegistry
View Source 
var NewKubernetesClientSet = newKubernetesClientSet
View Source 
var NewOperatorConfig = config.NewOperatorConfig
View Source 
var NewRemoteDoguDescriptorRepository = newRemoteDoguDescriptorRepository
View Source 
var NewWarpMenuEntryClientSet = newWarpMenuEntryClientSet

Functions

func GetAdditionalImages 

func GetAdditionalImages(configMapClient corev1.ConfigMapInterface) (resource.AdditionalImages, error)

func NewAuthRegistrationInterface added in v3.22.0 

func NewAuthRegistrationInterface(authRegistrationClientSet authRegClientV1.ApiV1Interface, operatorConfig *config.OperatorConfig) authRegClientV1.AuthRegistrationInterface

func NewConfigMapInterface 

func NewConfigMapInterface(clientSet kubernetes.Interface, operatorConfig *config.OperatorConfig) v1.ConfigMapInterface

func NewControllerManager 

func NewControllerManager(
	lc fx.Lifecycle,
	logger logr.Logger,
	options manager.Options,
	restConfig *rest.Config,
	handler health.HealthShutdownHandler,
) (manager.Manager, error)

func NewDeploymentInterface 

func NewDeploymentInterface(clientSet kubernetes.Interface, operatorConfig *config.OperatorConfig) appsv1.DeploymentInterface

func NewDoguInterface 

func NewDoguInterface(doguClientset doguClient.Interface, config *config.OperatorConfig) doguv2.DoguInterface

func NewDoguRestartInterface 

func NewDoguRestartInterface(doguClientset doguClient.Interface, config *config.OperatorConfig) doguv2.DoguRestartInterface

func NewDoguVersionRegistry 

func NewDoguVersionRegistry(cmInterface v1.ConfigMapInterface) dogu.VersionRegistry

func NewEventRecorder 

func NewEventRecorder(mgr manager.Manager) record.EventRecorder

func NewExpositionInterface added in v3.24.0 

func NewExpositionInterface(expositionClientSet expClientV1.ApiV1Interface, operatorConfig *config.OperatorConfig) expClientV1.ExpositionInterface

func NewHostAliasGenerator 

func NewHostAliasGenerator(repository resource.GlobalConfigRepository) resource.HostAliasGenerator

func NewK8sClient 

func NewK8sClient(mgr manager.Manager) client.Client

func NewLocalDoguFetcher 

func NewLocalDoguFetcher(registry dogu.VersionRegistry, repository dogu.LocalDoguDescriptorRepository) cesregistry.LocalDoguFetcher

func NewManagerOptions 

func NewManagerOptions(args Args, operatorConfig *config.OperatorConfig, webhookServer webhook.Server) (manager.Options, error)

func NewPersistentVolumeClaimInterface 

func NewPersistentVolumeClaimInterface(clientSet kubernetes.Interface, operatorConfig *config.OperatorConfig) v1.PersistentVolumeClaimInterface

func NewPodInterface 

func NewPodInterface(clientSet kubernetes.Interface, operatorConfig *config.OperatorConfig) v1.PodInterface

func NewResourceDoguFetcher 

func NewResourceDoguFetcher(client client.Client, repo dogu.RemoteDoguDescriptorRepository) cesregistry.ResourceDoguFetcher

func NewRestClient 

func NewRestClient(clientSet kubernetes.Interface) rest.Interface

func NewScheme 

func NewScheme(mgr manager.Manager) *runtime.Scheme

func NewSecretInterface 

func NewSecretInterface(clientSet kubernetes.Interface, operatorConfig *config.OperatorConfig) v1.SecretInterface

func NewServiceInterface 

func NewServiceInterface(clientSet kubernetes.Interface, operatorConfig *config.OperatorConfig) v1.ServiceInterface

func NewWarpMenuEntryInterface added in v3.27.0 

func NewWarpMenuEntryInterface(warpMenuEntryClientSet warpClientV1.ApiV1Interface, operatorConfig *config.OperatorConfig) warpClientV1.WarpMenuEntryInterface

Types

type Args 

type Args []string

type CollectApplier 

type CollectApplier interface {
	CollectApply(ctx context.Context, customK8sResources map[string]string, doguResource *doguv2.Dogu) error
}

func NewCollectApplier 

func NewCollectApplier(restConfig *rest.Config) (CollectApplier, error)

type DoguConfigRepository 

type DoguConfigRepository interface {
	Get(ctx context.Context, name cescommons.SimpleName) (config.DoguConfig, error)
	Create(ctx context.Context, doguConfig config.DoguConfig) (config.DoguConfig, error)
	Update(ctx context.Context, doguConfig config.DoguConfig) (config.DoguConfig, error)
	SaveOrMerge(ctx context.Context, doguConfig config.DoguConfig) (config.DoguConfig, error)
	Delete(ctx context.Context, name cescommons.SimpleName) error
	Watch(ctx context.Context, dName cescommons.SimpleName, filters ...config.WatchFilter) (<-chan repository.DoguConfigWatchResult, error)
	SetOwnerReference(ctx context.Context, dName cescommons.SimpleName, owners []metav1.OwnerReference) error
}

type LocalDoguDescriptorRepository 

type LocalDoguDescriptorRepository interface {
	dogu.LocalDoguDescriptorRepository
	OwnerReferenceSetter
}

func NewLocalDoguDescriptorRepository 

func NewLocalDoguDescriptorRepository(cmInterface v1.ConfigMapInterface) LocalDoguDescriptorRepository

type OwnerReferenceSetter 

type OwnerReferenceSetter interface {
	SetOwnerReference(ctx context.Context, dName cescommons.SimpleName, owners []metav1.OwnerReference) error
}

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.