v1alpha1

package
v0.28.8 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 30, 2023 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Overview

Package v1alpha1 contains API Schema definitions for the banzaicloud v1alpha1 API group +kubebuilder:object:generate=true +groupName=kafka.banzaicloud.io

Index

Constants

View Source 
const (
	// OperationStopExecution means a Cruise Control stop_proposal_execution operation
	OperationStopExecution CruiseControlTaskOperation = "stop_proposal_execution"
	// OperationAddBroker means a Cruise Control add_broker operation
	OperationAddBroker CruiseControlTaskOperation = "add_broker"
	// OperationRemoveBroker means a Cruise Control remove_broker operation
	OperationRemoveBroker CruiseControlTaskOperation = "remove_broker"
	// OperationRebalance means a Cruise Control rebalance operation
	OperationRebalance CruiseControlTaskOperation = "rebalance"
	// OperationStatus means a Cruise Control status operation
	OperationStatus CruiseControlTaskOperation = "status"
	// KafkaAccessTypeRead states that a user wants consume access to a topic
	KafkaAccessTypeRead KafkaAccessType = "read"
	// KafkaAccessTypeWrite states that a user wants produce access to a topic
	KafkaAccessTypeWrite KafkaAccessType = "write"
	// Resource pattern types. More info: https://kafka.apache.org/20/javadoc/org/apache/kafka/common/resource/PatternType.html
	KafkaPatternTypeAny      KafkaPatternType = "any"
	KafkaPatternTypeLiteral  KafkaPatternType = "literal"
	KafkaPatternTypeMatch    KafkaPatternType = "match"
	KafkaPatternTypePrefixed KafkaPatternType = "prefixed"
	KafkaPatternTypeDefault  KafkaPatternType = "literal"
	// TopicStateCreated describes the status of a KafkaTopic as created
	TopicStateCreated TopicState = "created"
	// UserStateCreated describes the status of a KafkaUser as created
	UserStateCreated UserState = "created"
	// TLSJKSKeyStore is where a JKS keystore is stored in a user secret when requested
	TLSJKSKeyStore string = "keystore.jks"
	// TLSJKSTrustStore is where a JKS truststore is stored in a user secret when requested
	TLSJKSTrustStore string = "truststore.jks"
	// CoreCACertKey is where ca certificates are stored in user certificates
	CoreCACertKey string = "ca.crt"
	// CaChainPem is where CA certificate(s) are stored as a chain for user secret
	CaChainPem string = "chain.pem"
	// CACertKey is the key where the CA certificate is stored in the operator secrets
	CACertKey string = "caCert"
	// CAPrivateKeyKey stores the private key for the CA
	CAPrivateKeyKey string = "caKey"
	// ClientCertKey stores the client certificate (cruisecontrol/operator usage)
	ClientCertKey string = "clientCert"
	// ClientPrivateKeyKey stores the client private key
	ClientPrivateKeyKey string = "clientKey"
	// PeerCertKey stores the peer certificate (broker certificates)
	PeerCertKey string = "peerCert"
	// PeerPrivateKeyKey stores the peer private key
	PeerPrivateKeyKey string = "peerKey"
	// PasswordKey stores the JKS password
	PasswordKey string = "password"
)
View Source 
const (
	MinPartitions        = -1
	MinReplicationFactor = -1
)
View Source 
const (

	// CertManagerSignerNamePrefix is acceptable pki backend signerName prefix for cert-manager
	CertManagerSignerNamePrefix string = "clusterissuers.cert-manager.io"
)

Variables

View Source 
var (
	// GroupVersion is group version used to register these objects
	GroupVersion = schema.GroupVersion{Group: "kafka.banzaicloud.io", Version: "v1alpha1"}

	// SchemeBuilder is used to add go types to the GroupVersionKind scheme
	SchemeBuilder = &scheme.Builder{GroupVersion: GroupVersion}

	// AddToScheme adds the types in this group-version to the given scheme.
	AddToScheme = SchemeBuilder.AddToScheme
)

Functions

This section is empty.

Types

type ClusterReference 

type ClusterReference struct {
	Name      string `json:"name"`
	Namespace string `json:"namespace,omitempty"`
}

ClusterReference states a reference to a cluster for topic/user provisioning

func (*ClusterReference) DeepCopy 

func (in *ClusterReference) DeepCopy() *ClusterReference

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterReference.

func (*ClusterReference) DeepCopyInto 

func (in *ClusterReference) DeepCopyInto(out *ClusterReference)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type CruiseControlOperation added in v0.22.0 

type CruiseControlOperation struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   CruiseControlOperationSpec   `json:"spec,omitempty"`
	Status CruiseControlOperationStatus `json:"status,omitempty"`
}

CruiseControlOperation is the Schema for the cruiseControlOperation API.

func (*CruiseControlOperation) CurrentTask added in v0.22.0 

func (o *CruiseControlOperation) CurrentTask() *CruiseControlTask

func (*CruiseControlOperation) CurrentTaskFinished added in v0.22.0 

func (o *CruiseControlOperation) CurrentTaskFinished() *metav1.Time

func (*CruiseControlOperation) CurrentTaskID added in v0.22.0 

func (o *CruiseControlOperation) CurrentTaskID() string

func (*CruiseControlOperation) CurrentTaskOperation added in v0.22.0 

func (o *CruiseControlOperation) CurrentTaskOperation() CruiseControlTaskOperation

func (*CruiseControlOperation) CurrentTaskParameters added in v0.22.0 

func (o *CruiseControlOperation) CurrentTaskParameters() map[string]string

func (*CruiseControlOperation) CurrentTaskState added in v0.22.0 

func (o *CruiseControlOperation) CurrentTaskState() v1beta1.CruiseControlUserTaskState

func (*CruiseControlOperation) DeepCopy added in v0.22.0 

func (in *CruiseControlOperation) DeepCopy() *CruiseControlOperation

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CruiseControlOperation.

func (*CruiseControlOperation) DeepCopyInto added in v0.22.0 

func (in *CruiseControlOperation) DeepCopyInto(out *CruiseControlOperation)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*CruiseControlOperation) DeepCopyObject added in v0.22.0 

func (in *CruiseControlOperation) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*CruiseControlOperation) GetClusterRef added in v0.22.0 

func (o *CruiseControlOperation) GetClusterRef() string

func (CruiseControlOperation) GetTTLSecondsAfterFinished added in v0.22.0 

func (c CruiseControlOperation) GetTTLSecondsAfterFinished() *int

GetTTLSecondsAfterFinished returns Spec.TTLSecondsAfterFinished

func (*CruiseControlOperation) IsCurrentTaskFinished added in v0.22.0 

func (o *CruiseControlOperation) IsCurrentTaskFinished() bool

func (*CruiseControlOperation) IsCurrentTaskOperationValid added in v0.22.0 

func (o *CruiseControlOperation) IsCurrentTaskOperationValid() bool

func (*CruiseControlOperation) IsCurrentTaskRunning added in v0.22.0 

func (o *CruiseControlOperation) IsCurrentTaskRunning() bool

func (*CruiseControlOperation) IsDone added in v0.22.0 

func (o *CruiseControlOperation) IsDone() bool

func (*CruiseControlOperation) IsErrorPolicyIgnore added in v0.22.0 

func (o *CruiseControlOperation) IsErrorPolicyIgnore() bool

func (*CruiseControlOperation) IsErrorPolicyRetry added in v0.22.0 

func (o *CruiseControlOperation) IsErrorPolicyRetry() bool

func (*CruiseControlOperation) IsFinished added in v0.22.0 

func (o *CruiseControlOperation) IsFinished() bool

func (*CruiseControlOperation) IsInProgress added in v0.22.0 

func (o *CruiseControlOperation) IsInProgress() bool

func (*CruiseControlOperation) IsPaused added in v0.22.0 

func (o *CruiseControlOperation) IsPaused() bool

func (*CruiseControlOperation) IsReadyForRetryExecution added in v0.22.0 

func (o *CruiseControlOperation) IsReadyForRetryExecution() bool

func (*CruiseControlOperation) IsWaitingForFirstExecution added in v0.22.0 

func (o *CruiseControlOperation) IsWaitingForFirstExecution() bool

func (*CruiseControlOperation) IsWaitingForRetryExecution added in v0.22.0 

func (o *CruiseControlOperation) IsWaitingForRetryExecution() bool

type CruiseControlOperationList added in v0.22.0 

type CruiseControlOperationList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []CruiseControlOperation `json:"items"`
}

+kubebuilder:object:root=true CruiseControlOperationList contains a list of CruiseControlOperation.

func (*CruiseControlOperationList) DeepCopy added in v0.22.0 

func (in *CruiseControlOperationList) DeepCopy() *CruiseControlOperationList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CruiseControlOperationList.

func (*CruiseControlOperationList) DeepCopyInto added in v0.22.0 

func (in *CruiseControlOperationList) DeepCopyInto(out *CruiseControlOperationList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*CruiseControlOperationList) DeepCopyObject added in v0.22.0 

func (in *CruiseControlOperationList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type CruiseControlOperationSpec added in v0.22.0 

type CruiseControlOperationSpec struct {
	// ErrorPolicy defines how failed Cruise Control operation should be handled.
	// When it is "retry", the Koperator re-executes the failed task in every 30 sec (by default).
	// When it is "ignore", the Koperator handles the failed task as completed.
	// +kubebuilder:validation:Enum=ignore;retry
	// +kubebuilder:default=retry
	// +optional
	ErrorPolicy ErrorPolicyType `json:"errorPolicy,omitempty"`
	// When TTLSecondsAfterFinished is specified, the created and finished (completed successfully or completedWithError and errorPolicy: ignore)
	// cruiseControlOperation custom resource will be deleted after the given time elapsed.
	// When it is 0 then the resource is going to be deleted instantly after the operation is finished.
	// When it is not specified the resource is not going to be removed.
	// Value can be only zero and positive integers
	// +kubebuilder:validation:Minimum=0
	TTLSecondsAfterFinished *int `json:"ttlSecondsAfterFinished,omitempty"`
}

CruiseControlOperationSpec defines the desired state of CruiseControlOperation.

func (*CruiseControlOperationSpec) DeepCopy added in v0.22.0 

func (in *CruiseControlOperationSpec) DeepCopy() *CruiseControlOperationSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CruiseControlOperationSpec.

func (*CruiseControlOperationSpec) DeepCopyInto added in v0.22.0 

func (in *CruiseControlOperationSpec) DeepCopyInto(out *CruiseControlOperationSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type CruiseControlOperationStatus added in v0.22.0 

type CruiseControlOperationStatus struct {
	CurrentTask *CruiseControlTask  `json:"currentTask,omitempty"`
	ErrorPolicy ErrorPolicyType     `json:"errorPolicy"`
	RetryCount  int                 `json:"retryCount"`
	FailedTasks []CruiseControlTask `json:"failedTasks,omitempty"`
}

CruiseControlOperationStatus defines the observed state of CruiseControlOperation.

func (*CruiseControlOperationStatus) DeepCopy added in v0.22.0 

func (in *CruiseControlOperationStatus) DeepCopy() *CruiseControlOperationStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CruiseControlOperationStatus.

func (*CruiseControlOperationStatus) DeepCopyInto added in v0.22.0 

func (in *CruiseControlOperationStatus) DeepCopyInto(out *CruiseControlOperationStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type CruiseControlTask added in v0.22.0 

type CruiseControlTask struct {
	ID       string       `json:"id,omitempty"`
	Started  *metav1.Time `json:"started,omitempty"`
	Finished *metav1.Time `json:"finished,omitempty"`
	// Operation defines the Cruise Control operation kind.
	Operation CruiseControlTaskOperation `json:"operation"`
	// Parameters defines the configuration of the operation.
	Parameters map[string]string `json:"parameters,omitempty"`
	// HTTPRequest is a Cruise Control user task HTTP request.
	HTTPRequest      string `json:"httpRequest,omitempty"`
	HTTPResponseCode *int   `json:"httpResponseCode,omitempty"`
	// Summary of the Cruise Control user task execution proposal.
	Summary map[string]string `json:"summary,omitempty"`
	// State is the current state of the Cruise Control user task.
	State        v1beta1.CruiseControlUserTaskState `json:"state,omitempty"`
	ErrorMessage string                             `json:"errorMessage,omitempty"`
}

CruiseControlTask defines the observed state of the Cruise Control user task.

func (*CruiseControlTask) DeepCopy added in v0.22.0 

func (in *CruiseControlTask) DeepCopy() *CruiseControlTask

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CruiseControlTask.

func (*CruiseControlTask) DeepCopyInto added in v0.22.0 

func (in *CruiseControlTask) DeepCopyInto(out *CruiseControlTask)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*CruiseControlTask) SetDefaults added in v0.22.0 

func (task *CruiseControlTask) SetDefaults()

type CruiseControlTaskOperation added in v0.22.0 

type CruiseControlTaskOperation string

CruiseControlTaskOperation defines distinct operation types used while running Cruise Control on the Kafka cluster. More details: https://github.com/linkedin/cruise-control/wiki/REST-APIs#post-requests

type ErrorPolicyType added in v0.22.0 

type ErrorPolicyType string

ErrorPolicyType defines methods of handling Cruise Control user task errors. 

const (
	// ErrorPolicyIgnore means the Koperator handles the failed task as completed.
	ErrorPolicyIgnore ErrorPolicyType = "ignore"
	// ErrorPolicyRetry means Koperator re-executes the failed task in every 30 sec (by default).
	ErrorPolicyRetry ErrorPolicyType = "retry"
	// DefaultRetryBackOffDurationSec defines the time between retries of the failed tasks.
	DefaultRetryBackOffDurationSec = 30
)

type KafkaAccessType 

type KafkaAccessType string

KafkaAccessType hold info about Kafka ACL

type KafkaPatternType 

type KafkaPatternType string

KafkaPatternType hold the Resource Pattern Type of kafka ACL

type KafkaTopic 

type KafkaTopic struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   KafkaTopicSpec   `json:"spec,omitempty"`
	Status KafkaTopicStatus `json:"status,omitempty"`
}

+k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object +k8s:openapi-gen=true KafkaTopic is the Schema for the kafkatopics API +kubebuilder:object:root=true +kubebuilder:subresource:status

func (*KafkaTopic) DeepCopy 

func (in *KafkaTopic) DeepCopy() *KafkaTopic

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KafkaTopic.

func (*KafkaTopic) DeepCopyInto 

func (in *KafkaTopic) DeepCopyInto(out *KafkaTopic)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*KafkaTopic) DeepCopyObject 

func (in *KafkaTopic) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type KafkaTopicList 

type KafkaTopicList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []KafkaTopic `json:"items"`
}

KafkaTopicList contains a list of KafkaTopic

func (*KafkaTopicList) DeepCopy 

func (in *KafkaTopicList) DeepCopy() *KafkaTopicList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KafkaTopicList.

func (*KafkaTopicList) DeepCopyInto 

func (in *KafkaTopicList) DeepCopyInto(out *KafkaTopicList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*KafkaTopicList) DeepCopyObject 

func (in *KafkaTopicList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type KafkaTopicSpec 

type KafkaTopicSpec struct {
	Name string `json:"name"`
	// Partitions defines the desired number of partitions; must be positive, or -1 to signify using the broker's default
	// +kubebuilder:validation:Minimum=-1
	Partitions int32 `json:"partitions"`
	// ReplicationFactor defines the desired replication factor; must be positive, or -1 to signify using the broker's default
	// +kubebuilder:validation:Minimum=-1
	ReplicationFactor int32             `json:"replicationFactor"`
	Config            map[string]string `json:"config,omitempty"`
	ClusterRef        ClusterReference  `json:"clusterRef"`
}

KafkaTopicSpec defines the desired state of KafkaTopic +k8s:openapi-gen=true

func (*KafkaTopicSpec) DeepCopy 

func (in *KafkaTopicSpec) DeepCopy() *KafkaTopicSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KafkaTopicSpec.

func (*KafkaTopicSpec) DeepCopyInto 

func (in *KafkaTopicSpec) DeepCopyInto(out *KafkaTopicSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type KafkaTopicStatus 

type KafkaTopicStatus struct {
	// ManagedBy describes who is the manager of the Kafka topic.
	// When its value is not "koperator" then modifications to the topic configurations of the KafkaTopic CR will not be propagated to the Kafka topic.
	// Manager of the Kafka topic can be changed by adding the "managedBy: <manager>" annotation to the KafkaTopic CR.
	ManagedBy string     `json:"managedBy"`
	State     TopicState `json:"state"`
}

KafkaTopicStatus defines the observed state of KafkaTopic +k8s:openapi-gen=true

func (*KafkaTopicStatus) DeepCopy 

func (in *KafkaTopicStatus) DeepCopy() *KafkaTopicStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KafkaTopicStatus.

func (*KafkaTopicStatus) DeepCopyInto 

func (in *KafkaTopicStatus) DeepCopyInto(out *KafkaTopicStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type KafkaUser 

type KafkaUser struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   KafkaUserSpec   `json:"spec,omitempty"`
	Status KafkaUserStatus `json:"status,omitempty"`
}

KafkaUser is the Schema for the kafka users API +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object +k8s:openapi-gen=true +kubebuilder:object:root=true +kubebuilder:subresource:status

func (*KafkaUser) DeepCopy 

func (in *KafkaUser) DeepCopy() *KafkaUser

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KafkaUser.

func (*KafkaUser) DeepCopyInto 

func (in *KafkaUser) DeepCopyInto(out *KafkaUser)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*KafkaUser) DeepCopyObject 

func (in *KafkaUser) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type KafkaUserList 

type KafkaUserList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []KafkaUser `json:"items"`
}

KafkaUserList contains a list of KafkaUser

func (*KafkaUserList) DeepCopy 

func (in *KafkaUserList) DeepCopy() *KafkaUserList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KafkaUserList.

func (*KafkaUserList) DeepCopyInto 

func (in *KafkaUserList) DeepCopyInto(out *KafkaUserList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*KafkaUserList) DeepCopyObject 

func (in *KafkaUserList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type KafkaUserSpec 

type KafkaUserSpec struct {
	// secretName is used as the name of the K8S secret that contains the certificate of the KafkaUser. SecretName should be unique inside the namespace where KafkaUser is located.
	SecretName string           `json:"secretName"`
	ClusterRef ClusterReference `json:"clusterRef"`
	// Annotations defines the annotations placed on the certificate or certificate signing request object
	Annotations    map[string]string `json:"annotations,omitempty"`
	DNSNames       []string          `json:"dnsNames,omitempty"`
	TopicGrants    []UserTopicGrant  `json:"topicGrants,omitempty"`
	IncludeJKS     bool              `json:"includeJKS,omitempty"`
	CreateCert     *bool             `json:"createCert,omitempty"`
	PKIBackendSpec *PKIBackendSpec   `json:"pkiBackendSpec,omitempty"`
	// expirationSeconds is the requested duration of validity of the issued certificate.
	// The minimum valid value for expirationSeconds is 3600 i.e. 1h.
	// When it is not specified the default validation duration is 90 days
	// +optional
	// +kubebuilder:validation:Minimum=3600
	ExpirationSeconds *int32 `json:"expirationSeconds,omitempty"`
}

KafkaUserSpec defines the desired state of KafkaUser +k8s:openapi-gen=true

func (*KafkaUserSpec) DeepCopy 

func (in *KafkaUserSpec) DeepCopy() *KafkaUserSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KafkaUserSpec.

func (*KafkaUserSpec) DeepCopyInto 

func (in *KafkaUserSpec) DeepCopyInto(out *KafkaUserSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*KafkaUserSpec) GetAnnotations 

func (spec *KafkaUserSpec) GetAnnotations() map[string]string

GetAnnotations returns Annotations to use for certificate or certificate signing request object

func (*KafkaUserSpec) GetExpirationSeconds added in v0.28.2 

func (spec *KafkaUserSpec) GetExpirationSeconds() int32

func (*KafkaUserSpec) GetIfCertShouldBeCreated 

func (spec *KafkaUserSpec) GetIfCertShouldBeCreated() bool

func (*KafkaUserSpec) ValidateAnnotations added in v0.28.6 

func (spec *KafkaUserSpec) ValidateAnnotations() error

ValidateAnnotations checks if certificate signing request annotations are valid

type KafkaUserStatus 

type KafkaUserStatus struct {
	State UserState `json:"state"`
	ACLs  []string  `json:"acls,omitempty"`
}

KafkaUserStatus defines the observed state of KafkaUser +k8s:openapi-gen=true

func (*KafkaUserStatus) DeepCopy 

func (in *KafkaUserStatus) DeepCopy() *KafkaUserStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KafkaUserStatus.

func (*KafkaUserStatus) DeepCopyInto 

func (in *KafkaUserStatus) DeepCopyInto(out *KafkaUserStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type PKIBackendSpec 

type PKIBackendSpec struct {
	IssuerRef *cmmeta.ObjectReference `json:"issuerRef,omitempty"`
	// +kubebuilder:validation:Enum={"cert-manager","k8s-csr"}
	PKIBackend string `json:"pkiBackend"`
	// SignerName indicates requested signer, and is a qualified name.
	SignerName string `json:"signerName,omitempty"`
}

func (*PKIBackendSpec) DeepCopy 

func (in *PKIBackendSpec) DeepCopy() *PKIBackendSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PKIBackendSpec.

func (*PKIBackendSpec) DeepCopyInto 

func (in *PKIBackendSpec) DeepCopyInto(out *PKIBackendSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type TopicState 

type TopicState string

TopicState defines the state of a KafkaTopic

type UserState 

type UserState string

UserState defines the state of a KafkaUser

type UserTopicGrant 

type UserTopicGrant struct {
	TopicName string `json:"topicName"`
	// +kubebuilder:validation:Enum={"read","write"}
	AccessType KafkaAccessType `json:"accessType"`
	// +kubebuilder:validation:Enum={"literal","match","prefixed","any"}
	PatternType KafkaPatternType `json:"patternType,omitempty"`
}

UserTopicGrant is the desired permissions for the KafkaUser

func (*UserTopicGrant) DeepCopy 

func (in *UserTopicGrant) DeepCopy() *UserTopicGrant

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new UserTopicGrant.

func (*UserTopicGrant) DeepCopyInto 

func (in *UserTopicGrant) DeepCopyInto(out *UserTopicGrant)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.