v1alpha1

package
v0.20.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 12, 2021 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Overview

+k8s:deepcopy-gen=package +groupName=eventing.knative.dev

Index

Constants

View Source 
const (
	// CloudEvents binary content mode.
	ModeBinary = "binary"
	// CloudEvents structured content mode.
	ModeStructured = "structured"
)
View Source 
const (
	ConditionAddressable apis.ConditionType = "Addressable"
)

Variables

View Source 
var (
	SchemeBuilder = runtime.NewSchemeBuilder(addKnownTypes)
	AddToScheme   = SchemeBuilder.AddToScheme
)
View Source 
var SchemeGroupVersion = schema.GroupVersion{Group: eventing.GroupName, Version: "v1alpha1"}

SchemeGroupVersion is group version used to register these objects.

Functions

func ErrImmutableField 

func ErrImmutableField(field string) *apis.FieldError

func Kind 

func Kind(kind string) schema.GroupKind

Kind takes an unqualified kind and returns back a Group qualified GroupKind.

func RegisterConditionSet 

func RegisterConditionSet(cs apis.ConditionSet)

func Resource 

func Resource(resource string) schema.GroupResource

Resource takes an unqualified resource and returns a Group qualified GroupResource.

Types

type KafkaSink 

type KafkaSink struct {
	metav1.TypeMeta `json:",inline"`

	// +optional
	metav1.ObjectMeta `json:"metadata,omitempty"`

	// Spec defines the desired state of the Kafka Sink.
	Spec KafkaSinkSpec `json:"spec,omitempty"`

	// Status represents the current state of the KafkaSink.
	// This data may be out of date.
	// +optional
	Status KafkaSinkStatus `json:"status,omitempty"`
}

KafkaSink is an addressable resource that represent a Kafka topic.

func (*KafkaSink) CheckImmutableFields 

func (ks *KafkaSink) CheckImmutableFields(ctx context.Context, original *KafkaSink) *apis.FieldError

func (*KafkaSink) ConvertFrom 

func (ks *KafkaSink) ConvertFrom(ctx context.Context, from apis.Convertible) error

func (*KafkaSink) ConvertTo 

func (ks *KafkaSink) ConvertTo(ctx context.Context, to apis.Convertible) error

func (*KafkaSink) DeepCopy 

func (in *KafkaSink) DeepCopy() *KafkaSink

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

func (*KafkaSink) DeepCopyInto 

func (in *KafkaSink) DeepCopyInto(out *KafkaSink)

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

func (*KafkaSink) DeepCopyObject 

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

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

func (*KafkaSink) GetConditionSet 

func (ks *KafkaSink) GetConditionSet() apis.ConditionSet

func (*KafkaSink) GetGroupVersionKind 

func (ks *KafkaSink) GetGroupVersionKind() schema.GroupVersionKind

GetGroupVersionKind returns GroupVersionKind for KafkaSinks.

func (*KafkaSink) GetStatus 

func (ks *KafkaSink) GetStatus() *duckv1.Status

GetStatus retrieves the status of the Kafka Sink. Implements the KRShaped interface.

func (*KafkaSink) GetUntypedSpec 

func (ks *KafkaSink) GetUntypedSpec() interface{}

GetUntypedSpec returns the spec of the Kafka Sink.

func (*KafkaSink) SetDefaults 

func (ks *KafkaSink) SetDefaults(ctx context.Context)

SetDefaults sets KafkaSink defaults.

func (*KafkaSink) Validate 

func (ks *KafkaSink) Validate(ctx context.Context) *apis.FieldError

type KafkaSinkList 

type KafkaSinkList struct {
	metav1.TypeMeta `json:",inline"`
	// +optional
	metav1.ListMeta `json:"metadata,omitempty"`

	Items []KafkaSink `json:"items"`
}

KafkaSinkList defines a list of Kafka Sink.

func (*KafkaSinkList) DeepCopy 

func (in *KafkaSinkList) DeepCopy() *KafkaSinkList

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

func (*KafkaSinkList) DeepCopyInto 

func (in *KafkaSinkList) DeepCopyInto(out *KafkaSinkList)

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

func (*KafkaSinkList) DeepCopyObject 

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

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

type KafkaSinkSpec 

type KafkaSinkSpec struct {

	// Topic name to send events.
	Topic string `json:"topic"`

	// Number of topic partitions.
	// +optional
	NumPartitions *int32 `json:"numPartitions,omitempty"`

	// Topic replication factor
	// +optional
	ReplicationFactor *int16 `json:"replicationFactor,omitempty"`

	// Kafka Broker bootstrap servers.
	BootstrapServers []string `json:"bootstrapServers"`

	// CloudEvent content mode of Kafka messages sent to the topic.
	// Possible values:
	// - structured
	// - binary
	//
	// - default: structured.
	//
	// - https://github.com/cloudevents/spec/blob/v1.0/spec.md#message
	//	 - https://github.com/cloudevents/spec/blob/v1.0/kafka-protocol-binding.md#33-structured-content-mode
	//	 - https://github.com/cloudevents/spec/blob/v1.0/kafka-protocol-binding.md#32-binary-content-mode'
	//
	// +optional
	ContentMode *string `json:"contentMode,omitempty"`
}

KafkaSinkSpec defines the desired state of the Kafka Sink.

func (*KafkaSinkSpec) CheckImmutableFields 

func (kss *KafkaSinkSpec) CheckImmutableFields(ctx context.Context, original *KafkaSinkSpec) *apis.FieldError

func (*KafkaSinkSpec) DeepCopy 

func (in *KafkaSinkSpec) DeepCopy() *KafkaSinkSpec

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

func (*KafkaSinkSpec) DeepCopyInto 

func (in *KafkaSinkSpec) DeepCopyInto(out *KafkaSinkSpec)

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

func (*KafkaSinkSpec) SetDefaults 

func (kss *KafkaSinkSpec) SetDefaults(ctx context.Context)

SetDefaults sets KafkaSinkSpec defaults.

func (*KafkaSinkSpec) Validate 

func (kss *KafkaSinkSpec) Validate(ctx context.Context) *apis.FieldError

type KafkaSinkStatus 

type KafkaSinkStatus struct {
	// inherits duck/v1 Status, which currently provides:
	// * ObservedGeneration - the 'Generation' of the Kafka Sink that was last processed by the controller.
	// * Conditions - the latest available observations of a resource's current state.
	duckv1.Status `json:",inline"`

	// Kafka Sink is Addressable.
	Address duckv1.Addressable `json:"address,omitempty"`
}

KafkaSinkStatus represents the current state of the KafkaSink.

func (*KafkaSinkStatus) DeepCopy 

func (in *KafkaSinkStatus) DeepCopy() *KafkaSinkStatus

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

func (*KafkaSinkStatus) DeepCopyInto 

func (in *KafkaSinkStatus) DeepCopyInto(out *KafkaSinkStatus)

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

func (*KafkaSinkStatus) GetConditionSet 

func (ks *KafkaSinkStatus) GetConditionSet() apis.ConditionSet

func (*KafkaSinkStatus) InitializeConditions 

func (kss *KafkaSinkStatus) InitializeConditions()

InitializeConditions sets relevant unset conditions to Unknown state.

func (*KafkaSinkStatus) SetAddress 

func (ks *KafkaSinkStatus) SetAddress(url *apis.URL)

SetAddress makes this Kafka Sink addressable by setting the URI. It also sets the ConditionAddressable to true.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.