v1alpha1

package

Go to main page

Versions in this module

v1

v1.10.0

Oct 1, 2021

Changes in this version

+ const AzureEventGridConditionSubscribed

+ const AzureServiceBusbGenericEventType

+ const GoogleCloudAuditLogsConditionSubscribed

+ const GoogleCloudAuditLogsGenericEventType

+ const GoogleCloudBillingConditionSubscribed

+ const GoogleCloudBillingGenericEventType

+ const GoogleCloudRepositoriesConditionSubscribed

+ const GoogleCloudRepositoriesGenericEventType

+ const GoogleCloudStorageConditionSubscribed

+ const GoogleCloudStorageGenericEventType

+ var GoogleCloudAuditLogsSourceConditionSet = NewEventSourceConditionSet(GoogleCloudAuditLogsConditionSubscribed)

+ var GoogleCloudBillingSourceConditionSet = NewEventSourceConditionSet(GoogleCloudBillingConditionSubscribed)

+ func AzureServiceBusQueueSourceName(namespace, name string) string

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

+ EventHubID EventHubResourceID

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

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

+ Topic *GCloudPubSubResourceName

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

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

+ Topic *GCloudPubSubResourceName

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

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

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

+ func (s *GoogleCloudBillingSourceStatus) 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 GoogleCloudStorageSourcePubSubSpec struct

+ Project *string

+ Topic *GCloudPubSubResourceName

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

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

type GoogleCloudStorageSourceSpec

+ Bucket string

+ EventTypes []string

+ PubSub GoogleCloudStorageSourcePubSubSpec

+ ServiceAccountKey ValueFromField

+ type GoogleCloudStorageSourceStatus struct

+ NotificationID *string

+ Subscription *GCloudPubSubResourceName

+ Topic *GCloudPubSubResourceName

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

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

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

+ func (s *GoogleCloudStorageSourceStatus) MarkSubscribed()

v1.9.0

Aug 30, 2021

Changes in this version

+ const AzureQueueStorageEventType

+ func AzureQueueStorageSourceName(namespace, name string) string

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

v1.8.0

Jul 30, 2021

v1.7.0

Jun 11, 2021

v1.6.0

Jun 1, 2021

v1.5.0

Apr 26, 2021

Changes in this version

+ const GCloudReasonAPIError

+ const GCloudReasonNoClient

+ const GoogleCloudPubSubConditionSubscribed

+ const GoogleCloudPubSubGenericEventType

+ type GCloudPubSubResourceName struct

+ Collection string

+ Project string

+ Resource string

+ func (in *GCloudPubSubResourceName) DeepCopy() *GCloudPubSubResourceName

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

+ func (n *GCloudPubSubResourceName) String() string

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

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

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

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

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

+ type GoogleCloudPubSubSourceStatus struct

+ Subscription *GCloudPubSubResourceName

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

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

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

+ func (s *GoogleCloudPubSubSourceStatus) MarkSubscribed()

v1.4.1

Apr 9, 2021

Changes in this version

+ const AzureActivityLogsConditionSubscribed

+ const AzureBlobStorageBlobCreatedEventType

+ const AzureBlobStorageBlobDeletedEventType

+ const AzureBlobStorageBlobRenamedEventType

+ const AzureBlobStorageConditionSubscribed

+ const AzureBlobStorageDirectoryCreatedEventType

+ const AzureBlobStorageDirectoryDeletedEventType

+ const AzureBlobStorageDirectoryRenamedEventType

+ const AzureReasonAPIError

+ const AzureReasonNoClient

+ const GoogleCloudStorageSourceGenericEventType

+ const ReasonFailedSync

+ func AzureEventHubSourceName(hubNamespace, hubName string) string

+ func GoogleCloudStorageSourceName(namespace, name string) string

type AzureActivityLogsSourceSpec

+ EventHubID EventHubResourceID

+ EventHubsSASPolicy *string

type AzureActivityLogsSourceStatus

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

+ func (s *AzureActivityLogsSourceStatus) MarkSubscribed()

type AzureBlobStorageSourceSpec

+ Auth AzureAuth

+ EventHubID EventHubResourceID

+ EventTypes []string

+ StorageAccountID StorageAccountResourceID

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

+ Spec GoogleCloudStorageSourceSpec

+ Status EventSourceStatus

+ 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) GetConditionSet() pkgapis.ConditionSet

+ func (s *GoogleCloudStorageSource) GetEventTypes() []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 GoogleCloudStorageSourceSpec struct

+ Credentials ValueFromField

+ Project string

+ Subscription string

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

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

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

v1.4.0

Mar 30, 2021

Changes in this version

+ func IsMultiTenant(src EventSource) bool

type EventSourceStatusManager

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

v1.3.0

Feb 8, 2021

Changes in this version

+ const ReasonRBACNotBound

type EventSourceStatusManager

+ func (m *EventSourceStatusManager) MarkRBACNotBound()

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

+ Metrics []OCIMetrics

v1.2.0

Jan 18, 2021

Changes in this version

+ const TwilioSourceGenericEventType

+ func TwilioSourceName(namespace, name string) string

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

v1.1.0

Nov 24, 2020

Changes in this version

type SalesforceSourceSpec

+ EventStore *esv1alpha1.EventStoreConnection

v1.0.0

Nov 11, 2020

v0

v0.7.0

Oct 15, 2020

Changes in this version

+ const OCIMetricsGenericEventType

+ func OCIGenerateEventSource(namespace, name string) string

+ 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

+ MetricsNamespace string

+ MetricsQuery string

+ OracleApiPrivateKey SecretValueFromSource

+ OracleApiPrivateKeyFingerprint SecretValueFromSource

+ OracleApiPrivateKeyPassphrase SecretValueFromSource

+ PollingFrequency *string

+ Region string

+ Tenancy string

+ User string

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

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

v0.6.0

Sep 14, 2020

Changes in this version

+ const AzureBlobStorageEventType

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

type AzureActivityLogsSource

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

+ type AzureBlobStorageSource struct

+ Spec AzureBlobStorageSourceSpec

+ Status EventSourceStatus

+ 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

+ AccountKey SecretValueFromSource

+ AccountName string

+ ContainerName string

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

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

type AzureEventHubSource

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

type EventSource

+ GetStatusManager func() *EventSourceStatusManager

+ type EventSourceStatusManager struct

+ func (m *EventSourceStatusManager) MarkNoSink()

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

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

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

+ type SalesforceAuth struct

+ CertKey SecretValueFromSource

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

+ SecretKeyRef *corev1.SecretKeySelector

+ func (in *SecretValueFromSource) DeepCopy() *SecretValueFromSource

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

v0.5.0

Aug 11, 2020

v0.4.1

Jul 25, 2020

Changes in this version

type AzureActivityLogsSource

+ func (s *AzureActivityLogsSource) AsEventSource() string

type AzureEventHubSource

+ func (s *AzureEventHubSource) AsEventSource() string

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

type EventSource

+ AsEventSource func() string

+ GetEventTypes func() []string

v0.1.0

Jul 14, 2020

Changes in this version

+ const AzureActivityLogsActivityLogEventType

+ const AzureActivityLogsConditionDiagnosticSettings

+ const AzureActivityLogsConditionReady

+ const AzureActivityLogsReasonFailedSync

+ const AzureEventHubGenericEventType

+ const ConditionDeployed

+ const ConditionReady

+ const ConditionSinkProvided

+ const ReasonSinkEmpty

+ const ReasonSinkNotFound

+ const ReasonUnavailable

+ var AddToScheme = SchemeBuilder.AddToScheme

+ var SchemeBuilder = runtime.NewSchemeBuilder(addKnownTypes)

+ var SchemeGroupVersion = schema.GroupVersion

+ func AzureEventType(service, eventType string) string

+ func EventType(service, eventType string) string

+ func Kind(kind string) schema.GroupKind

+ func Resource(resource string) schema.GroupResource

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

+ 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) GetConditionSet() apis.ConditionSet

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

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

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

+ func (s *AzureActivityLogsSource) GetSourceStatus() *EventSourceStatus

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

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

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

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

+ 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

+ EventHubName *string

+ EventHubsSASPolicyID EventHubsSASPolicyResourceID

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

+ func (s *AzureActivityLogsSourceStatus) MarkNoDiagnosticSettings(hasDiagSettings bool, msg string)

+ type AzureAuth struct

+ SASToken *AzureSASToken

+ ServicePrincipal *AzureServicePrincipal

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

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

+ 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) GetConditionSet() apis.ConditionSet

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

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

+ func (s *AzureEventHubSource) GetSourceStatus() *EventSourceStatus

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

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

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

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

+ 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

+ HubName string

+ HubNamespace string

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

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

+ func (s *AzureEventHubSourceSpec) ValidateSpec(_ context.Context) *apis.FieldError

+ type AzureSASToken struct

+ ConnectionString *string

+ KeyName *string

+ KeyValue *string

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

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

+ type AzureServicePrincipal struct

+ ClientID ValueFromField

+ ClientSecret ValueFromField

+ TenantID ValueFromField

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

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

+ type EventHubsSASPolicyResourceID struct

+ AuthorizationRule string

+ Namespace string

+ ResourceGroup string

+ SubscriptionID string

+ func (in *EventHubsSASPolicyResourceID) DeepCopy() *EventHubsSASPolicyResourceID

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

+ func (rID *EventHubsSASPolicyResourceID) String() string

+ func (rID *EventHubsSASPolicyResourceID) UnmarshalText(data []byte) error

+ func (rID EventHubsSASPolicyResourceID) MarshalText() ([]byte, error)

+ type EventSource interface

+ GetSink func() *duckv1.Destination

+ GetSourceStatus func() *EventSourceStatus

+ func SourceFromContext(ctx context.Context) EventSource

+ type EventSourceStatus struct

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

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

+ func (s *EventSourceStatus) InitializeConditions()

+ func (s *EventSourceStatus) MarkNoSink()

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

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

+ type ValueFromField struct

+ Value string

+ ValueFromSecret *corev1.SecretKeySelector

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

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

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