v1alpha1

Documentation

Overview

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

Index

• Variables
• type KafkaSchema
  • func (in *KafkaSchema) DeepCopy() *KafkaSchema
  • func (in *KafkaSchema) DeepCopyInto(out *KafkaSchema)
  • func (in *KafkaSchema) DeepCopyObject() runtime.Object
• type KafkaSchemaList
  • func (in *KafkaSchemaList) DeepCopy() *KafkaSchemaList
  • func (in *KafkaSchemaList) DeepCopyInto(out *KafkaSchemaList)
  • func (in *KafkaSchemaList) DeepCopyObject() runtime.Object
• type KafkaSchemaSpec
  • func (in *KafkaSchemaSpec) DeepCopy() *KafkaSchemaSpec
  • func (in *KafkaSchemaSpec) DeepCopyInto(out *KafkaSchemaSpec)
• type KafkaSchemaStatus
  • func (in *KafkaSchemaStatus) DeepCopy() *KafkaSchemaStatus
  • func (in *KafkaSchemaStatus) DeepCopyInto(out *KafkaSchemaStatus)
• type KafkaTopic
  • func (in *KafkaTopic) DeepCopy() *KafkaTopic
  • func (in *KafkaTopic) DeepCopyInto(out *KafkaTopic)
  • func (in *KafkaTopic) DeepCopyObject() runtime.Object
• type KafkaTopicList
  • func (in *KafkaTopicList) DeepCopy() *KafkaTopicList
  • func (in *KafkaTopicList) DeepCopyInto(out *KafkaTopicList)
  • func (in *KafkaTopicList) DeepCopyObject() runtime.Object
• type KafkaTopicSpec
  • func (in *KafkaTopicSpec) DeepCopy() *KafkaTopicSpec
  • func (in *KafkaTopicSpec) DeepCopyInto(out *KafkaTopicSpec)
• type KafkaTopicStatus
  • func (in *KafkaTopicStatus) DeepCopy() *KafkaTopicStatus
  • func (in *KafkaTopicStatus) DeepCopyInto(out *KafkaTopicStatus)
• type Segment
  • func (in *Segment) DeepCopy() *Segment
  • func (in *Segment) DeepCopyInto(out *Segment)

Variables

var (
	// GroupVersion is group version used to register these objects
	GroupVersion = schema.GroupVersion{Group: "xo.ninetypercent.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
)

Types

type KafkaSchema

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

	Spec   KafkaSchemaSpec   `json:"spec,omitempty"`
	Status KafkaSchemaStatus `json:"status,omitempty"`
}

KafkaSchema is the Schema for the kafkaschemas API

func (*KafkaSchema) DeepCopy

func (in *KafkaSchema) DeepCopy() *KafkaSchema

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

func (*KafkaSchema) DeepCopyInto

func (in *KafkaSchema) DeepCopyInto(out *KafkaSchema)

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

func (*KafkaSchema) DeepCopyObject

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

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

type KafkaSchemaList

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

KafkaSchemaList contains a list of KafkaSchema

func (*KafkaSchemaList) DeepCopy

func (in *KafkaSchemaList) DeepCopy() *KafkaSchemaList

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

func (*KafkaSchemaList) DeepCopyInto

func (in *KafkaSchemaList) DeepCopyInto(out *KafkaSchemaList)

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

func (*KafkaSchemaList) DeepCopyObject

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

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

type KafkaSchemaSpec

type KafkaSchemaSpec struct {

	// +required
	// +kubebuilder:validation:Required
	// +kubebuilder:validation:MinLength=3
	// +kubebuilder:validation:MaxLength=255
	// +kubebuilder:validation:Pattern=`^[a-zA-Z0-9\\._\\-]{1,255}$`
	Name string `json:"name"`

	// +required
	// +kubebuilder:validation:Required
	// +kubebuilder:validation:MinLength=2
	// +kubebuilder:default={}
	Schema string `json:"schema"`

	// +optional
	// +kubebuilder:validation:Required
	// +kubebuilder:validation:Pattern=`^(backward|backward_transitive|forward|forward_transitive|full|full_transitive|none)$`
	// +kubebuilder:default=backward
	Compatibility string `json:"compatibility,omitempty"`
}

KafkaSchemaSpec defines the desired state of KafkaSchema

func (*KafkaSchemaSpec) DeepCopy

func (in *KafkaSchemaSpec) DeepCopy() *KafkaSchemaSpec

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

func (*KafkaSchemaSpec) DeepCopyInto

func (in *KafkaSchemaSpec) DeepCopyInto(out *KafkaSchemaSpec)

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

type KafkaSchemaStatus

type KafkaSchemaStatus struct {

	// Conditions store the status conditions of the KafkaSchema instances
	// +operator-sdk:csv:customresourcedefinitions:type=status
	Conditions []metav1.Condition `json:"conditions,omitempty" patchStrategy:"merge" patchMergeKey:"type" protobuf:"bytes,1,rep,name=conditions"`
}

KafkaSchemaStatus defines the observed state of KafkaSchema

func (*KafkaSchemaStatus) DeepCopy

func (in *KafkaSchemaStatus) DeepCopy() *KafkaSchemaStatus

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

func (*KafkaSchemaStatus) DeepCopyInto

func (in *KafkaSchemaStatus) DeepCopyInto(out *KafkaSchemaStatus)

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.

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 {

	// +required
	// +kubebuilder:validation:Required
	// +kubebuilder:validation:MinLength=3
	// +kubebuilder:validation:MaxLength=255
	// +kubebuilder:validation:Pattern=`^[a-zA-Z0-9\\._\\-]{1,255}$`
	Name string `json:"name"`
	// +optional
	// +kubebuilder:validation:Required
	// +kubebuilder:validation:Pattern=`^(delete|compact)$`
	// +kubebuilder:default=delete
	CleanupPolicy string  `json:"cleanuppolicy,omitempty"`
	Segment       Segment `json:"segment,omitempty"`
	// +required
	// +kubebuilder:validation:Required
	// +kubebuilder:validation:Minimum=1
	Partitions uint `json:"partitions"`
	// +optional
	// +kubebuilder:validation:Required
	// +kubebuilder:validation:Minimum=1
	// +kubebuilder:default=1
	MinInSyncReplicas uint `json:"mininsyncreplicas,omitempty"`
	// +optional
	// +kubebuilder:default=-1
	RetentionHours int `json:"retentionhours,omitempty"`
	// +optional
	// +kubebuilder:default=-1
	RetentionBytes int `json:"retentionbytes,omitempty"`
	// +optional
	// +kubebuilder:default=1048576
	MaxMessageBytes int64 `json:"maxmessagebytes,omitempty"`
	// +required
	// +kubebuilder:validation:Required
	// +kubebuilder:validation:Minimum=1
	// +kubebuilder:default=2
	Replication uint `json:"replication"`
}

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 KafkaTopicStatus

type KafkaTopicStatus struct {

	// Conditions store the status conditions of the KafkaTopic instances
	// +operator-sdk:csv:customresourcedefinitions:type=status
	Conditions []metav1.Condition `json:"conditions,omitempty" patchStrategy:"merge" patchMergeKey:"type" protobuf:"bytes,1,rep,name=conditions"`
}

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 Segment

type Segment struct {
	// This configuration controls the segment file size for the log.
	// Retention and cleaning is always done a file at a time so a larger segment size
	// means fewer files but less granular control over retention.
	// +optional
	// +kubebuilder:default=0
	Bytes uint `json:"bytes,omitempty"`
	// This configuration controls the period of time after which Kafka will force the log
	// to roll even if the segment file isn't full to ensure that retention can delete or
	// compact old data.
	// +optional
	// +kubebuilder:default=0
	MS uint64 `json:"ms,omitempty"`
}

Segment to note Kafka segment size

func (*Segment) DeepCopy

func (in *Segment) DeepCopy() *Segment

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

func (*Segment) DeepCopyInto

func (in *Segment) DeepCopyInto(out *Segment)

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