v1alpha1

package
v0.10.2 Latest Latest
Warning

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

 Go to latest Published: Dec 3, 2019 License: Apache-2.0 Imports: 21 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 (
	// 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 (
	// ParallelConditionReady has status True when all subconditions below have been set to True.
	ParallelConditionReady = apis.ConditionReady

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

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

	// ParallelConditionAddressable has status true when this Parallel meets
	// the Addressable contract and has a non-empty hostname.
	ParallelConditionAddressable apis.ConditionType = "Addressable"
)
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"
)
View Source 
const (
	// SubscriptionConditionReady has status True when all subconditions below have been set to True.
	SubscriptionConditionReady = apis.ConditionReady
	// SubscriptionConditionReferencesResolved has status True when all the specified references have been successfully
	// resolved.
	SubscriptionConditionReferencesResolved apis.ConditionType = "Resolved"

	// SubscriptionConditionAddedToChannel has status True when controller has successfully added a
	// subscription to the spec.channel resource.
	SubscriptionConditionAddedToChannel apis.ConditionType = "AddedToChannel"

	// SubscriptionConditionChannelReady has status True when the channel has marked the subscriber as 'ready'
	SubscriptionConditionChannelReady apis.ConditionType = "ChannelReady"

	// SubscriptionConditionReplyDeprecated is used to tell the user they are using deprecated fields.
	SubscriptionConditionReplyDeprecated = "Deprecated"
)
View Source 
const (
	// StatusConditionTypeDeprecated is the status.conditions.type used to provide deprecation
	// warnings.
	StatusConditionTypeDeprecated = "Deprecated"
)

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 IsValidObjectReference added in v0.9.0 

func IsValidObjectReference(f corev1.ObjectReference) *apis.FieldError

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) GetUntypedSpec added in v0.10.0 

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

GetUntypedSpec returns the spec of the Channel.

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/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"`

	// 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 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) GetUntypedSpec added in v0.10.0 

func (i *InMemoryChannel) GetUntypedSpec() interface{}

GetUntypedSpec returns the spec of the InMemoryChannel.

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/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"`

	// 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 

func (in *InMemoryChannelStatus) DeepCopy() *InMemoryChannelStatus

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 Parallel added in v0.9.0 

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

	// Spec defines the desired state of the Parallel.
	Spec ParallelSpec `json:"spec,omitempty"`

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

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

func (*Parallel) DeepCopy added in v0.9.0 

func (in *Parallel) DeepCopy() *Parallel

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

func (*Parallel) DeepCopyInto added in v0.9.0 

func (in *Parallel) DeepCopyInto(out *Parallel)

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

func (*Parallel) DeepCopyObject added in v0.9.0 

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

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

func (*Parallel) GetGroupVersionKind added in v0.9.0 

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

GetGroupVersionKind returns GroupVersionKind for Parallel

func (*Parallel) GetUntypedSpec added in v0.10.0 

func (p *Parallel) GetUntypedSpec() interface{}

GetUntypedSpec returns the spec of the Parallel.

func (*Parallel) SetDefaults added in v0.9.0 

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

func (*Parallel) Validate added in v0.9.0 

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

type ParallelBranch added in v0.9.0 

type ParallelBranch struct {
	// Filter is the expression guarding the branch
	Filter *v1alpha1.Destination `json:"filter,omitempty"`

	// Subscriber receiving the event when the filter passes
	Subscriber v1alpha1.Destination `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 Parallel Reply
	// +optional
	Reply *v1alpha1.Destination `json:"reply,omitempty"`
}

func (*ParallelBranch) DeepCopy added in v0.9.0 

func (in *ParallelBranch) DeepCopy() *ParallelBranch

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

func (*ParallelBranch) DeepCopyInto added in v0.9.0 

func (in *ParallelBranch) DeepCopyInto(out *ParallelBranch)

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

type ParallelBranchStatus added in v0.9.0 

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

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

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

ParallelBranchStatus represents the current state of a Parallel branch

func (*ParallelBranchStatus) DeepCopy added in v0.9.0 

func (in *ParallelBranchStatus) DeepCopy() *ParallelBranchStatus

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

func (*ParallelBranchStatus) DeepCopyInto added in v0.9.0 

func (in *ParallelBranchStatus) DeepCopyInto(out *ParallelBranchStatus)

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

type ParallelChannelStatus added in v0.9.0 

type ParallelChannelStatus 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 (*ParallelChannelStatus) DeepCopy added in v0.9.0 

func (in *ParallelChannelStatus) DeepCopy() *ParallelChannelStatus

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

func (*ParallelChannelStatus) DeepCopyInto added in v0.9.0 

func (in *ParallelChannelStatus) DeepCopyInto(out *ParallelChannelStatus)

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

type ParallelList added in v0.9.0 

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

ParallelList is a collection of Parallels.

func (*ParallelList) DeepCopy added in v0.9.0 

func (in *ParallelList) DeepCopy() *ParallelList

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

func (*ParallelList) DeepCopyInto added in v0.9.0 

func (in *ParallelList) DeepCopyInto(out *ParallelList)

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

func (*ParallelList) DeepCopyObject added in v0.9.0 

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

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

type ParallelSpec added in v0.9.0 

type ParallelSpec struct {
	// Branches is the list of Filter/Subscribers pairs.
	Branches []ParallelBranch `json:"branches"`

	// 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
	// +optional
	Reply *v1alpha1.Destination `json:"reply,omitempty"`
}

func (*ParallelSpec) DeepCopy added in v0.9.0 

func (in *ParallelSpec) DeepCopy() *ParallelSpec

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

func (*ParallelSpec) DeepCopyInto added in v0.9.0 

func (in *ParallelSpec) DeepCopyInto(out *ParallelSpec)

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

func (*ParallelSpec) SetDefaults added in v0.9.0 

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

func (*ParallelSpec) Validate added in v0.9.0 

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

type ParallelStatus added in v0.9.0 

type ParallelStatus 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"`

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

	// BranchStatuses is an array of corresponding to branch statuses.
	// Matches the Spec.Branches array in the order.
	BranchStatuses []ParallelBranchStatus `json:"branchStatuses"`

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

ParallelStatus represents the current state of a Parallel.

func (*ParallelStatus) ClearDeprecated added in v0.10.0 

func (ps *ParallelStatus) ClearDeprecated()

ClearDeprecated removes the StatusConditionTypeDeprecated warning condition. Note that this does not affect the Ready condition.

func (*ParallelStatus) DeepCopy added in v0.9.0 

func (in *ParallelStatus) DeepCopy() *ParallelStatus

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

func (*ParallelStatus) DeepCopyInto added in v0.9.0 

func (in *ParallelStatus) DeepCopyInto(out *ParallelStatus)

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

func (*ParallelStatus) GetCondition added in v0.9.0 

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

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

func (*ParallelStatus) InitializeConditions added in v0.9.0 

func (ps *ParallelStatus) InitializeConditions()

InitializeConditions sets relevant unset conditions to Unknown state.

func (*ParallelStatus) IsReady added in v0.9.0 

func (ps *ParallelStatus) IsReady() bool

IsReady returns true if the resource is ready overall.

func (*ParallelStatus) MarkAddressableNotReady added in v0.9.0 

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

func (*ParallelStatus) MarkChannelsNotReady added in v0.9.0 

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

func (*ParallelStatus) MarkDestinationDeprecatedRef added in v0.10.0 

func (ps *ParallelStatus) MarkDestinationDeprecatedRef(reason, msg string)

MarkDeprecated adds a warning condition that this object's spec is using deprecated fields and will stop working in the future. Note that this does not affect the Ready condition.

func (*ParallelStatus) MarkSubscriptionsNotReady added in v0.9.0 

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

func (*ParallelStatus) PropagateChannelStatuses added in v0.9.0 

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

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

func (*ParallelStatus) PropagateSubscriptionStatuses added in v0.9.0 

func (ps *ParallelStatus) PropagateSubscriptionStatuses(filterSubscriptions []*Subscription, subscriptions []*Subscription)

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

type ParallelSubscriptionStatus added in v0.9.0 

type ParallelSubscriptionStatus 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 (*ParallelSubscriptionStatus) DeepCopy added in v0.9.0 

func (in *ParallelSubscriptionStatus) DeepCopy() *ParallelSubscriptionStatus

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

func (*ParallelSubscriptionStatus) DeepCopyInto added in v0.9.0 

func (in *ParallelSubscriptionStatus) DeepCopyInto(out *ParallelSubscriptionStatus)

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

type ReplyStrategy added in v0.9.0 

type ReplyStrategy struct {
	//  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
	Channel *apisv1alpha1.Destination `json:"channel,omitempty"`
}

ReplyStrategy specifies the handling of the Subscriber's returned replies. If no Subscriber is specified, the identity function is assumed.

func (*ReplyStrategy) DeepCopy added in v0.9.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.9.0 

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

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

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) GetUntypedSpec added in v0.10.0 

func (s *Sequence) GetUntypedSpec() interface{}

GetUntypedSpec returns the spec of the Sequence.

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 

func (in *SequenceChannelStatus) DeepCopy() *SequenceChannelStatus

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 Destinations (processors / functions) that will be called in the order
	// provided.
	Steps []v1alpha1.Destination `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.
	// +optional
	Reply *v1alpha1.Destination `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/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"`

	// 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) ClearDeprecated added in v0.10.0 

func (ss *SequenceStatus) ClearDeprecated()

ClearDeprecated removes the StatusConditionTypeDeprecated warning condition. Note that this does not affect the Ready condition.

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 (ss *SequenceStatus) GetCondition(t apis.ConditionType) *apis.Condition

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

func (*SequenceStatus) InitializeConditions 

func (ss *SequenceStatus) InitializeConditions()

InitializeConditions sets relevant unset conditions to Unknown state.

func (*SequenceStatus) IsReady 

func (ss *SequenceStatus) IsReady() bool

IsReady returns true if the resource is ready overall.

func (*SequenceStatus) MarkAddressableNotReady 

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

func (*SequenceStatus) MarkChannelsNotReady 

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

func (*SequenceStatus) MarkDestinationDeprecatedRef added in v0.10.0 

func (ss *SequenceStatus) MarkDestinationDeprecatedRef(reason, msg string)

MarkDeprecated adds a warning condition that this object's spec is using deprecated fields and will stop working in the future. Note that this does not affect the Ready condition.

func (*SequenceStatus) MarkSubscriptionsNotReady 

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

func (*SequenceStatus) PropagateChannelStatuses 

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

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

func (*SequenceStatus) PropagateSubscriptionStatuses 

func (ss *SequenceStatus) PropagateSubscriptionStatuses(subscriptions []*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 

func (in *SequenceSubscriptionStatus) DeepCopy() *SequenceSubscriptionStatus

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

func (*SequenceSubscriptionStatus) DeepCopyInto 

func (in *SequenceSubscriptionStatus) DeepCopyInto(out *SequenceSubscriptionStatus)

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

type Subscription added in v0.9.0 

type Subscription struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata"`
	Spec              SubscriptionSpec   `json:"spec"`
	Status            SubscriptionStatus `json:"status,omitempty"`
}

Subscription routes events received on a Channel to a DNS name and corresponds to the subscriptions.channels.knative.dev CRD.

func (*Subscription) CheckImmutableFields added in v0.9.0 

func (s *Subscription) CheckImmutableFields(ctx context.Context, og apis.Immutable) *apis.FieldError

func (*Subscription) DeepCopy added in v0.9.0 

func (in *Subscription) DeepCopy() *Subscription

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

func (*Subscription) DeepCopyInto added in v0.9.0 

func (in *Subscription) DeepCopyInto(out *Subscription)

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

func (*Subscription) DeepCopyObject added in v0.9.0 

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

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

func (*Subscription) GetGroupVersionKind added in v0.9.0 

func (t *Subscription) GetGroupVersionKind() schema.GroupVersionKind

GetGroupVersionKind returns GroupVersionKind for Subscriptions

func (*Subscription) GetUntypedSpec added in v0.10.0 

func (s *Subscription) GetUntypedSpec() interface{}

GetUntypedSpec returns the spec of the Subscription.

func (*Subscription) SetDefaults added in v0.9.0 

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

func (*Subscription) Validate added in v0.9.0 

func (s *Subscription) Validate(ctx context.Context) *apis.FieldError

type SubscriptionList added in v0.9.0 

type SubscriptionList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata"`
	Items           []Subscription `json:"items"`
}

SubscriptionList returned in list operations

func (*SubscriptionList) DeepCopy added in v0.9.0 

func (in *SubscriptionList) DeepCopy() *SubscriptionList

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

func (*SubscriptionList) DeepCopyInto added in v0.9.0 

func (in *SubscriptionList) DeepCopyInto(out *SubscriptionList)

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

func (*SubscriptionList) DeepCopyObject added in v0.9.0 

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

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

type SubscriptionSpec added in v0.9.0 

type SubscriptionSpec struct {
	// TODO By enabling the status subresource metadata.generation should increment
	// thus making this property obsolete.
	//
	// We should be able to drop this property with a CRD conversion webhook
	// in the future
	//
	// +optional
	DeprecatedGeneration int64 `json:"generation,omitempty"`

	// This field is immutable. We have no good answer on what happens to
	// the events that are currently in the channel being consumed from
	// and what the semantics there should be. For now, you can always
	// delete the Subscription and recreate it to point to a different
	// channel, giving the user more control over what semantics should
	// be used (drain the channel first, possibly have events dropped,
	// etc.)
	Channel corev1.ObjectReference `json:"channel"`

	// Subscriber is reference to (optional) function for processing events.
	// Events from the Channel will be delivered here and replies are
	// sent to a channel as specified by the Reply.
	// +optional
	Subscriber *apisv1alpha1.Destination `json:"subscriber,omitempty"`

	// Reply specifies (optionally) how to handle events returned from
	// the Subscriber target.
	// +optional
	Reply *ReplyStrategy `json:"reply,omitempty"`
}

SubscriptionSpec specifies the Channel for incoming events, a Subscriber target for processing those events and where to put the result of the processing. Only From (where the events are coming from) is always required. You can optionally only Process the events (results in no output events) by leaving out the Result. You can also perform an identity transformation on the incoming events by leaving out the Subscriber and only specifying Result.

The following are all valid specifications: channel --[subscriber]--> reply Sink, no outgoing events: channel -- subscriber no-op function (identity transformation): channel --> reply

func (*SubscriptionSpec) DeepCopy added in v0.9.0 

func (in *SubscriptionSpec) DeepCopy() *SubscriptionSpec

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

func (*SubscriptionSpec) DeepCopyInto added in v0.9.0 

func (in *SubscriptionSpec) DeepCopyInto(out *SubscriptionSpec)

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

func (*SubscriptionSpec) SetDefaults added in v0.9.0 

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

func (*SubscriptionSpec) Validate added in v0.9.0 

func (ss *SubscriptionSpec) Validate(ctx context.Context) *apis.FieldError

type SubscriptionStatus added in v0.9.0 

type SubscriptionStatus 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"`

	// PhysicalSubscription is the fully resolved values that this Subscription represents.
	PhysicalSubscription SubscriptionStatusPhysicalSubscription `json:"physicalSubscription,omitempty"`
}

SubscriptionStatus (computed) for a subscription

func (*SubscriptionStatus) AreReferencesResolved added in v0.9.0 

func (ss *SubscriptionStatus) AreReferencesResolved() bool

AreReferencesResolved returns true if SubscriptionConditionReferencesResolved is true

func (*SubscriptionStatus) ClearDeprecated added in v0.10.0 

func (s *SubscriptionStatus) ClearDeprecated()

ClearDeprecated removes the StatusConditionTypeDeprecated warning condition. Note that this does not affect the Ready condition.

func (*SubscriptionStatus) DeepCopy added in v0.9.0 

func (in *SubscriptionStatus) DeepCopy() *SubscriptionStatus

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

func (*SubscriptionStatus) DeepCopyInto added in v0.9.0 

func (in *SubscriptionStatus) DeepCopyInto(out *SubscriptionStatus)

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

func (*SubscriptionStatus) GetCondition added in v0.9.0 

func (ss *SubscriptionStatus) GetCondition(t apis.ConditionType) *apis.Condition

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

func (*SubscriptionStatus) InitializeConditions added in v0.9.0 

func (ss *SubscriptionStatus) InitializeConditions()

InitializeConditions sets relevant unset conditions to Unknown state.

func (*SubscriptionStatus) IsAddedToChannel added in v0.9.0 

func (ss *SubscriptionStatus) IsAddedToChannel() bool

IsAddedToChannel returns true if SubscriptionConditionAddedToChannel is true

func (*SubscriptionStatus) IsReady added in v0.9.0 

func (ss *SubscriptionStatus) IsReady() bool

IsReady returns true if the resource is ready overall.

func (*SubscriptionStatus) MarkAddedToChannel added in v0.9.0 

func (ss *SubscriptionStatus) MarkAddedToChannel()

MarkAddedToChannel sets the AddedToChannel condition to True state.

func (*SubscriptionStatus) MarkChannelNotReady added in v0.9.0 

func (ss *SubscriptionStatus) MarkChannelNotReady(reason, messageFormat string, messageA ...interface{})

MarkChannelNotReady sets the ChannelReady condition to False state.

func (*SubscriptionStatus) MarkChannelReady added in v0.9.0 

func (ss *SubscriptionStatus) MarkChannelReady()

MarkChannelReady sets the ChannelReady condition to True state.

func (*SubscriptionStatus) MarkNotAddedToChannel added in v0.9.0 

func (ss *SubscriptionStatus) MarkNotAddedToChannel(reason, messageFormat string, messageA ...interface{})

MarkNotAddedToChannel sets the AddedToChannel condition to False state.

func (*SubscriptionStatus) MarkReferencesNotResolved added in v0.9.0 

func (ss *SubscriptionStatus) MarkReferencesNotResolved(reason, messageFormat string, messageA ...interface{})

MarkReferencesNotResolved sets the ReferencesResolved condition to False state.

func (*SubscriptionStatus) MarkReferencesResolved added in v0.9.0 

func (ss *SubscriptionStatus) MarkReferencesResolved()

MarkReferencesResolved sets the ReferencesResolved condition to True state.

func (*SubscriptionStatus) MarkReplyDeprecatedRef added in v0.10.0 

func (s *SubscriptionStatus) MarkReplyDeprecatedRef(reason, msg string)

MarkDeprecated adds a warning condition that this object's spec is using deprecated fields and will stop working in the future. Note that this does not affect the Ready condition.

type SubscriptionStatusPhysicalSubscription added in v0.9.0 

type SubscriptionStatusPhysicalSubscription struct {
	// SubscriberURI is the fully resolved URI for spec.subscriber.
	SubscriberURI *apis.URL `json:"subscriberURI,omitempty"`

	// ReplyURI is the fully resolved URI for the spec.reply.
	ReplyURI *apis.URL `json:"replyURI,omitempty"`
}

SubscriptionStatusPhysicalSubscription represents the fully resolved values for this Subscription.

func (*SubscriptionStatusPhysicalSubscription) DeepCopy added in v0.9.0 

func (in *SubscriptionStatusPhysicalSubscription) DeepCopy() *SubscriptionStatusPhysicalSubscription

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

func (*SubscriptionStatusPhysicalSubscription) DeepCopyInto added in v0.9.0 

func (in *SubscriptionStatusPhysicalSubscription) DeepCopyInto(out *SubscriptionStatusPhysicalSubscription)

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.