v1beta1

Documentation

Overview

Package v1beta1 contains API Schema definitions for the dwh v1beta1 API group +k8s:openapi-gen=true +k8s:deepcopy-gen=package,register +k8s:conversion-gen=gitlab.com/zedge-oss/zeppa/event-taxonomy/pkg/apis/dwh +k8s:defaulter-gen=TypeMeta +groupName=dwh.zedge.io

Package v1beta1 contains API Schema definitions for the dwh v1beta1 API group +k8s:openapi-gen=true +k8s:deepcopy-gen=package,register +k8s:conversion-gen=gitlab.com/zedge-oss/zeppa/event-taxonomy/pkg/apis/dwh +k8s:defaulter-gen=TypeMeta +groupName=dwh.zedge.io

Index

• Variables
• func Resource(resource string) schema.GroupResource
• type ClickhouseSpec
  • func (in *ClickhouseSpec) DeepCopy() *ClickhouseSpec
  • func (in *ClickhouseSpec) DeepCopyInto(out *ClickhouseSpec)
  • func (cs *ClickhouseSpec) UnmarshalJSON(data []byte) error
• type ClickhouseTableBinding
  • func (in *ClickhouseTableBinding) DeepCopy() *ClickhouseTableBinding
  • func (in *ClickhouseTableBinding) DeepCopyInto(out *ClickhouseTableBinding)
  • func (tb *ClickhouseTableBinding) UnmarshalJSON(b []byte) error
• type EventTaxonomy
  • func (in *EventTaxonomy) DeepCopy() *EventTaxonomy
  • func (in *EventTaxonomy) DeepCopyInto(out *EventTaxonomy)
  • func (in *EventTaxonomy) DeepCopyObject() runtime.Object
• type EventTaxonomyList
  • func (in *EventTaxonomyList) DeepCopy() *EventTaxonomyList
  • func (in *EventTaxonomyList) DeepCopyInto(out *EventTaxonomyList)
  • func (in *EventTaxonomyList) DeepCopyObject() runtime.Object
• type EventTaxonomySpec
  • func (in *EventTaxonomySpec) DeepCopy() *EventTaxonomySpec
  • func (in *EventTaxonomySpec) DeepCopyInto(out *EventTaxonomySpec)
• type EventTaxonomyStatus
  • func (in *EventTaxonomyStatus) DeepCopy() *EventTaxonomyStatus
  • func (in *EventTaxonomyStatus) DeepCopyInto(out *EventTaxonomyStatus)
• type KafkaSpec
  • func (in *KafkaSpec) DeepCopy() *KafkaSpec
  • func (in *KafkaSpec) DeepCopyInto(out *KafkaSpec)
• type KafkaTopicBinding
  • func (in *KafkaTopicBinding) DeepCopy() *KafkaTopicBinding
  • func (in *KafkaTopicBinding) DeepCopyInto(out *KafkaTopicBinding)

Variables

var (
	// SchemeGroupVersion is group version used to register these objects
	SchemeGroupVersion = schema.GroupVersion{Group: "dwh.zedge.io", Version: "v1beta1"}

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

	// AddToScheme is required by pkg/client/...
	AddToScheme = SchemeBuilder.AddToScheme
)

Functions

func Resource

func Resource(resource string) schema.GroupResource

Resource is required by pkg/client/listers/...

Types

type ClickhouseSpec

type ClickhouseSpec struct {
	// Server should be host:port
	DSN string `json:"dsn"`

	// ClusterName must be set to ensure DDL queries are run with `ON CLUSTER ...`.
	ClusterName string `json:"clusterName,omitempty"`

	// Columns that should be present in all tables for this EventTaxonomy.
	BaseColumns []clickhouse.Column `json:"baseColumns,omitempty"`

	// Deprecated: use BaseColumns instead
	MaterializedColumns []clickhouse.Column      `json:"materializedColumns,omitempty"`
	TableBindings       []ClickhouseTableBinding `json:"tableBindings"`
}

ClickhouseSpec describes the Clickhouse table we're maintaining for this taxonomy

func (*ClickhouseSpec) DeepCopy

func (in *ClickhouseSpec) DeepCopy() *ClickhouseSpec

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

func (*ClickhouseSpec) DeepCopyInto

func (in *ClickhouseSpec) DeepCopyInto(out *ClickhouseSpec)

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

func (*ClickhouseSpec) UnmarshalJSON

func (cs *ClickhouseSpec) UnmarshalJSON(data []byte) error

type ClickhouseTableBinding

type ClickhouseTableBinding struct {
	Lifecycles []model.Lifecycle `json:"lifecycles"`
	// Deprecated: use Table.Database instead
	DatabaseName string `json:"databaseName,omitempty"`
	// Deprecated: use Table.Name instead
	TableName            string            `json:"tableName,omitempty"`
	Table                *clickhouse.Table `json:"table,omitempty"`
	ColumnTTLOverrides   map[string]string `json:"ttlOverrides,omitempty"`
	ColumnCodecOverrides map[string]string `json:"codecOverrides,omitempty"`
}

ClickhouseTableBinding describes a mapping from an event taxonomy to a Clickhouse table. Each binding typically includes event properties and enum fields with a certain set of lifecycles, to create separate tables for beta and production.

func (*ClickhouseTableBinding) DeepCopy

func (in *ClickhouseTableBinding) DeepCopy() *ClickhouseTableBinding

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

func (*ClickhouseTableBinding) DeepCopyInto

func (in *ClickhouseTableBinding) DeepCopyInto(out *ClickhouseTableBinding)

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

func (*ClickhouseTableBinding) UnmarshalJSON

func (tb *ClickhouseTableBinding) UnmarshalJSON(b []byte) error

type EventTaxonomy

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

	Spec   EventTaxonomySpec   `json:"spec,omitempty"`
	Status EventTaxonomyStatus `json:"status,omitempty"`
}

EventTaxonomy is the Schema for the eventtaxonomies API

func (*EventTaxonomy) DeepCopy

func (in *EventTaxonomy) DeepCopy() *EventTaxonomy

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

func (*EventTaxonomy) DeepCopyInto

func (in *EventTaxonomy) DeepCopyInto(out *EventTaxonomy)

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

func (*EventTaxonomy) DeepCopyObject

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

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

type EventTaxonomyList

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

EventTaxonomyList contains a list of EventTaxonomy

func (*EventTaxonomyList) DeepCopy

func (in *EventTaxonomyList) DeepCopy() *EventTaxonomyList

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

func (*EventTaxonomyList) DeepCopyInto

func (in *EventTaxonomyList) DeepCopyInto(out *EventTaxonomyList)

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

func (*EventTaxonomyList) DeepCopyObject

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

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

type EventTaxonomySpec

type EventTaxonomySpec struct {
	Clickhouse   *ClickhouseSpec     `json:"clickhouse,omitempty"`
	Kafka        *KafkaSpec          `json:"kafka,omitempty"`
	Taxonomy     model.EventTaxonomy `json:"taxonomy"`
	TwinTaxonomy string              `json:"twinTaxonomy,omitempty"`
}

EventTaxonomySpec defines the desired state of EventTaxonomy

func (*EventTaxonomySpec) DeepCopy

func (in *EventTaxonomySpec) DeepCopy() *EventTaxonomySpec

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

func (*EventTaxonomySpec) DeepCopyInto

func (in *EventTaxonomySpec) DeepCopyInto(out *EventTaxonomySpec)

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

type EventTaxonomyStatus

type EventTaxonomyStatus struct {
}

EventTaxonomyStatus defines the observed state of EventTaxonomy

func (*EventTaxonomyStatus) DeepCopy

func (in *EventTaxonomyStatus) DeepCopy() *EventTaxonomyStatus

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

func (*EventTaxonomyStatus) DeepCopyInto

func (in *EventTaxonomyStatus) DeepCopyInto(out *EventTaxonomyStatus)

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

type KafkaSpec

type KafkaSpec struct {
	TopicBindings []KafkaTopicBinding `json:"topicBindings"`
}

KafkaSpec defines kafka topic bindings for this taxonomy

func (*KafkaSpec) DeepCopy

func (in *KafkaSpec) DeepCopy() *KafkaSpec

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

func (*KafkaSpec) DeepCopyInto

func (in *KafkaSpec) DeepCopyInto(out *KafkaSpec)

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

type KafkaTopicBinding

type KafkaTopicBinding struct {
	Name       string            `json:"name"`
	Lifecycles []model.Lifecycle `json:"lifecycles,omitempty"`
}

KafkaTopicBinding maps a topic to a list of property and enum field lifecycles

func (*KafkaTopicBinding) DeepCopy

func (in *KafkaTopicBinding) DeepCopy() *KafkaTopicBinding

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

func (*KafkaTopicBinding) DeepCopyInto

func (in *KafkaTopicBinding) DeepCopyInto(out *KafkaTopicBinding)

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