Documentation
¶
Index ¶
- func Add(log logr.Logger, mgr manager.Manager, ...) (err error)
- func ForeachNamespace(ctx context.Context, controllerClient client.Client, ...) (err error)
- func GatherAdditionalMetadata(spec capsulev1beta2.ResourceSpec, fastContext map[string]string) (labels map[string]string, annotations map[string]string)
- type Collector
- func (co *Collector) AddToAccumulation(tnt *capsulev1beta2.Tenant, ns *corev1.Namespace, opts CollectorOptions, ...) (err error)
- func (co *Collector) Collect(ctx context.Context, c client.Client, opts CollectorOptions, ...) (err error)
- func (co *Collector) CollectNamespacedItems(ctx context.Context, c client.Client, opts CollectorOptions, ...) (items map[gvk.ResourceKey]*unstructured.Unstructured, err error)
- type CollectorIteratorOptions
- type CollectorOptions
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Add ¶ added in v0.13.0
func Add( log logr.Logger, mgr manager.Manager, configuration configuration.Configuration, opts utils.ControllerOptions, cache *cache.ImpersonationCache, ) (err error)
func ForeachNamespace ¶ added in v0.13.0
func ForeachNamespace( ctx context.Context, controllerClient client.Client, resourceClient client.Client, collector Collector, opts CollectorOptions, log logr.Logger, resource capsulev1beta2.ResourceSpec, resourceIndex int, tnt capsulev1beta2.Tenant, acc processor.Accumulator, ) (err error)
func GatherAdditionalMetadata ¶ added in v0.13.0
func GatherAdditionalMetadata( spec capsulev1beta2.ResourceSpec, fastContext map[string]string, ) (labels map[string]string, annotations map[string]string)
Allows templating in.
Types ¶
type Collector ¶ added in v0.13.0
type Collector struct {
// contains filtered or unexported fields
}
func NewCollector ¶ added in v0.13.0
func NewCollector(c client.Reader, mapper k8smeta.RESTMapper) Collector
func (*Collector) AddToAccumulation ¶ added in v0.13.0
func (co *Collector) AddToAccumulation( tnt *capsulev1beta2.Tenant, ns *corev1.Namespace, opts CollectorOptions, spec capsulev1beta2.ResourceSpec, obj *unstructured.Unstructured, origin string, combine bool, ) (err error)
Add an item to the accumulator Mainly handles conflicts.
func (*Collector) Collect ¶ added in v0.13.0
func (co *Collector) Collect( ctx context.Context, c client.Client, opts CollectorOptions, tnt *capsulev1beta2.Tenant, resourceIndex string, spec capsulev1beta2.ResourceSpec, ns *corev1.Namespace, ) (err error)
func (*Collector) CollectNamespacedItems ¶ added in v0.13.0
func (co *Collector) CollectNamespacedItems( ctx context.Context, c client.Client, opts CollectorOptions, spec capsulev1beta2.ResourceSpec, ns *corev1.Namespace, tnt capsulev1beta2.Tenant, ) (items map[gvk.ResourceKey]*unstructured.Unstructured, err error)
type CollectorIteratorOptions ¶ added in v0.13.0
type CollectorIteratorOptions struct {
Labels map[string]string
Annotations map[string]string
FastContext map[string]string
FastContextAny map[string]any
}
func NewCollectorIteratorOptions ¶ added in v0.13.0
func NewCollectorIteratorOptions( tnt *capsulev1beta2.Tenant, ns *corev1.Namespace, spec capsulev1beta2.ResourceSpec, ) CollectorIteratorOptions
type CollectorOptions ¶ added in v0.13.0
type CollectorOptions struct {
AllowCrossNamespaceSelection bool
Accumulator processor.Accumulator
Iterator CollectorIteratorOptions
ValidatorNamespaces tpl.NamespaceValidator
}
Source Files
Click to show internal directories.
Click to hide internal directories.