v1alpha1

package
v0.8.1 Latest Latest
Warning

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

Go to latest
Published: Nov 18, 2019 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Overview

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

Index

Constants

View Source
const (
	// ChannelConditionReady has status True when all subconditions below have been set to True.
	ChannelConditionReady = apis.ConditionReady

	// ChannelConditionBackingChannelReady has status True when the backing Channel CRD is ready.
	ChannelConditionBackingChannelReady apis.ConditionType = "BackingChannelReady"

	// ChannelConditionAddressable has status true when this Channel meets
	// the Addressable contract and has a non-empty hostname.
	ChannelConditionAddressable apis.ConditionType = "Addressable"
)
View Source
const (
	// ChoiceConditionReady has status True when all subconditions below have been set to True.
	ChoiceConditionReady = apis.ConditionReady

	// ChoiceConditionChannelsReady has status True when all the channels created as part of
	// this choice are ready.
	ChoiceConditionChannelsReady apis.ConditionType = "ChannelsReady"

	// ChoiceConditionSubscriptionsReady has status True when all the subscriptions created as part of
	// this choice are ready.
	ChoiceConditionSubscriptionsReady apis.ConditionType = "SubscriptionsReady"

	// ChoiceConditionAddressable has status true when this Choice meets
	// the Addressable contract and has a non-empty hostname.
	ChoiceConditionAddressable apis.ConditionType = "Addressable"
)
View Source
const (
	// InMemoryChannelConditionReady has status True when all subconditions below have been set to True.
	InMemoryChannelConditionReady = apis.ConditionReady

	// InMemoryChannelConditionDispatcherReady has status True when a Dispatcher deployment is ready
	// Keyed off appsv1.DeploymentAvaialble, which means minimum available replicas required are up
	// and running for at least minReadySeconds.
	InMemoryChannelConditionDispatcherReady apis.ConditionType = "DispatcherReady"

	// InMemoryChannelConditionServiceReady has status True when a k8s Service is ready. This
	// basically just means it exists because there's no meaningful status in Service. See Endpoints
	// below.
	InMemoryChannelConditionServiceReady apis.ConditionType = "ServiceReady"

	// InMemoryChannelConditionEndpointsReady has status True when a k8s Service Endpoints are backed
	// by at least one endpoint.
	InMemoryChannelConditionEndpointsReady apis.ConditionType = "EndpointsReady"

	// InMemoryChannelConditionAddressable has status true when this InMemoryChannel meets
	// the Addressable contract and has a non-empty hostname.
	InMemoryChannelConditionAddressable apis.ConditionType = "Addressable"

	// InMemoryChannelConditionServiceReady has status True when a k8s Service representing the channel is ready.
	// Because this uses ExternalName, there are no endpoints to check.
	InMemoryChannelConditionChannelServiceReady apis.ConditionType = "ChannelServiceReady"
)
View Source
const (
	// SequenceConditionReady has status True when all subconditions below have been set to True.
	SequenceConditionReady = apis.ConditionReady

	// SequenceChannelsReady has status True when all the channels created as part of
	// this sequence are ready.
	SequenceConditionChannelsReady apis.ConditionType = "ChannelsReady"

	// SequenceSubscriptionsReady has status True when all the subscriptions created as part of
	// this sequence are ready.
	SequenceConditionSubscriptionsReady apis.ConditionType = "SubscriptionsReady"

	// SequenceConditionAddressable has status true when this Sequence meets
	// the Addressable contract and has a non-empty hostname.
	SequenceConditionAddressable apis.ConditionType = "Addressable"
)

Variables

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

SchemeGroupVersion is group version used to register these objects

Functions

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 Channel added in v0.8.0

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

	// Spec defines the desired state of the Channel.
	Spec ChannelSpec `json:"spec,omitempty"`

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

Channel represents a generic Channel. It is normally used when we want a Channel, but don't need a specific Channel implementation.

func (*Channel) CheckImmutableFields added in v0.8.0

func (c *Channel) CheckImmutableFields(ctx context.Context, og apis.Immutable) *apis.FieldError

func (*Channel) DeepCopy added in v0.8.0

func (in *Channel) DeepCopy() *Channel

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

func (*Channel) DeepCopyInto added in v0.8.0

func (in *Channel) DeepCopyInto(out *Channel)

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

func (*Channel) DeepCopyObject added in v0.8.0

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

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

func (*Channel) GetGroupVersionKind added in v0.8.0

func (dc *Channel) GetGroupVersionKind() schema.GroupVersionKind

GetGroupVersionKind returns GroupVersionKind for Channels.

func (*Channel) SetDefaults added in v0.8.0

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

func (*Channel) Validate added in v0.8.0

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

type ChannelList added in v0.8.0

type ChannelList struct {
	metav1.TypeMeta `json:",inline"`
	// +optional
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []Channel `json:"items"`
}

ChannelList is a collection of Channels.

func (*ChannelList) DeepCopy added in v0.8.0

func (in *ChannelList) DeepCopy() *ChannelList

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

func (*ChannelList) DeepCopyInto added in v0.8.0

func (in *ChannelList) DeepCopyInto(out *ChannelList)

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

func (*ChannelList) DeepCopyObject added in v0.8.0

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

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

type ChannelSpec added in v0.8.0

type ChannelSpec struct {

	// ChannelTemplate specifies which Channel CRD to use to create the CRD Channel backing this Channel.
	// This is immutable after creation. Normally this is set by the Channel defaulter, not directly by the user.
	ChannelTemplate *eventingduck.ChannelTemplateSpec `json:"channelTemplate"`

	// Channel conforms to Duck type Subscribable.
	Subscribable *eventingduck.Subscribable `json:"subscribable,omitempty"`
}

ChannelSpec defines which subscribers have expressed interest in receiving events from this Channel. It also defines the ChannelTemplate to use in order to create the CRD Channel backing this Channel.

func (*ChannelSpec) DeepCopy added in v0.8.0

func (in *ChannelSpec) DeepCopy() *ChannelSpec

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

func (*ChannelSpec) DeepCopyInto added in v0.8.0

func (in *ChannelSpec) DeepCopyInto(out *ChannelSpec)

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

func (*ChannelSpec) SetDefaults added in v0.8.0

func (cs *ChannelSpec) SetDefaults(ctx context.Context)

func (*ChannelSpec) Validate added in v0.8.0

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

type ChannelStatus added in v0.8.0

type ChannelStatus struct {
	// inherits duck/v1beta1 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.
	duckv1beta1.Status `json:",inline"`

	// Channel is Addressable. It currently exposes the endpoint as a
	// fully-qualified DNS name which will distribute traffic over the
	// provided targets from inside the cluster.
	//
	// It generally has the form {channel}.{namespace}.svc.{cluster domain name}
	duckv1alpha1.AddressStatus `json:",inline"`

	// Subscribers is populated with the statuses of each of the Channelable's subscribers.
	eventingduck.SubscribableTypeStatus `json:",inline"`

	// Channel is an ObjectReference to the Channel CRD backing this Channel.
	Channel *corev1.ObjectReference `json:"channel,omitempty"`
}

ChannelStatus represents the current state of a Channel.

func (*ChannelStatus) DeepCopy added in v0.8.0

func (in *ChannelStatus) DeepCopy() *ChannelStatus

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

func (*ChannelStatus) DeepCopyInto added in v0.8.0

func (in *ChannelStatus) DeepCopyInto(out *ChannelStatus)

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

func (*ChannelStatus) GetCondition added in v0.8.0

func (cs *ChannelStatus) GetCondition(t apis.ConditionType) *apis.Condition

GetCondition returns the condition currently associated with the given type, or nil.

func (*ChannelStatus) InitializeConditions added in v0.8.0

func (cs *ChannelStatus) InitializeConditions()

InitializeConditions sets relevant unset conditions to Unknown state.

func (*ChannelStatus) IsReady added in v0.8.0

func (cs *ChannelStatus) IsReady() bool

IsReady returns true if the resource is ready overall.

func (*ChannelStatus) MarkBackingChannelFailed added in v0.8.0

func (cs *ChannelStatus) MarkBackingChannelFailed(reason, messageFormat string, messageA ...interface{})

func (*ChannelStatus) MarkBackingChannelReady added in v0.8.0

func (cs *ChannelStatus) MarkBackingChannelReady()

func (*ChannelStatus) PropagateStatuses added in v0.8.0

func (cs *ChannelStatus) PropagateStatuses(chs *eventingduck.ChannelableStatus)

func (*ChannelStatus) SetAddress added in v0.8.0

func (cs *ChannelStatus) SetAddress(address *v1alpha1.Addressable)

type Choice added in v0.8.0

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

	// Spec defines the desired state of the Choice.
	Spec ChoiceSpec `json:"spec,omitempty"`

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

+genclient +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object Choice defines conditional branches that will be wired in series through Channels and Subscriptions.

func (*Choice) DeepCopy added in v0.8.0

func (in *Choice) DeepCopy() *Choice

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

func (*Choice) DeepCopyInto added in v0.8.0

func (in *Choice) DeepCopyInto(out *Choice)

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

func (*Choice) DeepCopyObject added in v0.8.0

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

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

func (*Choice) GetGroupVersionKind added in v0.8.0

func (p *Choice) GetGroupVersionKind() schema.GroupVersionKind

GetGroupVersionKind returns GroupVersionKind for Choice

func (*Choice) SetDefaults added in v0.8.0

func (s *Choice) SetDefaults(ctx context.Context)

func (*Choice) Validate added in v0.8.0

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

type ChoiceCase added in v0.8.0

type ChoiceCase struct {
	// Filter is the expression guarding the branch/case
	Filter *eventingv1alpha1.SubscriberSpec `json:"filter,omitempty"`

	// Subscriber receiving the event when the filter passes
	Subscriber eventingv1alpha1.SubscriberSpec `json:"subscriber"`

	// Reply is a Reference to where the result of Subscriber of this case gets sent to.
	// If not specified, sent the result to the Choice Reply
	//
	// You can specify only the following fields of the ObjectReference:
	//   - Kind
	//   - APIVersion
	//   - Name
	//
	//  The resource pointed by this ObjectReference must meet the Addressable contract
	//  with a reference to the Addressable duck type. If the resource does not meet this contract,
	//  it will be reflected in the Subscription's status.
	// +optional
	Reply *corev1.ObjectReference `json:"reply,omitempty"`
}

func (*ChoiceCase) DeepCopy added in v0.8.0

func (in *ChoiceCase) DeepCopy() *ChoiceCase

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

func (*ChoiceCase) DeepCopyInto added in v0.8.0

func (in *ChoiceCase) DeepCopyInto(out *ChoiceCase)

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

type ChoiceCaseStatus added in v0.8.0

type ChoiceCaseStatus struct {
	// FilterSubscriptionStatus corresponds to the filter subscription status.
	FilterSubscriptionStatus ChoiceSubscriptionStatus `json:"filterSubscriptionStatus"`

	// FilterChannelStatus corresponds to the filter channel status.
	FilterChannelStatus ChoiceChannelStatus `json:"filterChannelStatus"`

	// SubscriptionStatus corresponds to the subscriber subscription status.
	SubscriptionStatus ChoiceSubscriptionStatus `json:"subscriberSubscriptionStatus"`
}

ChoiceCaseStatus represents the current state of a Choice case

func (*ChoiceCaseStatus) DeepCopy added in v0.8.0

func (in *ChoiceCaseStatus) DeepCopy() *ChoiceCaseStatus

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

func (*ChoiceCaseStatus) DeepCopyInto added in v0.8.0

func (in *ChoiceCaseStatus) DeepCopyInto(out *ChoiceCaseStatus)

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

type ChoiceChannelStatus added in v0.8.0

type ChoiceChannelStatus struct {
	// Channel is the reference to the underlying channel.
	Channel corev1.ObjectReference `json:"channel"`

	// ReadyCondition indicates whether the Channel is ready or not.
	ReadyCondition apis.Condition `json:"ready"`
}

func (*ChoiceChannelStatus) DeepCopy added in v0.8.0

func (in *ChoiceChannelStatus) DeepCopy() *ChoiceChannelStatus

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

func (*ChoiceChannelStatus) DeepCopyInto added in v0.8.0

func (in *ChoiceChannelStatus) DeepCopyInto(out *ChoiceChannelStatus)

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

type ChoiceList added in v0.8.0

type ChoiceList struct {
	metav1.TypeMeta `json:",inline"`
	// +optional
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []Choice `json:"items"`
}

ChoiceList is a collection of Choices.

func (*ChoiceList) DeepCopy added in v0.8.0

func (in *ChoiceList) DeepCopy() *ChoiceList

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

func (*ChoiceList) DeepCopyInto added in v0.8.0

func (in *ChoiceList) DeepCopyInto(out *ChoiceList)

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

func (*ChoiceList) DeepCopyObject added in v0.8.0

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

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

type ChoiceSpec added in v0.8.0

type ChoiceSpec struct {
	// Cases is the list of Filter/Subscribers pairs. Filters are evaluated in the order
	// provided, until one pass (returns true)
	Cases []ChoiceCase `json:"cases"`

	// ChannelTemplate specifies which Channel CRD to use. If left unspecified, it is set to the default Channel CRD
	// for the namespace (or cluster, in case there are no defaults for the namespace).
	// +optional
	ChannelTemplate *eventingduckv1alpha1.ChannelTemplateSpec `json:"channelTemplate"`

	// Reply is a Reference to where the result of a case Subscriber gets sent to
	// when the case does not have a Reply
	//
	// You can specify only the following fields of the ObjectReference:
	//   - Kind
	//   - APIVersion
	//   - Name
	//
	//  The resource pointed by this ObjectReference must meet the Addressable contract
	//  with a reference to the Addressable duck type. If the resource does not meet this contract,
	//  it will be reflected in the Subscription's status.
	// +optional
	Reply *corev1.ObjectReference `json:"reply,omitempty"`
}

func (*ChoiceSpec) DeepCopy added in v0.8.0

func (in *ChoiceSpec) DeepCopy() *ChoiceSpec

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

func (*ChoiceSpec) DeepCopyInto added in v0.8.0

func (in *ChoiceSpec) DeepCopyInto(out *ChoiceSpec)

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

func (*ChoiceSpec) SetDefaults added in v0.8.0

func (ss *ChoiceSpec) SetDefaults(ctx context.Context)

func (*ChoiceSpec) Validate added in v0.8.0

func (ps *ChoiceSpec) Validate(ctx context.Context) *apis.FieldError

type ChoiceStatus added in v0.8.0

type ChoiceStatus struct {
	// inherits duck/v1alpha1 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.
	duckv1beta1.Status `json:",inline"`

	// IngressChannelStatus corresponds to the ingress channel status.
	IngressChannelStatus ChoiceChannelStatus `json:"ingressChannelStatus"`

	// CaseStatuses is an array of corresponding to cases status.
	// Matches the Spec.Cases array in the order.
	CaseStatuses []ChoiceCaseStatus `json:"caseStatuses"`

	// AddressStatus is the starting point to this Choice. Sending to this
	// will target the first subscriber.
	// It generally has the form {channel}.{namespace}.svc.{cluster domain name}
	duckv1alpha1.AddressStatus `json:",inline"`
}

ChoiceStatus represents the current state of a Choice.

func (*ChoiceStatus) DeepCopy added in v0.8.0

func (in *ChoiceStatus) DeepCopy() *ChoiceStatus

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

func (*ChoiceStatus) DeepCopyInto added in v0.8.0

func (in *ChoiceStatus) DeepCopyInto(out *ChoiceStatus)

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

func (*ChoiceStatus) GetCondition added in v0.8.0

func (ps *ChoiceStatus) GetCondition(t apis.ConditionType) *apis.Condition

GetCondition returns the condition currently associated with the given type, or nil.

func (*ChoiceStatus) InitializeConditions added in v0.8.0

func (ps *ChoiceStatus) InitializeConditions()

InitializeConditions sets relevant unset conditions to Unknown state.

func (*ChoiceStatus) IsReady added in v0.8.0

func (ps *ChoiceStatus) IsReady() bool

IsReady returns true if the resource is ready overall.

func (*ChoiceStatus) MarkAddressableNotReady added in v0.8.0

func (ps *ChoiceStatus) MarkAddressableNotReady(reason, messageFormat string, messageA ...interface{})

func (*ChoiceStatus) MarkChannelsNotReady added in v0.8.0

func (ps *ChoiceStatus) MarkChannelsNotReady(reason, messageFormat string, messageA ...interface{})

func (*ChoiceStatus) MarkSubscriptionsNotReady added in v0.8.0

func (ps *ChoiceStatus) MarkSubscriptionsNotReady(reason, messageFormat string, messageA ...interface{})

func (*ChoiceStatus) PropagateChannelStatuses added in v0.8.0

func (ps *ChoiceStatus) PropagateChannelStatuses(ingressChannel *duckv1alpha1.Channelable, channels []*duckv1alpha1.Channelable)

PropagateChannelStatuses sets the ChannelStatuses and ChoiceConditionChannelsReady based on the status of the incoming channels.

func (*ChoiceStatus) PropagateSubscriptionStatuses added in v0.8.0

func (ps *ChoiceStatus) PropagateSubscriptionStatuses(filterSubscriptions []*eventingv1alpha1.Subscription, subscriptions []*eventingv1alpha1.Subscription)

PropagateSubscriptionStatuses sets the ChoiceConditionSubscriptionsReady based on the status of the incoming subscriptions.

type ChoiceSubscriptionStatus added in v0.8.0

type ChoiceSubscriptionStatus struct {
	// Subscription is the reference to the underlying Subscription.
	Subscription corev1.ObjectReference `json:"subscription"`

	// ReadyCondition indicates whether the Subscription is ready or not.
	ReadyCondition apis.Condition `json:"ready"`
}

func (*ChoiceSubscriptionStatus) DeepCopy added in v0.8.0

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

func (*ChoiceSubscriptionStatus) DeepCopyInto added in v0.8.0

func (in *ChoiceSubscriptionStatus) DeepCopyInto(out *ChoiceSubscriptionStatus)

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

type InMemoryChannel

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

	// Spec defines the desired state of the Channel.
	Spec InMemoryChannelSpec `json:"spec,omitempty"`

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

InMemoryChannel is a resource representing an in memory channel

func (*InMemoryChannel) DeepCopy

func (in *InMemoryChannel) DeepCopy() *InMemoryChannel

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

func (*InMemoryChannel) DeepCopyInto

func (in *InMemoryChannel) DeepCopyInto(out *InMemoryChannel)

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

func (*InMemoryChannel) DeepCopyObject

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

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

func (*InMemoryChannel) GetGroupVersionKind

func (imc *InMemoryChannel) GetGroupVersionKind() schema.GroupVersionKind

GetGroupVersionKind returns GroupVersionKind for InMemoryChannels

func (*InMemoryChannel) SetDefaults

func (imc *InMemoryChannel) SetDefaults(ctx context.Context)

func (*InMemoryChannel) Validate

func (imc *InMemoryChannel) Validate(ctx context.Context) *apis.FieldError

type InMemoryChannelList

type InMemoryChannelList struct {
	metav1.TypeMeta `json:",inline"`
	// +optional
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []InMemoryChannel `json:"items"`
}

InMemoryChannelList is a collection of in-memory channels.

func (*InMemoryChannelList) DeepCopy

func (in *InMemoryChannelList) DeepCopy() *InMemoryChannelList

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

func (*InMemoryChannelList) DeepCopyInto

func (in *InMemoryChannelList) DeepCopyInto(out *InMemoryChannelList)

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

func (*InMemoryChannelList) DeepCopyObject

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

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

type InMemoryChannelSpec

type InMemoryChannelSpec struct {
	// Channel conforms to Duck type Subscribable.
	Subscribable *eventingduck.Subscribable `json:"subscribable,omitempty"`
}

InMemoryChannelSpec defines which subscribers have expressed interest in receiving events from this InMemoryChannel. arguments for a Channel.

func (*InMemoryChannelSpec) DeepCopy

func (in *InMemoryChannelSpec) DeepCopy() *InMemoryChannelSpec

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

func (*InMemoryChannelSpec) DeepCopyInto

func (in *InMemoryChannelSpec) DeepCopyInto(out *InMemoryChannelSpec)

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

func (*InMemoryChannelSpec) SetDefaults

func (imcs *InMemoryChannelSpec) SetDefaults(ctx context.Context)

func (*InMemoryChannelSpec) Validate

func (imcs *InMemoryChannelSpec) Validate(ctx context.Context) *apis.FieldError

type InMemoryChannelStatus

type InMemoryChannelStatus struct {
	// inherits duck/v1beta1 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.
	duckv1beta1.Status `json:",inline"`

	// InMemoryChannel is Addressable. It currently exposes the endpoint as a
	// fully-qualified DNS name which will distribute traffic over the
	// provided targets from inside the cluster.
	//
	// It generally has the form {channel}.{namespace}.svc.{cluster domain name}
	duckv1alpha1.AddressStatus `json:",inline"`

	// Subscribers is populated with the statuses of each of the Channelable's subscribers.
	eventingduck.SubscribableTypeStatus `json:",inline"`
}

ChannelStatus represents the current state of a Channel.

func (*InMemoryChannelStatus) DeepCopy

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

func (*InMemoryChannelStatus) DeepCopyInto

func (in *InMemoryChannelStatus) DeepCopyInto(out *InMemoryChannelStatus)

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

func (*InMemoryChannelStatus) GetCondition

func (imcs *InMemoryChannelStatus) GetCondition(t apis.ConditionType) *apis.Condition

GetCondition returns the condition currently associated with the given type, or nil.

func (*InMemoryChannelStatus) InitializeConditions

func (imcs *InMemoryChannelStatus) InitializeConditions()

InitializeConditions sets relevant unset conditions to Unknown state.

func (*InMemoryChannelStatus) IsReady

func (imcs *InMemoryChannelStatus) IsReady() bool

IsReady returns true if the resource is ready overall.

func (*InMemoryChannelStatus) MarkChannelServiceFailed

func (imcs *InMemoryChannelStatus) MarkChannelServiceFailed(reason, messageFormat string, messageA ...interface{})

func (*InMemoryChannelStatus) MarkChannelServiceTrue

func (imcs *InMemoryChannelStatus) MarkChannelServiceTrue()

func (*InMemoryChannelStatus) MarkDispatcherFailed

func (imcs *InMemoryChannelStatus) MarkDispatcherFailed(reason, messageFormat string, messageA ...interface{})

func (*InMemoryChannelStatus) MarkEndpointsFailed

func (imcs *InMemoryChannelStatus) MarkEndpointsFailed(reason, messageFormat string, messageA ...interface{})

func (*InMemoryChannelStatus) MarkEndpointsTrue

func (imcs *InMemoryChannelStatus) MarkEndpointsTrue()

func (*InMemoryChannelStatus) MarkServiceFailed

func (imcs *InMemoryChannelStatus) MarkServiceFailed(reason, messageFormat string, messageA ...interface{})

func (*InMemoryChannelStatus) MarkServiceTrue

func (imcs *InMemoryChannelStatus) MarkServiceTrue()

func (*InMemoryChannelStatus) PropagateDispatcherStatus

func (imcs *InMemoryChannelStatus) PropagateDispatcherStatus(ds *appsv1.DeploymentStatus)

TODO: Unify this with the ones from Eventing. Say: Broker, Trigger.

func (*InMemoryChannelStatus) SetAddress

func (imcs *InMemoryChannelStatus) SetAddress(url *apis.URL)

TODO: Use the new beta duck types.

type Sequence

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

	// Spec defines the desired state of the Sequence.
	Spec SequenceSpec `json:"spec,omitempty"`

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

+genclient +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object Sequence defines a sequence of Subscribers that will be wired in series through Channels and Subscriptions.

func (*Sequence) DeepCopy

func (in *Sequence) DeepCopy() *Sequence

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

func (*Sequence) DeepCopyInto

func (in *Sequence) DeepCopyInto(out *Sequence)

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

func (*Sequence) DeepCopyObject

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

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

func (*Sequence) GetGroupVersionKind

func (p *Sequence) GetGroupVersionKind() schema.GroupVersionKind

GetGroupVersionKind returns GroupVersionKind for InMemoryChannels

func (*Sequence) SetDefaults

func (s *Sequence) SetDefaults(ctx context.Context)

func (*Sequence) Validate

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

type SequenceChannelStatus

type SequenceChannelStatus struct {
	// Channel is the reference to the underlying channel.
	Channel corev1.ObjectReference `json:"channel"`

	// ReadyCondition indicates whether the Channel is ready or not.
	ReadyCondition apis.Condition `json:"ready"`
}

func (*SequenceChannelStatus) DeepCopy

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

func (*SequenceChannelStatus) DeepCopyInto

func (in *SequenceChannelStatus) DeepCopyInto(out *SequenceChannelStatus)

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

type SequenceList

type SequenceList struct {
	metav1.TypeMeta `json:",inline"`
	// +optional
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []Sequence `json:"items"`
}

SequenceList is a collection of Sequences.

func (*SequenceList) DeepCopy

func (in *SequenceList) DeepCopy() *SequenceList

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

func (*SequenceList) DeepCopyInto

func (in *SequenceList) DeepCopyInto(out *SequenceList)

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

func (*SequenceList) DeepCopyObject

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

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

type SequenceSpec

type SequenceSpec struct {
	// Steps is the list of Subscribers (processors / functions) that will be called in the order
	// provided.
	Steps []eventingv1alpha1.SubscriberSpec `json:"steps"`

	// ChannelTemplate specifies which Channel CRD to use. If left unspecified, it is set to the default Channel CRD
	// for the namespace (or cluster, in case there are no defaults for the namespace).
	// +optional
	ChannelTemplate *eventingduckv1alpha1.ChannelTemplateSpec `json:"channelTemplate,omitempty"`

	// Reply is a Reference to where the result of the last Subscriber gets sent to.
	//
	// You can specify only the following fields of the ObjectReference:
	//   - Kind
	//   - APIVersion
	//   - Name
	//
	//  The resource pointed by this ObjectReference must meet the Addressable contract
	//  with a reference to the Addressable duck type. If the resource does not meet this contract,
	//  it will be reflected in the Subscription's status.
	// +optional
	Reply *corev1.ObjectReference `json:"reply,omitempty"`
}

func (*SequenceSpec) DeepCopy

func (in *SequenceSpec) DeepCopy() *SequenceSpec

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

func (*SequenceSpec) DeepCopyInto

func (in *SequenceSpec) DeepCopyInto(out *SequenceSpec)

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

func (*SequenceSpec) SetDefaults

func (ss *SequenceSpec) SetDefaults(ctx context.Context)

func (*SequenceSpec) Validate

func (ps *SequenceSpec) Validate(ctx context.Context) *apis.FieldError

type SequenceStatus

type SequenceStatus struct {
	// inherits duck/v1alpha1 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.
	duckv1beta1.Status `json:",inline"`

	// SubscriptionStatuses is an array of corresponding Subscription statuses.
	// Matches the Spec.Steps array in the order.
	SubscriptionStatuses []SequenceSubscriptionStatus `json:"subscriptionStatuses"`

	// ChannelStatuses is an array of corresponding Channel statuses.
	// Matches the Spec.Steps array in the order.
	ChannelStatuses []SequenceChannelStatus `json:"channelStatuses"`

	// AddressStatus is the starting point to this Sequence. Sending to this
	// will target the first subscriber.
	// It generally has the form {channel}.{namespace}.svc.{cluster domain name}
	duckv1alpha1.AddressStatus `json:",inline"`
}

SequenceStatus represents the current state of a Sequence.

func (*SequenceStatus) DeepCopy

func (in *SequenceStatus) DeepCopy() *SequenceStatus

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

func (*SequenceStatus) DeepCopyInto

func (in *SequenceStatus) DeepCopyInto(out *SequenceStatus)

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

func (*SequenceStatus) GetCondition

func (ps *SequenceStatus) GetCondition(t apis.ConditionType) *apis.Condition

GetCondition returns the condition currently associated with the given type, or nil.

func (*SequenceStatus) InitializeConditions

func (ps *SequenceStatus) InitializeConditions()

InitializeConditions sets relevant unset conditions to Unknown state.

func (*SequenceStatus) IsReady

func (ps *SequenceStatus) IsReady() bool

IsReady returns true if the resource is ready overall.

func (*SequenceStatus) MarkAddressableNotReady

func (ps *SequenceStatus) MarkAddressableNotReady(reason, messageFormat string, messageA ...interface{})

func (*SequenceStatus) MarkChannelsNotReady

func (ps *SequenceStatus) MarkChannelsNotReady(reason, messageFormat string, messageA ...interface{})

func (*SequenceStatus) MarkSubscriptionsNotReady

func (ps *SequenceStatus) MarkSubscriptionsNotReady(reason, messageFormat string, messageA ...interface{})

func (*SequenceStatus) PropagateChannelStatuses

func (ps *SequenceStatus) PropagateChannelStatuses(channels []*duckv1alpha1.Channelable)

PropagateChannelStatuses sets the ChannelStatuses and SequenceConditionChannelsReady based on the status of the incoming channels.

func (*SequenceStatus) PropagateSubscriptionStatuses

func (ps *SequenceStatus) PropagateSubscriptionStatuses(subscriptions []*eventingv1alpha1.Subscription)

PropagateSubscriptionStatuses sets the SubscriptionStatuses and SequenceConditionSubscriptionsReady based on the status of the incoming subscriptions.

type SequenceSubscriptionStatus

type SequenceSubscriptionStatus struct {
	// Subscription is the reference to the underlying Subscription.
	Subscription corev1.ObjectReference `json:"subscription"`

	// ReadyCondition indicates whether the Subscription is ready or not.
	ReadyCondition apis.Condition `json:"ready"`
}

func (*SequenceSubscriptionStatus) DeepCopy

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

func (*SequenceSubscriptionStatus) DeepCopyInto

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL