v1alpha1

Documentation

Overview

Package v1alpha1 contains API Schema definitions for the operator v1alpha1 API group +k8s:deepcopy-gen=package,register +groupName=operator.serverless.openshift.io

Package v1alpha1 contains API Schema definitions for the operator v1alpha1 API group +k8s:deepcopy-gen=package,register +groupName=operator.serverless.openshift.io

Index

• Variables
• type Channel
  • func (in *Channel) DeepCopy() *Channel
  • func (in *Channel) DeepCopyInto(out *Channel)
• type KnativeKafka
  • func (in *KnativeKafka) DeepCopy() *KnativeKafka
  • func (in *KnativeKafka) DeepCopyInto(out *KnativeKafka)
  • func (in *KnativeKafka) DeepCopyObject() runtime.Object
• type KnativeKafkaList
  • func (in *KnativeKafkaList) DeepCopy() *KnativeKafkaList
  • func (in *KnativeKafkaList) DeepCopyInto(out *KnativeKafkaList)
  • func (in *KnativeKafkaList) DeepCopyObject() runtime.Object
• type KnativeKafkaSpec
  • func (in *KnativeKafkaSpec) DeepCopy() *KnativeKafkaSpec
  • func (in *KnativeKafkaSpec) DeepCopyInto(out *KnativeKafkaSpec)
• type KnativeKafkaStatus
  • func (in *KnativeKafkaStatus) DeepCopy() *KnativeKafkaStatus
  • func (in *KnativeKafkaStatus) DeepCopyInto(out *KnativeKafkaStatus)
  • func (is *KnativeKafkaStatus) InitializeConditions()
  • func (is *KnativeKafkaStatus) IsReady() bool
  • func (is *KnativeKafkaStatus) MarkInstallFailed(msg string)
  • func (is *KnativeKafkaStatus) MarkInstallSucceeded()
• type Source
  • func (in *Source) DeepCopy() *Source
  • func (in *Source) DeepCopyInto(out *Source)

Variables

var (
	// SchemeGroupVersion is group version used to register these objects
	SchemeGroupVersion = schema.GroupVersion{Group: "operator.serverless.openshift.io", Version: "v1alpha1"}

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

Types

type Channel

type Channel struct {
	// Enabled defines if the KafkaChannel installation is enabled
	Enabled bool `json:"enabled"`

	// BootstrapServers is comma separated string of bootstrapservers that the
	// KafkaChannels will use
	// +optional
	BootstrapServers string `json:"bootstrapServers"`
}

Channel allows configuration for KafkaSource installation

func (*Channel) DeepCopy

func (in *Channel) DeepCopy() *Channel

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

func (*Channel) DeepCopyInto

func (in *Channel) DeepCopyInto(out *Channel)

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

type KnativeKafka

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

	Spec   KnativeKafkaSpec   `json:"spec,omitempty"`
	Status KnativeKafkaStatus `json:"status,omitempty"`
}

KnativeKafka is the Schema for the knativekafkas API +k8s:openapi-gen=true +kubebuilder:subresource:status

func (*KnativeKafka) DeepCopy

func (in *KnativeKafka) DeepCopy() *KnativeKafka

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

func (*KnativeKafka) DeepCopyInto

func (in *KnativeKafka) DeepCopyInto(out *KnativeKafka)

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

func (*KnativeKafka) DeepCopyObject

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

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

type KnativeKafkaList

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

KnativeKafkaList contains a list of KnativeKafka

func (*KnativeKafkaList) DeepCopy

func (in *KnativeKafkaList) DeepCopy() *KnativeKafkaList

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

func (*KnativeKafkaList) DeepCopyInto

func (in *KnativeKafkaList) DeepCopyInto(out *KnativeKafkaList)

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

func (*KnativeKafkaList) DeepCopyObject

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

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

type KnativeKafkaSpec

type KnativeKafkaSpec struct {
	// Allows configuration for KafkaSource installation
	// +optional
	Source Source `json:"source,omitempty"`

	// Allows configuration for KafkaChannel installation
	// +optional
	Channel Channel `json:"channel,omitempty"`
}

KnativeKafkaSpec defines the desired state of KnativeKafka +k8s:openapi-gen=true

func (*KnativeKafkaSpec) DeepCopy

func (in *KnativeKafkaSpec) DeepCopy() *KnativeKafkaSpec

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

func (*KnativeKafkaSpec) DeepCopyInto

func (in *KnativeKafkaSpec) DeepCopyInto(out *KnativeKafkaSpec)

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

type KnativeKafkaStatus

type KnativeKafkaStatus struct {
	duckv1.Status `json:",inline"`

	// The version of the installed release
	// +optional
	Version string `json:"version,omitempty"`
}

KnativeKafkaStatus defines the observed state of KnativeKafka +k8s:openapi-gen=true

func (*KnativeKafkaStatus) DeepCopy

func (in *KnativeKafkaStatus) DeepCopy() *KnativeKafkaStatus

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

func (*KnativeKafkaStatus) DeepCopyInto

func (in *KnativeKafkaStatus) DeepCopyInto(out *KnativeKafkaStatus)

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

func (*KnativeKafkaStatus) InitializeConditions

func (is *KnativeKafkaStatus) InitializeConditions()

InitializeConditions initializes conditions of an KnativeKafkaStatus

func (*KnativeKafkaStatus) IsReady

func (is *KnativeKafkaStatus) IsReady() bool

IsReady looks at the conditions returns true if they are all true.

func (*KnativeKafkaStatus) MarkInstallFailed

func (is *KnativeKafkaStatus) MarkInstallFailed(msg string)

MarkInstallFailed marks the InstallationSucceeded status as false with the given message.

func (*KnativeKafkaStatus) MarkInstallSucceeded

func (is *KnativeKafkaStatus) MarkInstallSucceeded()

MarkInstallSucceeded marks the InstallationSucceeded status as true.

type Source

type Source struct {
	// Enabled defines if the KafkaSource installation is enabled
	Enabled bool `json:"enabled"`
}

Source allows configuration for KafkaSource installation

func (*Source) DeepCopy

func (in *Source) DeepCopy() *Source

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

func (*Source) DeepCopyInto

func (in *Source) DeepCopyInto(out *Source)

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