v1

Documentation

Index

• Constants
• Variables
• 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
• type KafkaTopicStatus

Constants

const GroupName = "kafka.steeleye.co"

const GroupVersion = "v1"

Variables

var (
	SchemeBuilder = runtime.NewSchemeBuilder(addKnownTypes)
	AddToScheme   = SchemeBuilder.AddToScheme
)

var SchemeGroupVersion = schema.GroupVersion{Group: GroupName, Version: GroupVersion}

Types

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

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"`
}

+k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object

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,omitempty"`
	Partitions int32              `json:"partitions,omitempty"`
	Replicas   int16              `json:"replicas,omitempty"`
	Config     map[string]*string `json:"config,omitempty"`
}

type KafkaTopicStatus

type KafkaTopicStatus struct {
	Name       string             `json:"name,omitempty"`
	Partitions int32              `json:"partitions,omitempty"`
	Replicas   int16              `json:"replicas,omitempty"`
	Error      string             `json:"error,omitempty"`
	Config     map[string]*string `json:"config,omitempty"`
}