Versions in this module Expand all Collapse all v0 v0.14.0 Apr 14, 2020 Changes in this version + const PullSubscriptionConditionDeployed + const PullSubscriptionConditionReady + const PullSubscriptionConditionSinkProvided + const PullSubscriptionConditionSubscribed + const PullSubscriptionConditionTransformerProvided + const TopicConditionAddressable + const TopicConditionPublisherReady + const TopicConditionReady + const TopicConditionTopicExists + 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 ModeType string + const ModeCloudEventsBinary + const ModeCloudEventsStructured + const ModePushCompatible + type PropagationPolicyType string + const TopicPolicyCreateDelete + const TopicPolicyCreateNoDelete + const TopicPolicyNoCreateNoDelete + type PullSubscription struct + Spec PullSubscriptionSpec + Status PullSubscriptionStatus + func (*PullSubscription) ConditionSet() *apis.ConditionSet + func (*PullSubscription) ConvertFrom(_ context.Context, from apis.Convertible) error + func (*PullSubscription) ConvertTo(_ context.Context, to apis.Convertible) error + func (current *PullSubscription) CheckImmutableFields(ctx context.Context, original *PullSubscription) *apis.FieldError + func (current *PullSubscription) Validate(ctx context.Context) *apis.FieldError + func (in *PullSubscription) DeepCopy() *PullSubscription + func (in *PullSubscription) DeepCopyInto(out *PullSubscription) + func (in *PullSubscription) DeepCopyObject() runtime.Object + func (p *PullSubscription) PubSubMode() ModeType + func (s *PullSubscription) GetGroupVersion() schema.GroupVersion + func (s *PullSubscription) GetGroupVersionKind() schema.GroupVersionKind + func (s *PullSubscription) IdentitySpec() *v1beta1.IdentitySpec + func (s *PullSubscription) IdentityStatus() *v1beta1.IdentityStatus + func (s *PullSubscription) SetDefaults(ctx context.Context) + type PullSubscriptionList struct + Items []PullSubscription + func (in *PullSubscriptionList) DeepCopy() *PullSubscriptionList + func (in *PullSubscriptionList) DeepCopyInto(out *PullSubscriptionList) + func (in *PullSubscriptionList) DeepCopyObject() runtime.Object + type PullSubscriptionSpec struct + AckDeadline *string + AdapterType string + Mode ModeType + RetainAckedMessages bool + RetentionDuration *string + Topic string + Transformer *duckv1.Destination + func (current *PullSubscriptionSpec) Validate(ctx context.Context) *apis.FieldError + func (in *PullSubscriptionSpec) DeepCopy() *PullSubscriptionSpec + func (in *PullSubscriptionSpec) DeepCopyInto(out *PullSubscriptionSpec) + func (ps PullSubscriptionSpec) GetAckDeadline() time.Duration + func (ps PullSubscriptionSpec) GetRetentionDuration() time.Duration + func (ss *PullSubscriptionSpec) SetDefaults(ctx context.Context) + type PullSubscriptionStatus struct + SubscriptionID string + TransformerURI *apis.URL + func (in *PullSubscriptionStatus) DeepCopy() *PullSubscriptionStatus + func (in *PullSubscriptionStatus) DeepCopyInto(out *PullSubscriptionStatus) + func (s *PullSubscriptionStatus) GetCondition(t apis.ConditionType) *apis.Condition + func (s *PullSubscriptionStatus) GetTopLevelCondition() *apis.Condition + func (s *PullSubscriptionStatus) InitializeConditions() + func (s *PullSubscriptionStatus) IsReady() bool + func (s *PullSubscriptionStatus) MarkDeployed() + func (s *PullSubscriptionStatus) MarkNoSink(reason, messageFormat string, messageA ...interface{}) + func (s *PullSubscriptionStatus) MarkNoSubscription(reason, messageFormat string, messageA ...interface{}) + func (s *PullSubscriptionStatus) MarkNoTransformer(reason, messageFormat string, messageA ...interface{}) + func (s *PullSubscriptionStatus) MarkNotDeployed(reason, messageFormat string, messageA ...interface{}) + func (s *PullSubscriptionStatus) MarkSink(uri *apis.URL) + func (s *PullSubscriptionStatus) MarkSubscribed(subscriptionID string) + func (s *PullSubscriptionStatus) MarkTransformer(uri *apis.URL) + type Topic struct + Spec TopicSpec + Status TopicStatus + func (*Topic) ConvertFrom(_ context.Context, from apis.Convertible) error + func (*Topic) ConvertTo(_ context.Context, to apis.Convertible) error + func (current *Topic) CheckImmutableFields(ctx context.Context, original *Topic) *apis.FieldError + func (in *Topic) DeepCopy() *Topic + func (in *Topic) DeepCopyInto(out *Topic) + func (in *Topic) DeepCopyObject() runtime.Object + func (ps *Topic) ConditionSet() *apis.ConditionSet + func (s *Topic) IdentitySpec() *v1beta1.IdentitySpec + func (s *Topic) IdentityStatus() *v1beta1.IdentityStatus + func (t *Topic) GetGroupVersionKind() schema.GroupVersionKind + func (t *Topic) SetDefaults(ctx context.Context) + func (t *Topic) Validate(ctx context.Context) *apis.FieldError + type TopicList struct + Items []Topic + func (in *TopicList) DeepCopy() *TopicList + func (in *TopicList) DeepCopyInto(out *TopicList) + func (in *TopicList) DeepCopyObject() runtime.Object + type TopicSpec struct + Project string + PropagationPolicy PropagationPolicyType + Secret *corev1.SecretKeySelector + Topic string + func (in *TopicSpec) DeepCopy() *TopicSpec + func (in *TopicSpec) DeepCopyInto(out *TopicSpec) + func (ts *TopicSpec) SetDefaults(ctx context.Context) + func (ts *TopicSpec) Validate(ctx context.Context) *apis.FieldError + type TopicStatus struct + ProjectID string + TopicID string + func (in *TopicStatus) DeepCopy() *TopicStatus + func (in *TopicStatus) DeepCopyInto(out *TopicStatus) + func (ts *TopicStatus) GetCondition(t apis.ConditionType) *apis.Condition + func (ts *TopicStatus) GetTopLevelCondition() *apis.Condition + func (ts *TopicStatus) InitializeConditions() + func (ts *TopicStatus) IsReady() bool + func (ts *TopicStatus) MarkNoTopic(reason, messageFormat string, messageA ...interface{}) + func (ts *TopicStatus) MarkPublisherDeployed() + func (ts *TopicStatus) MarkPublisherNotConfigured() + func (ts *TopicStatus) MarkPublisherNotDeployed(reason, messageFormat string, messageA ...interface{}) + func (ts *TopicStatus) MarkPublisherUnknown(reason, messageFormat string, messageA ...interface{}) + func (ts *TopicStatus) MarkTopicReady() + func (ts *TopicStatus) PropagatePublisherStatus(ss *v1.ServiceStatus) + func (ts *TopicStatus) SetAddress(url *apis.URL)