v1alpha1

Documentation

Overview

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

Index

• Variables
• type KsqldbCluster
  • func (in *KsqldbCluster) DeepCopy() *KsqldbCluster
  • func (in *KsqldbCluster) DeepCopyInto(out *KsqldbCluster)
  • func (in *KsqldbCluster) DeepCopyObject() runtime.Object
• type KsqldbClusterList
  • func (in *KsqldbClusterList) DeepCopy() *KsqldbClusterList
  • func (in *KsqldbClusterList) DeepCopyInto(out *KsqldbClusterList)
  • func (in *KsqldbClusterList) DeepCopyObject() runtime.Object
• type KsqldbClusterSpec
  • func (in *KsqldbClusterSpec) DeepCopy() *KsqldbClusterSpec
  • func (in *KsqldbClusterSpec) DeepCopyInto(out *KsqldbClusterSpec)
  • func (spec *KsqldbClusterSpec) DefaultServiceID(namespace, name string)
• type KsqldbClusterStatus
  • func (in *KsqldbClusterStatus) DeepCopy() *KsqldbClusterStatus
  • func (in *KsqldbClusterStatus) DeepCopyInto(out *KsqldbClusterStatus)
• type KsqldbQuery
  • func (in *KsqldbQuery) DeepCopy() *KsqldbQuery
  • func (in *KsqldbQuery) DeepCopyInto(out *KsqldbQuery)
  • func (in *KsqldbQuery) DeepCopyObject() runtime.Object
• type KsqldbQueryList
  • func (in *KsqldbQueryList) DeepCopy() *KsqldbQueryList
  • func (in *KsqldbQueryList) DeepCopyInto(out *KsqldbQueryList)
  • func (in *KsqldbQueryList) DeepCopyObject() runtime.Object
• type KsqldbQuerySpec
  • func (in *KsqldbQuerySpec) DeepCopy() *KsqldbQuerySpec
  • func (in *KsqldbQuerySpec) DeepCopyInto(out *KsqldbQuerySpec)
• type KsqldbQueryStatus
  • func (in *KsqldbQueryStatus) DeepCopy() *KsqldbQueryStatus
  • func (in *KsqldbQueryStatus) DeepCopyInto(out *KsqldbQueryStatus)
• type KsqldbQueryType

Variables

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

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

	Spec   KsqldbClusterSpec   `json:"spec,omitempty"`
	Status KsqldbClusterStatus `json:"status,omitempty"`
}

KsqldbCluster is the Schema for the ksqldbclusters API

func (*KsqldbCluster) DeepCopy

func (in *KsqldbCluster) DeepCopy() *KsqldbCluster

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

func (*KsqldbCluster) DeepCopyInto

func (in *KsqldbCluster) DeepCopyInto(out *KsqldbCluster)

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

func (*KsqldbCluster) DeepCopyObject

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

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

type KsqldbClusterList

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

KsqldbClusterList contains a list of KsqldbCluster

func (*KsqldbClusterList) DeepCopy

func (in *KsqldbClusterList) DeepCopy() *KsqldbClusterList

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

func (*KsqldbClusterList) DeepCopyInto

func (in *KsqldbClusterList) DeepCopyInto(out *KsqldbClusterList)

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

func (*KsqldbClusterList) DeepCopyObject

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

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

type KsqldbClusterSpec

type KsqldbClusterSpec struct {
	// Version/image tag of Ksqldb
	// Default: "latest"
	// +kubebuilder:default=latest
	// +optional
	Version string `json:"version,omitempty"`
	// replicas of Ksqldb Cluster deployment
	// Default: "1"
	// +kubebuilder:default=1
	// +optional
	Replicas int32 `json:"replicas,omitempty"`
	// Bootstrap servers
	// +kubebuilder:validation:MinItems=1
	BootstrapServers []string `json:"bootstrapServers"`
	// e.g. "something_" will be used as a prefix for internal topics
	// Default: "{namespace}_{ksqldb resource name}_"
	// +optional
	ServiceID string `json:"serviceID,omitempty"`
	// number of replicas for KSQL topics (default: 1)
	// +kubebuilder:default=1
	// +optional
	SinkReplicas int `json:"sinkReplicas,omitempty"`
	// replication factor of KSQL internal, command and output topics (default: 3)
	// +kubebuilder:default=3
	// +optional
	StreamReplicationFactor int `json:"streamReplicationFactor,omitempty"`
	// replication factor of KSQL internal topics (default: 3)
	// +kubebuilder:default=3
	// +optional
	InternalTopicReplicas int `json:"internalTopicReplicas,omitempty"`
	// Security Protocol of KSQL Cluster (e.g. "SASL_SSL")
	// +optional
	SecurityProtocol string `json:"securityProtocol,omitempty"`
	// Sasl Mechanism used for Authentication (e.g. "PLAIN")
	// +optional
	SaslMechanism string `json:"saslMechanism,omitempty"`
	// String format of JAAS Config (e.g. "org.apache.kafka.common.security.plain.PlainLoginModule required....")
	// +optional
	SaslJaasConfig string `json:"saslJaasConfig,omitempty"`
	// creation k8s service resource on the ksqldb cluster(default: true)
	// +kubebuilder:default=true
	// +optional
	ServiceResourceDisabled bool `json:"serviceResourceDisabled,omitempty"`
}

serviceID ("KSQL_KSQL_SERVICE_ID") will be created by f

func (*KsqldbClusterSpec) DeepCopy

func (in *KsqldbClusterSpec) DeepCopy() *KsqldbClusterSpec

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

func (*KsqldbClusterSpec) DeepCopyInto

func (in *KsqldbClusterSpec) DeepCopyInto(out *KsqldbClusterSpec)

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

func (*KsqldbClusterSpec) DefaultServiceID

func (spec *KsqldbClusterSpec) DefaultServiceID(namespace, name string)

type KsqldbClusterStatus

type KsqldbClusterStatus struct {
	// +optional
	Version string `json:"version"`
	// +optional
	Replicas int `json:"replica"`
}

KsqldbClusterStatus defines the observed state of KsqldbCluster

func (*KsqldbClusterStatus) DeepCopy

func (in *KsqldbClusterStatus) DeepCopy() *KsqldbClusterStatus

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

func (*KsqldbClusterStatus) DeepCopyInto

func (in *KsqldbClusterStatus) DeepCopyInto(out *KsqldbClusterStatus)

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

type KsqldbQuery

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

	Spec   KsqldbQuerySpec   `json:"spec,omitempty"`
	Status KsqldbQueryStatus `json:"status,omitempty"`
}

KsqldbQuery is the Schema for the ksqldbqueries API

func (*KsqldbQuery) DeepCopy

func (in *KsqldbQuery) DeepCopy() *KsqldbQuery

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

func (*KsqldbQuery) DeepCopyInto

func (in *KsqldbQuery) DeepCopyInto(out *KsqldbQuery)

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

func (*KsqldbQuery) DeepCopyObject

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

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

type KsqldbQueryList

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

KsqldbQueryList contains a list of KsqldbQuery

func (*KsqldbQueryList) DeepCopy

func (in *KsqldbQueryList) DeepCopy() *KsqldbQueryList

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

func (*KsqldbQueryList) DeepCopyInto

func (in *KsqldbQueryList) DeepCopyInto(out *KsqldbQueryList)

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

func (*KsqldbQueryList) DeepCopyObject

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

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

type KsqldbQuerySpec

type KsqldbQuerySpec struct {
	// Name of KsqldbCluster Resource in the same namespace
	KsqldbCluster string `json:"ksqldbCluster"`
	// KSQLDB Query
	Query string `json:"query"`
	// KSQLDB Query type
	// allowed value: "onetime", "stream" (default)
	// + optional
	QueryType KsqldbQueryType `json:"queryType,omitempty"`
}

KsqldbQuerySpec defines the desired state of KsqldbQuery

func (*KsqldbQuerySpec) DeepCopy

func (in *KsqldbQuerySpec) DeepCopy() *KsqldbQuerySpec

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

func (*KsqldbQuerySpec) DeepCopyInto

func (in *KsqldbQuerySpec) DeepCopyInto(out *KsqldbQuerySpec)

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

type KsqldbQueryStatus

type KsqldbQueryStatus struct {
	QueryStatus string `json:"queryStatus"`
}

KsqldbQueryStatus defines the observed state of KsqldbQuery

func (*KsqldbQueryStatus) DeepCopy

func (in *KsqldbQueryStatus) DeepCopy() *KsqldbQueryStatus

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

func (*KsqldbQueryStatus) DeepCopyInto

func (in *KsqldbQueryStatus) DeepCopyInto(out *KsqldbQueryStatus)

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

type KsqldbQueryType

type KsqldbQueryType string

const (
	ONE_TIME KsqldbQueryType = "onetime"
	STREAM   KsqldbQueryType = "stream"
)