v1alpha1

May 27, 2020

Changes in this version

type PullSubscriptionStatus

+ func (s *PullSubscriptionStatus) MarkDeprecated()

type TopicStatus

+ func (ts *TopicStatus) MarkDeprecated()

Apr 14, 2020

Changes in this version

type PullSubscription

+ func (*PullSubscription) ConditionSet() *apis.ConditionSet

+ func (s *PullSubscription) IdentitySpec() *v1alpha1.IdentitySpec

+ func (s *PullSubscription) IdentityStatus() *v1alpha1.IdentityStatus

+ func (sink *PullSubscription) ConvertFrom(_ context.Context, from apis.Convertible) error

+ func (source *PullSubscription) ConvertTo(_ context.Context, to apis.Convertible) error

type Topic

+ func (ps *Topic) ConditionSet() *apis.ConditionSet

+ func (s *Topic) IdentitySpec() *v1alpha1.IdentitySpec

+ func (s *Topic) IdentityStatus() *v1alpha1.IdentityStatus

+ func (sink *Topic) ConvertFrom(ctx context.Context, from apis.Convertible) error

+ func (source *Topic) ConvertTo(ctx context.Context, to apis.Convertible) error

Mar 4, 2020

Changes in this version

type PullSubscription

+ func (s *PullSubscription) GetGroupVersion() schema.GroupVersion

Feb 14, 2020

Changes in this version

type TopicStatus

+ 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{})

Jan 22, 2020

Changes in this version

type PullSubscriptionSpec

+ AdapterType string

type PullSubscriptionStatus

+ func (s *PullSubscriptionStatus) GetTopLevelCondition() *apis.Condition

type TopicStatus

+ func (ts *TopicStatus) GetTopLevelCondition() *apis.Condition

Oct 29, 2019

Changes in this version

+ const PubSubPublish

type PullSubscriptionStatus

+ func (s *PullSubscriptionStatus) ClearDeprecated()

+ func (s *PullSubscriptionStatus) MarkDestinationDeprecatedRef(reason, msg string)

Aug 20, 2019

Changes in this version

+ func DefaultGoogleCloudSecretSelector() *corev1.SecretKeySelector

+ type CloudEventOverrides struct

+ Extensions map[string]string

+ func (in *CloudEventOverrides) DeepCopy() *CloudEventOverrides

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

type PullSubscriptionSpec

+ CloudEventOverrides *CloudEventOverrides

Aug 7, 2019

Changes in this version

+ const PullSubscriptionConditionDeployed

+ const PullSubscriptionConditionEventTypesProvided

+ 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 PubSubEventSource(googleCloudProject, topic string) string

+ func Resource(resource string) schema.GroupResource

+ type Destination struct

+ URI *apis.URL

+ func (in *Destination) DeepCopy() *Destination

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

+ type ModeType string

+ const ModeCloudEventsBinary

+ const ModeCloudEventsStructured

+ const ModePushCompatible

+ const PubSubEventType

+ type PropagationPolicyType string

+ const TopicPolicyCreateDelete

+ const TopicPolicyCreateNoDelete

+ const TopicPolicyNoCreateNoDelete

+ type PullSubscription struct

+ Spec PullSubscriptionSpec

+ Status PullSubscriptionStatus

+ func (current *PullSubscription) CheckImmutableFields(ctx context.Context, og apis.Immutable) *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) GetGroupVersionKind() schema.GroupVersionKind

+ 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

+ Mode ModeType

+ Project string

+ RetainAckedMessages bool

+ RetentionDuration *string

+ Secret *corev1.SecretKeySelector

+ Sink Destination

+ Topic string

+ Transformer *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

+ ProjectID string

+ SinkURI string

+ SubscriptionID string

+ TransformerURI string

+ func (in *PullSubscriptionStatus) DeepCopy() *PullSubscriptionStatus

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

+ func (s *PullSubscriptionStatus) GetCondition(t apis.ConditionType) *apis.Condition

+ func (s *PullSubscriptionStatus) InitializeConditions()

+ func (s *PullSubscriptionStatus) IsReady() bool

+ func (s *PullSubscriptionStatus) MarkDeployed()

+ func (s *PullSubscriptionStatus) MarkDeploying(reason, messageFormat string, messageA ...interface{})

+ func (s *PullSubscriptionStatus) MarkEventTypes()

+ func (s *PullSubscriptionStatus) MarkNoEventTypes(reason, messageFormat string, messageA ...interface{})

+ 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 string)

+ func (s *PullSubscriptionStatus) MarkSubscribed()

+ func (s *PullSubscriptionStatus) MarkSubscriptionOperation(reason, messageFormat string, messageA ...interface{})

+ func (s *PullSubscriptionStatus) MarkTransformer(uri string)

+ type Topic struct

+ Spec TopicSpec

+ Status TopicStatus

+ func (current *Topic) CheckImmutableFields(ctx context.Context, og apis.Immutable) *apis.FieldError

+ func (in *Topic) DeepCopy() *Topic

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

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

+ 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) InitializeConditions()

+ func (ts *TopicStatus) IsReady() bool

+ func (ts *TopicStatus) MarkDeployed()

+ func (ts *TopicStatus) MarkDeploying(reason, messageFormat string, messageA ...interface{})

+ func (ts *TopicStatus) MarkNoTopic(reason, messageFormat string, messageA ...interface{})

+ func (ts *TopicStatus) MarkNotDeployed(reason, messageFormat string, messageA ...interface{})

+ func (ts *TopicStatus) MarkPublisherNotOwned(messageFormat string, messageA ...interface{})

+ func (ts *TopicStatus) MarkTopicOperating(reason, messageFormat string, messageA ...interface{})

+ func (ts *TopicStatus) MarkTopicReady()

+ func (ts *TopicStatus) PropagatePublisherStatus(ready *apis.Condition)

+ func (ts *TopicStatus) SetAddress(url *apis.URL)