kubernetes

package
v0.0.0-...-cc7cbc4 Latest Latest
Warning

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

Go to latest
Published: Dec 21, 2021 License: Apache-2.0 Imports: 19 Imported by: 0

Documentation

Index

Constants

View Source
const (
	ConfigLabel              = "serverless.kyma-project.io/config"
	RuntimeLabel             = "serverless.kyma-project.io/runtime"
	RbacLabel                = "serverless.kyma-project.io/rbac"
	RoleLabelValue           = "role"
	RoleBindingLabelValue    = "rolebinding"
	CredentialsLabelValue    = "credentials"
	ServiceAccountLabelValue = "service-account"
	RuntimeLabelValue        = "runtime"
)

Variables

This section is empty.

Functions

This section is empty.

Types

type Config

type Config struct {
	BaseNamespace                 string        `envconfig:"default=kyma-system"`
	ExcludedNamespaces            []string      `` /* 137-byte string literal not displayed */
	RoleRequeueDuration           time.Duration `envconfig:"default=1m"`
	RoleBindingRequeueDuration    time.Duration `envconfig:"default=1m"`
	ConfigMapRequeueDuration      time.Duration `envconfig:"default=1m"`
	SecretRequeueDuration         time.Duration `envconfig:"default=1m"`
	ServiceAccountRequeueDuration time.Duration `envconfig:"default=1m"`
}

type ConfigMapReconciler

type ConfigMapReconciler struct {
	Log logr.Logger
	// contains filtered or unexported fields
}

func NewConfigMap

func NewConfigMap(client client.Client, log logr.Logger, config Config, service ConfigMapService) *ConfigMapReconciler

func (*ConfigMapReconciler) Reconcile

func (r *ConfigMapReconciler) Reconcile(request ctrl.Request) (ctrl.Result, error)

func (*ConfigMapReconciler) SetupWithManager

func (r *ConfigMapReconciler) SetupWithManager(mgr ctrl.Manager) error

type ConfigMapService

type ConfigMapService interface {
	IsBase(configMap *corev1.ConfigMap) bool
	ListBase(ctx context.Context) ([]corev1.ConfigMap, error)
	UpdateNamespace(ctx context.Context, logger logr.Logger, namespace string, baseInstance *corev1.ConfigMap) error
}

func NewConfigMapService

func NewConfigMapService(client resource.Client, config Config) ConfigMapService

type NamespaceReconciler

type NamespaceReconciler struct {
	Log logr.Logger
	// contains filtered or unexported fields
}

func NewNamespace

func NewNamespace(client client.Client, log logr.Logger, config Config,
	configMapSvc ConfigMapService, secretSvc SecretService, serviceAccountSvc ServiceAccountService,
	roleService RoleService, roleBindingService RoleBindingService) *NamespaceReconciler

func (*NamespaceReconciler) Reconcile

func (r *NamespaceReconciler) Reconcile(request ctrl.Request) (ctrl.Result, error)

func (*NamespaceReconciler) SetupWithManager

func (r *NamespaceReconciler) SetupWithManager(mgr ctrl.Manager) error

type RemoteRegistryCfgUpdater

type RemoteRegistryCfgUpdater interface {
	Handle(context.Context, admission.Request) admission.Response
	InjectDecoder(*admission.Decoder) error
}

func NewRegistryWatcher

func NewRegistryWatcher(c client.Client) RemoteRegistryCfgUpdater

type RoleBindingReconciler

type RoleBindingReconciler struct {
	Log logr.Logger
	// contains filtered or unexported fields
}

func NewRoleBinding

func NewRoleBinding(client client.Client, log logr.Logger, config Config, service RoleBindingService) *RoleBindingReconciler

func (*RoleBindingReconciler) Reconcile

func (r *RoleBindingReconciler) Reconcile(request ctrl.Request) (ctrl.Result, error)

func (*RoleBindingReconciler) SetupWithManager

func (r *RoleBindingReconciler) SetupWithManager(mgr ctrl.Manager) error

type RoleBindingService

type RoleBindingService interface {
	IsBase(role *rbacv1.RoleBinding) bool
	ListBase(ctx context.Context) ([]rbacv1.RoleBinding, error)
	UpdateNamespace(ctx context.Context, logger logr.Logger, namespace string, baseInstance *rbacv1.RoleBinding) error
}

func NewRoleBindingService

func NewRoleBindingService(client resource.Client, config Config) RoleBindingService

type RoleReconciler

type RoleReconciler struct {
	Log logr.Logger
	// contains filtered or unexported fields
}

func NewRole

func NewRole(client client.Client, log logr.Logger, config Config, service RoleService) *RoleReconciler

func (*RoleReconciler) Reconcile

func (r *RoleReconciler) Reconcile(request ctrl.Request) (ctrl.Result, error)

func (*RoleReconciler) SetupWithManager

func (r *RoleReconciler) SetupWithManager(mgr ctrl.Manager) error

type RoleService

type RoleService interface {
	IsBase(role *rbacv1.Role) bool
	ListBase(ctx context.Context) ([]rbacv1.Role, error)
	UpdateNamespace(ctx context.Context, logger logr.Logger, namespace string, baseInstance *rbacv1.Role) error
}

func NewRoleService

func NewRoleService(client resource.Client, config Config) RoleService

type SecretReconciler

type SecretReconciler struct {
	Log logr.Logger
	// contains filtered or unexported fields
}

func NewSecret

func NewSecret(client client.Client, log logr.Logger, config Config, secretSvc SecretService) *SecretReconciler

func (*SecretReconciler) Reconcile

func (r *SecretReconciler) Reconcile(request ctrl.Request) (ctrl.Result, error)

func (*SecretReconciler) SetupWithManager

func (r *SecretReconciler) SetupWithManager(mgr ctrl.Manager) error

type SecretService

type SecretService interface {
	IsBase(secret *corev1.Secret) bool
	ListBase(ctx context.Context) ([]corev1.Secret, error)
	UpdateNamespace(ctx context.Context, logger logr.Logger, namespace string, baseInstance *corev1.Secret) error
	HandleFinalizer(ctx context.Context, logger logr.Logger, secret *corev1.Secret, namespaces []string) error
}

func NewSecretService

func NewSecretService(client resource.Client, config Config) SecretService

type ServiceAccountReconciler

type ServiceAccountReconciler struct {
	Log logr.Logger
	// contains filtered or unexported fields
}

func NewServiceAccount

func NewServiceAccount(client client.Client, log logr.Logger, config Config, serviceAccountSvc ServiceAccountService) *ServiceAccountReconciler

func (*ServiceAccountReconciler) Reconcile

func (r *ServiceAccountReconciler) Reconcile(request ctrl.Request) (ctrl.Result, error)

func (*ServiceAccountReconciler) SetupWithManager

func (r *ServiceAccountReconciler) SetupWithManager(mgr ctrl.Manager) error

type ServiceAccountService

type ServiceAccountService interface {
	IsBase(serviceAccount *corev1.ServiceAccount) bool
	ListBase(ctx context.Context) ([]corev1.ServiceAccount, error)
	UpdateNamespace(ctx context.Context, logger logr.Logger, namespace string, baseInstance *corev1.ServiceAccount) error
}

func NewServiceAccountService

func NewServiceAccountService(client resource.Client, config Config) ServiceAccountService

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL