Versions in this module Expand all Collapse all v0 v0.23.0 May 25, 2021 v0.22.0 May 4, 2021 Changes in this version + const BrokerClass + const BrokerConditionBrokerCell + const BrokerConditionSubscription + const BrokerConditionTopic + const DependencyAnnotation + const InjectionAnnotation + const TriggerConditionSubscription + const TriggerConditionTopic + var AddToScheme = SchemeBuilder.AddToScheme + var SchemeBuilder = runtime.NewSchemeBuilder(addKnownTypes) + var SchemeGroupVersion = schema.GroupVersion + var TestHelper = testHelper + func Kind(kind string) schema.GroupKind + func Resource(resource string) schema.GroupResource + func ValidateDeadLetterSink(ctx context.Context, sink *duckv1.Destination) *apis.FieldError + func ValidateDeliverySpec(ctx context.Context, spec *eventingduckv1.DeliverySpec) *apis.FieldError + type Broker struct + Spec eventingv1.BrokerSpec + Status BrokerStatus + func (*Broker) GetConditionSet() apis.ConditionSet + func (b *Broker) GetGroupVersionKind() schema.GroupVersionKind + func (b *Broker) GetStatus() *duckv1.Status + func (b *Broker) GetUntypedSpec() interface{} + func (b *Broker) SetDefaults(ctx context.Context) + func (b *Broker) Validate(ctx context.Context) *apis.FieldError + func (in *Broker) DeepCopy() *Broker + func (in *Broker) DeepCopyInto(out *Broker) + func (in *Broker) DeepCopyObject() runtime.Object + type BrokerList struct + Items []Broker + func (in *BrokerList) DeepCopy() *BrokerList + func (in *BrokerList) DeepCopyInto(out *BrokerList) + func (in *BrokerList) DeepCopyObject() runtime.Object + type BrokerStatus struct + func (bs *BrokerStatus) GetCondition(t apis.ConditionType) *apis.Condition + func (bs *BrokerStatus) GetTopLevelCondition() *apis.Condition + func (bs *BrokerStatus) InitializeConditions() + func (bs *BrokerStatus) IsReady() bool + func (bs *BrokerStatus) MarkBrokerCellFailed(reason, format string, args ...interface{}) + func (bs *BrokerStatus) MarkBrokerCellReady() + func (bs *BrokerStatus) MarkBrokerCellUnknown(reason, format string, args ...interface{}) + func (bs *BrokerStatus) MarkSubscriptionFailed(reason, format string, args ...interface{}) + func (bs *BrokerStatus) MarkSubscriptionReady(_ string) + func (bs *BrokerStatus) MarkSubscriptionUnknown(reason, format string, args ...interface{}) + func (bs *BrokerStatus) MarkTopicFailed(reason, format string, args ...interface{}) + func (bs *BrokerStatus) MarkTopicReady() + func (bs *BrokerStatus) MarkTopicUnknown(reason, format string, args ...interface{}) + func (bs *BrokerStatus) SetAddress(url *apis.URL) + func (in *BrokerStatus) DeepCopy() *BrokerStatus + func (in *BrokerStatus) DeepCopyInto(out *BrokerStatus) + type Trigger struct + Spec eventingv1.TriggerSpec + Status TriggerStatus + func (*Trigger) GetConditionSet() apis.ConditionSet + func (in *Trigger) DeepCopy() *Trigger + func (in *Trigger) DeepCopyInto(out *Trigger) + func (in *Trigger) DeepCopyObject() runtime.Object + func (t *Trigger) GetGroupVersionKind() schema.GroupVersionKind + func (t *Trigger) GetStatus() *duckv1.Status + func (t *Trigger) GetUntypedSpec() interface{} + func (t *Trigger) SetDefaults(ctx context.Context) + func (t *Trigger) Validate(ctx context.Context) *apis.FieldError + type TriggerList struct + Items []Trigger + func (in *TriggerList) DeepCopy() *TriggerList + func (in *TriggerList) DeepCopyInto(out *TriggerList) + func (in *TriggerList) DeepCopyObject() runtime.Object + type TriggerStatus struct + func (bs *TriggerStatus) MarkSubscriptionFailed(reason, format string, args ...interface{}) + func (bs *TriggerStatus) MarkSubscriptionReady(_ string) + func (bs *TriggerStatus) MarkSubscriptionUnknown(reason, format string, args ...interface{}) + func (bs *TriggerStatus) MarkTopicFailed(reason, format string, args ...interface{}) + func (bs *TriggerStatus) MarkTopicReady() + func (bs *TriggerStatus) MarkTopicUnknown(reason, format string, args ...interface{}) + func (in *TriggerStatus) DeepCopy() *TriggerStatus + func (in *TriggerStatus) DeepCopyInto(out *TriggerStatus) + func (ts *TriggerStatus) GetCondition(t apis.ConditionType) *apis.Condition + func (ts *TriggerStatus) GetTopLevelCondition() *apis.Condition + func (ts *TriggerStatus) InitializeConditions() + func (ts *TriggerStatus) IsReady() bool + func (ts *TriggerStatus) MarkBrokerFailed(reason, messageFormat string, messageA ...interface{}) + func (ts *TriggerStatus) MarkBrokerNotConfigured() + func (ts *TriggerStatus) MarkBrokerUnknown(reason, messageFormat string, messageA ...interface{}) + func (ts *TriggerStatus) MarkDependencyFailed(reason, messageFormat string, messageA ...interface{}) + func (ts *TriggerStatus) MarkDependencyNotConfigured() + func (ts *TriggerStatus) MarkDependencySucceeded() + func (ts *TriggerStatus) MarkDependencyUnknown(reason, messageFormat string, messageA ...interface{}) + func (ts *TriggerStatus) MarkSubscriberResolvedFailed(reason, messageFormat string, messageA ...interface{}) + func (ts *TriggerStatus) MarkSubscriberResolvedSucceeded() + func (ts *TriggerStatus) MarkSubscriberResolvedUnknown(reason, messageFormat string, messageA ...interface{}) + func (ts *TriggerStatus) PropagateBrokerStatus(bs *BrokerStatus) + func (ts *TriggerStatus) PropagateDependencyStatus(src *duckv1.Source)