webhooks

package

v0.25.1 Latest Latest Go to latest Published: Jul 12, 2023 License: Apache-2.0 Imports: 19 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/banzaicloud/koperator

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func IsAdmissionCantConnect(err error) bool
func IsAdmissionCantConnectAPIServer(err error) bool
func IsAdmissionErrorDuringValidation(err error) bool
func IsAdmissionInvalidExternalListenerPort(err error) bool
func IsAdmissionInvalidRemovingStorage(err error) bool
func IsAdmissionInvalidReplicationFactor(err error) bool
func IsAdmissionOutOfRangePartitions(err error) bool
func IsAdmissionOutOfRangeReplicationFactor(err error) bool
type KafkaClusterValidator
type KafkaTopicValidator

Constants ¶

View Source

const (
	TopicManagedByAnnotationKey            = "managedBy"
	TopicManagedByKoperatorAnnotationValue = "koperator"
)

Variables ¶

This section is empty.

Functions ¶

func IsAdmissionCantConnect ¶

func IsAdmissionCantConnect(err error) bool

func IsAdmissionCantConnectAPIServer ¶ added in v0.23.0

func IsAdmissionCantConnectAPIServer(err error) bool

func IsAdmissionErrorDuringValidation ¶ added in v0.23.0

func IsAdmissionErrorDuringValidation(err error) bool

func IsAdmissionInvalidExternalListenerPort ¶ added in v0.24.0

func IsAdmissionInvalidExternalListenerPort(err error) bool

func IsAdmissionInvalidRemovingStorage ¶ added in v0.23.0

func IsAdmissionInvalidRemovingStorage(err error) bool

func IsAdmissionInvalidReplicationFactor ¶ added in v0.23.0

func IsAdmissionInvalidReplicationFactor(err error) bool

func IsAdmissionOutOfRangePartitions ¶ added in v0.23.0

func IsAdmissionOutOfRangePartitions(err error) bool

func IsAdmissionOutOfRangeReplicationFactor ¶ added in v0.23.0

func IsAdmissionOutOfRangeReplicationFactor(err error) bool

Types ¶

type KafkaClusterValidator ¶

type KafkaClusterValidator struct {
	Log logr.Logger
}

func (KafkaClusterValidator) ValidateCreate ¶

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

func (KafkaClusterValidator) ValidateDelete ¶

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

func (KafkaClusterValidator) ValidateUpdate ¶

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

type KafkaTopicValidator ¶

type KafkaTopicValidator struct {
	Client              client.Client
	NewKafkaFromCluster func(client.Client, *banzaicloudv1beta1.KafkaCluster) (kafkaclient.KafkaClient, func(), error)
	Log                 logr.Logger
}

func (KafkaTopicValidator) ValidateCreate ¶

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

func (KafkaTopicValidator) ValidateDelete ¶

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

func (KafkaTopicValidator) ValidateUpdate ¶

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

Source Files ¶

View all Source files

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