webhooks

Apr 4, 2023

Changes in this version

+ const TopicManagedByAnnotationKey

+ const TopicManagedByKoperatorAnnotationValue

+ func IsAdmissionInvalidExternalListenerPort(err error) bool

Feb 13, 2023

Changes in this version

+ func IsAdmissionCantConnectAPIServer(err error) bool

+ func IsAdmissionErrorDuringValidation(err error) bool

+ func IsAdmissionInvalidRemovingStorage(err error) bool

+ func IsAdmissionInvalidReplicationFactor(err error) bool

+ func IsAdmissionOutOfRangePartitions(err error) bool

+ func IsAdmissionOutOfRangeReplicationFactor(err error) bool

Nov 15, 2022

Changes in this version

+ func IsAdmissionCantConnect(err error) bool

+ func IsInvalidReplicationFactor(err error) bool

+ type KafkaClusterValidator struct

+ Log logr.Logger

+ func (s KafkaClusterValidator) ValidateCreate(ctx context.Context, obj runtime.Object) error

+ func (s KafkaClusterValidator) ValidateDelete(ctx context.Context, obj runtime.Object) error

+ func (s KafkaClusterValidator) ValidateUpdate(ctx context.Context, oldObj, newObj runtime.Object) error

+ type KafkaTopicValidator struct

+ Client client.Client

+ Log logr.Logger

+ NewKafkaFromCluster func(client.Client, *banzaicloudv1beta1.KafkaCluster) (kafkaclient.KafkaClient, func(), error)

+ func (s KafkaTopicValidator) ValidateCreate(ctx context.Context, obj runtime.Object) error

+ func (s KafkaTopicValidator) ValidateDelete(ctx context.Context, obj runtime.Object) error

+ func (s KafkaTopicValidator) ValidateUpdate(ctx context.Context, oldObj, newObj runtime.Object) error