operator

Oct 2, 2024

Changes in this version

+ type KubernetesBasedIformerOptions struct

+ CacheResyncInterval time.Duration

+ ListWatchOptions ListWatchOptions

+ type Runner struct

+ func NewRunner(cfg RunnerConfig) (*Runner, error)

+ func (s *Runner) Run(ctx context.Context, provider app.Provider) error

+ type RunnerConfig struct

+ Filesystem fs.FS

+ KubeConfig rest.Config

+ MetricsConfig RunnerMetricsConfig

+ WebhookConfig RunnerWebhookConfig

+ type RunnerMetricsConfig struct

+ Enabled bool

+ Namespace string

+ type RunnerWebhookConfig struct

+ Port int

+ TLSConfig k8s.TLSConfig

Sep 6, 2024

Changes in this version

type CustomCacheInformer

+ func NewMemcachedInformerWithFilters(kind resource.Kind, client ListWatchClient, filterOptions ListWatchOptions, ...) (*CustomCacheInformer, error)

+ type ListWatchOptions struct

+ FieldSelectors []string

+ LabelFilters []string

+ Namespace string

Aug 1, 2024

Changes in this version

+ const MemcachedStoreDefaultPageSize

+ func NewListerWatcher(client ListWatchClient, sch resource.Schema, namespace string, ...) cache.ListerWatcher

+ type CustomCacheInformer struct

+ CacheResyncInterval time.Duration

+ ErrorHandler func(context.Context, error)

+ func NewCustomCacheInformer(store cache.Store, lw cache.ListerWatcher, kind resource.Kind) *CustomCacheInformer

+ func NewMemcachedInformer(kind resource.Kind, client ListWatchClient, namespace string, addrs ...string) (*CustomCacheInformer, error)

+ func NewMemcachedInformerWithLabelFilters(kind resource.Kind, client ListWatchClient, namespace string, ...) (*CustomCacheInformer, error)

+ func (c *CustomCacheInformer) AddEventHandler(handler ResourceWatcher) error

+ func (c *CustomCacheInformer) HasStarted() bool

+ func (c *CustomCacheInformer) HasSynced() bool

+ func (c *CustomCacheInformer) LastSyncResourceVersion() string

+ func (c *CustomCacheInformer) OnAdd(obj any, isInInitialList bool)

+ func (c *CustomCacheInformer) OnDelete(obj any)

+ func (c *CustomCacheInformer) OnUpdate(oldObj any, newObj any)

+ func (c *CustomCacheInformer) PrometheusCollectors() []prometheus.Collector

+ func (c *CustomCacheInformer) Run(stopCh <-chan struct{}) error

+ type MemcachedStore struct

+ func NewMemcachedStore(kind resource.Kind, cfg MemcachedStoreConfig) (*MemcachedStore, error)

+ func (*MemcachedStore) Replace([]any, string) error

+ func (*MemcachedStore) Resync() error

+ func (m *MemcachedStore) Add(obj any) error

+ func (m *MemcachedStore) Delete(obj any) error

+ func (m *MemcachedStore) Get(obj any) (item any, exists bool, err error)

+ func (m *MemcachedStore) GetByKey(key string) (item any, exists bool, err error)

+ func (m *MemcachedStore) List() []any

+ func (m *MemcachedStore) ListKeys() []string

+ func (m *MemcachedStore) PrometheusCollectors() []prometheus.Collector

+ func (m *MemcachedStore) Update(obj any) error

+ type MemcachedStoreConfig struct

+ Addrs []string

+ KeyFunc func(any) (string, error)

+ KeySyncInterval time.Duration

+ MaxIdleConns int

+ Metrics metrics.Config

+ PageSize int

+ ShardKey string

+ Timeout time.Duration

Jul 5, 2024

Changes in this version

+ func LoadOperatorRestConfig(path string, opts RestConfigOptions, dst *RestConfig) error

+ type RestConfig = rest.Config

+ type RestConfigOptions struct

+ Burst int

+ NoLimit bool

+ QPS float64

Sep 26, 2023

Changes in this version

+ var DefaultErrorHandler = func(ctx context.Context, err error)

+ var ErrNilObject = errors.New("object cannot be nil")

type InformerController

+ func (c *InformerController) PrometheusCollectors() []prometheus.Collector

+ type InformerControllerConfig struct

+ MetricsConfig metrics.Config

+ func DefaultInformerControllerConfig() InformerControllerConfig

type Operator

+ func (o *Operator) PrometheusCollectors() []prometheus.Collector

Sep 12, 2023

Changes in this version

+ func GetTracer() trace.Tracer

+ func SetTracer(t trace.Tracer)

Aug 15, 2023

Changes in this version

+ type CannotCastError struct

+ Group string

+ Kind string

+ Name string

+ Namespace string

+ func NewCannotCastError(meta resource.StaticMetadata) *CannotCastError

+ func (c *CannotCastError) Error() string

type InformerController

+ func (c *InformerController) AddReconciler(reconciler Reconciler, resourceKind string) error

+ func (c *InformerController) RemoveAllReconcilersForResource(resourceKind string)

+ func (c *InformerController) RemoveReconciler(reconciler Reconciler, resourceKind string)

+ type OpinionatedReconciler struct

+ Reconciler Reconciler

+ func NewOpinionatedReconciler(client PatchClient, finalizer string) (*OpinionatedReconciler, error)

+ func (o *OpinionatedReconciler) Reconcile(ctx context.Context, request ReconcileRequest) (ReconcileResult, error)

+ func (o *OpinionatedReconciler) Wrap(reconciler Reconciler)

+ type ReconcileAction int

+ const ReconcileActionCreated

+ const ReconcileActionDeleted

+ const ReconcileActionResynced

+ const ReconcileActionUnknown

+ const ReconcileActionUpdated

+ func ReconcileActionFromResourceAction(action ResourceAction) ReconcileAction

+ type ReconcileRequest struct

+ Action ReconcileAction

+ Object resource.Object

+ State map[string]any

+ type ReconcileResult struct

+ RequeueAfter *time.Duration

+ State map[string]any

+ type Reconciler interface

+ Reconcile func(ctx context.Context, req ReconcileRequest) (ReconcileResult, error)

type ResourceAction

+ func ResourceActionFromReconcileAction(action ReconcileAction) ResourceAction

+ type SimpleReconciler struct

+ ReconcileFunc func(context.Context, ReconcileRequest) (ReconcileResult, error)

+ func (s *SimpleReconciler) Reconcile(ctx context.Context, req ReconcileRequest) (ReconcileResult, error)

+ type TypedReconcileRequest struct

+ Action ReconcileAction

+ Object T

+ State map[string]any

+ type TypedReconciler struct

+ ReconcileFunc func(context.Context, TypedReconcileRequest[T]) (ReconcileResult, error)

+ func (t *TypedReconciler[T]) Reconcile(ctx context.Context, request ReconcileRequest) (ReconcileResult, error)

Jun 29, 2023

Changes in this version

+ const ResourceActionCreate

+ const ResourceActionDelete

+ const ResourceActionUpdate

+ var OpinionatedRetryDequeuePolicy = func(newAction ResourceAction, newObject resource.Object, ...) bool

type InformerController

+ RetryDequeuePolicy RetryDequeuePolicy

type ListMap

+ func (l *ListMap[K, V]) RemoveItems(key K, match func(V) bool, limit int) int

+ type ResourceAction string

+ type RetryDequeuePolicy func(newAction ResourceAction, newObject resource.Object, ...) bool

May 30, 2023

Changes in this version

+ var DefaultRetryPolicy = ExponentialBackoffRetryPolicy(5 * time.Second, 5)

+ var EmptyLabelFilters []string

+ var ErrInformerAlreadyAdded = errors.New("informer for resource kind already added")

+ func DefaultFinalizerSupplier(sch resource.Schema) string

+ type Controller interface

+ Run func(<-chan struct{}) error

+ type ConvertableIntoResourceObject interface

+ Into func(object resource.Object) error

+ type FinalizerSupplier func(sch resource.Schema) string

+ type Informer interface

+ AddEventHandler func(handler ResourceWatcher) error

+ Run func(stopCh <-chan struct{}) error

+ type InformerController struct

+ ErrorHandler func(error)

+ RetryPolicy RetryPolicy

+ func NewInformerController() *InformerController

+ func (c *InformerController) AddInformer(informer Informer, resourceKind string) error

+ func (c *InformerController) AddWatcher(watcher ResourceWatcher, resourceKind string) error

+ func (c *InformerController) RemoveAllWatchersForResource(resourceKind string)

+ func (c *InformerController) RemoveWatcher(watcher ResourceWatcher, resourceKind string)

+ func (c *InformerController) Run(stopCh <-chan struct{}) error

+ type KubernetesBasedInformer struct

+ ErrorHandler func(error)

+ SharedIndexInformer cache.SharedIndexInformer

+ func NewKubernetesBasedInformer(sch resource.Schema, client ListWatchClient, namespace string) (*KubernetesBasedInformer, error)

+ func NewKubernetesBasedInformerWithFilters(sch resource.Schema, client ListWatchClient, namespace string, ...) (*KubernetesBasedInformer, error)

+ func (k *KubernetesBasedInformer) AddEventHandler(handler ResourceWatcher) error

+ func (k *KubernetesBasedInformer) Run(stopCh <-chan struct{}) error

+ func (k *KubernetesBasedInformer) Schema() resource.Schema

+ type KubernetesCompatibleWatch interface

+ KubernetesWatch func() watch.Interface

+ type ListMap struct

+ func NewListMap() *ListMap[string, T]

+ func (l *ListMap[K, V]) AddItem(key K, items ...V)

+ func (l *ListMap[K, V]) ItemAt(key K, index int) (V, bool)

+ func (l *ListMap[K, V]) KeySize(key K) int

+ func (l *ListMap[K, V]) Keys() []K

+ func (l *ListMap[K, V]) Range(key K, rangeFunc func(index int, value V))

+ func (l *ListMap[K, V]) RangeAll(rangeFunc func(key K, index int, value V))

+ func (l *ListMap[K, V]) RemoveItem(key K, match func(V) bool) bool

+ func (l *ListMap[K, V]) RemoveItemAt(key K, index int)

+ func (l *ListMap[K, V]) RemoveKey(key K)

+ func (l *ListMap[K, V]) Size() int

+ type ListWatchClient interface

+ ListInto func(ctx context.Context, namespace string, options resource.ListOptions, ...) error

+ Watch func(ctx context.Context, namespace string, options resource.WatchOptions) (resource.WatchResponse, error)

+ type Operator struct

+ func New() *Operator

+ func (o *Operator) AddController(c Controller)

+ func (o *Operator) Run(stopCh <-chan struct{}) error

+ type OpinionatedWatcher struct

+ AddFunc func(ctx context.Context, object resource.Object) error

+ DeleteFunc func(ctx context.Context, object resource.Object) error

+ SyncFunc func(ctx context.Context, object resource.Object) error

+ UpdateFunc func(ctx context.Context, old resource.Object, new resource.Object) error

+ func NewOpinionatedWatcher(sch resource.Schema, client PatchClient) (*OpinionatedWatcher, error)

+ func NewOpinionatedWatcherWithFinalizer(sch resource.Schema, client PatchClient, supplier FinalizerSupplier) (*OpinionatedWatcher, error)

+ func (*OpinionatedWatcher) Delete(context.Context, resource.Object) error

+ func (o *OpinionatedWatcher) Add(ctx context.Context, object resource.Object) error

+ func (o *OpinionatedWatcher) Update(ctx context.Context, old resource.Object, new resource.Object) error

+ func (o *OpinionatedWatcher) Wrap(watcher ResourceWatcher, syncToAdd bool)

+ type PatchClient interface

+ PatchInto func(context.Context, resource.Identifier, resource.PatchRequest, ...) error

+ type ResourceObjectWrapper interface

+ ResourceObject func() resource.Object

+ type ResourceWatcher interface

+ Add func(context.Context, resource.Object) error

+ Delete func(context.Context, resource.Object) error

+ Update func(ctx context.Context, old, new resource.Object) error

+ type RetryPolicy func(err error, attempt int) (bool, time.Duration)

+ func ExponentialBackoffRetryPolicy(initialDelay time.Duration, maxAttempts int) RetryPolicy

+ type SimpleWatcher struct

+ AddFunc func(context.Context, resource.Object) error

+ DeleteFunc func(context.Context, resource.Object) error

+ UpdateFunc func(context.Context, resource.Object, resource.Object) error

+ func (w *SimpleWatcher) Add(ctx context.Context, object resource.Object) error

+ func (w *SimpleWatcher) Delete(ctx context.Context, object resource.Object) error

+ func (w *SimpleWatcher) Update(ctx context.Context, old resource.Object, new resource.Object) error