v1beta1

package
v0.36.3 Latest Latest
Warning

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

 Go to latest Published: Feb 6, 2023 License: Apache-2.0 Imports: 11 Imported by: 27

Documentation

Overview

Package v1beta1 is the v1beta1 version of the API. +k8s:deepcopy-gen=package +groupName=duck.knative.dev

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type BackoffPolicyType 

type BackoffPolicyType string

BackoffPolicyType is the type for backoff policies 

const (
	// Linear backoff policy
	BackoffPolicyLinear BackoffPolicyType = "linear"

	// Exponential backoff policy
	BackoffPolicyExponential BackoffPolicyType = "exponential"
)

type Channelable 

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

	// Spec is the part where the Channelable fulfills the Subscribable contract.
	Spec ChannelableSpec `json:"spec,omitempty"`

	Status ChannelableStatus `json:"status,omitempty"`
}

Channelable is a skeleton type wrapping Subscribable and Addressable in the manner we expect resource writers defining compatible resources to embed it. We will typically use this type to deserialize Channelable ObjectReferences and access their subscription and address data. This is not a real resource.

func (*Channelable) DeepCopy 

func (in *Channelable) DeepCopy() *Channelable

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

func (*Channelable) DeepCopyInto 

func (in *Channelable) DeepCopyInto(out *Channelable)

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

func (*Channelable) DeepCopyObject 

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

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

func (*Channelable) GetFullType 

func (s *Channelable) GetFullType() duck.Populatable

GetFullType implements duck.Implementable

func (*Channelable) GetListType 

func (c *Channelable) GetListType() runtime.Object

GetListType implements apis.Listable

func (*Channelable) Populate 

func (c *Channelable) Populate()

Populate implements duck.Populatable

type ChannelableList 

type ChannelableList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata"`

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

ChannelableList is a list of Channelable resources.

func (*ChannelableList) DeepCopy 

func (in *ChannelableList) DeepCopy() *ChannelableList

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

func (*ChannelableList) DeepCopyInto 

func (in *ChannelableList) DeepCopyInto(out *ChannelableList)

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

func (*ChannelableList) DeepCopyObject 

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

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

type ChannelableSpec 

type ChannelableSpec struct {
	SubscribableSpec `json:",inline"`

	// DeliverySpec contains options controlling the event delivery
	// +optional
	Delivery *DeliverySpec `json:"delivery,omitempty"`
}

ChannelableSpec contains Spec of the Channelable object

func (*ChannelableSpec) DeepCopy 

func (in *ChannelableSpec) DeepCopy() *ChannelableSpec

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

func (*ChannelableSpec) DeepCopyInto 

func (in *ChannelableSpec) DeepCopyInto(out *ChannelableSpec)

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

type ChannelableStatus 

type ChannelableStatus struct {
	// inherits duck/v1 Status, which currently provides:
	// * ObservedGeneration - the 'Generation' of the Service that was last processed by the controller.
	// * Conditions - the latest available observations of a resource's current state.
	duckv1.Status `json:",inline"`
	// AddressStatus is the part where the Channelable fulfills the Addressable contract.
	duckv1.AddressStatus `json:",inline"`
	// Subscribers is populated with the statuses of each of the Channelable's subscribers.
	SubscribableStatus `json:",inline"`
	// DeadLetterChannel is a KReference and is set by the channel when it supports native error handling via a channel
	// Failed messages are delivered here.
	// +optional
	DeadLetterChannel *duckv1.KReference `json:"deadLetterChannel,omitempty"`
}

ChannelableStatus contains the Status of a Channelable object.

func (*ChannelableStatus) DeepCopy 

func (in *ChannelableStatus) DeepCopy() *ChannelableStatus

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

func (*ChannelableStatus) DeepCopyInto 

func (in *ChannelableStatus) DeepCopyInto(out *ChannelableStatus)

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

type DeliverySpec 

type DeliverySpec struct {
	// DeadLetterSink is the sink receiving event that could not be sent to
	// a destination.
	// +optional
	DeadLetterSink *duckv1.Destination `json:"deadLetterSink,omitempty"`

	// Retry is the minimum number of retries the sender should attempt when
	// sending an event before moving it to the dead letter sink.
	// +optional
	Retry *int32 `json:"retry,omitempty"`

	// Timeout is the timeout of each single request.
	// More information on Duration format:
	//  - https://www.iso.org/iso-8601-date-and-time-format.html
	//  - https://en.wikipedia.org/wiki/ISO_8601
	//
	Timeout *string `json:"timeout,omitempty"`

	// BackoffPolicy is the retry backoff policy (linear, exponential).
	// +optional
	BackoffPolicy *BackoffPolicyType `json:"backoffPolicy,omitempty"`

	// BackoffDelay is the delay before retrying.
	// More information on Duration format:
	//  - https://www.iso.org/iso-8601-date-and-time-format.html
	//  - https://en.wikipedia.org/wiki/ISO_8601
	//
	// For linear policy, backoff delay is backoffDelay*<numberOfRetries>.
	// For exponential policy, backoff delay is backoffDelay*2^<numberOfRetries>.
	// +optional
	BackoffDelay *string `json:"backoffDelay,omitempty"`
}

DeliverySpec contains the delivery options for event senders, such as channelable and source.

func (*DeliverySpec) ConvertFrom 

func (sink *DeliverySpec) ConvertFrom(ctx context.Context, from apis.Convertible) error

ConvertFrom implements apis.Convertible

func (*DeliverySpec) ConvertTo 

func (source *DeliverySpec) ConvertTo(ctx context.Context, to apis.Convertible) error

ConvertTo implements apis.Convertible

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) Validate 

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

type DeliveryStatus 

type DeliveryStatus struct {
	// DeadLetterChannel is a KReference that is the reference to the native, platform specific channel
	// where failed events are sent to.
	// +optional
	DeadLetterChannel *duckv1.KReference `json:"deadLetterChannel,omitempty"`
}

DeliveryStatus contains the Status of an object supporting delivery options.

func (*DeliveryStatus) DeepCopy 

func (in *DeliveryStatus) DeepCopy() *DeliveryStatus

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

func (*DeliveryStatus) DeepCopyInto 

func (in *DeliveryStatus) DeepCopyInto(out *DeliveryStatus)

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

type Subscribable 

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

	// SubscribableSpec is the part where Subscribable object is
	// configured as to be compatible with Subscribable contract.
	Spec SubscribableSpec `json:"spec"`

	// SubscribableStatus is the part where SubscribableStatus object is
	// configured as to be compatible with Subscribable contract.
	Status SubscribableStatus `json:"status"`
}

Subscribable is a skeleton type wrapping Subscribable in the manner we expect resource writers defining compatible resources to embed it. We will typically use this type to deserialize SubscribableType ObjectReferences and access the Subscription data. This is not a real resource.

func (*Subscribable) ConvertFrom added in v0.14.0 

func (sink *Subscribable) ConvertFrom(ctx context.Context, from apis.Convertible) error

ConvertFrom implements apis.Convertible.

func (*Subscribable) ConvertTo added in v0.14.0 

func (source *Subscribable) ConvertTo(ctx context.Context, to apis.Convertible) error

ConvertTo implements apis.Convertible

func (*Subscribable) DeepCopy 

func (in *Subscribable) DeepCopy() *Subscribable

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

func (*Subscribable) DeepCopyInto 

func (in *Subscribable) DeepCopyInto(out *Subscribable)

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

func (*Subscribable) DeepCopyObject 

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

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

func (*Subscribable) GetFullType 

func (s *Subscribable) GetFullType() duck.Populatable

GetFullType implements duck.Implementable

func (*Subscribable) GetListType 

func (c *Subscribable) GetListType() runtime.Object

GetListType implements apis.Listable

func (*Subscribable) Populate 

func (c *Subscribable) Populate()

Populate implements duck.Populatable

type SubscribableList 

type SubscribableList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata"`

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

SubscribableTypeList is a list of SubscribableType resources

func (*SubscribableList) DeepCopy 

func (in *SubscribableList) DeepCopy() *SubscribableList

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

func (*SubscribableList) DeepCopyInto 

func (in *SubscribableList) DeepCopyInto(out *SubscribableList)

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

func (*SubscribableList) DeepCopyObject 

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

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

type SubscribableSpec 

type SubscribableSpec struct {
	// This is the list of subscriptions for this subscribable.
	// +patchMergeKey=uid
	// +patchStrategy=merge
	Subscribers []SubscriberSpec `json:"subscribers,omitempty" patchStrategy:"merge" patchMergeKey:"uid"`
}

SubscribableSpec shows how we expect folks to embed Subscribable in their Spec field.

func (*SubscribableSpec) ConvertFrom added in v0.16.0 

func (sink *SubscribableSpec) ConvertFrom(ctx context.Context, obj apis.Convertible) error

ConvertFrom helps implement apis.Convertible

func (*SubscribableSpec) ConvertTo added in v0.16.0 

func (source *SubscribableSpec) ConvertTo(ctx context.Context, obj apis.Convertible) error

ConvertTo helps implement apis.Convertible

func (*SubscribableSpec) DeepCopy 

func (in *SubscribableSpec) DeepCopy() *SubscribableSpec

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

func (*SubscribableSpec) DeepCopyInto 

func (in *SubscribableSpec) DeepCopyInto(out *SubscribableSpec)

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

type SubscribableStatus 

type SubscribableStatus struct {
	// This is the list of subscription's statuses for this channel.
	// +patchMergeKey=uid
	// +patchStrategy=merge
	Subscribers []SubscriberStatus `json:"subscribers,omitempty" patchStrategy:"merge" patchMergeKey:"uid"`
}

SubscribableStatus is the schema for the subscribable's status portion of the status section of the resource.

func (*SubscribableStatus) ConvertFrom added in v0.16.0 

func (sink *SubscribableStatus) ConvertFrom(ctx context.Context, obj apis.Convertible) error

ConvertFrom implements apis.Convertible

func (*SubscribableStatus) ConvertTo added in v0.16.0 

func (source *SubscribableStatus) ConvertTo(ctx context.Context, obj apis.Convertible) error

ConvertTo implements apis.Convertible

func (*SubscribableStatus) DeepCopy 

func (in *SubscribableStatus) DeepCopy() *SubscribableStatus

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

func (*SubscribableStatus) DeepCopyInto 

func (in *SubscribableStatus) DeepCopyInto(out *SubscribableStatus)

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

type SubscriberSpec 

type SubscriberSpec struct {
	// UID is used to understand the origin of the subscriber.
	// +optional
	UID types.UID `json:"uid,omitempty"`
	// Generation of the origin of the subscriber with uid:UID.
	// +optional
	Generation int64 `json:"generation,omitempty"`
	// SubscriberURI is the endpoint for the subscriber
	// +optional
	SubscriberURI *apis.URL `json:"subscriberUri,omitempty"`
	// ReplyURI is the endpoint for the reply
	// +optional
	ReplyURI *apis.URL `json:"replyUri,omitempty"`
	// +optional
	// DeliverySpec contains options controlling the event delivery
	// +optional
	Delivery *DeliverySpec `json:"delivery,omitempty"`
}

SubscriberSpec defines a single subscriber to a Subscribable.

At least one of SubscriberURI and ReplyURI must be present

func (*SubscriberSpec) ConvertFrom added in v0.16.0 

func (sink *SubscriberSpec) ConvertFrom(ctx context.Context, obj apis.Convertible) error

ConvertFrom helps implement apis.Convertible

func (*SubscriberSpec) ConvertTo added in v0.16.0 

func (source *SubscriberSpec) ConvertTo(ctx context.Context, obj apis.Convertible) error

ConvertTo implements apis.Convertible

func (*SubscriberSpec) DeepCopy 

func (in *SubscriberSpec) DeepCopy() *SubscriberSpec

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

func (*SubscriberSpec) DeepCopyInto 

func (in *SubscriberSpec) DeepCopyInto(out *SubscriberSpec)

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

type SubscriberStatus 

type SubscriberStatus struct {
	// UID is used to understand the origin of the subscriber.
	// +optional
	UID types.UID `json:"uid,omitempty"`
	// Generation of the origin of the subscriber with uid:UID.
	// +optional
	ObservedGeneration int64 `json:"observedGeneration,omitempty"`
	// Status of the subscriber.
	Ready corev1.ConditionStatus `json:"ready,omitempty"`
	// A human readable message indicating details of Ready status.
	// +optional
	Message string `json:"message,omitempty"`
}

SubscriberStatus defines the status of a single subscriber to a Channel.

func (*SubscriberStatus) ConvertFrom added in v0.16.0 

func (sink *SubscriberStatus) ConvertFrom(ctx context.Context, obj apis.Convertible) error

ConvertFrom implements apis.Convertible

func (*SubscriberStatus) ConvertTo added in v0.16.0 

func (source *SubscriberStatus) ConvertTo(ctx context.Context, obj apis.Convertible) error

ConvertTo implements apis.Convertible

func (*SubscriberStatus) DeepCopy 

func (in *SubscriberStatus) DeepCopy() *SubscriberStatus

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

func (*SubscriberStatus) DeepCopyInto 

func (in *SubscriberStatus) DeepCopyInto(out *SubscriberStatus)

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.