v1alpha1

package

Go to main page

Versions in this module

v0

v0.11.0

Dec 10, 2019

Changes in this version

type ParallelStatus

+ func (ps *ParallelStatus) MarkDeprecated(reason, msg string)

type ReplyStrategy

+ DeprecatedChannel *duckv1beta1.Destination

type SequenceStatus

+ func (ss *SequenceStatus) MarkDeprecated(reason, msg string)

type SubscriptionSpec

+ Delivery *eventingduckv1alpha1.DeliverySpec

type SubscriptionStatusPhysicalSubscription

+ DeadLetterSinkURI *apis.URL

v0.10.2

Dec 3, 2019

v0.10.1

Nov 13, 2019

v0.10.0

Oct 29, 2019

Changes in this version

+ const StatusConditionTypeDeprecated

+ const SubscriptionConditionReplyDeprecated

type Channel

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

type InMemoryChannel

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

type Parallel

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

type ParallelStatus

+ func (ps *ParallelStatus) ClearDeprecated()

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

type Sequence

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

type SequenceStatus

+ func (ss *SequenceStatus) ClearDeprecated()

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

type Subscription

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

type SubscriptionStatus

+ func (s *SubscriptionStatus) ClearDeprecated()

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

v0.9.0

Sep 17, 2019

Changes in this version

+ const ParallelConditionAddressable

+ const ParallelConditionChannelsReady

+ const ParallelConditionReady

+ const ParallelConditionSubscriptionsReady

+ const SubscriptionConditionAddedToChannel

+ const SubscriptionConditionChannelReady

+ const SubscriptionConditionReady

+ const SubscriptionConditionReferencesResolved

+ func IsSubscriberSpecNilOrEmpty(s *SubscriberSpec) bool

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

+ func IsValidSubscriberSpec(s SubscriberSpec) *apis.FieldError

+ type HasSpec interface

+ GetSpec func() interface{}

+ type Parallel struct

+ Spec ParallelSpec

+ Status ParallelStatus

+ func (in *Parallel) DeepCopy() *Parallel

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

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

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

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

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

+ type ParallelBranch struct

+ Filter *SubscriberSpec

+ Reply *corev1.ObjectReference

+ Subscriber SubscriberSpec

+ func (in *ParallelBranch) DeepCopy() *ParallelBranch

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

+ type ParallelBranchStatus struct

+ FilterChannelStatus ParallelChannelStatus

+ FilterSubscriptionStatus ParallelSubscriptionStatus

+ SubscriptionStatus ParallelSubscriptionStatus

+ func (in *ParallelBranchStatus) DeepCopy() *ParallelBranchStatus

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

+ type ParallelChannelStatus struct

+ Channel corev1.ObjectReference

+ ReadyCondition apis.Condition

+ func (in *ParallelChannelStatus) DeepCopy() *ParallelChannelStatus

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

+ type ParallelList struct

+ Items []Parallel

+ func (in *ParallelList) DeepCopy() *ParallelList

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

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

+ type ParallelSpec struct

+ Branches []ParallelBranch

+ ChannelTemplate *eventingduckv1alpha1.ChannelTemplateSpec

+ Reply *corev1.ObjectReference

+ func (in *ParallelSpec) DeepCopy() *ParallelSpec

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

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

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

+ type ParallelStatus struct

+ BranchStatuses []ParallelBranchStatus

+ IngressChannelStatus ParallelChannelStatus

+ func (in *ParallelStatus) DeepCopy() *ParallelStatus

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

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

+ func (ps *ParallelStatus) InitializeConditions()

+ func (ps *ParallelStatus) IsReady() bool

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

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

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

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

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

+ type ParallelSubscriptionStatus struct

+ ReadyCondition apis.Condition

+ Subscription corev1.ObjectReference

+ func (in *ParallelSubscriptionStatus) DeepCopy() *ParallelSubscriptionStatus

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

+ type ReplyStrategy struct

+ Channel *corev1.ObjectReference

+ func (in *ReplyStrategy) DeepCopy() *ReplyStrategy

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

+ type SubscriberSpec struct

+ DeprecatedDNSName *string

+ Ref *corev1.ObjectReference

+ URI *string

+ func (in *SubscriberSpec) DeepCopy() *SubscriberSpec

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

+ type Subscription struct

+ Spec SubscriptionSpec

+ Status SubscriptionStatus

+ func (in *Subscription) DeepCopy() *Subscription

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

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

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

+ func (s *Subscription) GetSpec() interface{}

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

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

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

+ type SubscriptionList struct

+ Items []Subscription

+ func (in *SubscriptionList) DeepCopy() *SubscriptionList

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

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

+ type SubscriptionSpec struct

+ Channel corev1.ObjectReference

+ DeprecatedGeneration int64

+ Reply *ReplyStrategy

+ Subscriber *SubscriberSpec

+ func (in *SubscriptionSpec) DeepCopy() *SubscriptionSpec

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

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

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

+ type SubscriptionStatus struct

+ PhysicalSubscription SubscriptionStatusPhysicalSubscription

+ func (in *SubscriptionStatus) DeepCopy() *SubscriptionStatus

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

+ func (ss *SubscriptionStatus) AreReferencesResolved() bool

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

+ func (ss *SubscriptionStatus) InitializeConditions()

+ func (ss *SubscriptionStatus) IsAddedToChannel() bool

+ func (ss *SubscriptionStatus) IsReady() bool

+ func (ss *SubscriptionStatus) MarkAddedToChannel()

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

+ func (ss *SubscriptionStatus) MarkChannelReady()

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

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

+ func (ss *SubscriptionStatus) MarkReferencesResolved()

+ type SubscriptionStatusPhysicalSubscription struct

+ ReplyURI string

+ SubscriberURI string

+ func (in *SubscriptionStatusPhysicalSubscription) DeepCopy() *SubscriptionStatusPhysicalSubscription

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

v0.8.1

Nov 18, 2019

v0.8.0

Aug 6, 2019

Changes in this version

+ const ChannelConditionAddressable

+ const ChannelConditionBackingChannelReady

+ const ChannelConditionReady

+ const ChoiceConditionAddressable

+ const ChoiceConditionChannelsReady

+ const ChoiceConditionReady

+ const ChoiceConditionSubscriptionsReady

+ type Channel struct

+ Spec ChannelSpec

+ Status ChannelStatus

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

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

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

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

+ func (in *Channel) DeepCopy() *Channel

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

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

+ type ChannelList struct

+ Items []Channel

+ func (in *ChannelList) DeepCopy() *ChannelList

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

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

+ type ChannelSpec struct

+ ChannelTemplate *eventingduck.ChannelTemplateSpec

+ Subscribable *eventingduck.Subscribable

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

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

+ func (in *ChannelSpec) DeepCopy() *ChannelSpec

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

+ type ChannelStatus struct

+ Channel *corev1.ObjectReference

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

+ func (cs *ChannelStatus) InitializeConditions()

+ func (cs *ChannelStatus) IsReady() bool

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

+ func (cs *ChannelStatus) MarkBackingChannelReady()

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

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

+ func (in *ChannelStatus) DeepCopy() *ChannelStatus

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

+ type Choice struct

+ Spec ChoiceSpec

+ Status ChoiceStatus

+ func (in *Choice) DeepCopy() *Choice

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

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

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

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

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

+ type ChoiceCase struct

+ Filter *eventingv1alpha1.SubscriberSpec

+ Reply *corev1.ObjectReference

+ Subscriber eventingv1alpha1.SubscriberSpec

+ func (in *ChoiceCase) DeepCopy() *ChoiceCase

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

+ type ChoiceCaseStatus struct

+ FilterChannelStatus ChoiceChannelStatus

+ FilterSubscriptionStatus ChoiceSubscriptionStatus

+ SubscriptionStatus ChoiceSubscriptionStatus

+ func (in *ChoiceCaseStatus) DeepCopy() *ChoiceCaseStatus

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

+ type ChoiceChannelStatus struct

+ Channel corev1.ObjectReference

+ ReadyCondition apis.Condition

+ func (in *ChoiceChannelStatus) DeepCopy() *ChoiceChannelStatus

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

+ type ChoiceList struct

+ Items []Choice

+ func (in *ChoiceList) DeepCopy() *ChoiceList

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

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

+ type ChoiceSpec struct

+ Cases []ChoiceCase

+ ChannelTemplate *eventingduckv1alpha1.ChannelTemplateSpec

+ Reply *corev1.ObjectReference

+ func (in *ChoiceSpec) DeepCopy() *ChoiceSpec

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

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

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

+ type ChoiceStatus struct

+ CaseStatuses []ChoiceCaseStatus

+ IngressChannelStatus ChoiceChannelStatus

+ func (in *ChoiceStatus) DeepCopy() *ChoiceStatus

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

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

+ func (ps *ChoiceStatus) InitializeConditions()

+ func (ps *ChoiceStatus) IsReady() bool

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

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

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

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

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

+ type ChoiceSubscriptionStatus struct

+ ReadyCondition apis.Condition

+ Subscription corev1.ObjectReference

+ func (in *ChoiceSubscriptionStatus) DeepCopy() *ChoiceSubscriptionStatus

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

v0.7.1

Jul 2, 2019

v0.7.0

Jun 25, 2019

Changes in this version

+ const InMemoryChannelConditionAddressable

+ const InMemoryChannelConditionChannelServiceReady

+ const InMemoryChannelConditionDispatcherReady

+ const InMemoryChannelConditionEndpointsReady

+ const InMemoryChannelConditionReady

+ const InMemoryChannelConditionServiceReady

+ const SequenceConditionAddressable

+ const SequenceConditionChannelsReady

+ const SequenceConditionReady

+ const SequenceConditionSubscriptionsReady

+ var AddToScheme = SchemeBuilder.AddToScheme

+ var SchemeBuilder = runtime.NewSchemeBuilder(addKnownTypes)

+ var SchemeGroupVersion = schema.GroupVersion

+ func Kind(kind string) schema.GroupKind

+ func Resource(resource string) schema.GroupResource

+ type ChannelTemplateSpec struct

+ Spec *runtime.RawExtension

+ func (in *ChannelTemplateSpec) DeepCopy() *ChannelTemplateSpec

+ func (in *ChannelTemplateSpec) DeepCopyInto(out *ChannelTemplateSpec)

+ func (in *ChannelTemplateSpec) DeepCopyObject() runtime.Object

+ type ChannelTemplateSpecInternal struct

+ Spec *runtime.RawExtension

+ func (in *ChannelTemplateSpecInternal) DeepCopy() *ChannelTemplateSpecInternal

+ func (in *ChannelTemplateSpecInternal) DeepCopyInto(out *ChannelTemplateSpecInternal)

+ func (in *ChannelTemplateSpecInternal) DeepCopyObject() runtime.Object

+ type InMemoryChannel struct

+ Spec InMemoryChannelSpec

+ Status InMemoryChannelStatus

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

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

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

+ func (in *InMemoryChannel) DeepCopy() *InMemoryChannel

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

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

+ type InMemoryChannelList struct

+ Items []InMemoryChannel

+ func (in *InMemoryChannelList) DeepCopy() *InMemoryChannelList

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

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

+ type InMemoryChannelSpec struct

+ Subscribable *eventingduck.Subscribable

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

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

+ func (in *InMemoryChannelSpec) DeepCopy() *InMemoryChannelSpec

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

+ type InMemoryChannelStatus struct

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

+ func (imcs *InMemoryChannelStatus) InitializeConditions()

+ func (imcs *InMemoryChannelStatus) IsReady() bool

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

+ func (imcs *InMemoryChannelStatus) MarkChannelServiceTrue()

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

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

+ func (imcs *InMemoryChannelStatus) MarkEndpointsTrue()

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

+ func (imcs *InMemoryChannelStatus) MarkServiceTrue()

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

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

+ func (in *InMemoryChannelStatus) DeepCopy() *InMemoryChannelStatus

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

+ type Sequence struct

+ Spec SequenceSpec

+ Status SequenceStatus

+ func (in *Sequence) DeepCopy() *Sequence

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

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

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

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

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

+ type SequenceChannelStatus struct

+ Channel corev1.ObjectReference

+ ReadyCondition apis.Condition

+ func (in *SequenceChannelStatus) DeepCopy() *SequenceChannelStatus

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

+ type SequenceList struct

+ Items []Sequence

+ func (in *SequenceList) DeepCopy() *SequenceList

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

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

+ type SequenceSpec struct

+ ChannelTemplate ChannelTemplateSpec

+ Reply *corev1.ObjectReference

+ Steps []eventingv1alpha1.SubscriberSpec

+ func (in *SequenceSpec) DeepCopy() *SequenceSpec

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

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

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

+ type SequenceStatus struct

+ ChannelStatuses []SequenceChannelStatus

+ SubscriptionStatuses []SequenceSubscriptionStatus

+ func (in *SequenceStatus) DeepCopy() *SequenceStatus

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

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

+ func (ps *SequenceStatus) InitializeConditions()

+ func (ps *SequenceStatus) IsReady() bool

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

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

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

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

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

+ type SequenceSubscriptionStatus struct

+ ReadyCondition apis.Condition

+ Subscription corev1.ObjectReference

+ func (in *SequenceSubscriptionStatus) DeepCopy() *SequenceSubscriptionStatus

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

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