v1alpha1

package
v0.38.13 Latest Latest
Warning

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

 Go to latest Published: Feb 8, 2024 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Overview

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

Index

Constants

View Source 
const (
	ConditionConsumerGroupConsumers          apis.ConditionType = "Consumers"
	ConditionConsumerGroupConsumersScheduled apis.ConditionType = "ConsumersScheduled"
	ConditionAutoscaling                     apis.ConditionType = "Autoscaler"
	// Labels
	KafkaChannelNameLabel           = "kafkachannel-name"
	ConsumerLabelSelector           = "kafka.eventing.knative.dev/metadata.uid"
	UserFacingResourceLabelSelector = "kafka.eventing.knative.dev/metadata.kind"
)
View Source 
const (
	ConsumerConditionContract = "Contract"
	ConsumerConditionBind     = "Bind"
)
View Source 
const (
	SourceStatefulSetName  = "kafka-source-dispatcher"
	ChannelStatefulSetName = "kafka-channel-dispatcher"
	BrokerStatefulSetName  = "kafka-broker-dispatcher"
)
View Source 
const (
	DispatcherVolumeName = "contract-resources"
)

Variables

View Source 
var (
	SchemeBuilder = runtime.NewSchemeBuilder(addKnownTypes)
	AddToScheme   = SchemeBuilder.AddToScheme
)
View Source 
var ConsumerGroupGroupVersionKind = schema.GroupVersionKind{
	Group:   SchemeGroupVersion.Group,
	Version: SchemeGroupVersion.Version,
	Kind:    "ConsumerGroup",
}
View Source 
var ConsumerGroupVersionKind = schema.GroupVersionKind{
	Group:   SchemeGroupVersion.Group,
	Version: SchemeGroupVersion.Version,
	Kind:    "Consumer",
}
View Source 
var SchemeGroupVersion = schema.GroupVersion{Group: kafkaeventing.GroupName, Version: "v1alpha1"}

SchemeGroupVersion is group version used to register these objects.

Functions

func ErrImmutableField added in v0.29.0 

func ErrImmutableField(field, details string) *apis.FieldError

func IsKnownStatefulSet added in v0.30.0 

func IsKnownStatefulSet(name string) bool

func Kind 

func Kind(kind string) schema.GroupKind

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

func Resource 

func Resource(resource string) schema.GroupResource

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

Types

type Auth added in v0.29.0 

type Auth struct {
	NetSpec *bindings.KafkaNetSpec
	// Deprecated, use secret spec
	AuthSpec   *eventingv1alpha1.Auth `json:"AuthSpec,omitempty"`
	SecretSpec *SecretSpec
}

func (*Auth) DeepCopy added in v0.29.0 

func (in *Auth) DeepCopy() *Auth

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

func (*Auth) DeepCopyInto added in v0.29.0 

func (in *Auth) DeepCopyInto(out *Auth)

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

type ByReadinessAndCreationTime added in v0.30.0 

type ByReadinessAndCreationTime []*Consumer

func (ByReadinessAndCreationTime) DeepCopy added in v0.30.0 

func (in ByReadinessAndCreationTime) DeepCopy() ByReadinessAndCreationTime

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

func (ByReadinessAndCreationTime) DeepCopyInto added in v0.30.0 

func (in ByReadinessAndCreationTime) DeepCopyInto(out *ByReadinessAndCreationTime)

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

func (ByReadinessAndCreationTime) Len added in v0.30.0 

func (consumers ByReadinessAndCreationTime) Len() int

func (ByReadinessAndCreationTime) Less added in v0.30.0 

func (consumers ByReadinessAndCreationTime) Less(i, j int) bool

func (ByReadinessAndCreationTime) Swap added in v0.30.0 

func (consumers ByReadinessAndCreationTime) Swap(i, j int)

type Consumer 

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

	// Standard object's metadata.
	// More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#metadata
	// +optional
	metav1.ObjectMeta `json:"metadata,omitempty"`

	// Specification of the desired behavior of the consumer.
	// More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#spec-and-status
	Spec ConsumerSpec `json:"spec"`

	// Most recently observed status of the Consumer.
	// This data may not be up-to-date.
	// Populated by the system.
	// Read-only.
	// More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#spec-and-status
	// +optional
	Status ConsumerStatus `json:"status,omitempty"`
}

func (*Consumer) DeepCopy 

func (in *Consumer) DeepCopy() *Consumer

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

func (*Consumer) DeepCopyInto 

func (in *Consumer) DeepCopyInto(out *Consumer)

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

func (*Consumer) DeepCopyObject 

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

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

func (*Consumer) GetConditionSet 

func (c *Consumer) GetConditionSet() apis.ConditionSet

func (*Consumer) GetConsumerGroup added in v0.29.0 

func (c *Consumer) GetConsumerGroup() *metav1.OwnerReference

GetConsumerGroup gets the resource reference to the ConsumerGroup using the OwnerReference list.

func (*Consumer) GetGroupVersionKind 

func (c *Consumer) GetGroupVersionKind() schema.GroupVersionKind

GetGroupVersionKind returns GroupVersionKind for Consumer.

func (*Consumer) GetStatus 

func (c *Consumer) GetStatus() *duckv1.Status

GetStatus retrieves the status of the Consumer. Implements the KRShaped interface.

func (*Consumer) GetUntypedSpec 

func (c *Consumer) GetUntypedSpec() interface{}

GetUntypedSpec returns the spec of the Consumer.

func (Consumer) HasDeadLetterSink added in v0.30.0 

func (c Consumer) HasDeadLetterSink() bool

func (*Consumer) IsReady 

func (c *Consumer) IsReady() bool

func (*Consumer) MarkBindFailed added in v0.29.0 

func (c *Consumer) MarkBindFailed(err error) reconciler.Event

func (*Consumer) MarkBindInProgress added in v0.29.0 

func (c *Consumer) MarkBindInProgress()

func (*Consumer) MarkBindSucceeded added in v0.29.0 

func (c *Consumer) MarkBindSucceeded()

func (*Consumer) MarkReconcileContractFailed added in v0.29.0 

func (c *Consumer) MarkReconcileContractFailed(err error) reconciler.Event

func (*Consumer) MarkReconcileContractSucceeded added in v0.29.0 

func (c *Consumer) MarkReconcileContractSucceeded()

func (*Consumer) SetDefaults 

func (c *Consumer) SetDefaults(ctx context.Context)

SetDefaults implements apis.Defaultable.

func (*Consumer) Validate added in v0.29.0 

func (c *Consumer) Validate(ctx context.Context) *apis.FieldError

type ConsumerConfigs 

type ConsumerConfigs struct {
	// +optional
	Configs map[string]string `json:",inline,omitempty"`

	// key-type label value
	// Possible values:
	// - "byte-array"
	// - "string":
	// - "int":
	// - "float":
	//
	// Default value: string
	KeyType *string `json:"keyType,omitempty"`
}

ConsumerConfigs are the Consumer configurations. More info: https://kafka.apache.org/documentation/#consumerconfigs

func (*ConsumerConfigs) DeepCopy 

func (in *ConsumerConfigs) DeepCopy() *ConsumerConfigs

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

func (*ConsumerConfigs) DeepCopyInto 

func (in *ConsumerConfigs) DeepCopyInto(out *ConsumerConfigs)

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

func (*ConsumerConfigs) Validate 

func (cc *ConsumerConfigs) Validate(ctx context.Context) *apis.FieldError

type ConsumerGroup 

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

	// Standard object's metadata.
	// More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#metadata
	// +optional
	metav1.ObjectMeta `json:"metadata,omitempty"`

	// Specification of the desired behavior of the ConsumerGroup.
	// More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#spec-and-status
	// +optional
	Spec ConsumerGroupSpec `json:"spec,omitempty"`

	// Most recently observed status of the ConsumerGroup.
	// This data may not be up-to-date.
	// Populated by the system.
	// Read-only.
	// More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#spec-and-status
	// +optional
	Status ConsumerGroupStatus `json:"status,omitempty"`
}

func (*ConsumerGroup) CheckImmutableFields added in v0.30.0 

func (c *ConsumerGroup) CheckImmutableFields(ctx context.Context, original map[string]string) *apis.FieldError

func (*ConsumerGroup) ConsumerFromTemplate 

func (cg *ConsumerGroup) ConsumerFromTemplate(options ...ConsumerOption) *Consumer

ConsumerFromTemplate returns a Consumer from the Consumer template in the ConsumerGroup spec.

func (*ConsumerGroup) DeepCopy 

func (in *ConsumerGroup) DeepCopy() *ConsumerGroup

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

func (*ConsumerGroup) DeepCopyInto 

func (in *ConsumerGroup) DeepCopyInto(out *ConsumerGroup)

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

func (*ConsumerGroup) DeepCopyObject 

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

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

func (*ConsumerGroup) GetConditionSet 

func (c *ConsumerGroup) GetConditionSet() apis.ConditionSet

func (*ConsumerGroup) GetGroupVersionKind 

func (c *ConsumerGroup) GetGroupVersionKind() schema.GroupVersionKind

GetGroupVersionKind returns GroupVersionKind for ConsumerGroup.

func (*ConsumerGroup) GetKey added in v0.29.0 

func (cg *ConsumerGroup) GetKey() types.NamespacedName

GetKey implements scheduler.VPod interface.

func (*ConsumerGroup) GetPlacements added in v0.29.0 

func (cg *ConsumerGroup) GetPlacements() []eventingduckv1alpha1.Placement

GetPlacements implements scheduler.VPod interface.

func (*ConsumerGroup) GetResourceVersion added in v0.30.0 

func (cg *ConsumerGroup) GetResourceVersion() string

func (*ConsumerGroup) GetStatus 

func (c *ConsumerGroup) GetStatus() *duckv1.Status

GetStatus retrieves the status of the ConsumerGroup. Implements the KRShaped interface.

func (*ConsumerGroup) GetUntypedSpec 

func (c *ConsumerGroup) GetUntypedSpec() interface{}

GetUntypedSpec returns the spec of the ConsumerGroup.

func (*ConsumerGroup) GetUserFacingResourceRef added in v0.29.0 

func (cg *ConsumerGroup) GetUserFacingResourceRef() *metav1.OwnerReference

GetUserFacingResourceRef gets the resource reference to the user-facing resources that are backed by this ConsumerGroup using the OwnerReference list.

func (*ConsumerGroup) GetVReplicas added in v0.29.0 

func (cg *ConsumerGroup) GetVReplicas() int32

GetVReplicas implements scheduler.VPod interface.

func (*ConsumerGroup) HasDeadLetterSink added in v0.30.0 

func (cg *ConsumerGroup) HasDeadLetterSink() bool

func (*ConsumerGroup) InitializeConditions added in v0.31.0 

func (cg *ConsumerGroup) InitializeConditions()

func (*ConsumerGroup) IsNotScheduled added in v0.29.0 

func (cg *ConsumerGroup) IsNotScheduled() bool

func (*ConsumerGroup) IsReady added in v0.29.0 

func (cg *ConsumerGroup) IsReady() bool

func (*ConsumerGroup) MarkAutoscalerDisabled added in v0.35.0 

func (cg *ConsumerGroup) MarkAutoscalerDisabled()

func (*ConsumerGroup) MarkAutoscalerFailed added in v0.35.0 

func (cg *ConsumerGroup) MarkAutoscalerFailed(reason string, err error) error

func (*ConsumerGroup) MarkAutoscalerSucceeded added in v0.35.0 

func (cg *ConsumerGroup) MarkAutoscalerSucceeded()

func (*ConsumerGroup) MarkDeleteOffsetFailed added in v0.37.7 

func (cg *ConsumerGroup) MarkDeleteOffsetFailed(reason string, err error) error

func (*ConsumerGroup) MarkInitializeOffsetFailed added in v0.31.0 

func (cg *ConsumerGroup) MarkInitializeOffsetFailed(reason string, err error) error

func (*ConsumerGroup) MarkReconcileConsumersFailed 

func (cg *ConsumerGroup) MarkReconcileConsumersFailed(reason string, err error) error

func (*ConsumerGroup) MarkReconcileConsumersFailedCondition added in v0.34.0 

func (cg *ConsumerGroup) MarkReconcileConsumersFailedCondition(condition *apis.Condition) error

func (*ConsumerGroup) MarkReconcileConsumersSucceeded 

func (cg *ConsumerGroup) MarkReconcileConsumersSucceeded()

func (*ConsumerGroup) MarkScheduleConsumerFailed added in v0.29.0 

func (cg *ConsumerGroup) MarkScheduleConsumerFailed(reason string, err error) error

func (*ConsumerGroup) MarkScheduleSucceeded added in v0.29.0 

func (cg *ConsumerGroup) MarkScheduleSucceeded()

func (*ConsumerGroup) SetDefaults 

func (cg *ConsumerGroup) SetDefaults(ctx context.Context)

SetDefaults implements apis.Defaultable.

func (*ConsumerGroup) Validate 

func (c *ConsumerGroup) Validate(ctx context.Context) *apis.FieldError

type ConsumerGroupList 

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

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

ConsumerGroupList defines a list of consumer groups.

func (*ConsumerGroupList) DeepCopy 

func (in *ConsumerGroupList) DeepCopy() *ConsumerGroupList

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

func (*ConsumerGroupList) DeepCopyInto 

func (in *ConsumerGroupList) DeepCopyInto(out *ConsumerGroupList)

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

func (*ConsumerGroupList) DeepCopyObject 

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

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

type ConsumerGroupSpec 

type ConsumerGroupSpec struct {

	// Template is the object that describes the consumer that will be created if
	// insufficient replicas are detected. Each consumer stamped out by the
	// ConsumerGroup will fulfill this Template, but have a unique identity from
	// the rest of the ConsumerGroup.
	Template ConsumerTemplateSpec `json:"template"`

	// Replicas is the desired number of replicas of the given Template.
	// These are replicas in the sense that they are instantiations of the
	// same Template, but individual replicas also have a consistent identity.
	// If unspecified, defaults to 1.
	// +optional
	Replicas *int32 `json:"replicas,omitempty"`

	// Selector is a label query over consumers that should match the Replicas count.
	// If Selector is empty, it is defaulted to the labels present on the template.
	// Label keys and values that must match in order to be controlled by this
	// controller, if empty defaulted to labels on template.
	// More info: https://kubernetes.io/docs/concepts/overview/working-with-objects/labels/#label-selectors
	// +optional
	Selector map[string]string `json:"selector,omitempty" protobuf:"bytes,2,rep,name=selector"`
}

func (*ConsumerGroupSpec) DeepCopy 

func (in *ConsumerGroupSpec) DeepCopy() *ConsumerGroupSpec

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

func (*ConsumerGroupSpec) DeepCopyInto 

func (in *ConsumerGroupSpec) DeepCopyInto(out *ConsumerGroupSpec)

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

func (*ConsumerGroupSpec) Validate 

func (cgs *ConsumerGroupSpec) Validate(ctx context.Context) *apis.FieldError

type ConsumerGroupStatus 

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

	// inherits PlaceableStatus Status
	eventingduckv1alpha1.PlaceableStatus `json:",inline"`

	// SubscriberURI is the resolved URI of the receiver for this Trigger.
	// +optional
	SubscriberURI *apis.URL `json:"subscriberUri,omitempty"`

	// DeliveryStatus contains a resolved URL to the dead letter sink address, and any other
	// resolved delivery options.
	eventingduckv1.DeliveryStatus `json:",inline"`

	// Replicas is the latest observed number of replicas of the given Template.
	// These are replicas in the sense that they are instantiations of the
	// same Template, but individual replicas also have a consistent identity.
	// +optional
	Replicas *int32 `json:"replicas,omitempty"`
}

func (*ConsumerGroupStatus) DeepCopy 

func (in *ConsumerGroupStatus) DeepCopy() *ConsumerGroupStatus

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

func (*ConsumerGroupStatus) DeepCopyInto 

func (in *ConsumerGroupStatus) DeepCopyInto(out *ConsumerGroupStatus)

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

type ConsumerList 

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

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

ConsumerList defines a list of Consumers.

func (*ConsumerList) DeepCopy 

func (in *ConsumerList) DeepCopy() *ConsumerList

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

func (*ConsumerList) DeepCopyInto 

func (in *ConsumerList) DeepCopyInto(out *ConsumerList)

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

func (*ConsumerList) DeepCopyObject 

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

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

type ConsumerOption 

type ConsumerOption func(consumer *Consumer)

ConsumerOption is a functional option for Consumer.

type ConsumerSpec 

type ConsumerSpec struct {
	// Topics is the list of topics to subscribe to.
	Topics []string `json:"topics"`

	// Configs are the Consumer configurations.
	// More info: https://kafka.apache.org/documentation/#consumerconfigs
	Configs ConsumerConfigs `json:"configs,omitempty"`

	// Auth is the auth configuration for the Consumer.
	// +optional
	Auth *Auth `json:"auth,omitempty"`

	// DeliverySpec contains the delivery options for event senders.
	// +optional
	Delivery *DeliverySpec `json:"delivery,omitempty"`

	// Reply is the strategy to handle event replies.
	// +optional
	Reply *ReplyStrategy `json:"reply,omitempty"`

	// Filters is a set of filters.
	// +optional
	Filters *Filters `json:"filters,omitempty"`

	// Subscriber is the addressable that receives events that pass the Filters.
	Subscriber duckv1.Destination `json:"subscriber"`

	// CloudEventOverrides defines overrides to control the output format and
	// modifications of the event sent to the subscriber.
	// +optional
	CloudEventOverrides *duckv1.CloudEventOverrides `json:"ceOverrides,omitempty"`

	// VReplicas is the number of virtual replicas for a consumer.
	VReplicas *int32 `json:"vReplicas"`

	// PodBind represents a reference to the pod in which the consumer should be placed.
	PodBind *PodBind `json:"podBind"`
}

func (*ConsumerSpec) DeepCopy 

func (in *ConsumerSpec) DeepCopy() *ConsumerSpec

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

func (*ConsumerSpec) DeepCopyInto 

func (in *ConsumerSpec) DeepCopyInto(out *ConsumerSpec)

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

func (*ConsumerSpec) SetDefaults 

func (c *ConsumerSpec) SetDefaults(ctx context.Context)

func (*ConsumerSpec) Validate 

func (cs *ConsumerSpec) Validate(ctx context.Context) *apis.FieldError

type ConsumerStatus 

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

	// SubscriberURI is the resolved URI of the receiver for this Trigger.
	// +optional
	SubscriberURI *apis.URL `json:"subscriberUri,omitempty"`

	// DeliveryStatus contains a resolved URL to the dead letter sink address, and any other
	// resolved delivery options.
	eventingduck.DeliveryStatus `json:",inline"`
}

func (*ConsumerStatus) DeepCopy 

func (in *ConsumerStatus) DeepCopy() *ConsumerStatus

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

func (*ConsumerStatus) DeepCopyInto 

func (in *ConsumerStatus) DeepCopyInto(out *ConsumerStatus)

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

type ConsumerTemplateSpec 

type ConsumerTemplateSpec struct {

	// Standard object's metadata.
	// More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#metadata
	// +optional
	metav1.ObjectMeta `json:"metadata,omitempty"`

	// Specification of the desired behavior of the consumer.
	// More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#spec-and-status
	// +optional
	Spec ConsumerSpec `json:"spec,omitempty"`
}

ConsumerTemplateSpec describes the data a consumer should have when created from a template.

func (*ConsumerTemplateSpec) DeepCopy 

func (in *ConsumerTemplateSpec) DeepCopy() *ConsumerTemplateSpec

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

func (*ConsumerTemplateSpec) DeepCopyInto 

func (in *ConsumerTemplateSpec) DeepCopyInto(out *ConsumerTemplateSpec)

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

func (*ConsumerTemplateSpec) Validate 

func (cts *ConsumerTemplateSpec) Validate(ctx context.Context) *apis.FieldError

type DeliverySpec 

type DeliverySpec struct {
	// DeliverySpec is the Knative core delivery spec.
	// DeliverySpec contains the delivery options for event senders.
	*eventingduck.DeliverySpec `json:",inline,omitempty"`

	// Ordering is the ordering of the event delivery.
	Ordering sources.DeliveryOrdering `json:"ordering"`

	// InitialOffset initial offset.
	InitialOffset sources.Offset `json:"initialOffset"`
}

func (*DeliverySpec) DeepCopy 

func (in *DeliverySpec) DeepCopy() *DeliverySpec

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

func (*DeliverySpec) DeepCopyInto 

func (in *DeliverySpec) DeepCopyInto(out *DeliverySpec)

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

func (*DeliverySpec) SetDefaults 

func (d *DeliverySpec) SetDefaults(ctx context.Context)

func (*DeliverySpec) Validate 

func (d *DeliverySpec) Validate(ctx context.Context) *apis.FieldError

type DestinationReply added in v0.29.0 

type DestinationReply struct {
	Enabled     bool `json:"enabled"`
	Destination duckv1.Destination
}

func (*DestinationReply) DeepCopy added in v0.29.0 

func (in *DestinationReply) DeepCopy() *DestinationReply

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

func (*DestinationReply) DeepCopyInto added in v0.29.0 

func (in *DestinationReply) DeepCopyInto(out *DestinationReply)

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

type Filters 

type Filters struct {

	// Filter is the filter to apply against all events from the Broker. Only events that pass this
	// filter will be sent to the Subscriber. If not specified, will default to allowing all events.
	//
	// +optional
	Filter *eventing.TriggerFilter `json:"filter,omitempty"`

	// Filters is an experimental field that conforms to the CNCF CloudEvents Subscriptions
	// API. It's an array of filter expressions that evaluate to true or false.
	// If any filter expression in the array evaluates to false, the event MUST
	// NOT be sent to the Subscriber. If all the filter expressions in the array
	// evaluate to true, the event MUST be attempted to be delivered. Absence of
	// a filter or empty array implies a value of true. In the event of users
	// specifying both Filters and Filters, then the latter will override the former.
	// This will allow users to try out the effect of the new Filters field
	// without compromising the existing attribute-based Filters and try it out on existing
	// Trigger objects.
	//
	// +optional
	Filters []eventing.SubscriptionsAPIFilter `json:"filters,omitempty"`
}

Filters is the filter to apply against all events. Only events that pass this filter will be sent to the Subscriber. If not specified, will default to allowing all events.

func (*Filters) DeepCopy 

func (in *Filters) DeepCopy() *Filters

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

func (*Filters) DeepCopyInto 

func (in *Filters) DeepCopyInto(out *Filters)

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

func (*Filters) Validate 

func (f *Filters) Validate(ctx context.Context) *apis.FieldError

type NoReply added in v0.30.0 

type NoReply struct {
	Enabled bool `json:"enabled"`
}

func (*NoReply) DeepCopy added in v0.30.0 

func (in *NoReply) DeepCopy() *NoReply

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

func (*NoReply) DeepCopyInto added in v0.30.0 

func (in *NoReply) DeepCopyInto(out *NoReply)

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

type PodBind added in v0.29.0 

type PodBind struct {
	PodName      string `json:"podName"`
	PodNamespace string `json:"podNamespace"`
}

PodBind is a reference to a corev1.Pod.

func (PodBind) CheckImmutableFields added in v0.29.0 

func (p PodBind) CheckImmutableFields(ctx context.Context, original *PodBind) *apis.FieldError

func (*PodBind) DeepCopy added in v0.29.0 

func (in *PodBind) DeepCopy() *PodBind

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

func (*PodBind) DeepCopyInto added in v0.29.0 

func (in *PodBind) DeepCopyInto(out *PodBind)

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

func (*PodBind) Validate added in v0.29.0 

func (p *PodBind) Validate(ctx context.Context) *apis.FieldError

type ReplyStrategy added in v0.29.0 

type ReplyStrategy struct {
	TopicReply *TopicReply       `json:"topicReply,omitempty"`
	URLReply   *DestinationReply `json:"URLReply,omitempty"`
	NoReply    *NoReply          `json:"noReply,omitempty"`
}

func (*ReplyStrategy) DeepCopy added in v0.29.0 

func (in *ReplyStrategy) DeepCopy() *ReplyStrategy

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

func (*ReplyStrategy) DeepCopyInto added in v0.29.0 

func (in *ReplyStrategy) DeepCopyInto(out *ReplyStrategy)

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

func (*ReplyStrategy) Validate added in v0.30.0 

func (in *ReplyStrategy) Validate(ctx context.Context) *apis.FieldError

type SecretReference added in v0.36.0 

type SecretReference struct {
	Name      string `json:"name"`
	Namespace string `json:"namespace"`
}

func (*SecretReference) DeepCopy added in v0.36.0 

func (in *SecretReference) DeepCopy() *SecretReference

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

func (*SecretReference) DeepCopyInto added in v0.36.0 

func (in *SecretReference) DeepCopyInto(out *SecretReference)

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

type SecretSpec added in v0.36.0 

type SecretSpec struct {
	// Secret reference for SASL and SSL configurations.
	Ref *SecretReference `json:"ref,omitempty"`
}

func (*SecretSpec) DeepCopy added in v0.36.0 

func (in *SecretSpec) DeepCopy() *SecretSpec

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

func (*SecretSpec) DeepCopyInto added in v0.36.0 

func (in *SecretSpec) DeepCopyInto(out *SecretSpec)

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

func (*SecretSpec) HasSecret added in v0.36.0 

func (a *SecretSpec) HasSecret() bool

type TopicReply added in v0.29.0 

type TopicReply struct {
	Enabled bool `json:"enabled"`
}

func (*TopicReply) DeepCopy added in v0.29.0 

func (in *TopicReply) DeepCopy() *TopicReply

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

func (*TopicReply) DeepCopyInto added in v0.29.0 

func (in *TopicReply) DeepCopyInto(out *TopicReply)

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

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.