v1alpha1

package
v0.0.0-...-27a480c Latest Latest
Warning

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

 Go to latest Published: Sep 21, 2021 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Overview

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

Index

Constants

View Source 
const (
	CONNECTION_CREATED = "Created"
	CONNECTION_ERROR   = "Error"
)
View Source 
const (
	TOPIC_CREATED            = "TopicCreated"
	TOPIC_CONNECTION_ERROR   = "ConnectionError"
	TOPIC_CREATION_ERROR     = "TopicCreationError"
	CONFIGMAP_CREATION_ERROR = "ConfigMapCreationError"
	TOPIC_DELETE_ERROR       = "TopicDeleteError"
)
View Source 
const (
	NOT_DELETABLE = "NotDeletable"
	KEEP_TOPIC    = "KeepTopic"
	DELETE_ALL    = "DeleteAll"
)

Variables

View Source 
var (
	// GroupVersion is group version used to register these objects
	GroupVersion = schema.GroupVersion{Group: "kafka.btrace.com", 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 ClusterConnection 

type ClusterConnection struct {
	Name string `json:"name"`
}

func (*ClusterConnection) DeepCopy 

func (in *ClusterConnection) DeepCopy() *ClusterConnection

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

func (*ClusterConnection) DeepCopyInto 

func (in *ClusterConnection) DeepCopyInto(out *ClusterConnection)

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

type KafkaConnection 

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

	Spec   KafkaConnectionSpec   `json:"spec,omitempty"`
	Status KafkaConnectionStatus `json:"status,omitempty"`
}

KafkaConnection is the Schema for the kafkaconnections API

func (*KafkaConnection) DeepCopy 

func (in *KafkaConnection) DeepCopy() *KafkaConnection

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

func (*KafkaConnection) DeepCopyInto 

func (in *KafkaConnection) DeepCopyInto(out *KafkaConnection)

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

func (*KafkaConnection) DeepCopyObject 

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

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

func (*KafkaConnection) SetupWebhookWithManager 

func (r *KafkaConnection) SetupWebhookWithManager(mgr ctrl.Manager) error

func (*KafkaConnection) ValidateCreate 

func (r *KafkaConnection) ValidateCreate() error

ValidateCreate implements webhook.Validator so a webhook will be registered for the type

func (*KafkaConnection) ValidateDelete 

func (r *KafkaConnection) ValidateDelete() error

ValidateDelete implements webhook.Validator so a webhook will be registered for the type

func (*KafkaConnection) ValidateUpdate 

func (r *KafkaConnection) ValidateUpdate(old runtime.Object) error

ValidateUpdate implements webhook.Validator so a webhook will be registered for the type

type KafkaConnectionList 

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

KafkaConnectionList contains a list of KafkaConnection

func (*KafkaConnectionList) DeepCopy 

func (in *KafkaConnectionList) DeepCopy() *KafkaConnectionList

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

func (*KafkaConnectionList) DeepCopyInto 

func (in *KafkaConnectionList) DeepCopyInto(out *KafkaConnectionList)

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

func (*KafkaConnectionList) DeepCopyObject 

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

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

type KafkaConnectionSpec 

type KafkaConnectionSpec struct {
	Brokers          []string          `json:"brokers"`
	Username         string            `json:"username,omitempty"`
	Password         string            `json:"password,omitempty"`
	SecurityProtocol string            `json:"security-protocol,omitempty"`
	Config           map[string]string `json:"config,omitempty"`
}

KafkaConnectionSpec defines the desired state of KafkaConnection

func (*KafkaConnectionSpec) DeepCopy 

func (in *KafkaConnectionSpec) DeepCopy() *KafkaConnectionSpec

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

func (*KafkaConnectionSpec) DeepCopyInto 

func (in *KafkaConnectionSpec) DeepCopyInto(out *KafkaConnectionSpec)

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

type KafkaConnectionState 

type KafkaConnectionState string

KafkaConnectionState, possible states : created, error

type KafkaConnectionStatus 

type KafkaConnectionStatus struct {
	State KafkaConnectionState `json:"state"`
}

KafkaConnectionStatus defines the observed state of KafkaConnection

func (*KafkaConnectionStatus) DeepCopy 

func (in *KafkaConnectionStatus) DeepCopy() *KafkaConnectionStatus

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

func (*KafkaConnectionStatus) DeepCopyInto 

func (in *KafkaConnectionStatus) DeepCopyInto(out *KafkaConnectionStatus)

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

type KafkaTopic 

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

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

KafkaTopic is the Schema for the kafkatopics API

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.

func (*KafkaTopic) Default 

func (r *KafkaTopic) Default()

Default implements webhook.Defaulter so a webhook will be registered for the type

func (*KafkaTopic) SetupWebhookWithManager 

func (r *KafkaTopic) SetupWebhookWithManager(mgr ctrl.Manager) error

func (*KafkaTopic) ValidateCreate 

func (r *KafkaTopic) ValidateCreate() error

ValidateCreate implements webhook.Validator so a webhook will be registered for the type

func (*KafkaTopic) ValidateDelete 

func (r *KafkaTopic) ValidateDelete() error

ValidateDelete implements webhook.Validator so a webhook will be registered for the type

func (*KafkaTopic) ValidateUpdate 

func (r *KafkaTopic) ValidateUpdate(old runtime.Object) error

ValidateUpdate implements webhook.Validator so a webhook will be registered for the type

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 {
	Partitions        int32                       `json:"partitions"`
	ReplicationFactor int16                       `json:"replication-factor"`
	Config            map[string]string           `json:"config,omitempty"`
	TargetCluster     ClusterConnection           `json:"target-cluster"`
	TerminationPolicy KafkaTopicTerminationPolicy `json:"termination-policy,omitempty"`
}

KafkaTopicSpec defines the desired state of KafkaTopic

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 KafkaTopicState 

type KafkaTopicState string

KafkaTopicState, possible states : TopicCreated , ConnectionError, TopicCreationError, ConfigMapCreationError, TopicDeleteError

type KafkaTopicStatus 

type KafkaTopicStatus struct {
	State KafkaTopicState `json:"state"`
}

KafkaTopicStatus defines the observed state of KafkaTopic

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 KafkaTopicTerminationPolicy 

type KafkaTopicTerminationPolicy string

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.