controller

package
v1.5.0 Latest Latest
Warning

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

 Go to latest Published: Jul 6, 2023 License: Apache-2.0 Imports: 45 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ImmutableAnnotation = "goharbor.io/immutable"
	WarningAnnotation   = "goharbor.io/warning"
	WarningValueTmpl    = "⚠️ This Resource is managed by *%s* ⚠️"
)
View Source 
const (
	OperatorNameLabel    = "goharbor.io/operator-controller"
	OperatorVersionLabel = "goharbor.io/operator-version"
)
View Source 
const DefaultClassName = ""

Variables

View Source 
var ErrorOwnerNotFound = errors.New("owner not found")

Functions

func IsOptimisticLockError 

func IsOptimisticLockError(err error) bool

Types

type Controller 

type Controller struct {
	client.Client

	BaseController controllers.Controller
	Version        string
	GitCommit      string

	ConfigStore *configstore.Store

	Log             logr.Logger
	Scheme          *runtime.Scheme
	DiscoveryClient *discovery.DiscoveryClient
	// contains filtered or unexported fields
}

func NewController 

func NewController(ctx context.Context, base controllers.Controller, rm ResourceManager, config *configstore.Store) *Controller

func (*Controller) AddBasicResource 

func (c *Controller) AddBasicResource(ctx context.Context, resource resources.Resource, dependencies ...graph.Resource) (*Resource, error)

func (*Controller) AddCertificateToManage 

func (c *Controller) AddCertificateToManage(ctx context.Context, resource *certv1.Certificate, dependencies ...graph.Resource) (graph.Resource, error)

func (*Controller) AddConfigMapToManage 

func (c *Controller) AddConfigMapToManage(ctx context.Context, resource *corev1.ConfigMap, dependencies ...graph.Resource) (graph.Resource, error)

func (*Controller) AddDeploymentToManage 

func (c *Controller) AddDeploymentToManage(ctx context.Context, resource *appsv1.Deployment, dependencies ...graph.Resource) (graph.Resource, error)

func (*Controller) AddExternalConfigMap 

func (c *Controller) AddExternalConfigMap(ctx context.Context, configMap *corev1.ConfigMap, dependencies ...graph.Resource) (graph.Resource, error)

func (*Controller) AddExternalResource 

func (c *Controller) AddExternalResource(ctx context.Context, resource resources.Resource, dependencies ...graph.Resource) (graph.Resource, error)

func (*Controller) AddExternalTypedSecret 

func (c *Controller) AddExternalTypedSecret(ctx context.Context, secret *corev1.Secret, secretType corev1.SecretType, dependencies ...graph.Resource) (graph.Resource, error)

func (*Controller) AddGVKToSpan 

func (c *Controller) AddGVKToSpan(ctx context.Context, span opentracing.Span, resource runtime.Object) (gvk schema.GroupVersionKind)

func (*Controller) AddIngressToManage 

func (c *Controller) AddIngressToManage(ctx context.Context, resource *netv1.Ingress, dependencies ...graph.Resource) (graph.Resource, error)

func (*Controller) AddIssuerToManage 

func (c *Controller) AddIssuerToManage(ctx context.Context, resource *certv1.Issuer, dependencies ...graph.Resource) (graph.Resource, error)

func (*Controller) AddNetworkPolicyToManage 

func (c *Controller) AddNetworkPolicyToManage(ctx context.Context, resource *netv1.NetworkPolicy, dependencies ...graph.Resource) (graph.Resource, error)

func (*Controller) AddNonCheckableResource 

func (c *Controller) AddNonCheckableResource(ctx context.Context, resource resources.Resource, dependencies ...graph.Resource) (*Resource, error)

func (*Controller) AddSecretToManage 

func (c *Controller) AddSecretToManage(ctx context.Context, resource *corev1.Secret, dependencies ...graph.Resource) (graph.Resource, error)

func (*Controller) AddServiceToManage 

func (c *Controller) AddServiceToManage(ctx context.Context, resource *corev1.Service, dependencies ...graph.Resource) (graph.Resource, error)

func (*Controller) AddUnsctructuredToManage 

func (c *Controller) AddUnsctructuredToManage(ctx context.Context, resource *unstructured.Unstructured, dependencies ...graph.Resource) (graph.Resource, error)

func (*Controller) Apply 

func (c *Controller) Apply(ctx context.Context, res *Resource) error

func (*Controller) AreNetworkPoliciesEnabled 

func (c *Controller) AreNetworkPoliciesEnabled(ctx context.Context, resource resources.Resource) (bool, error)

func (*Controller) BoolConfig 

func (c *Controller) BoolConfig(ctx context.Context, key string, defaultValue bool) (bool, error)

func (*Controller) Changed 

func (c *Controller) Changed(ctx context.Context, depManager *checksum.Dependencies, resource resources.Resource) (bool, error)

func (*Controller) DeploymentMutateFn 

func (c *Controller) DeploymentMutateFn(ctx context.Context, dependencies ...graph.Resource) (resources.Mutable, error)

func (*Controller) EnsureReady 

func (c *Controller) EnsureReady(ctx context.Context, node graph.Resource) error

func (*Controller) EnsureSecretType 

func (c *Controller) EnsureSecretType(ctx context.Context, node graph.Resource) error

func (*Controller) Funcs 

func (c *Controller) Funcs(ctx context.Context, owner resources.Resource) template.FuncMap

func (*Controller) GetAndFilter 

func (c *Controller) GetAndFilter(ctx context.Context, key client.ObjectKey, obj client.Object) (bool, error)

func (*Controller) GetClassName 

func (c *Controller) GetClassName(ctx context.Context) (string, error)

func (*Controller) GetFQDN 

func (c *Controller) GetFQDN() string

func (*Controller) GetGitCommit 

func (c *Controller) GetGitCommit() string

func (*Controller) GetName 

func (c *Controller) GetName() string

func (*Controller) GetTemplatedConfig 

func (c *Controller) GetTemplatedConfig(ctx context.Context, templateConfig string, owner resources.Resource) ([]byte, error)

func (*Controller) GetVersion 

func (c *Controller) GetVersion() string

func (*Controller) GlobalMutateFn 

func (c *Controller) GlobalMutateFn(ctx context.Context) (resources.Mutable, error)

func (*Controller) HandleError 

func (c *Controller) HandleError(ctx context.Context, resource client.Object, resultError error) (ctrl.Result, error)

func (*Controller) IntConfig 

func (c *Controller) IntConfig(ctx context.Context, key string, defaultValue int) (int, error)

func (*Controller) Label 

func (c *Controller) Label(suffix ...string) string

func (*Controller) LabelWithPrefix 

func (c *Controller) LabelWithPrefix(prefix string, suffix ...string) string

func (*Controller) Mark 

func (c *Controller) Mark(ctx context.Context, owner client.Object) error

func (*Controller) NormalizeName 

func (c *Controller) NormalizeName(ctx context.Context, name string, suffixes ...string) string

func (*Controller) PopulateContext 

func (c *Controller) PopulateContext(ctx context.Context, req ctrl.Request) context.Context

func (*Controller) PrepareStatus 

func (c *Controller) PrepareStatus(ctx context.Context, owner resources.Resource) error

func (*Controller) ProcessFunc 

func (c *Controller) ProcessFunc(ctx context.Context, resource runtime.Object, dependencies ...graph.Resource) func(context.Context, graph.Resource) error

func (*Controller) Reconcile 

func (c *Controller) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*Controller) Run 

func (c *Controller) Run(ctx context.Context, owner resources.Resource) error

func (*Controller) SecretMutateFn 

func (c *Controller) SecretMutateFn(ctx context.Context, immutable *bool) (resources.Mutable, error)

func (*Controller) SetControllerStatus 

func (c *Controller) SetControllerStatus(ctx context.Context, data map[string]interface{}) error

func (*Controller) SetErrorConditions 

func (c *Controller) SetErrorConditions(ctx context.Context, data map[string]interface{}, resultError error) error

func (*Controller) SetErrorStatus 

func (c *Controller) SetErrorStatus(ctx context.Context, resource runtime.Object, resultError error) error

func (*Controller) SetSuccessConditions 

func (c *Controller) SetSuccessConditions(ctx context.Context, data map[string]interface{}) error

func (*Controller) SetSuccessStatus 

func (c *Controller) SetSuccessStatus(ctx context.Context, resource runtime.Object) error

func (*Controller) SetupWithManager 

func (c *Controller) SetupWithManager(ctx context.Context, mgr ctrl.Manager) error

func (*Controller) StringConfig 

func (c *Controller) StringConfig(ctx context.Context, key string, defaultValue string) (string, error)

func (*Controller) Sweep 

func (c *Controller) Sweep(ctx context.Context, resource graph.Resource) error

type Reconciler 

type Reconciler interface {
	reconcile.Reconciler

	NormalizeName(context.Context, string, ...string) string
	SetupWithManager(context.Context, manager.Manager) error
}

type Resource 

type Resource struct {
	// contains filtered or unexported fields
}

func (*Resource) GetResource 

func (res *Resource) GetResource() resources.Resource

type ResourceManager 

type ResourceManager interface {
	AddResources(context.Context, resources.Resource) error
	NewEmpty(context.Context) resources.Resource
}

Source Files

View all Source files

Directories

Path Synopsis
internal
graph

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.