v1alpha1

package

Go to main page

Versions in this module

v1

v1.27.0

Oct 17, 2023

v1.26.0

Jul 5, 2023

Changes in this version

+ const GoogleCloudStorageArchiveEventType

+ const GoogleCloudStorageDeleteEventType

+ const GoogleCloudStorageFinalizeEventType

+ const GoogleCloudStorageUpdateEventType

+ func PubSubAttributeToCEType(eventType string) string

type AzureServiceBusSourceSpec

+ MaxConcurrent *int

v1.25.2

Jul 4, 2023

v1.25.1

May 17, 2023

v1.25.0

May 17, 2023

Changes in this version

+ const AzureServiceBusConditionSubscribed

+ const MongoDBSourceEventType

+ var AllTypes = []v1alpha1.GroupObject

type AWSCloudWatchLogsSource

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

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

type AWSCloudWatchSource

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

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

type AWSCodeCommitSource

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

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

type AWSCognitoIdentitySource

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

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

type AWSCognitoUserPoolSource

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

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

type AWSDynamoDBSource

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

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

type AWSEventBridgeSource

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

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

type AWSKinesisSource

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

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

type AWSPerformanceInsightsSource

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

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

type AWSS3Source

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

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

type AWSSNSSource

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

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

type AWSSQSSource

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

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

type AzureActivityLogsSource

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

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

type AzureBlobStorageSource

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

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

type AzureEventGridSource

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

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

type AzureEventHubsSource

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

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

type AzureEventHubsSourceSpec

+ MessageCountSize *string

+ MessageTimeout *string

type AzureIOTHubSource

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

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

type AzureQueueStorageSource

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

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

type AzureServiceBusQueueSource

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

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

+ type AzureServiceBusSource struct

+ Spec AzureServiceBusSourceSpec

+ Status AzureServiceBusSourceStatus

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

+ func (in *AzureServiceBusSource) DeepCopy() *AzureServiceBusSource

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

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

+ func (s *AzureServiceBusSource) AsEventSource() string

+ func (s *AzureServiceBusSource) GetAdapterOverrides() *v1alpha1.AdapterOverrides

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

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

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

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

+ func (s *AzureServiceBusSource) GetStatusManager() *v1alpha1.StatusManager

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

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

+ type AzureServiceBusSourceList struct

+ Items []AzureServiceBusSource

+ func (in *AzureServiceBusSourceList) DeepCopy() *AzureServiceBusSourceList

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

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

+ type AzureServiceBusSourceSpec struct

+ AdapterOverrides *v1alpha1.AdapterOverrides

+ Auth AzureAuth

+ QueueID *AzureResourceID

+ TopicID *AzureResourceID

+ WebSocketsEnable *bool

+ func (in *AzureServiceBusSourceSpec) DeepCopy() *AzureServiceBusSourceSpec

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

+ type AzureServiceBusSourceStatus struct

+ SubscriptionID *AzureResourceID

+ func (in *AzureServiceBusSourceStatus) DeepCopy() *AzureServiceBusSourceStatus

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

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

+ func (s *AzureServiceBusSourceStatus) MarkSubscribed()

+ func (s *AzureServiceBusSourceStatus) MarkSubscribedWithReason(reason, msg string)

type AzureServiceBusTopicSource

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

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

type GoogleCloudAuditLogsSource

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

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

type GoogleCloudBillingSource

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

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

type GoogleCloudPubSubSource

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

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

type GoogleCloudSourceRepositoriesSource

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

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

type GoogleCloudStorageSource

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

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

type GoogleCloudStorageSourceSpec

+ ObjectNamePrefix string

type HTTPPollerSource

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

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

type IBMMQSource

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

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

type KafkaSource

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

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

+ type MongoDBSource struct

+ Spec MongoDBSourceSpec

+ Status v1alpha1.Status

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

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

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

+ func (in *MongoDBSource) DeepCopy() *MongoDBSource

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

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

+ func (s *MongoDBSource) AsEventSource() string

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

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

+ func (s *MongoDBSource) GetStatusManager() *v1alpha1.StatusManager

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

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

+ type MongoDBSourceList struct

+ Items []MongoDBSource

+ func (in *MongoDBSourceList) DeepCopy() *MongoDBSourceList

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

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

+ type MongoDBSourceSpec struct

+ Collection string

+ ConnectionString string

+ Database string

+ func (in *MongoDBSourceSpec) DeepCopy() *MongoDBSourceSpec

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

type OCIMetricsSource

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

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

type SalesforceSource

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

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

type SlackSource

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

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

type SolaceSource

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

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

type TwilioSource

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

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

type WebhookSource

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

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

type ZendeskSource

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

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

v1.24.4

Apr 18, 2023

v1.24.3

Apr 4, 2023

Changes in this version

type AzureQueueStorageSourceSpec

+ VisibilityTimeout *string

type GoogleCloudSourceAuth

+ KubernetesServiceAccount *string

v1.24.2

Apr 3, 2023

v1.24.1

Mar 21, 2023

Changes in this version

type AzureActivityLogsSourceDestinationEventHubs

+ ConsumerGroup *string

type AzureEventGridSourceDestinationEventHubs

+ ConsumerGroup *string

type AzureEventHubsSourceSpec

+ ConsumerGroup *string

v1.24.0

Feb 28, 2023

Changes in this version

+ const SolaceSourceEventType

type GoogleCloudAuditLogsSource

+ func (s *GoogleCloudAuditLogsSource) ServiceAccountOptions() []resource.ServiceAccountOption

+ func (s *GoogleCloudAuditLogsSource) WantsOwnServiceAccount() bool

type GoogleCloudAuditLogsSourceSpec

+ Auth *GoogleCloudSourceAuth

type GoogleCloudBillingSource

+ func (s *GoogleCloudBillingSource) ServiceAccountOptions() []resource.ServiceAccountOption

+ func (s *GoogleCloudBillingSource) WantsOwnServiceAccount() bool

type GoogleCloudBillingSourceSpec

+ Auth *GoogleCloudSourceAuth

type GoogleCloudPubSubSource

+ func (s *GoogleCloudPubSubSource) ServiceAccountOptions() []resource.ServiceAccountOption

+ func (s *GoogleCloudPubSubSource) WantsOwnServiceAccount() bool

type GoogleCloudPubSubSourceSpec

+ Auth *GoogleCloudSourceAuth

+ type GoogleCloudSourceAuth struct

+ GCPServiceAccount *string

+ ServiceAccountKey *v1alpha1.ValueFromField

+ func (in *GoogleCloudSourceAuth) DeepCopy() *GoogleCloudSourceAuth

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

type GoogleCloudSourceRepositoriesSource

+ func (s *GoogleCloudSourceRepositoriesSource) ServiceAccountOptions() []resource.ServiceAccountOption

+ func (s *GoogleCloudSourceRepositoriesSource) WantsOwnServiceAccount() bool

type GoogleCloudSourceRepositoriesSourceSpec

+ Auth *GoogleCloudSourceAuth

type GoogleCloudStorageSource

+ func (s *GoogleCloudStorageSource) ServiceAccountOptions() []resource.ServiceAccountOption

+ func (s *GoogleCloudStorageSource) WantsOwnServiceAccount() bool

type GoogleCloudStorageSourceSpec

+ Auth *GoogleCloudSourceAuth

+ type SolaceSource struct

+ Spec SolaceSourceSpec

+ Status v1alpha1.Status

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

+ func (in *SolaceSource) DeepCopy() *SolaceSource

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

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

+ func (s *SolaceSource) AsEventSource() string

+ func (s *SolaceSource) GetAdapterOverrides() *v1alpha1.AdapterOverrides

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

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

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

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

+ func (s *SolaceSource) GetStatusManager() *v1alpha1.StatusManager

+ type SolaceSourceAuth struct

+ Password *v1alpha1.ValueFromField

+ SASLEnable *bool

+ TLS *SolaceSourceTLSAuth

+ TLSEnable *bool

+ Username *string

+ func (in *SolaceSourceAuth) DeepCopy() *SolaceSourceAuth

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

+ type SolaceSourceList struct

+ Items []SolaceSource

+ func (in *SolaceSourceList) DeepCopy() *SolaceSourceList

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

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

+ type SolaceSourceSpec struct

+ AdapterOverrides *v1alpha1.AdapterOverrides

+ Auth *SolaceSourceAuth

+ QueueName string

+ URL string

+ func (in *SolaceSourceSpec) DeepCopy() *SolaceSourceSpec

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

+ type SolaceSourceTLSAuth struct

+ CA *v1alpha1.ValueFromField

+ ClientCert *v1alpha1.ValueFromField

+ ClientKey *v1alpha1.ValueFromField

+ SkipVerify *bool

+ func (in *SolaceSourceTLSAuth) DeepCopy() *SolaceSourceTLSAuth

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

v1.23.3

Feb 17, 2023

v1.23.2

Feb 6, 2023

v1.23.1

Feb 2, 2023

v1.23.0

Jan 10, 2023

v1.22.0

Dec 1, 2022

Changes in this version

+ const KafkaSourceEventType

+ type AzureEventHubsSource struct

+ Spec AzureEventHubsSourceSpec

+ Status v1alpha1.Status

+ func (in *AzureEventHubsSource) DeepCopy() *AzureEventHubsSource

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

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

+ func (s *AzureEventHubsSource) AsEventSource() string

+ func (s *AzureEventHubsSource) GetAdapterOverrides() *v1alpha1.AdapterOverrides

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

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

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

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

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

+ func (s *AzureEventHubsSource) GetStatusManager() *v1alpha1.StatusManager

+ type AzureEventHubsSourceList struct

+ Items []AzureEventHubsSource

+ func (in *AzureEventHubsSourceList) DeepCopy() *AzureEventHubsSourceList

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

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

+ type AzureEventHubsSourceSpec struct

+ AdapterOverrides *v1alpha1.AdapterOverrides

+ Auth AzureAuth

+ EventHubID AzureResourceID

+ func (in *AzureEventHubsSourceSpec) DeepCopy() *AzureEventHubsSourceSpec

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

type KafkaSource

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

+ func (s *KafkaSource) AsEventSource() string

+ func (s *KafkaSource) GetAdapterOverrides() *v1alpha1.AdapterOverrides

type KafkaSourceSpec

+ Topic string

v1.21.2

Mar 8, 2023

v1.21.1

Oct 6, 2022

v1.21.0

Sep 6, 2022

v1.20.0

Aug 2, 2022

v1.19.3

Jul 27, 2022

v1.19.2

Jul 19, 2022

Changes in this version

type AzureServiceBusTopicSourceSpec

+ WebSocketsEnable *bool

type CloudEventsSource

+ func (s *CloudEventsSource) AsEventSource() string

+ func (s *CloudEventsSource) GetAdapterOverrides() *v1alpha1.AdapterOverrides

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

type CloudEventsSourceSpec

+ AdapterOverrides *v1alpha1.AdapterOverrides

+ type WebhookEventExtensionAttributes struct

+ From []string

+ func (in *WebhookEventExtensionAttributes) DeepCopy() *WebhookEventExtensionAttributes

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

type WebhookSourceSpec

+ EventExtensionAttributes *WebhookEventExtensionAttributes

v1.19.1

Jul 7, 2022

Changes in this version

type KafkaSourceAuth

+ TLSEnable *bool

v1.19.0

Jul 6, 2022

Changes in this version

+ type KafkaSource struct

+ Spec KafkaSourceSpec

+ Status v1alpha1.Status

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

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

+ func (in *KafkaSource) DeepCopy() *KafkaSource

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

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

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

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

+ func (s *KafkaSource) GetStatusManager() *v1alpha1.StatusManager

+ type KafkaSourceAuth struct

+ Kerberos *KafkaSourceKerberos

+ Password *v1alpha1.ValueFromField

+ SASLEnable bool

+ SecurityMechanisms *string

+ TLS *KafkaSourceTLSAuth

+ Username *string

+ func (in *KafkaSourceAuth) DeepCopy() *KafkaSourceAuth

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

+ type KafkaSourceKerberos struct

+ Config *v1alpha1.ValueFromField

+ ConfigPath *string

+ Keytab *v1alpha1.ValueFromField

+ KeytabPath *string

+ Password *v1alpha1.ValueFromField

+ Realm *string

+ ServiceName *string

+ Username *string

+ func (in *KafkaSourceKerberos) DeepCopy() *KafkaSourceKerberos

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

+ type KafkaSourceList struct

+ Items []KafkaSource

+ func (in *KafkaSourceList) DeepCopy() *KafkaSourceList

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

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

+ type KafkaSourceSpec struct

+ AdapterOverrides *v1alpha1.AdapterOverrides

+ Auth KafkaSourceAuth

+ BootstrapServers []string

+ GroupID string

+ Topics []string

+ func (in *KafkaSourceSpec) DeepCopy() *KafkaSourceSpec

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

+ type KafkaSourceTLSAuth struct

+ CA *v1alpha1.ValueFromField

+ ClientCert *v1alpha1.ValueFromField

+ ClientKey *v1alpha1.ValueFromField

+ SkipVerify *bool

+ func (in *KafkaSourceTLSAuth) DeepCopy() *KafkaSourceTLSAuth

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

v1.18.1

Jun 21, 2022

v1.18.0

Jun 2, 2022

Changes in this version

+ const AWSEventBridgeConditionSubscribed

+ const AWSEventBridgeGenericEventType

+ const AWSEventBridgeReasonAPIError

+ const AWSEventBridgeReasonInvalidEventPattern

+ const AWSEventBridgeReasonNoClient

+ const AWSEventBridgeReasonNoEventBus

type AWSCloudWatchLogsSource

+ func (s *AWSCloudWatchLogsSource) ServiceAccountOptions() []resource.ServiceAccountOption

+ func (s *AWSCloudWatchLogsSource) WantsOwnServiceAccount() bool

type AWSCloudWatchSource

+ func (s *AWSCloudWatchSource) ServiceAccountOptions() []resource.ServiceAccountOption

+ func (s *AWSCloudWatchSource) WantsOwnServiceAccount() bool

type AWSCodeCommitSource

+ func (s *AWSCodeCommitSource) ServiceAccountOptions() []resource.ServiceAccountOption

+ func (s *AWSCodeCommitSource) WantsOwnServiceAccount() bool

type AWSCognitoIdentitySource

+ func (s *AWSCognitoIdentitySource) ServiceAccountOptions() []resource.ServiceAccountOption

+ func (s *AWSCognitoIdentitySource) WantsOwnServiceAccount() bool

type AWSCognitoUserPoolSource

+ func (s *AWSCognitoUserPoolSource) ServiceAccountOptions() []resource.ServiceAccountOption

+ func (s *AWSCognitoUserPoolSource) WantsOwnServiceAccount() bool

type AWSDynamoDBSource

+ func (s *AWSDynamoDBSource) ServiceAccountOptions() []resource.ServiceAccountOption

+ func (s *AWSDynamoDBSource) WantsOwnServiceAccount() bool

+ type AWSEventBridgeSource struct

+ Spec AWSEventBridgeSourceSpec

+ Status AWSEventBridgeSourceStatus

+ func (in *AWSEventBridgeSource) DeepCopy() *AWSEventBridgeSource

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

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

+ func (s *AWSEventBridgeSource) AsEventSource() string

+ func (s *AWSEventBridgeSource) GetAdapterOverrides() *v1alpha1.AdapterOverrides

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

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

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

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

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

+ func (s *AWSEventBridgeSource) GetStatusManager() *v1alpha1.StatusManager

+ func (s *AWSEventBridgeSource) ServiceAccountOptions() []resource.ServiceAccountOption

+ func (s *AWSEventBridgeSource) WantsOwnServiceAccount() bool

+ type AWSEventBridgeSourceDestination struct

+ SQS *AWSEventBridgeSourceDestinationSQS

+ func (in *AWSEventBridgeSourceDestination) DeepCopy() *AWSEventBridgeSourceDestination

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

+ type AWSEventBridgeSourceDestinationSQS struct

+ QueueARN apis.ARN

+ func (in *AWSEventBridgeSourceDestinationSQS) DeepCopy() *AWSEventBridgeSourceDestinationSQS

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

+ type AWSEventBridgeSourceList struct

+ Items []AWSEventBridgeSource

+ func (in *AWSEventBridgeSourceList) DeepCopy() *AWSEventBridgeSourceList

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

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

+ type AWSEventBridgeSourceSpec struct

+ ARN apis.ARN

+ AdapterOverrides *v1alpha1.AdapterOverrides

+ Auth AWSAuth

+ Destination *AWSEventBridgeSourceDestination

+ EventPattern *string

+ func (in *AWSEventBridgeSourceSpec) DeepCopy() *AWSEventBridgeSourceSpec

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

+ type AWSEventBridgeSourceStatus struct

+ EventRuleARN *apis.ARN

+ QueueARN *apis.ARN

+ func (in *AWSEventBridgeSourceStatus) DeepCopy() *AWSEventBridgeSourceStatus

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

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

+ func (s *AWSEventBridgeSourceStatus) MarkSubscribed(ruleARN tmapis.ARN)

type AWSKinesisSource

+ func (s *AWSKinesisSource) ServiceAccountOptions() []resource.ServiceAccountOption

+ func (s *AWSKinesisSource) WantsOwnServiceAccount() bool

type AWSPerformanceInsightsSource

+ func (s *AWSPerformanceInsightsSource) ServiceAccountOptions() []resource.ServiceAccountOption

+ func (s *AWSPerformanceInsightsSource) WantsOwnServiceAccount() bool

+ type GoogleCloudSourcePubSubSpec struct

+ Project *string

+ Topic *GCloudResourceName

+ func (in *GoogleCloudSourcePubSubSpec) DeepCopy() *GoogleCloudSourcePubSubSpec

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

v1.17.0

May 3, 2022

Changes in this version

type AWSS3Source

+ func (s *AWSS3Source) ServiceAccountOptions() []resource.ServiceAccountOption

+ func (s *AWSS3Source) WantsOwnServiceAccount() bool

type AWSSQSSourceSpec

+ MessageProcessor *string

+ type CloudEventsSource struct

+ Spec CloudEventsSourceSpec

+ Status v1alpha1.Status

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

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

+ func (in *CloudEventsSource) DeepCopy() *CloudEventsSource

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

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

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

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

+ func (s *CloudEventsSource) GetStatusManager() *v1alpha1.StatusManager

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

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

+ type CloudEventsSourceList struct

+ Items []CloudEventsSource

+ func (in *CloudEventsSourceList) DeepCopy() *CloudEventsSourceList

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

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

+ type CloudEventsSourceSpec struct

+ Credentials *HTTPCredentials

+ Path *string

+ RateLimiter *RateLimiter

+ func (in *CloudEventsSourceSpec) DeepCopy() *CloudEventsSourceSpec

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

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

type GoogleCloudSourceRepositoriesSourceSpec

+ PublishServiceAccount *string

+ type HTTPBasicAuth struct

+ Password v1alpha1.ValueFromField

+ Username string

+ func (in *HTTPBasicAuth) DeepCopy() *HTTPBasicAuth

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

+ type HTTPCredentials struct

+ BasicAuths []HTTPBasicAuth

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

+ func (in *HTTPCredentials) DeepCopy() *HTTPCredentials

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

+ type RateLimiter struct

+ RequestsPerSecond int

+ func (in *RateLimiter) DeepCopy() *RateLimiter

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

v1.16.1

Apr 22, 2022

Changes in this version

type AWSCloudWatchLogsSource

+ func (s *AWSCloudWatchLogsSource) GetAdapterOverrides() *v1alpha1.AdapterOverrides

type AWSCloudWatchLogsSourceSpec

+ AdapterOverrides *v1alpha1.AdapterOverrides

type AWSCloudWatchSource

+ func (s *AWSCloudWatchSource) GetAdapterOverrides() *v1alpha1.AdapterOverrides

type AWSCloudWatchSourceSpec

+ AdapterOverrides *v1alpha1.AdapterOverrides

type AWSCodeCommitSource

+ func (s *AWSCodeCommitSource) GetAdapterOverrides() *v1alpha1.AdapterOverrides

type AWSCodeCommitSourceSpec

+ AdapterOverrides *v1alpha1.AdapterOverrides

type AWSCognitoIdentitySource

+ func (s *AWSCognitoIdentitySource) GetAdapterOverrides() *v1alpha1.AdapterOverrides

type AWSCognitoIdentitySourceSpec

+ AdapterOverrides *v1alpha1.AdapterOverrides

type AWSCognitoUserPoolSource

+ func (s *AWSCognitoUserPoolSource) GetAdapterOverrides() *v1alpha1.AdapterOverrides

type AWSCognitoUserPoolSourceSpec

+ AdapterOverrides *v1alpha1.AdapterOverrides

type AWSDynamoDBSource

+ func (s *AWSDynamoDBSource) GetAdapterOverrides() *v1alpha1.AdapterOverrides

type AWSDynamoDBSourceSpec

+ AdapterOverrides *v1alpha1.AdapterOverrides

type AWSKinesisSource

+ func (s *AWSKinesisSource) GetAdapterOverrides() *v1alpha1.AdapterOverrides

type AWSKinesisSourceSpec

+ AdapterOverrides *v1alpha1.AdapterOverrides

type AWSPerformanceInsightsSource

+ func (s *AWSPerformanceInsightsSource) GetAdapterOverrides() *v1alpha1.AdapterOverrides

type AWSPerformanceInsightsSourceSpec

+ AdapterOverrides *v1alpha1.AdapterOverrides

type AWSS3Source

+ func (s *AWSS3Source) GetAdapterOverrides() *v1alpha1.AdapterOverrides

type AWSS3SourceSpec

+ AdapterOverrides *v1alpha1.AdapterOverrides

type AWSSNSSource

+ func (s *AWSSNSSource) GetAdapterOverrides() *v1alpha1.AdapterOverrides

type AWSSNSSourceSpec

+ AdapterOverrides *v1alpha1.AdapterOverrides

type AWSSQSSource

+ func (s *AWSSQSSource) GetAdapterOverrides() *v1alpha1.AdapterOverrides

type AWSSQSSourceSpec

+ AdapterOverrides *v1alpha1.AdapterOverrides

type AzureActivityLogsSource

+ func (s *AzureActivityLogsSource) GetAdapterOverrides() *v1alpha1.AdapterOverrides

type AzureActivityLogsSourceSpec

+ AdapterOverrides *v1alpha1.AdapterOverrides

type AzureBlobStorageSource

+ func (s *AzureBlobStorageSource) GetAdapterOverrides() *v1alpha1.AdapterOverrides

type AzureBlobStorageSourceSpec

+ AdapterOverrides *v1alpha1.AdapterOverrides

type AzureEventGridSource

+ func (s *AzureEventGridSource) GetAdapterOverrides() *v1alpha1.AdapterOverrides

type AzureEventGridSourceSpec

+ AdapterOverrides *v1alpha1.AdapterOverrides

type AzureEventHubSource

+ func (s *AzureEventHubSource) GetAdapterOverrides() *v1alpha1.AdapterOverrides

type AzureEventHubSourceSpec

+ AdapterOverrides *v1alpha1.AdapterOverrides

type AzureIOTHubSource

+ func (s *AzureIOTHubSource) GetAdapterOverrides() *v1alpha1.AdapterOverrides

type AzureIOTHubSourceSpec

+ AdapterOverrides *v1alpha1.AdapterOverrides

type AzureQueueStorageSource

+ func (s *AzureQueueStorageSource) GetAdapterOverrides() *v1alpha1.AdapterOverrides

type AzureQueueStorageSourceSpec

+ AdapterOverrides *v1alpha1.AdapterOverrides

type AzureServiceBusQueueSource

+ func (s *AzureServiceBusQueueSource) GetAdapterOverrides() *v1alpha1.AdapterOverrides

type AzureServiceBusQueueSourceSpec

+ AdapterOverrides *v1alpha1.AdapterOverrides

type AzureServiceBusTopicSource

+ func (s *AzureServiceBusTopicSource) GetAdapterOverrides() *v1alpha1.AdapterOverrides

type AzureServiceBusTopicSourceSpec

+ AdapterOverrides *v1alpha1.AdapterOverrides

type GoogleCloudAuditLogsSource

+ func (s *GoogleCloudAuditLogsSource) GetAdapterOverrides() *v1alpha1.AdapterOverrides

type GoogleCloudAuditLogsSourceSpec

+ AdapterOverrides *v1alpha1.AdapterOverrides

type GoogleCloudBillingSource

+ func (s *GoogleCloudBillingSource) GetAdapterOverrides() *v1alpha1.AdapterOverrides

type GoogleCloudBillingSourceSpec

+ AdapterOverrides *v1alpha1.AdapterOverrides

type GoogleCloudIoTSource

+ func (s *GoogleCloudIoTSource) GetAdapterOverrides() *v1alpha1.AdapterOverrides

type GoogleCloudIoTSourceSpec

+ AdapterOverrides *v1alpha1.AdapterOverrides

type GoogleCloudPubSubSource

+ func (s *GoogleCloudPubSubSource) GetAdapterOverrides() *v1alpha1.AdapterOverrides

type GoogleCloudPubSubSourceSpec

+ AdapterOverrides *v1alpha1.AdapterOverrides

type GoogleCloudSourceRepositoriesSource

+ func (s *GoogleCloudSourceRepositoriesSource) GetAdapterOverrides() *v1alpha1.AdapterOverrides

type GoogleCloudSourceRepositoriesSourceSpec

+ AdapterOverrides *v1alpha1.AdapterOverrides

type GoogleCloudStorageSource

+ func (s *GoogleCloudStorageSource) GetAdapterOverrides() *v1alpha1.AdapterOverrides

type GoogleCloudStorageSourceSpec

+ AdapterOverrides *v1alpha1.AdapterOverrides

type HTTPPollerSource

+ func (s *HTTPPollerSource) GetAdapterOverrides() *v1alpha1.AdapterOverrides

type HTTPPollerSourceSpec

+ AdapterOverrides *v1alpha1.AdapterOverrides

type IBMMQSource

+ func (s *IBMMQSource) GetAdapterOverrides() *v1alpha1.AdapterOverrides

type IBMMQSourceSpec

+ AdapterOverrides *v1alpha1.AdapterOverrides

type OCIMetricsSource

+ func (s *OCIMetricsSource) GetAdapterOverrides() *v1alpha1.AdapterOverrides

type OCIMetricsSourceSpec

+ AdapterOverrides *v1alpha1.AdapterOverrides

type SalesforceSource

+ func (s *SalesforceSource) GetAdapterOverrides() *v1alpha1.AdapterOverrides

type SalesforceSourceSpec

+ AdapterOverrides *v1alpha1.AdapterOverrides

type SlackSource

+ func (s *SlackSource) GetAdapterOverrides() *v1alpha1.AdapterOverrides

type SlackSourceSpec

+ AdapterOverrides *v1alpha1.AdapterOverrides

type TwilioSource

+ func (s *TwilioSource) GetAdapterOverrides() *v1alpha1.AdapterOverrides

type TwilioSourceSpec

+ AdapterOverrides *v1alpha1.AdapterOverrides

type WebhookSource

+ func (s *WebhookSource) GetAdapterOverrides() *v1alpha1.AdapterOverrides

type WebhookSourceSpec

+ AdapterOverrides *v1alpha1.AdapterOverrides

type ZendeskSource

+ func (s *ZendeskSource) GetAdapterOverrides() *v1alpha1.AdapterOverrides

type ZendeskSourceSpec

+ AdapterOverrides *v1alpha1.AdapterOverrides

v1.16.0

Mar 31, 2022

Changes in this version

+ func WithReconcilable(ctx context.Context, r Reconcilable) context.Context

+ type Reconcilable interface

+ AsEventSource func() string

+ GetEventTypes func() []string

+ GetSink func() *duckv1.Destination

+ GetStatusManager func() *StatusManager

+ func ReconcilableFromContext(ctx context.Context) Reconcilable

+ type StatusManager struct

+ func (m *StatusManager) MarkNoSink()

+ func (m *StatusManager) MarkRBACNotBound()

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

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

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

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

v1.15.2

Mar 11, 2022

v1.15.1

Mar 10, 2022

v1.15.0

Feb 28, 2022

v1.14.1

Feb 6, 2022

v1.14.0

Feb 1, 2022

Changes in this version

type Credentials

+ TLS *TLSSpec

+ type Keystore struct

+ KeyDatabase ValueFromField

+ PasswordStash ValueFromField

+ func (in *Keystore) DeepCopy() *Keystore

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

+ type TLSSpec struct

+ CertLabel *string

+ Cipher string

+ ClientAuthRequired bool

+ KeyRepository Keystore

+ func (in *TLSSpec) DeepCopy() *TLSSpec

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

v1.13.0

Jan 3, 2022

Changes in this version

+ const GoogleCloudSourceRepoConditionSubscribed

+ const GoogleCloudSourceRepoGenericEventType

+ const IBMMQSourceEventType

+ var IBMMQSourceCondSet = apis.NewLivingConditionSet(ConditionDeployed)

+ type Credentials struct

+ Password ValueFromField

+ User ValueFromField

+ func (in *Credentials) DeepCopy() *Credentials

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

+ type Delivery struct

+ BackoffDelay int

+ DeadLetterQueue string

+ DeadLetterQueueManager string

+ Retry int

+ func (in *Delivery) DeepCopy() *Delivery

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

+ type GoogleCloudSourceRepositoriesSource struct

+ Spec GoogleCloudSourceRepositoriesSourceSpec

+ Status GoogleCloudSourceRepositoriesSourceStatus

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

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

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

+ func (in *GoogleCloudSourceRepositoriesSource) DeepCopy() *GoogleCloudSourceRepositoriesSource

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

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

+ func (s *GoogleCloudSourceRepositoriesSource) AsEventSource() string

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

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

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

+ type GoogleCloudSourceRepositoriesSourceList struct

+ Items []GoogleCloudSourceRepositoriesSource

+ func (in *GoogleCloudSourceRepositoriesSourceList) DeepCopy() *GoogleCloudSourceRepositoriesSourceList

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

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

+ type GoogleCloudSourceRepositoriesSourcePubSubSpec struct

+ Project *string

+ Topic *GCloudResourceName

+ func (in *GoogleCloudSourceRepositoriesSourcePubSubSpec) DeepCopy() *GoogleCloudSourceRepositoriesSourcePubSubSpec

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

+ type GoogleCloudSourceRepositoriesSourceSpec struct

+ PubSub GoogleCloudSourceRepositoriesSourcePubSubSpec

+ Repository GCloudResourceName

+ ServiceAccountKey ValueFromField

+ func (in *GoogleCloudSourceRepositoriesSourceSpec) DeepCopy() *GoogleCloudSourceRepositoriesSourceSpec

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

+ type GoogleCloudSourceRepositoriesSourceStatus struct

+ Subscription *GCloudResourceName

+ Topic *GCloudResourceName

+ func (in *GoogleCloudSourceRepositoriesSourceStatus) DeepCopy() *GoogleCloudSourceRepositoriesSourceStatus

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

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

+ func (s *GoogleCloudSourceRepositoriesSourceStatus) MarkSubscribed()

+ type IBMMQSource struct

+ Spec IBMMQSourceSpec

+ Status IBMMQSourceStatus

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

+ func (in *IBMMQSource) DeepCopy() *IBMMQSource

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

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

+ func (s *IBMMQSource) AsEventSource() string

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

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

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

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

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

+ type IBMMQSourceList struct

+ Items []IBMMQSource

+ func (in *IBMMQSourceList) DeepCopy() *IBMMQSourceList

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

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

+ type IBMMQSourceSpec struct

+ Auth Credentials

+ ChannelName string

+ ConnectionName string

+ Delivery Delivery

+ QueueManager string

+ QueueName string

+ func (in *IBMMQSourceSpec) DeepCopy() *IBMMQSourceSpec

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

+ type IBMMQSourceStatus struct

+ func (in *IBMMQSourceStatus) DeepCopy() *IBMMQSourceStatus

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

type WebhookSourceSpec

+ CORSAllowOrigin *string

v1.12.0

Dec 8, 2021

Changes in this version

+ const AzureServiceBusGenericEventType

+ const AzureServiceBusTopicConditionSubscribed

+ func ServiceAccountOptions(src EventSource) []resource.ServiceAccountOption

+ func WantsOwnServiceAccount(src EventSource) bool

+ type AWSAuth struct

+ Credentials *AWSSecurityCredentials

+ EksIAMRole *apis.ARN

+ func (in *AWSAuth) DeepCopy() *AWSAuth

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

type AWSCloudWatchLogsSourceSpec

+ Auth AWSAuth

type AWSCloudWatchSourceSpec

+ Auth AWSAuth

type AWSCodeCommitSourceSpec

+ Auth AWSAuth

type AWSCognitoIdentitySourceSpec

+ Auth AWSAuth

type AWSCognitoUserPoolSourceSpec

+ Auth AWSAuth

type AWSDynamoDBSourceSpec

+ Auth AWSAuth

+ type AWSEndpoint struct

+ URL *pkgapis.URL

+ func (in *AWSEndpoint) DeepCopy() *AWSEndpoint

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

type AWSKinesisSourceSpec

+ Auth AWSAuth

type AWSPerformanceInsightsSourceSpec

+ Auth AWSAuth

+ type AWSS3SourceDestination struct

+ SQS *AWSS3SourceDestinationSQS

+ func (in *AWSS3SourceDestination) DeepCopy() *AWSS3SourceDestination

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

+ type AWSS3SourceDestinationSQS struct

+ QueueARN apis.ARN

+ func (in *AWSS3SourceDestinationSQS) DeepCopy() *AWSS3SourceDestinationSQS

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

type AWSS3SourceSpec

+ Auth AWSAuth

+ Destination *AWSS3SourceDestination

type AWSSNSSourceSpec

+ Auth AWSAuth

type AWSSQSSource

+ func (s *AWSSQSSource) ServiceAccountOptions() []resource.ServiceAccountOption

+ func (s *AWSSQSSource) WantsOwnServiceAccount() bool

type AWSSQSSourceSpec

+ Auth AWSAuth

+ Endpoint *AWSEndpoint

+ type AzureActivityLogsSourceDestination struct

+ EventHubs AzureActivityLogsSourceDestinationEventHubs

+ func (in *AzureActivityLogsSourceDestination) DeepCopy() *AzureActivityLogsSourceDestination

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

+ type AzureActivityLogsSourceDestinationEventHubs struct

+ HubName *string

+ NamespaceID AzureResourceID

+ SASPolicy *string

+ func (in *AzureActivityLogsSourceDestinationEventHubs) DeepCopy() *AzureActivityLogsSourceDestinationEventHubs

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

type AzureActivityLogsSourceSpec

+ Destination AzureActivityLogsSourceDestination

+ SubscriptionID string

type AzureBlobStorageSourceSpec

+ Endpoint AzureEventGridSourceEndpoint

+ type AzureEventGridSourceDestinationEventHubs struct

+ HubName *string

+ NamespaceID AzureResourceID

+ func (in *AzureEventGridSourceDestinationEventHubs) DeepCopy() *AzureEventGridSourceDestinationEventHubs

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

+ type AzureEventGridSourceEndpoint struct

+ EventHubs AzureEventGridSourceDestinationEventHubs

+ func (in *AzureEventGridSourceEndpoint) DeepCopy() *AzureEventGridSourceEndpoint

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

type AzureEventGridSourceSpec

+ Endpoint AzureEventGridSourceEndpoint

type AzureResourceID

+ Namespace string

+ SubResourceName string

+ SubResourceType string

type AzureServiceBusQueueSourceSpec

+ QueueID AzureResourceID

+ type AzureServiceBusTopicSource struct

+ Spec AzureServiceBusTopicSourceSpec

+ Status AzureServiceBusTopicSourceStatus

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

+ func (in *AzureServiceBusTopicSource) DeepCopy() *AzureServiceBusTopicSource

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

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

+ func (s *AzureServiceBusTopicSource) AsEventSource() string

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

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

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

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

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

+ type AzureServiceBusTopicSourceList struct

+ Items []AzureServiceBusTopicSource

+ func (in *AzureServiceBusTopicSourceList) DeepCopy() *AzureServiceBusTopicSourceList

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

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

+ type AzureServiceBusTopicSourceSpec struct

+ Auth AzureAuth

+ TopicID AzureResourceID

+ func (in *AzureServiceBusTopicSourceSpec) DeepCopy() *AzureServiceBusTopicSourceSpec

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

+ type AzureServiceBusTopicSourceStatus struct

+ SubscriptionID *AzureResourceID

+ func (in *AzureServiceBusTopicSourceStatus) DeepCopy() *AzureServiceBusTopicSourceStatus

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

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

+ func (s *AzureServiceBusTopicSourceStatus) MarkSubscribed()

v1.11.0

Nov 2, 2021

Changes in this version

+ const GoogleCloudIoTConditionSubscribed

+ const GoogleCloudIoTGenericEventType

+ type GCloudIoTResourceName struct

+ Collection string

+ Location string

+ Project string

+ Resource string

+ func (in *GCloudIoTResourceName) DeepCopy() *GCloudIoTResourceName

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

+ func (n *GCloudIoTResourceName) String() string

+ func (n *GCloudIoTResourceName) UnmarshalJSON(data []byte) error

+ func (n GCloudIoTResourceName) MarshalJSON() ([]byte, error)

+ type GoogleCloudIoTSource struct

+ Spec GoogleCloudIoTSourceSpec

+ Status GoogleCloudIoTSourceStatus

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

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

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

+ func (in *GoogleCloudIoTSource) DeepCopy() *GoogleCloudIoTSource

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

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

+ func (s *GoogleCloudIoTSource) AsEventSource() string

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

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

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

+ type GoogleCloudIoTSourceList struct

+ Items []GoogleCloudIoTSource

+ func (in *GoogleCloudIoTSourceList) DeepCopy() *GoogleCloudIoTSourceList

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

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

+ type GoogleCloudIoTSourcePubSubSpec struct

+ Project *string

+ Topic *GCloudResourceName

+ func (in *GoogleCloudIoTSourcePubSubSpec) DeepCopy() *GoogleCloudIoTSourcePubSubSpec

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

+ type GoogleCloudIoTSourceSpec struct

+ PubSub GoogleCloudIoTSourcePubSubSpec

+ Registry GCloudIoTResourceName

+ ServiceAccountKey ValueFromField

+ func (in *GoogleCloudIoTSourceSpec) DeepCopy() *GoogleCloudIoTSourceSpec

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

+ type GoogleCloudIoTSourceStatus struct

+ Subscription *GCloudResourceName

+ Topic *GCloudResourceName

+ func (in *GoogleCloudIoTSourceStatus) DeepCopy() *GoogleCloudIoTSourceStatus

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

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

+ func (s *GoogleCloudIoTSourceStatus) MarkSubscribed()

v1.10.1

Oct 11, 2021

Changes in this version

+ const AWSCloudWatchLogsGenericEventType

+ const AWSCloudWatchMessageEventType

+ const AWSCloudWatchMetricEventType

+ const AWSCognitoIdentityGenericEventType

+ const AWSCognitoUserPoolGenericEventType

+ const AWSDynamoDBGenericEventType

+ const AWSKinesisGenericEventType

+ const AWSPerformanceInsightsGenericEventType

+ const AWSS3ConditionSubscribed

+ const AWSS3ObjCreatedEventType

+ const AWSS3ObjRemovedEventType

+ const AWSS3ObjRestoreEventType

+ const AWSS3ReasonAPIError

+ const AWSS3ReasonNoBucket

+ const AWSS3ReasonNoClient

+ const AWSS3ReducedRedundancyLostObjEventType

+ const AWSS3ReplicationEventType

+ const AWSS3TestEventType

+ const AWSSNSConditionHandlerRegistered

+ const AWSSNSConditionSubscribed

+ const AWSSNSGenericEventType

+ const AWSSNSReasonAPIError

+ const AWSSNSReasonFailedSync

+ const AWSSNSReasonNoClient

+ const AWSSNSReasonNoURL

+ const AWSSNSReasonPending

+ const AWSSNSReasonRejected

+ const AWSSQSGenericEventType

+ const AzureActivityLogsActivityLogEventType

+ const AzureActivityLogsConditionSubscribed

+ const AzureBlobStorageBlobCreatedEventType

+ const AzureBlobStorageBlobDeletedEventType

+ const AzureBlobStorageConditionSubscribed

+ const AzureEventGridConditionSubscribed

+ const AzureEventHubGenericEventType

+ const AzureIOTHubGenericEventType

+ const AzureQueueStorageEventType

+ const AzureReasonAPIError

+ const AzureReasonNoClient

+ const AzureServiceBusbGenericEventType

+ const ConditionDeployed

+ const ConditionReady

+ const ConditionSinkProvided

+ const GCloudReasonAPIError

+ const GCloudReasonNoClient

+ const GoogleCloudAuditLogsConditionSubscribed

+ const GoogleCloudAuditLogsGenericEventType

+ const GoogleCloudBillingConditionSubscribed

+ const GoogleCloudBillingGenericEventType

+ const GoogleCloudPubSubConditionSubscribed

+ const GoogleCloudPubSubGenericEventType

+ const GoogleCloudRepositoriesConditionSubscribed

+ const GoogleCloudRepositoriesGenericEventType

+ const GoogleCloudStorageConditionSubscribed

+ const GoogleCloudStorageGenericEventType

+ const OCIMetricsGenericEventType

+ const ReasonFailedSync

+ const ReasonRBACNotBound

+ const ReasonSinkEmpty

+ const ReasonSinkNotFound

+ const ReasonUnavailable

+ const ServiceCloudWatch

+ const SlackGenericEventType

+ const TwilioSourceGenericEventType

+ const ZendeskConditionTargetSynced

+ const ZendeskReasonFailedSync

+ const ZendeskReasonNoSecret

+ const ZendeskReasonNoURL

+ const ZendeskTicketCreatedEventType

+ var AddToScheme = SchemeBuilder.AddToScheme

+ var GoogleCloudAuditLogsSourceConditionSet = NewEventSourceConditionSet(GoogleCloudAuditLogsConditionSubscribed)

+ var GoogleCloudBillingSourceConditionSet = NewEventSourceConditionSet(GoogleCloudBillingConditionSubscribed)

+ var SchemeBuilder = runtime.NewSchemeBuilder(addKnownTypes)

+ var SchemeGroupVersion = schema.GroupVersion

+ func AWSCloudWatchSourceName(ns, name string) string

+ func AWSEventType(awsService, eventType string) string

+ func AzureEventType(service, eventType string) string

+ func AzureIOTHubSourceName(namespace, name string) string

+ func AzureQueueStorageSourceName(namespace, name string) string

+ func AzureServiceBusQueueSourceName(namespace, name string) string

+ func EventType(service, eventType string) string

+ func IsMultiTenant(src EventSource) bool

+ func Kind(kind string) schema.GroupKind

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

+ func OCIGenerateEventSource(namespace, name string) string

+ func Resource(resource string) schema.GroupResource

+ func TwilioSourceName(namespace, name string) string

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

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

+ type AWSCodeCommitSource struct

+ Spec AWSCodeCommitSourceSpec

+ Status EventSourceStatus

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

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

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

+ func (s *AWSCodeCommitSource) AsEventSource() string

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

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

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

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

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

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

+ 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 apis.ARN

+ Branch string

+ Credentials AWSSecurityCredentials

+ EventTypes []string

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

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

+ type AWSCognitoIdentitySource struct

+ Spec AWSCognitoIdentitySourceSpec

+ Status EventSourceStatus

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

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

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

+ func (s *AWSCognitoIdentitySource) AsEventSource() string

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

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

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

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

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

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

+ 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 apis.ARN

+ Credentials AWSSecurityCredentials

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

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

+ type AWSCognitoUserPoolSource struct

+ Spec AWSCognitoUserPoolSourceSpec

+ Status EventSourceStatus

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

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

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

+ func (s *AWSCognitoUserPoolSource) AsEventSource() string

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

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

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

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

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

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

+ 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 apis.ARN

+ Credentials AWSSecurityCredentials

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

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

+ type AWSDynamoDBSource struct

+ Spec AWSDynamoDBSourceSpec

+ Status EventSourceStatus

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

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

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

+ func (s *AWSDynamoDBSource) AsEventSource() string

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

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

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

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

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

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

+ 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 apis.ARN

+ Credentials AWSSecurityCredentials

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

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

+ type AWSKinesisSource struct

+ Spec AWSKinesisSourceSpec

+ Status EventSourceStatus

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

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

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

+ func (s *AWSKinesisSource) AsEventSource() string

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

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

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

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

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

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

+ 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 apis.ARN

+ Credentials AWSSecurityCredentials

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

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

+ 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

+ Metrics []string

+ PollingInterval apis.Duration

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

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

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

+ type AWSSNSSource struct

+ Spec AWSSNSSourceSpec

+ Status AWSSNSSourceStatus

+ func (*AWSSNSSource) IsMultiTenant() bool

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

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

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

+ func (s *AWSSNSSource) AsEventSource() string

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

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

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

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

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

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

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

+ 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 apis.ARN

+ Credentials AWSSecurityCredentials

+ SubscriptionAttributes map[string]*string

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

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

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

+ type AWSSQSSource struct

+ Spec AWSSQSSourceSpec

+ Status EventSourceStatus

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

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

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

+ func (s *AWSSQSSource) AsEventSource() string

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

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

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

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

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

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

+ type AWSSQSSourceList struct

+ Items []AWSSQSSource

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

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

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

+ type AWSSQSSourceReceiveOptions struct

+ VisibilityTimeout *apis.Duration

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

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

+ type AWSSQSSourceSpec struct

+ ARN apis.ARN

+ Credentials AWSSecurityCredentials

+ ReceiveOptions *AWSSQSSourceReceiveOptions

+ 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 AzureActivityLogsSource struct

+ Spec AzureActivityLogsSourceSpec

+ Status AzureActivityLogsSourceStatus

+ func (in *AzureActivityLogsSource) DeepCopy() *AzureActivityLogsSource

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

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

+ func (s *AzureActivityLogsSource) AsEventSource() string

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

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

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

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

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

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

+ type AzureActivityLogsSourceList struct

+ Items []AzureActivityLogsSource

+ func (in *AzureActivityLogsSourceList) DeepCopy() *AzureActivityLogsSourceList

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

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

+ type AzureActivityLogsSourceSpec struct

+ Auth AzureAuth

+ Categories []string

+ EventHubID EventHubResourceID

+ EventHubsSASPolicy *string

+ func (in *AzureActivityLogsSourceSpec) DeepCopy() *AzureActivityLogsSourceSpec

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

+ type AzureActivityLogsSourceStatus struct

+ func (in *AzureActivityLogsSourceStatus) DeepCopy() *AzureActivityLogsSourceStatus

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

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

+ func (s *AzureActivityLogsSourceStatus) MarkSubscribed()

+ type AzureAuth struct

+ SASToken *AzureSASToken

+ ServicePrincipal *AzureServicePrincipal

+ func (in *AzureAuth) DeepCopy() *AzureAuth

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

+ type AzureBlobStorageSource struct

+ Spec AzureBlobStorageSourceSpec

+ Status AzureBlobStorageSourceStatus

+ func (in *AzureBlobStorageSource) DeepCopy() *AzureBlobStorageSource

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

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

+ func (s *AzureBlobStorageSource) AsEventSource() string

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

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

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

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

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

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

+ type AzureBlobStorageSourceList struct

+ Items []AzureBlobStorageSource

+ func (in *AzureBlobStorageSourceList) DeepCopy() *AzureBlobStorageSourceList

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

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

+ type AzureBlobStorageSourceSpec struct

+ Auth AzureAuth

+ EventHubID EventHubResourceID

+ EventTypes []string

+ StorageAccountID StorageAccountResourceID

+ func (in *AzureBlobStorageSourceSpec) DeepCopy() *AzureBlobStorageSourceSpec

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

+ type AzureBlobStorageSourceStatus struct

+ EventHubID *EventHubResourceID

+ func (in *AzureBlobStorageSourceStatus) DeepCopy() *AzureBlobStorageSourceStatus

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

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

+ func (s *AzureBlobStorageSourceStatus) MarkSubscribed()

+ type AzureEventGridSource struct

+ Spec AzureEventGridSourceSpec

+ Status AzureEventGridSourceStatus

+ func (in *AzureEventGridSource) DeepCopy() *AzureEventGridSource

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

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

+ func (s *AzureEventGridSource) AsEventSource() string

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

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

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

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

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

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

+ type AzureEventGridSourceList struct

+ Items []AzureEventGridSource

+ func (in *AzureEventGridSourceList) DeepCopy() *AzureEventGridSourceList

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

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

+ type AzureEventGridSourceSpec struct

+ Auth AzureAuth

+ EventHubID EventHubResourceID

+ EventTypes []string

+ Scope AzureResourceID

+ func (in *AzureEventGridSourceSpec) DeepCopy() *AzureEventGridSourceSpec

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

+ type AzureEventGridSourceStatus struct

+ EventHubID *EventHubResourceID

+ EventSubscriptionID *AzureResourceID

+ func (in *AzureEventGridSourceStatus) DeepCopy() *AzureEventGridSourceStatus

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

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

+ func (s *AzureEventGridSourceStatus) MarkSubscribed()

+ type AzureEventHubSource struct

+ Spec AzureEventHubSourceSpec

+ Status EventSourceStatus

+ func (in *AzureEventHubSource) DeepCopy() *AzureEventHubSource

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

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

+ func (s *AzureEventHubSource) AsEventSource() string

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

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

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

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

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

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

+ type AzureEventHubSourceList struct

+ Items []AzureEventHubSource

+ func (in *AzureEventHubSourceList) DeepCopy() *AzureEventHubSourceList

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

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

+ type AzureEventHubSourceSpec struct

+ Auth AzureAuth

+ EventHubID EventHubResourceID

+ func (in *AzureEventHubSourceSpec) DeepCopy() *AzureEventHubSourceSpec

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

+ type AzureIOTHubSource struct

+ Spec AzureIOTHubSourceSpec

+ Status AzureIOTHubSourceStatus

+ func (in *AzureIOTHubSource) DeepCopy() *AzureIOTHubSource

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

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

+ func (s *AzureIOTHubSource) AsEventSource() string

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

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

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

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

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

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

+ type AzureIOTHubSourceList struct

+ Items []AzureIOTHubSource

+ func (in *AzureIOTHubSourceList) DeepCopy() *AzureIOTHubSourceList

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

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

+ type AzureIOTHubSourceSpec struct

+ Auth AzureAuth

+ func (in *AzureIOTHubSourceSpec) DeepCopy() *AzureIOTHubSourceSpec

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

+ type AzureIOTHubSourceStatus struct

+ func (in *AzureIOTHubSourceStatus) DeepCopy() *AzureIOTHubSourceStatus

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

+ type AzureQueueStorageSource struct

+ Spec AzureQueueStorageSourceSpec

+ Status EventSourceStatus

+ func (in *AzureQueueStorageSource) DeepCopy() *AzureQueueStorageSource

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

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

+ func (s *AzureQueueStorageSource) AsEventSource() string

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

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

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

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

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

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

+ type AzureQueueStorageSourceList struct

+ Items []AzureQueueStorageSource

+ func (in *AzureQueueStorageSourceList) DeepCopy() *AzureQueueStorageSourceList

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

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

+ type AzureQueueStorageSourceSpec struct

+ AccountKey ValueFromField

+ AccountName string

+ QueueName string

+ func (in *AzureQueueStorageSourceSpec) DeepCopy() *AzureQueueStorageSourceSpec

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

+ type AzureResourceID struct

+ ResourceGroup string

+ ResourceName string

+ ResourceProvider string

+ ResourceType string

+ SubscriptionID string

+ func (in *AzureResourceID) DeepCopy() *AzureResourceID

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

+ func (rID *AzureResourceID) String() string

+ func (rID *AzureResourceID) UnmarshalJSON(data []byte) error

+ func (rID AzureResourceID) MarshalJSON() ([]byte, error)

+ type AzureSASToken struct

+ ConnectionString ValueFromField

+ KeyName ValueFromField

+ KeyValue ValueFromField

+ func (in *AzureSASToken) DeepCopy() *AzureSASToken

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

+ type AzureServiceBusQueueSource struct

+ Spec AzureServiceBusQueueSourceSpec

+ Status AzureServiceBusQueueSourceStatus

+ func (in *AzureServiceBusQueueSource) DeepCopy() *AzureServiceBusQueueSource

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

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

+ func (s *AzureServiceBusQueueSource) AsEventSource() string

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

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

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

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

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

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

+ type AzureServiceBusQueueSourceList struct

+ Items []AzureServiceBusQueueSource

+ func (in *AzureServiceBusQueueSourceList) DeepCopy() *AzureServiceBusQueueSourceList

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

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

+ type AzureServiceBusQueueSourceSpec struct

+ Auth AzureAuth

+ func (in *AzureServiceBusQueueSourceSpec) DeepCopy() *AzureServiceBusQueueSourceSpec

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

+ type AzureServiceBusQueueSourceStatus struct

+ func (in *AzureServiceBusQueueSourceStatus) DeepCopy() *AzureServiceBusQueueSourceStatus

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

+ type AzureServicePrincipal struct

+ ClientID ValueFromField

+ ClientSecret ValueFromField

+ TenantID ValueFromField

+ func (in *AzureServicePrincipal) DeepCopy() *AzureServicePrincipal

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

+ type EventHubResourceID struct

+ EventHub string

+ Namespace string

+ ResourceGroup string

+ SubscriptionID string

+ func (in *EventHubResourceID) DeepCopy() *EventHubResourceID

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

+ func (rID *EventHubResourceID) String() string

+ func (rID *EventHubResourceID) UnmarshalJSON(data []byte) error

+ func (rID EventHubResourceID) MarshalJSON() ([]byte, error)

+ type EventSource interface

+ AsEventSource func() string

+ GetEventTypes func() []string

+ GetSink func() *duckv1.Destination

+ GetStatusManager func() *EventSourceStatusManager

+ func SourceFromContext(ctx context.Context) EventSource

+ type EventSourceStatus struct

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

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

+ type EventSourceStatusManager struct

+ func (m *EventSourceStatusManager) MarkNoSink()

+ func (m *EventSourceStatusManager) MarkRBACNotBound()

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

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

+ type GCloudResourceName struct

+ Collection string

+ Project string

+ Resource string

+ func (in *GCloudResourceName) DeepCopy() *GCloudResourceName

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

+ func (n *GCloudResourceName) String() string

+ func (n *GCloudResourceName) UnmarshalJSON(data []byte) error

+ func (n GCloudResourceName) MarshalJSON() ([]byte, error)

+ type GoogleCloudAuditLogsSource struct

+ Spec GoogleCloudAuditLogsSourceSpec

+ Status GoogleCloudAuditLogsSourceStatus

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

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

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

+ func (in *GoogleCloudAuditLogsSource) DeepCopy() *GoogleCloudAuditLogsSource

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

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

+ func (s *GoogleCloudAuditLogsSource) AsEventSource() string

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

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

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

+ type GoogleCloudAuditLogsSourceList struct

+ Items []GoogleCloudAuditLogsSource

+ func (in *GoogleCloudAuditLogsSourceList) DeepCopy() *GoogleCloudAuditLogsSourceList

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

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

+ type GoogleCloudAuditLogsSourcePubSubSpec struct

+ Project *string

+ Topic *GCloudResourceName

+ func (in *GoogleCloudAuditLogsSourcePubSubSpec) DeepCopy() *GoogleCloudAuditLogsSourcePubSubSpec

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

+ type GoogleCloudAuditLogsSourceSpec struct

+ MethodName string

+ PubSub GoogleCloudAuditLogsSourcePubSubSpec

+ ResourceName *string

+ ServiceAccountKey ValueFromField

+ ServiceName string

+ func (in *GoogleCloudAuditLogsSourceSpec) DeepCopy() *GoogleCloudAuditLogsSourceSpec

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

+ type GoogleCloudAuditLogsSourceStatus struct

+ AuditLogsSink *string

+ Subscription *GCloudResourceName

+ Topic *GCloudResourceName

+ func (in *GoogleCloudAuditLogsSourceStatus) DeepCopy() *GoogleCloudAuditLogsSourceStatus

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

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

+ func (s *GoogleCloudAuditLogsSourceStatus) MarkSubscribed()

+ type GoogleCloudBillingSource struct

+ Spec GoogleCloudBillingSourceSpec

+ Status GoogleCloudBillingSourceStatus

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

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

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

+ func (in *GoogleCloudBillingSource) DeepCopy() *GoogleCloudBillingSource

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

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

+ func (s *GoogleCloudBillingSource) AsEventSource() string

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

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

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

+ type GoogleCloudBillingSourceList struct

+ Items []GoogleCloudBillingSource

+ func (in *GoogleCloudBillingSourceList) DeepCopy() *GoogleCloudBillingSourceList

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

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

+ type GoogleCloudBillingSourcePubSubSpec struct

+ Project *string

+ Topic *GCloudResourceName

+ func (in *GoogleCloudBillingSourcePubSubSpec) DeepCopy() *GoogleCloudBillingSourcePubSubSpec

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

+ type GoogleCloudBillingSourceSpec struct

+ BillingAccountID string

+ BudgetID string

+ PubSub GoogleCloudBillingSourcePubSubSpec

+ ServiceAccountKey ValueFromField

+ func (in *GoogleCloudBillingSourceSpec) DeepCopy() *GoogleCloudBillingSourceSpec

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

+ type GoogleCloudBillingSourceStatus struct

+ Subscription *GCloudResourceName

+ Topic *GCloudResourceName

+ func (in *GoogleCloudBillingSourceStatus) DeepCopy() *GoogleCloudBillingSourceStatus

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

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

+ func (s *GoogleCloudBillingSourceStatus) MarkSubscribed()

+ type GoogleCloudPubSubSource struct

+ Spec GoogleCloudPubSubSourceSpec

+ Status GoogleCloudPubSubSourceStatus

+ func (in *GoogleCloudPubSubSource) DeepCopy() *GoogleCloudPubSubSource

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

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

+ func (s *GoogleCloudPubSubSource) AsEventSource() string

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

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

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

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

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

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

+ type GoogleCloudPubSubSourceList struct

+ Items []GoogleCloudPubSubSource

+ func (in *GoogleCloudPubSubSourceList) DeepCopy() *GoogleCloudPubSubSourceList

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

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

+ type GoogleCloudPubSubSourceSpec struct

+ ServiceAccountKey ValueFromField

+ SubscriptionID *string

+ Topic GCloudResourceName

+ func (in *GoogleCloudPubSubSourceSpec) DeepCopy() *GoogleCloudPubSubSourceSpec

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

+ type GoogleCloudPubSubSourceStatus struct

+ Subscription *GCloudResourceName

+ func (in *GoogleCloudPubSubSourceStatus) DeepCopy() *GoogleCloudPubSubSourceStatus

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

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

+ func (s *GoogleCloudPubSubSourceStatus) MarkSubscribed()

+ type GoogleCloudRepositoriesSource struct

+ Spec GoogleCloudRepositoriesSourceSpec

+ Status GoogleCloudRepositoriesSourceStatus

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

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

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

+ func (in *GoogleCloudRepositoriesSource) DeepCopy() *GoogleCloudRepositoriesSource

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

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

+ func (s *GoogleCloudRepositoriesSource) AsEventSource() string

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

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

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

+ type GoogleCloudRepositoriesSourceList struct

+ Items []GoogleCloudRepositoriesSource

+ func (in *GoogleCloudRepositoriesSourceList) DeepCopy() *GoogleCloudRepositoriesSourceList

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

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

+ type GoogleCloudRepositoriesSourcePubSubSpec struct

+ Project *string

+ Topic *GCloudResourceName

+ func (in *GoogleCloudRepositoriesSourcePubSubSpec) DeepCopy() *GoogleCloudRepositoriesSourcePubSubSpec

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

+ type GoogleCloudRepositoriesSourceSpec struct

+ PubSub GoogleCloudRepositoriesSourcePubSubSpec

+ Repository GCloudResourceName

+ ServiceAccountKey ValueFromField

+ func (in *GoogleCloudRepositoriesSourceSpec) DeepCopy() *GoogleCloudRepositoriesSourceSpec

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

+ type GoogleCloudRepositoriesSourceStatus struct

+ Subscription *GCloudResourceName

+ Topic *GCloudResourceName

+ func (in *GoogleCloudRepositoriesSourceStatus) DeepCopy() *GoogleCloudRepositoriesSourceStatus

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

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

+ func (s *GoogleCloudRepositoriesSourceStatus) MarkSubscribed()

+ type GoogleCloudStorageSource struct

+ Spec GoogleCloudStorageSourceSpec

+ Status GoogleCloudStorageSourceStatus

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

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

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

+ func (in *GoogleCloudStorageSource) DeepCopy() *GoogleCloudStorageSource

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

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

+ func (s *GoogleCloudStorageSource) AsEventSource() string

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

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

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

+ type GoogleCloudStorageSourceList struct

+ Items []GoogleCloudStorageSource

+ func (in *GoogleCloudStorageSourceList) DeepCopy() *GoogleCloudStorageSourceList

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

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

+ type GoogleCloudStorageSourcePubSubSpec struct

+ Project *string

+ Topic *GCloudResourceName

+ func (in *GoogleCloudStorageSourcePubSubSpec) DeepCopy() *GoogleCloudStorageSourcePubSubSpec

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

+ type GoogleCloudStorageSourceSpec struct

+ Bucket string

+ EventTypes []string

+ PubSub GoogleCloudStorageSourcePubSubSpec

+ ServiceAccountKey ValueFromField

+ func (in *GoogleCloudStorageSourceSpec) DeepCopy() *GoogleCloudStorageSourceSpec

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

+ type GoogleCloudStorageSourceStatus struct

+ NotificationID *string

+ Subscription *GCloudResourceName

+ Topic *GCloudResourceName

+ func (in *GoogleCloudStorageSourceStatus) DeepCopy() *GoogleCloudStorageSourceStatus

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

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

+ func (s *GoogleCloudStorageSourceStatus) MarkSubscribed()

+ type HTTPPollerSource struct

+ Spec HTTPPollerSourceSpec

+ Status EventSourceStatus

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

+ func (in *HTTPPollerSource) DeepCopy() *HTTPPollerSource

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

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

+ func (s *HTTPPollerSource) AsEventSource() string

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

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

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

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

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

+ type HTTPPollerSourceList struct

+ Items []HTTPPollerSource

+ func (in *HTTPPollerSourceList) DeepCopy() *HTTPPollerSourceList

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

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

+ type HTTPPollerSourceSpec struct

+ BasicAuthPassword *ValueFromField

+ BasicAuthUsername *string

+ CACertificate *string

+ Endpoint apis.URL

+ EventSource *string

+ EventType string

+ Headers map[string]string

+ Interval tmapis.Duration

+ Method string

+ SkipVerify *bool

+ func (in *HTTPPollerSourceSpec) DeepCopy() *HTTPPollerSourceSpec

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

+ type OCIMetrics struct

+ Compartment *string

+ MetricsNamespace string

+ MetricsQuery string

+ Name string

+ func (in *OCIMetrics) DeepCopy() *OCIMetrics

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

+ type OCIMetricsDecodedList []OCIMetrics

+ func (in OCIMetricsDecodedList) DeepCopy() OCIMetricsDecodedList

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

+ func (o *OCIMetricsDecodedList) Decode(value string) error

+ type OCIMetricsSource struct

+ Spec OCIMetricsSourceSpec

+ Status EventSourceStatus

+ func (*OCIMetricsSource) GetConditionSet() pkgapis.ConditionSet

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

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

+ func (in *OCIMetricsSource) DeepCopy() *OCIMetricsSource

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

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

+ func (s *OCIMetricsSource) AsEventSource() string

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

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

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

+ type OCIMetricsSourceList struct

+ Items []OCIMetricsSource

+ func (in *OCIMetricsSourceList) DeepCopy() *OCIMetricsSourceList

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

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

+ type OCIMetricsSourceSpec struct

+ Metrics []OCIMetrics

+ OracleAPIPrivateKey ValueFromField

+ OracleAPIPrivateKeyFingerprint ValueFromField

+ OracleAPIPrivateKeyPassphrase ValueFromField

+ PollingFrequency *string

+ Region string

+ Tenancy string

+ User string

+ func (in *OCIMetricsSourceSpec) DeepCopy() *OCIMetricsSourceSpec

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

+ type SalesforceAuth struct

+ CertKey ValueFromField

+ ClientID string

+ Server string

+ User string

+ func (in *SalesforceAuth) DeepCopy() *SalesforceAuth

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

+ type SalesforceSource struct

+ Spec SalesforceSourceSpec

+ Status EventSourceStatus

+ func (in *SalesforceSource) DeepCopy() *SalesforceSource

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

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

+ func (s *SalesforceSource) AsEventSource() string

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

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

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

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

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

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

+ type SalesforceSourceList struct

+ Items []SalesforceSource

+ func (in *SalesforceSourceList) DeepCopy() *SalesforceSourceList

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

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

+ type SalesforceSourceSpec struct

+ APIVersion *string

+ Auth SalesforceAuth

+ Subscription SalesforceSubscription

+ func (in *SalesforceSourceSpec) DeepCopy() *SalesforceSourceSpec

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

+ type SalesforceSubscription struct

+ Channel string

+ ReplayID *int

+ func (in *SalesforceSubscription) DeepCopy() *SalesforceSubscription

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

+ type SlackSource struct

+ Spec SlackSourceSpec

+ Status EventSourceStatus

+ func (*SlackSource) GetConditionSet() pkgapis.ConditionSet

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

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

+ func (in *SlackSource) DeepCopy() *SlackSource

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

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

+ func (s *SlackSource) AsEventSource() string

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

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

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

+ type SlackSourceList struct

+ Items []SlackSource

+ func (in *SlackSourceList) DeepCopy() *SlackSourceList

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

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

+ type SlackSourceSpec struct

+ AppID *string

+ SigningSecret *ValueFromField

+ func (in *SlackSourceSpec) DeepCopy() *SlackSourceSpec

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

+ type StorageAccountResourceID struct

+ ResourceGroup string

+ StorageAccount string

+ SubscriptionID string

+ func (in *StorageAccountResourceID) DeepCopy() *StorageAccountResourceID

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

+ func (rID *StorageAccountResourceID) String() string

+ func (rID *StorageAccountResourceID) UnmarshalJSON(data []byte) error

+ func (rID StorageAccountResourceID) MarshalJSON() ([]byte, error)

+ type TwilioSource struct

+ Spec TwilioSourceSpec

+ Status EventSourceStatus

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

+ func (in *TwilioSource) DeepCopy() *TwilioSource

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

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

+ func (s *TwilioSource) AsEventSource() string

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

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

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

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

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

+ type TwilioSourceList struct

+ Items []TwilioSource

+ func (in *TwilioSourceList) DeepCopy() *TwilioSourceList

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

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

+ type TwilioSourceSpec struct

+ func (in *TwilioSourceSpec) DeepCopy() *TwilioSourceSpec

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

+ type ValueFromField struct

+ Value string

+ ValueFromSecret *corev1.SecretKeySelector

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

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

+ type WebhookSource struct

+ Spec WebhookSourceSpec

+ Status EventSourceStatus

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

+ func (in *WebhookSource) DeepCopy() *WebhookSource

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

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

+ func (s *WebhookSource) AsEventSource() string

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

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

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

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

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

+ type WebhookSourceList struct

+ Items []WebhookSource

+ func (in *WebhookSourceList) DeepCopy() *WebhookSourceList

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

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

+ type WebhookSourceSpec struct

+ BasicAuthPassword *ValueFromField

+ BasicAuthUsername *string

+ EventSource *string

+ EventType string

+ func (in *WebhookSourceSpec) DeepCopy() *WebhookSourceSpec

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

+ type ZendeskSource struct

+ Spec ZendeskSourceSpec

+ Status ZendeskSourceStatus

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

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

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

+ func (*ZendeskSource) IsMultiTenant() bool

+ func (in *ZendeskSource) DeepCopy() *ZendeskSource

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

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

+ func (s *ZendeskSource) AsEventSource() string

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

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

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

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

+ type ZendeskSourceList struct

+ Items []ZendeskSource

+ func (in *ZendeskSourceList) DeepCopy() *ZendeskSourceList

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

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

+ type ZendeskSourceSpec struct

+ Email string

+ Subdomain string

+ Token ValueFromField

+ WebhookPassword ValueFromField

+ WebhookUsername string

+ func (in *ZendeskSourceSpec) DeepCopy() *ZendeskSourceSpec

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

+ type ZendeskSourceStatus struct

+ func (in *ZendeskSourceStatus) DeepCopy() *ZendeskSourceStatus

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

+ func (s *ZendeskSourceStatus) MarkTargetNotSynced(reason, msg string)

+ func (s *ZendeskSourceStatus) MarkTargetSynced()

v1.10.1-rc1

Oct 7, 2021

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