kapi

package module

Go to main page

Versions in this module

v1

v1.2.0

Dec 11, 2024

v1.1.1

Dec 11, 2024

Changes in this version

+ type Subresource string

+ const SubresourceScale

+ const SubresourceStatus

v1.1.0

Dec 9, 2024

Changes in this version

type ClusterConfig

+ LeaderElection LeaderElectionConfig

+ type LeaderElectionConfig struct

+ Enabled bool

+ LockResource string

+ Namespace string

v1.0.1

Dec 7, 2024

v1.0.0

Dec 6, 2024

Changes in this version

+ var ReconcileEventTypeCreatedOrUpdated = ReconcileEventType(0)

+ var ReconcileEventTypeDeleted = ReconcileEventType(1)

+ var ResourceEventTypeCreated = ResourceEventType(0)

+ var ResourceEventTypeDeleted = ResourceEventType(2)

+ var ResourceEventTypeUpdated = ResourceEventType(1)

+ func AddHook[T client.Object](ctx context.Context, cluster *Cluster, hook *Hook[T]) error

+ func AddReconciler[T client.Object](ctx context.Context, cluster *Cluster, ...) error

+ func Init(cfg ObservabilityConfig)

+ type CRDs struct

+ APIGroup string

+ APIVersion string

+ Kinds map[string]KindType

+ type Client struct

+ func ClientFor[TItem client.Object, TList client.ObjectList](ctx context.Context, cluster *Cluster, cache bool) *Client[TItem, TList]

+ func (c *Client[TItem, TList]) Create(ctx context.Context, resource TItem) error

+ func (c *Client[TItem, TList]) Delete(ctx context.Context, resource TItem) error

+ func (c *Client[TItem, TList]) Get(ctx context.Context, namespace, name string) (TItem, error)

+ func (c *Client[TItem, TList]) List(ctx context.Context) (TList, error)

+ func (c *Client[TItem, TList]) Update(ctx context.Context, resource TItem) error

+ type Cluster struct

+ func NewCluster(ctx context.Context, cfg ClusterConfig) (*Cluster, error)

+ func (cluster *Cluster) Connect(ctx context.Context) error

+ type ClusterConfig struct

+ CRDs []CRDs

+ DisableCaching bool

+ Namespaces []string

+ TLS string

+ type CustomResource struct

+ Scale TScale

+ Spec TSpec

+ Status TStatus

+ func (e *CustomResource[TSpec, TStatus, TScale]) DeepCopyObject() runtime.Object

+ type CustomResourceList struct

+ Items []T

+ func (e *CustomResourceList[T]) DeepCopyObject() runtime.Object

+ type FieldUndefined *struct

+ type Hook struct

+ DefaulterFunc func(ctx context.Context, resource T) error

+ ValidateCreateFunc func(ctx context.Context, resource T) (warnings []string, err error)

+ ValidateDeleteFunc func(ctx context.Context, resource T) (warnings []string, err error)

+ ValidateUpdateFunc func(ctx context.Context, oldResource, newResource T) (warnings []string, err error)

+ func (h *Hook[T]) Default(ctx context.Context, obj runtime.Object) error

+ func (h *Hook[T]) ValidateCreate(ctx context.Context, obj runtime.Object) (admission.Warnings, error)

+ func (h *Hook[T]) ValidateDelete(ctx context.Context, obj runtime.Object) (admission.Warnings, error)

+ func (h *Hook[T]) ValidateUpdate(ctx context.Context, oldObj, newObj runtime.Object) (admission.Warnings, error)

+ type KindType runtime.Object

+ type ListUndefined struct

+ type ObservabilityConfig struct

+ BackgroundContext context.Context

+ LogFunc func(ctx context.Context, level int, msg string, attributes ...any)

+ MetricTimerFunc func(ctx context.Context, metric string) func(attributes ...string)

+ NewCorrelationCtx func(ctx context.Context) context.Context

+ func UseSlog(ctx context.Context, log *slog.Logger) ObservabilityConfig

+ type ReconcileEventType int

+ func (r ReconcileEventType) String() string

+ type ReconcilerFilterFunc func(ResourceEventType, client.Object) bool

+ type ReconcilerFunc func(ctx context.Context, eventType ReconcileEventType, resource T) error

+ type ResourceEventType int

+ func (r ResourceEventType) String() string

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