v1alpha1

package

Go to main page

Versions in this module

v1

v1.10.0

Sep 30, 2021

Changes in this version

+ const AWSDynamoDBGenericEventType

type AWSPerformanceInsightsSourceSpec

+ Metrics []string

+ type AWSSQSSourceReceiveOptions struct

+ VisibilityTimeout *apis.Duration

+ func (in *AWSSQSSourceReceiveOptions) DeepCopy() *AWSSQSSourceReceiveOptions

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

type AWSSQSSourceSpec

+ ReceiveOptions *AWSSQSSourceReceiveOptions

v1.9.0

Jul 31, 2021

v1.8.0

Jul 31, 2021

v1.7.0

Jul 6, 2021

v1.6.0

Jun 1, 2021

Changes in this version

+ const AWSPerformanceInsightsGenericEventType

+ type AWSPerformanceInsightsSource struct

+ Spec AWSPerformanceInsightsSourceSpec

+ Status EventSourceStatus

+ func (*AWSPerformanceInsightsSource) GetConditionSet() apis.ConditionSet

+ func (*AWSPerformanceInsightsSource) GetGroupVersionKind() schema.GroupVersionKind

+ func (in *AWSPerformanceInsightsSource) DeepCopy() *AWSPerformanceInsightsSource

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

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

+ func (s *AWSPerformanceInsightsSource) AsEventSource() string

+ func (s *AWSPerformanceInsightsSource) GetEventTypes() []string

+ func (s *AWSPerformanceInsightsSource) GetSink() *duckv1.Destination

+ func (s *AWSPerformanceInsightsSource) GetStatus() *duckv1.Status

+ func (s *AWSPerformanceInsightsSource) GetStatusManager() *EventSourceStatusManager

+ type AWSPerformanceInsightsSourceList struct

+ Items []AWSPerformanceInsightsSource

+ func (in *AWSPerformanceInsightsSourceList) DeepCopy() *AWSPerformanceInsightsSourceList

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

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

+ type AWSPerformanceInsightsSourceSpec struct

+ ARN apis.ARN

+ Credentials AWSSecurityCredentials

+ MetricQueries []string

+ PollingInterval *apis.Duration

+ func (in *AWSPerformanceInsightsSourceSpec) DeepCopy() *AWSPerformanceInsightsSourceSpec

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

v1.5.0

Apr 26, 2021

v1.4.1

Apr 6, 2021

Changes in this version

+ const AWSS3ReasonNoBucket

v1.4.0

Apr 1, 2021

Changes in this version

+ const AWSS3ConditionSubscribed

+ const AWSS3ObjCreatedEventType

+ const AWSS3ObjRemovedEventType

+ const AWSS3ObjRestoreEventType

+ const AWSS3ReasonAPIError

+ const AWSS3ReasonNoClient

+ const AWSS3ReducedRedundancyLostObjEventType

+ const AWSS3ReplicationEventType

+ const AWSS3TestEventType

+ type AWSS3Source struct

+ Spec AWSS3SourceSpec

+ Status AWSS3SourceStatus

+ func (in *AWSS3Source) DeepCopy() *AWSS3Source

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

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

+ func (s *AWSS3Source) AsEventSource() string

+ func (s *AWSS3Source) GetConditionSet() apis.ConditionSet

+ func (s *AWSS3Source) GetEventTypes() []string

+ func (s *AWSS3Source) GetGroupVersionKind() schema.GroupVersionKind

+ func (s *AWSS3Source) GetSink() *duckv1.Destination

+ func (s *AWSS3Source) GetStatus() *duckv1.Status

+ func (s *AWSS3Source) GetStatusManager() *EventSourceStatusManager

+ type AWSS3SourceList struct

+ Items []AWSS3Source

+ func (in *AWSS3SourceList) DeepCopy() *AWSS3SourceList

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

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

+ type AWSS3SourceSpec struct

+ ARN apis.ARN

+ Credentials AWSSecurityCredentials

+ EventTypes []string

+ QueueARN *apis.ARN

+ func (in *AWSS3SourceSpec) DeepCopy() *AWSS3SourceSpec

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

+ type AWSS3SourceStatus struct

+ QueueARN *apis.ARN

+ func (in *AWSS3SourceStatus) DeepCopy() *AWSS3SourceStatus

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

+ func (s *AWSS3SourceStatus) MarkNotSubscribed(reason, msg string)

+ func (s *AWSS3SourceStatus) MarkSubscribed()

v1.3.0

Feb 3, 2021

Changes in this version

+ const AWSSNSConditionHandlerRegistered

+ const AWSSNSReasonAPIError

+ const AWSSNSReasonPending

+ const ReasonRBACNotBound

+ func IsMultiTenant(src EventSource) bool

type AWSSNSSource

+ func (*AWSSNSSource) IsMultiTenant() bool

type EventSourceStatusManager

+ func (m *EventSourceStatusManager) MarkRBACNotBound()

+ func (m *EventSourceStatusManager) SetRoute(urlPath string)

v1.2.0

Jan 19, 2021

Changes in this version

+ const AWSCloudWatchLogsGenericEventType

+ const AWSCloudWatchMessageEventType

+ const AWSCloudWatchMetricEventType

+ const ServiceCloudWatch

+ func AWSCloudWatchSourceName(ns, name string) string

+ type AWSCloudWatchLogsSource struct

+ Spec AWSCloudWatchLogsSourceSpec

+ Status EventSourceStatus

+ func (*AWSCloudWatchLogsSource) GetConditionSet() apis.ConditionSet

+ func (*AWSCloudWatchLogsSource) GetGroupVersionKind() schema.GroupVersionKind

+ func (in *AWSCloudWatchLogsSource) DeepCopy() *AWSCloudWatchLogsSource

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

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

+ func (s *AWSCloudWatchLogsSource) AsEventSource() string

+ func (s *AWSCloudWatchLogsSource) GetEventTypes() []string

+ func (s *AWSCloudWatchLogsSource) GetSink() *duckv1.Destination

+ func (s *AWSCloudWatchLogsSource) GetStatus() *duckv1.Status

+ func (s *AWSCloudWatchLogsSource) GetStatusManager() *EventSourceStatusManager

+ type AWSCloudWatchLogsSourceList struct

+ Items []AWSCloudWatchLogsSource

+ func (in *AWSCloudWatchLogsSourceList) DeepCopy() *AWSCloudWatchLogsSourceList

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

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

+ type AWSCloudWatchLogsSourceSpec struct

+ ARN apis.ARN

+ Credentials AWSSecurityCredentials

+ PollingInterval *apis.Duration

+ func (in *AWSCloudWatchLogsSourceSpec) DeepCopy() *AWSCloudWatchLogsSourceSpec

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

+ type AWSCloudWatchMetric struct

+ Dimensions []AWSCloudWatchMetricDimension

+ MetricName string

+ Namespace string

+ func (in *AWSCloudWatchMetric) DeepCopy() *AWSCloudWatchMetric

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

+ type AWSCloudWatchMetricDimension struct

+ Name string

+ Value string

+ func (in *AWSCloudWatchMetricDimension) DeepCopy() *AWSCloudWatchMetricDimension

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

+ type AWSCloudWatchMetricQuery struct

+ Expression *string

+ Metric *AWSCloudWatchMetricStat

+ Name string

+ func (in *AWSCloudWatchMetricQuery) DeepCopy() *AWSCloudWatchMetricQuery

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

+ type AWSCloudWatchMetricStat struct

+ Metric AWSCloudWatchMetric

+ Period int64

+ Stat string

+ Unit string

+ func (in *AWSCloudWatchMetricStat) DeepCopy() *AWSCloudWatchMetricStat

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

+ type AWSCloudWatchSource struct

+ Spec AWSCloudWatchSourceSpec

+ Status EventSourceStatus

+ func (*AWSCloudWatchSource) GetConditionSet() apis.ConditionSet

+ func (*AWSCloudWatchSource) GetEventTypes() []string

+ func (*AWSCloudWatchSource) GetGroupVersionKind() schema.GroupVersionKind

+ func (in *AWSCloudWatchSource) DeepCopy() *AWSCloudWatchSource

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

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

+ func (s *AWSCloudWatchSource) AsEventSource() string

+ func (s *AWSCloudWatchSource) GetSink() *duckv1.Destination

+ func (s *AWSCloudWatchSource) GetStatus() *duckv1.Status

+ func (s *AWSCloudWatchSource) GetStatusManager() *EventSourceStatusManager

+ type AWSCloudWatchSourceList struct

+ Items []AWSCloudWatchSource

+ func (in *AWSCloudWatchSourceList) DeepCopy() *AWSCloudWatchSourceList

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

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

+ type AWSCloudWatchSourceSpec struct

+ Credentials AWSSecurityCredentials

+ MetricQueries []AWSCloudWatchMetricQuery

+ PollingInterval *apis.Duration

+ Region string

+ func (in *AWSCloudWatchSourceSpec) DeepCopy() *AWSCloudWatchSourceSpec

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

v1.1.0

Dec 7, 2020

v1.0.0

Nov 11, 2020

v0

v0.7.0

Oct 13, 2020

v0.6.0

Sep 9, 2020

Changes in this version

+ const AWSSNSConditionSubscribed

+ const AWSSNSReasonFailedSync

+ const AWSSNSReasonNoClient

+ const AWSSNSReasonNoURL

+ const AWSSNSReasonRejected

+ func NewEventSourceConditionSet(cts ...apis.ConditionType) apis.ConditionSet

type AWSCodeCommitSource

+ func (s *AWSCodeCommitSource) GetStatusManager() *EventSourceStatusManager

type AWSCognitoIdentitySource

+ func (s *AWSCognitoIdentitySource) GetStatusManager() *EventSourceStatusManager

type AWSCognitoUserPoolSource

+ func (s *AWSCognitoUserPoolSource) GetStatusManager() *EventSourceStatusManager

type AWSDynamoDBSource

+ func (s *AWSDynamoDBSource) GetStatusManager() *EventSourceStatusManager

type AWSIoTSource

+ func (s *AWSIoTSource) GetStatusManager() *EventSourceStatusManager

type AWSKinesisSource

+ func (s *AWSKinesisSource) GetStatusManager() *EventSourceStatusManager

type AWSSNSSource

+ func (s *AWSSNSSource) GetStatusManager() *EventSourceStatusManager

+ type AWSSNSSourceStatus struct

+ SubscriptionARN *string

+ func (in *AWSSNSSourceStatus) DeepCopy() *AWSSNSSourceStatus

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

+ func (s *AWSSNSSourceStatus) MarkNotSubscribed(reason, msg string)

+ func (s *AWSSNSSourceStatus) MarkSubscribed()

type AWSSQSSource

+ func (s *AWSSQSSource) GetStatusManager() *EventSourceStatusManager

type EventSource

+ GetStatusManager func() *EventSourceStatusManager

+ type EventSourceStatusManager struct

+ func (m *EventSourceStatusManager) MarkNoSink()

+ func (m *EventSourceStatusManager) MarkSink(uri *apis.URL)

+ func (m *EventSourceStatusManager) PropagateDeploymentAvailability(ctx context.Context, d *appsv1.Deployment, pi coreclientv1.PodInterface)

+ func (m *EventSourceStatusManager) PropagateServiceAvailability(ksvc *servingv1.Service)

v0.5.0

Aug 11, 2020

Changes in this version

+ const AWSCognitoUserPoolGenericEventType

type AWSCodeCommitSource

+ func (s *AWSCodeCommitSource) AsEventSource() string

type AWSCognitoIdentitySource

+ func (s *AWSCognitoIdentitySource) AsEventSource() string

type AWSCognitoUserPoolSource

+ func (s *AWSCognitoUserPoolSource) AsEventSource() string

type AWSDynamoDBSource

+ func (s *AWSDynamoDBSource) AsEventSource() string

type AWSIoTSource

+ func (s *AWSIoTSource) AsEventSource() string

type AWSKinesisSource

+ func (s *AWSKinesisSource) AsEventSource() string

type AWSSNSSource

+ func (s *AWSSNSSource) AsEventSource() string

type AWSSQSSource

+ func (s *AWSSQSSource) AsEventSource() string

+ type EventSource interface

+ AsEventSource func() string

+ GetEventTypes func() []string

+ GetSink func() *duckv1.Destination

+ GetSourceStatus func() *EventSourceStatus

+ type EventSourceStatus struct

+ func (in *EventSourceStatus) DeepCopy() *EventSourceStatus

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

+ func (s *EventSourceStatus) InitializeConditions()

+ func (s *EventSourceStatus) MarkNoSink()

+ func (s *EventSourceStatus) MarkSink(uri *apis.URL)

+ func (s *EventSourceStatus) PropagateAvailability(obj interface{})

v0.4.2

Jul 28, 2020

v0.4.1

Jul 25, 2020

v0.3.0

Jul 8, 2020

Changes in this version

type AWSCodeCommitSource

+ func (s *AWSCodeCommitSource) GetConditionSet() pkgapis.ConditionSet

+ func (s *AWSCodeCommitSource) GetSourceStatus() *AWSEventSourceStatus

type AWSCognitoIdentitySource

+ func (s *AWSCognitoIdentitySource) GetConditionSet() pkgapis.ConditionSet

+ func (s *AWSCognitoIdentitySource) GetSourceStatus() *AWSEventSourceStatus

type AWSCognitoUserPoolSource

+ func (s *AWSCognitoUserPoolSource) GetConditionSet() pkgapis.ConditionSet

+ func (s *AWSCognitoUserPoolSource) GetSourceStatus() *AWSEventSourceStatus

type AWSDynamoDBSource

+ func (s *AWSDynamoDBSource) GetConditionSet() pkgapis.ConditionSet

+ func (s *AWSDynamoDBSource) GetSourceStatus() *AWSEventSourceStatus

type AWSEventSource

+ GetSourceStatus func() *AWSEventSourceStatus

type AWSIoTSource

+ func (s *AWSIoTSource) GetConditionSet() pkgapis.ConditionSet

+ func (s *AWSIoTSource) GetSourceStatus() *AWSEventSourceStatus

type AWSKinesisSource

+ func (s *AWSKinesisSource) GetConditionSet() pkgapis.ConditionSet

+ func (s *AWSKinesisSource) GetSourceStatus() *AWSEventSourceStatus

type AWSSNSSource

+ func (s *AWSSNSSource) GetConditionSet() pkgapis.ConditionSet

+ func (s *AWSSNSSource) GetSourceStatus() *AWSEventSourceStatus

type AWSSQSSource

+ func (s *AWSSQSSource) GetConditionSet() pkgapis.ConditionSet

+ func (s *AWSSQSSource) GetSourceStatus() *AWSEventSourceStatus

v0.2.0

Jun 15, 2020

Changes in this version

+ const AWSCognitoGenericEventType

+ const AWSCognitoIdentityGenericEventType

+ const AWSDynamoDBAddEventType

+ const AWSDynamoDBModifyEventType

+ const AWSDynamoDBRemoveEventType

+ const AWSIoTGenericEventType

+ const AWSKinesisGenericEventType

+ const AWSSNSGenericEventType

+ const AWSSQSGenericEventType

+ const ConditionDeployed

+ const ConditionReady

+ const ConditionSinkProvided

+ const ReasonSinkEmpty

+ const ReasonSinkNotFound

+ const ReasonUnavailable

+ var AddToScheme = SchemeBuilder.AddToScheme

+ var SchemeBuilder = runtime.NewSchemeBuilder(addKnownTypes)

+ var SchemeGroupVersion = schema.GroupVersion

+ func AWSEventType(awsService, eventType string) string

+ func Kind(kind string) schema.GroupKind

+ func Resource(resource string) schema.GroupResource

+ func WithSource(ctx context.Context, s AWSEventSource) context.Context

+ type AWSCodeCommitSource struct

+ Spec AWSCodeCommitSourceSpec

+ Status AWSEventSourceStatus

+ func (in *AWSCodeCommitSource) DeepCopy() *AWSCodeCommitSource

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

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

+ func (s *AWSCodeCommitSource) GetARN() string

+ func (s *AWSCodeCommitSource) GetEventTypes() []string

+ func (s *AWSCodeCommitSource) GetGroupVersionKind() schema.GroupVersionKind

+ func (s *AWSCodeCommitSource) GetSink() *duckv1.Destination

+ func (s *AWSCodeCommitSource) GetStatus() *AWSEventSourceStatus

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

+ func (s *AWSCodeCommitSource) SetDefaults(_ context.Context)

+ func (s *AWSCodeCommitSource) Validate(_ context.Context) *apis.FieldError

+ type AWSCodeCommitSourceList struct

+ Items []AWSCodeCommitSource

+ func (in *AWSCodeCommitSourceList) DeepCopy() *AWSCodeCommitSourceList

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

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

+ type AWSCodeCommitSourceSpec struct

+ ARN string

+ Branch string

+ Credentials AWSSecurityCredentials

+ EventTypes []string

+ func (in *AWSCodeCommitSourceSpec) DeepCopy() *AWSCodeCommitSourceSpec

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

+ type AWSCognitoIdentitySource struct

+ Spec AWSCognitoIdentitySourceSpec

+ Status AWSEventSourceStatus

+ func (in *AWSCognitoIdentitySource) DeepCopy() *AWSCognitoIdentitySource

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

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

+ func (s *AWSCognitoIdentitySource) GetARN() string

+ func (s *AWSCognitoIdentitySource) GetEventTypes() []string

+ func (s *AWSCognitoIdentitySource) GetGroupVersionKind() schema.GroupVersionKind

+ func (s *AWSCognitoIdentitySource) GetSink() *duckv1.Destination

+ func (s *AWSCognitoIdentitySource) GetStatus() *AWSEventSourceStatus

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

+ func (s *AWSCognitoIdentitySource) SetDefaults(_ context.Context)

+ func (s *AWSCognitoIdentitySource) Validate(_ context.Context) *apis.FieldError

+ type AWSCognitoIdentitySourceList struct

+ Items []AWSCognitoIdentitySource

+ func (in *AWSCognitoIdentitySourceList) DeepCopy() *AWSCognitoIdentitySourceList

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

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

+ type AWSCognitoIdentitySourceSpec struct

+ ARN string

+ Credentials AWSSecurityCredentials

+ func (in *AWSCognitoIdentitySourceSpec) DeepCopy() *AWSCognitoIdentitySourceSpec

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

+ type AWSCognitoUserPoolSource struct

+ Spec AWSCognitoUserPoolSourceSpec

+ Status AWSEventSourceStatus

+ func (in *AWSCognitoUserPoolSource) DeepCopy() *AWSCognitoUserPoolSource

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

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

+ func (s *AWSCognitoUserPoolSource) GetARN() string

+ func (s *AWSCognitoUserPoolSource) GetEventTypes() []string

+ func (s *AWSCognitoUserPoolSource) GetGroupVersionKind() schema.GroupVersionKind

+ func (s *AWSCognitoUserPoolSource) GetSink() *duckv1.Destination

+ func (s *AWSCognitoUserPoolSource) GetStatus() *AWSEventSourceStatus

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

+ func (s *AWSCognitoUserPoolSource) SetDefaults(_ context.Context)

+ func (s *AWSCognitoUserPoolSource) Validate(_ context.Context) *apis.FieldError

+ type AWSCognitoUserPoolSourceList struct

+ Items []AWSCognitoUserPoolSource

+ func (in *AWSCognitoUserPoolSourceList) DeepCopy() *AWSCognitoUserPoolSourceList

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

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

+ type AWSCognitoUserPoolSourceSpec struct

+ ARN string

+ Credentials AWSSecurityCredentials

+ func (in *AWSCognitoUserPoolSourceSpec) DeepCopy() *AWSCognitoUserPoolSourceSpec

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

+ type AWSDynamoDBSource struct

+ Spec AWSDynamoDBSourceSpec

+ Status AWSEventSourceStatus

+ func (in *AWSDynamoDBSource) DeepCopy() *AWSDynamoDBSource

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

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

+ func (s *AWSDynamoDBSource) GetARN() string

+ func (s *AWSDynamoDBSource) GetEventTypes() []string

+ func (s *AWSDynamoDBSource) GetGroupVersionKind() schema.GroupVersionKind

+ func (s *AWSDynamoDBSource) GetSink() *duckv1.Destination

+ func (s *AWSDynamoDBSource) GetStatus() *AWSEventSourceStatus

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

+ func (s *AWSDynamoDBSource) SetDefaults(_ context.Context)

+ func (s *AWSDynamoDBSource) Validate(_ context.Context) *apis.FieldError

+ type AWSDynamoDBSourceList struct

+ Items []AWSDynamoDBSource

+ func (in *AWSDynamoDBSourceList) DeepCopy() *AWSDynamoDBSourceList

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

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

+ type AWSDynamoDBSourceSpec struct

+ ARN string

+ Credentials AWSSecurityCredentials

+ func (in *AWSDynamoDBSourceSpec) DeepCopy() *AWSDynamoDBSourceSpec

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

+ type AWSEventSource interface

+ GetARN func() string

+ GetEventTypes func() []string

+ GetSink func() *duckv1.Destination

+ GetStatus func() *AWSEventSourceStatus

+ func SourceFromContext(ctx context.Context) AWSEventSource

+ type AWSEventSourceStatus struct

+ func (in *AWSEventSourceStatus) DeepCopy() *AWSEventSourceStatus

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

+ func (s *AWSEventSourceStatus) InitializeConditions()

+ func (s *AWSEventSourceStatus) MarkNoSink()

+ func (s *AWSEventSourceStatus) MarkSink(uri *apis.URL)

+ func (s *AWSEventSourceStatus) PropagateAvailability(obj interface{})

+ type AWSIoTSource struct

+ Spec AWSIoTSourceSpec

+ Status AWSEventSourceStatus

+ func (in *AWSIoTSource) DeepCopy() *AWSIoTSource

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

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

+ func (s *AWSIoTSource) GetARN() string

+ func (s *AWSIoTSource) GetEventTypes() []string

+ func (s *AWSIoTSource) GetGroupVersionKind() schema.GroupVersionKind

+ func (s *AWSIoTSource) GetSink() *duckv1.Destination

+ func (s *AWSIoTSource) GetStatus() *AWSEventSourceStatus

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

+ func (s *AWSIoTSource) SetDefaults(_ context.Context)

+ func (s *AWSIoTSource) Validate(_ context.Context) *apis.FieldError

+ type AWSIoTSourceList struct

+ Items []AWSIoTSource

+ func (in *AWSIoTSourceList) DeepCopy() *AWSIoTSourceList

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

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

+ type AWSIoTSourceSpec struct

+ ARN string

+ Certificate ValueFromField

+ CertificatePath *string

+ Endpoint string

+ PrivateKey ValueFromField

+ PrivateKeyPath *string

+ RootCA ValueFromField

+ RootCAPath *string

+ func (in *AWSIoTSourceSpec) DeepCopy() *AWSIoTSourceSpec

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

+ type AWSKinesisSource struct

+ Spec AWSKinesisSourceSpec

+ Status AWSEventSourceStatus

+ func (in *AWSKinesisSource) DeepCopy() *AWSKinesisSource

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

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

+ func (s *AWSKinesisSource) GetARN() string

+ func (s *AWSKinesisSource) GetEventTypes() []string

+ func (s *AWSKinesisSource) GetGroupVersionKind() schema.GroupVersionKind

+ func (s *AWSKinesisSource) GetSink() *duckv1.Destination

+ func (s *AWSKinesisSource) GetStatus() *AWSEventSourceStatus

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

+ func (s *AWSKinesisSource) SetDefaults(_ context.Context)

+ func (s *AWSKinesisSource) Validate(_ context.Context) *apis.FieldError

+ type AWSKinesisSourceList struct

+ Items []AWSKinesisSource

+ func (in *AWSKinesisSourceList) DeepCopy() *AWSKinesisSourceList

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

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

+ type AWSKinesisSourceSpec struct

+ ARN string

+ Credentials AWSSecurityCredentials

+ func (in *AWSKinesisSourceSpec) DeepCopy() *AWSKinesisSourceSpec

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

+ type AWSSNSSource struct

+ Spec AWSSNSSourceSpec

+ Status AWSEventSourceStatus

+ func (in *AWSSNSSource) DeepCopy() *AWSSNSSource

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

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

+ func (s *AWSSNSSource) GetARN() string

+ func (s *AWSSNSSource) GetEventTypes() []string

+ func (s *AWSSNSSource) GetGroupVersionKind() schema.GroupVersionKind

+ func (s *AWSSNSSource) GetSink() *duckv1.Destination

+ func (s *AWSSNSSource) GetStatus() *AWSEventSourceStatus

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

+ func (s *AWSSNSSource) SetDefaults(_ context.Context)

+ func (s *AWSSNSSource) Validate(_ context.Context) *apis.FieldError

+ type AWSSNSSourceList struct

+ Items []AWSSNSSource

+ func (in *AWSSNSSourceList) DeepCopy() *AWSSNSSourceList

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

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

+ type AWSSNSSourceSpec struct

+ ARN string

+ Credentials AWSSecurityCredentials

+ SubscriptionAttributes map[string]*string

+ func (in *AWSSNSSourceSpec) DeepCopy() *AWSSNSSourceSpec

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

+ type AWSSQSSource struct

+ Spec AWSSQSSourceSpec

+ Status AWSEventSourceStatus

+ func (in *AWSSQSSource) DeepCopy() *AWSSQSSource

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

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

+ func (s *AWSSQSSource) GetARN() string

+ func (s *AWSSQSSource) GetEventTypes() []string

+ func (s *AWSSQSSource) GetGroupVersionKind() schema.GroupVersionKind

+ func (s *AWSSQSSource) GetSink() *duckv1.Destination

+ func (s *AWSSQSSource) GetStatus() *AWSEventSourceStatus

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

+ func (s *AWSSQSSource) SetDefaults(_ context.Context)

+ func (s *AWSSQSSource) Validate(_ context.Context) *apis.FieldError

+ type AWSSQSSourceList struct

+ Items []AWSSQSSource

+ func (in *AWSSQSSourceList) DeepCopy() *AWSSQSSourceList

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

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

+ type AWSSQSSourceSpec struct

+ ARN string

+ Credentials AWSSecurityCredentials

+ func (in *AWSSQSSourceSpec) DeepCopy() *AWSSQSSourceSpec

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

+ type AWSSecurityCredentials struct

+ AccessKeyID ValueFromField

+ SecretAccessKey ValueFromField

+ func (in *AWSSecurityCredentials) DeepCopy() *AWSSecurityCredentials

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

+ type ValueFromField struct

+ Value string

+ ValueFromSecret *corev1.SecretKeySelector

+ func (in *ValueFromField) DeepCopy() *ValueFromField

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

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