v1alpha1

package
v1.10.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 1, 2021 License: Apache-2.0 Imports: 23 Imported by: 0

Documentation

Overview

Package v1alpha1 contains API Schema definitions for the sources/v1alpha1 API group. +k8s:deepcopy-gen=package +groupName=sources.triggermesh.io

Index

Constants

View Source 
const (
	// AzureReasonNoClient is set on a status condition when an Azure API client cannot be obtained.
	AzureReasonNoClient = "NoClient"
	// AzureReasonAPIError is set on a status condition when an Azure API returns an error.
	AzureReasonAPIError = "APIError"
)

Reasons for status conditions

View Source 
const (
	AzureBlobStorageBlobCreatedEventType = "Microsoft.Storage.BlobCreated"
	AzureBlobStorageBlobDeletedEventType = "Microsoft.Storage.BlobDeleted"
)

Default event types. This list is non-exhaustive, see AzureBlobStorageSourceSpec.

View Source 
const (
	// ConditionReady has status True when the source is ready to send events.
	ConditionReady = apis.ConditionReady
	// ConditionSinkProvided has status True when the source has been configured with a sink target.
	ConditionSinkProvided apis.ConditionType = "SinkProvided"
	// ConditionDeployed has status True when the source's adapter is up and running.
	ConditionDeployed apis.ConditionType = "Deployed"
)

Status conditions

View Source 
const (
	// ReasonSinkNotFound is set on a SinkProvided condition when a sink does not exist.
	ReasonSinkNotFound = "SinkNotFound"
	// ReasonSinkEmpty is set on a SinkProvided condition when a sink URI is empty.
	ReasonSinkEmpty = "EmptySinkURI"

	// ReasonRBACNotBound is set on a Deployed condition when an adapter's
	// ServiceAccount cannot be bound.
	ReasonRBACNotBound = "RBACNotBound"
	// ReasonUnavailable is set on a Deployed condition when an adapter in unavailable.
	ReasonUnavailable = "AdapterUnavailable"

	// ReasonFailedSync is set on a status condition when some external resource can not be reconciled.
	ReasonFailedSync = "FailedSync"
)

Reasons for status conditions

View Source 
const (
	// GCloudReasonNoClient is set on a status condition when a Google Cloud API client cannot be obtained.
	GCloudReasonNoClient = "NoClient"
	// GCloudReasonAPIError is set on a status condition when a Google Cloud API returns an error.
	GCloudReasonAPIError = "APIError"
)

Reasons for status conditions

View Source 
const (
	// https://docs.microsoft.com/en-us/azure/azure-monitor/platform/activity-log-schema
	AzureActivityLogsActivityLogEventType = "activity-log"
)

Supported event types

View Source 
const (
	// AzureActivityLogsConditionSubscribed has status True when Diagnostic Settings are successfully registered for
	// the Azure subscription.
	AzureActivityLogsConditionSubscribed apis.ConditionType = "Subscribed"
)

Status conditions

View Source 
const (
	// AzureBlobStorageConditionSubscribed has status True when an event subscription exists for the source.
	AzureBlobStorageConditionSubscribed apis.ConditionType = "Subscribed"
)

Status conditions

View Source 
const (
	// AzureEventGridConditionSubscribed has status True when an event subscription exists for the source.
	AzureEventGridConditionSubscribed apis.ConditionType = "Subscribed"
)

Status conditions

View Source 
const (
	AzureEventHubGenericEventType = "message"
)

Supported event types

View Source 
const (
	AzureQueueStorageEventType = "com.microsoft.azure.queuestorage"
)

Supported event types

View Source 
const (
	AzureServiceBusbGenericEventType = "message"
)

Supported event types

View Source 
const (
	// GoogleCloudAuditLogsConditionSubscribed has status True when the source has subscribed to a topic.
	GoogleCloudAuditLogsConditionSubscribed apis.ConditionType = "Subscribed"
)

Status conditions

View Source 
const (
	GoogleCloudAuditLogsGenericEventType = "com.google.cloud.auditlogs.notification"
)

Supported event types

View Source 
const (
	// GoogleCloudBillingConditionSubscribed has status True when the source has subscribed to a topic.
	GoogleCloudBillingConditionSubscribed apis.ConditionType = "Subscribed"
)

Status conditions

View Source 
const (
	GoogleCloudBillingGenericEventType = "com.google.cloud.billing.notification"
)

Supported event types

View Source 
const (
	// GoogleCloudPubSubConditionSubscribed has status True when the source has subscribed to a topic.
	GoogleCloudPubSubConditionSubscribed apis.ConditionType = "Subscribed"
)

Status conditions

View Source 
const (
	GoogleCloudPubSubGenericEventType = "com.google.cloud.pubsub.message"
)

Supported event types

View Source 
const (
	// GoogleCloudRepositoriesConditionSubscribed has status True when the source has subscribed to a topic.
	GoogleCloudRepositoriesConditionSubscribed apis.ConditionType = "Subscribed"
)

Status conditions

View Source 
const (
	GoogleCloudRepositoriesGenericEventType = "com.google.cloud.repositories.notification"
)

Supported event types

View Source 
const (
	// GoogleCloudStorageConditionSubscribed has status True when the source has subscribed to a topic.
	GoogleCloudStorageConditionSubscribed apis.ConditionType = "Subscribed"
)

Status conditions

View Source 
const (
	GoogleCloudStorageGenericEventType = "com.google.cloud.storage.notification"
)

Supported event types

View Source 
const (
	OCIMetricsGenericEventType = "com.oracle.cloud.monitoring"
)

Supported event types

View Source 
const (
	TwilioSourceGenericEventType = "com.triggermesh.twilio.sms"
)

Variables

View Source 
var (
	// SchemeGroupVersion contains the group and version used to register types for this custom API.
	SchemeGroupVersion = schema.GroupVersion{Group: sources.GroupName, Version: "v1alpha1"}
	// SchemeBuilder creates a Scheme builder that is used to register types for this custom API.
	SchemeBuilder = runtime.NewSchemeBuilder(addKnownTypes)
	// AddToScheme registers the types stored in SchemeBuilder.
	AddToScheme = SchemeBuilder.AddToScheme
)
View Source 
var GoogleCloudAuditLogsSourceConditionSet = NewEventSourceConditionSet(
	GoogleCloudAuditLogsConditionSubscribed,
)

GoogleCloudAuditLogsSourceConditionSet is a set of conditions for GoogleCloudAuditLogsSource objects.

View Source 
var GoogleCloudBillingSourceConditionSet = NewEventSourceConditionSet(
	GoogleCloudBillingConditionSubscribed,
)

GoogleCloudBillingSourceConditionSet is a set of conditions for GoogleCloudBillingSource objects.

Functions

func AzureEventType 

func AzureEventType(service, eventType string) string

AzureEventType returns an event type in a format suitable for usage as a CloudEvent type attribute.

func AzureQueueStorageSourceName added in v1.9.0 

func AzureQueueStorageSourceName(namespace, name string) string

AzureQueueStorageSourceName returns a unique reference to the source suitable for use as as a CloudEvent source.

func AzureServiceBusQueueSourceName added in v1.10.0 

func AzureServiceBusQueueSourceName(namespace, name string) string

AzureServiceBusQueueSourceName returns a unique reference to the source suitable for use as as a CloudEvent source.

func EventType 

func EventType(service, eventType string) string

EventType returns an event type in a format suitable for usage as a CloudEvent type attribute.

func IsMultiTenant added in v1.4.0 

func IsMultiTenant(src EventSource) bool

IsMultiTenant returns whether the given source type is multi-tenant.

func Kind 

func Kind(kind string) schema.GroupKind

Kind takes an unqualified kind and returns back a Group qualified GroupKind.

func NewEventSourceConditionSet added in v0.6.0 

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

NewEventSourceConditionSet returns a set of status conditions for an event source. Default conditions can be augmented by passing condition types as function arguments.

func OCIGenerateEventSource added in v0.7.0 

func OCIGenerateEventSource(namespace, name string) string

OCIGenerateEventSource generate the event source name to be used in the adapter

func Resource 

func Resource(resource string) schema.GroupResource

Resource takes an unqualified resource and returns a Group qualified GroupResource.

func TwilioSourceName added in v1.2.0 

func TwilioSourceName(namespace, name string) string

TwilioSourceName returns a unique reference to the source suitable for use as as a CloudEvent source.

func WithSource 

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

WithSource returns a copy of the parent context in which the value associated with the source key is the given event source.

Types

type AzureActivityLogsSource 

type AzureActivityLogsSource struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   AzureActivityLogsSourceSpec   `json:"spec,omitempty"`
	Status AzureActivityLogsSourceStatus `json:"status,omitempty"`
}

AzureActivityLogsSource is the Schema for the event source.

func (*AzureActivityLogsSource) AsEventSource added in v0.4.1 

func (s *AzureActivityLogsSource) AsEventSource() string

AsEventSource implements EventSource.

func (*AzureActivityLogsSource) DeepCopy 

func (in *AzureActivityLogsSource) DeepCopy() *AzureActivityLogsSource

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AzureActivityLogsSource.

func (*AzureActivityLogsSource) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*AzureActivityLogsSource) DeepCopyObject 

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*AzureActivityLogsSource) GetConditionSet 

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

GetConditionSet implements duckv1.KRShaped.

func (*AzureActivityLogsSource) GetEventTypes 

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

GetEventTypes returns the event types generated by the source.

func (*AzureActivityLogsSource) GetGroupVersionKind 

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

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*AzureActivityLogsSource) GetSink 

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

GetSink implements EventSource.

func (*AzureActivityLogsSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*AzureActivityLogsSource) GetStatusManager added in v0.6.0 

func (s *AzureActivityLogsSource) GetStatusManager() *EventSourceStatusManager

GetStatusManager implements EventSource.

type AzureActivityLogsSourceList 

type AzureActivityLogsSourceList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []AzureActivityLogsSource `json:"items"`
}

AzureActivityLogsSourceList contains a list of event sources.

func (*AzureActivityLogsSourceList) DeepCopy 

func (in *AzureActivityLogsSourceList) DeepCopy() *AzureActivityLogsSourceList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AzureActivityLogsSourceList.

func (*AzureActivityLogsSourceList) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*AzureActivityLogsSourceList) DeepCopyObject 

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type AzureActivityLogsSourceSpec 

type AzureActivityLogsSourceSpec struct {
	duckv1.SourceSpec `json:",inline"`

	// Resource ID of either the Event Hubs instance or Event Hubs namespace to send activity logs to.
	// This resource ID also conveniently contains the ID of the subscription which activity logs are to be
	// subscribed to.
	//
	// If the resource ID represents an Event Hubs namespace, Azure automatically creates an Event Hub with the name
	// 'insights-activity-logs' inside that namespace. Otherwise, the user-provided Event Hub is used.
	//
	// Accepted formats:
	// * /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.EventHub/namespaces/{namespaceName}/eventHubs/{eventHubName}
	// * /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.EventHub/namespaces/{namespaceName}
	EventHubID EventHubResourceID `json:"eventHubID"`

	// Name of a SAS policy with Manage permissions inside the Event Hubs namespace referenced in the EventHubID
	// field.
	//
	// Defaults to "RootManageSharedAccessKey".
	//
	// References:
	//  * https://docs.microsoft.com/en-us/rest/api/eventhub/2017-04-01/authorization%20rules%20-%20namespaces/getauthorizationrule
	//  * https://docs.microsoft.com/en-us/azure/event-hubs/authorize-access-shared-access-signature
	//
	// +optional
	EventHubsSASPolicy *string `json:"eventHubsSASPolicy,omitempty"`

	// Categories of Activity Logs to collect.
	//
	// All available categories are selected when this attribute is empty.
	// https://docs.microsoft.com/en-us/azure/azure-monitor/platform/activity-log-schema#categories
	//
	// +optional
	Categories []string `json:"categories,omitempty"`

	// Authentication method to interact with the Azure Monitor REST API.
	// This event source only supports the ServicePrincipal authentication.
	Auth AzureAuth `json:"auth"`
}

AzureActivityLogsSourceSpec defines the desired state of the event source.

func (*AzureActivityLogsSourceSpec) DeepCopy 

func (in *AzureActivityLogsSourceSpec) DeepCopy() *AzureActivityLogsSourceSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AzureActivityLogsSourceSpec.

func (*AzureActivityLogsSourceSpec) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type AzureActivityLogsSourceStatus 

type AzureActivityLogsSourceStatus struct {
	EventSourceStatus `json:",inline"`
}

AzureActivityLogsSourceStatus defines the observed state of the event source.

func (*AzureActivityLogsSourceStatus) DeepCopy 

func (in *AzureActivityLogsSourceStatus) DeepCopy() *AzureActivityLogsSourceStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AzureActivityLogsSourceStatus.

func (*AzureActivityLogsSourceStatus) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*AzureActivityLogsSourceStatus) MarkNotSubscribed added in v1.4.1 

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

MarkNotSubscribed sets the Subscribed condition to False with the given reason and message.

func (*AzureActivityLogsSourceStatus) MarkSubscribed added in v1.4.1 

func (s *AzureActivityLogsSourceStatus) MarkSubscribed()

MarkSubscribed sets the Subscribed condition to True.

type AzureAuth 

type AzureAuth struct {
	// Service principals provide a way to create a non-interactive account
	// associated with your identity to which you grant only the privileges
	// your app needs to run.
	// See https://docs.microsoft.com/en-us/azure/active-directory/develop/app-objects-and-service-principals
	ServicePrincipal *AzureServicePrincipal `json:"servicePrincipal,omitempty"`

	// A shared access signature (SAS) provides secure delegated access to
	// resources in a storage account.
	// See https://docs.microsoft.com/en-us/azure/storage/common/storage-sas-overview
	SASToken *AzureSASToken `json:"sasToken,omitempty"`
}

AzureAuth contains multiple authentication methods for Azure services.

func (*AzureAuth) DeepCopy 

func (in *AzureAuth) DeepCopy() *AzureAuth

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AzureAuth.

func (*AzureAuth) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type AzureBlobStorageSource added in v0.6.0 

type AzureBlobStorageSource struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   AzureBlobStorageSourceSpec   `json:"spec,omitempty"`
	Status AzureBlobStorageSourceStatus `json:"status,omitempty"`
}

AzureBlobStorageSource is the Schema for the event source.

func (*AzureBlobStorageSource) AsEventSource added in v0.6.0 

func (s *AzureBlobStorageSource) AsEventSource() string

AsEventSource implements EventSource.

func (*AzureBlobStorageSource) DeepCopy added in v0.6.0 

func (in *AzureBlobStorageSource) DeepCopy() *AzureBlobStorageSource

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AzureBlobStorageSource.

func (*AzureBlobStorageSource) DeepCopyInto added in v0.6.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*AzureBlobStorageSource) DeepCopyObject added in v0.6.0 

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*AzureBlobStorageSource) GetConditionSet added in v0.6.0 

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

GetConditionSet implements duckv1.KRShaped.

func (*AzureBlobStorageSource) GetEventTypes added in v0.6.0 

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

GetEventTypes returns the event types generated by the source.

func (*AzureBlobStorageSource) GetGroupVersionKind added in v0.6.0 

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

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*AzureBlobStorageSource) GetSink added in v0.6.0 

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

GetSink implements EventSource.

func (*AzureBlobStorageSource) GetStatus added in v0.6.0 

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

GetStatus implements duckv1.KRShaped.

func (*AzureBlobStorageSource) GetStatusManager added in v0.6.0 

func (s *AzureBlobStorageSource) GetStatusManager() *EventSourceStatusManager

GetStatusManager implements EventSource.

type AzureBlobStorageSourceList added in v0.6.0 

type AzureBlobStorageSourceList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []AzureBlobStorageSource `json:"items"`
}

AzureBlobStorageSourceList contains a list of event sources.

func (*AzureBlobStorageSourceList) DeepCopy added in v0.6.0 

func (in *AzureBlobStorageSourceList) DeepCopy() *AzureBlobStorageSourceList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AzureBlobStorageSourceList.

func (*AzureBlobStorageSourceList) DeepCopyInto added in v0.6.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*AzureBlobStorageSourceList) DeepCopyObject added in v0.6.0 

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type AzureBlobStorageSourceSpec added in v0.6.0 

type AzureBlobStorageSourceSpec struct {
	duckv1.SourceSpec `json:",inline"`

	// Resource ID of the Storage Account to receive events for.
	//
	// Format: /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.Storage/storageAccounts/{storageAccountName}
	//
	// Besides the Storage Account name itself, the resource ID contains
	// the subscription ID and resource group name which all together
	// uniquely identify the Storage Account within Azure.
	StorageAccountID StorageAccountResourceID `json:"storageAccountID"`

	// Resource ID of either the Event Hubs instance or Event Hubs
	// namespace to send events to.
	//
	// Accepted formats:
	// - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.EventHub/namespaces/{namespaceName}/eventHubs/{eventHubName}
	// - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.EventHub/namespaces/{namespaceName}
	//
	// If the resource ID represents an Event Hubs namespace, an Event Hubs
	// instance is created on behalf of the user inside that namespace.
	// Otherwise, the user-provided Event Hub is used.
	EventHubID EventHubResourceID `json:"eventHubID"`

	// Types of events to subscribe to.
	//
	// The list of available event types can be found at
	// https://docs.microsoft.com/en-us/azure/event-grid/event-schema-blob-storage
	//
	// When this attribute is not set, the source automatically subscribes
	// to the following event types:
	// - Microsoft.Storage.BlobCreated
	// - Microsoft.Storage.BlobDeleted
	//
	// +optional
	EventTypes []string `json:"eventTypes,omitempty"`

	// Authentication method to interact with the Azure REST API.
	// This event source only supports the ServicePrincipal authentication.
	Auth AzureAuth `json:"auth"`
}

AzureBlobStorageSourceSpec defines the desired state of the event source.

func (*AzureBlobStorageSourceSpec) DeepCopy added in v0.6.0 

func (in *AzureBlobStorageSourceSpec) DeepCopy() *AzureBlobStorageSourceSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AzureBlobStorageSourceSpec.

func (*AzureBlobStorageSourceSpec) DeepCopyInto added in v0.6.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type AzureBlobStorageSourceStatus added in v1.4.1 

type AzureBlobStorageSourceStatus struct {
	EventSourceStatus `json:",inline"`

	// Resource ID of the Event Hubs instance that is currently receiving
	// events from the Azure Event Grid subscription.
	EventHubID *EventHubResourceID `json:"eventHubID,omitempty"`
}

AzureBlobStorageSourceStatus defines the observed state of the event source.

func (*AzureBlobStorageSourceStatus) DeepCopy added in v1.4.1 

func (in *AzureBlobStorageSourceStatus) DeepCopy() *AzureBlobStorageSourceStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AzureBlobStorageSourceStatus.

func (*AzureBlobStorageSourceStatus) DeepCopyInto added in v1.4.1 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*AzureBlobStorageSourceStatus) MarkNotSubscribed added in v1.4.1 

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

MarkNotSubscribed sets the Subscribed condition to False with the given reason and message.

func (*AzureBlobStorageSourceStatus) MarkSubscribed added in v1.4.1 

func (s *AzureBlobStorageSourceStatus) MarkSubscribed()

MarkSubscribed sets the Subscribed condition to True.

type AzureEventGridSource added in v1.10.0 

type AzureEventGridSource struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   AzureEventGridSourceSpec   `json:"spec,omitempty"`
	Status AzureEventGridSourceStatus `json:"status,omitempty"`
}

AzureEventGridSource is the Schema for the event source.

func (*AzureEventGridSource) AsEventSource added in v1.10.0 

func (s *AzureEventGridSource) AsEventSource() string

AsEventSource implements EventSource.

func (*AzureEventGridSource) DeepCopy added in v1.10.0 

func (in *AzureEventGridSource) DeepCopy() *AzureEventGridSource

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AzureEventGridSource.

func (*AzureEventGridSource) DeepCopyInto added in v1.10.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*AzureEventGridSource) DeepCopyObject added in v1.10.0 

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*AzureEventGridSource) GetConditionSet added in v1.10.0 

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

GetConditionSet implements duckv1.KRShaped.

func (*AzureEventGridSource) GetEventTypes added in v1.10.0 

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

GetEventTypes returns the event types generated by the source.

func (*AzureEventGridSource) GetGroupVersionKind added in v1.10.0 

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

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*AzureEventGridSource) GetSink added in v1.10.0 

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

GetSink implements EventSource.

func (*AzureEventGridSource) GetStatus added in v1.10.0 

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

GetStatus implements duckv1.KRShaped.

func (*AzureEventGridSource) GetStatusManager added in v1.10.0 

func (s *AzureEventGridSource) GetStatusManager() *EventSourceStatusManager

GetStatusManager implements EventSource.

type AzureEventGridSourceList added in v1.10.0 

type AzureEventGridSourceList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []AzureEventGridSource `json:"items"`
}

AzureEventGridSourceList contains a list of event sources.

func (*AzureEventGridSourceList) DeepCopy added in v1.10.0 

func (in *AzureEventGridSourceList) DeepCopy() *AzureEventGridSourceList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AzureEventGridSourceList.

func (*AzureEventGridSourceList) DeepCopyInto added in v1.10.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*AzureEventGridSourceList) DeepCopyObject added in v1.10.0 

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type AzureEventGridSourceSpec added in v1.10.0 

type AzureEventGridSourceSpec struct {
	duckv1.SourceSpec `json:",inline"`

	// The resource ID the event subscription applies to.
	//
	// Can be
	// - an Azure subscription:
	//   /subscriptions/{subscriptionId}
	// - a resource group:
	//   /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}
	// - a top-level resource from a resource provider (including Event Grid topic):
	//   /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName}
	Scope AzureResourceID `json:"scope"`

	// Types of events to subscribe to.
	//
	// If not specified, Azure automatically selects all available event types for the provided Scope.
	//
	// For a list of all available event types, please refer to the list of
	// Azure services that support system topics at
	// https://docs.microsoft.com/en-us/azure/event-grid/system-topics
	//
	// +optional
	EventTypes []string `json:"eventTypes,omitempty"`

	// Resource ID of either the Event Hubs instance or Event Hubs
	// namespace to send events to.
	//
	// Accepted formats:
	// - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.EventHub/namespaces/{namespaceName}/eventHubs/{eventHubName}
	// - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.EventHub/namespaces/{namespaceName}
	//
	// If the resource ID represents an Event Hubs namespace, an Event Hubs
	// instance is created on behalf of the user inside that namespace.
	// Otherwise, the user-provided Event Hub is used.
	EventHubID EventHubResourceID `json:"eventHubID"`

	// Authentication method to interact with the Azure REST API.
	// This event source only supports the ServicePrincipal authentication.
	Auth AzureAuth `json:"auth"`
}

AzureEventGridSourceSpec defines the desired state of the event source.

func (*AzureEventGridSourceSpec) DeepCopy added in v1.10.0 

func (in *AzureEventGridSourceSpec) DeepCopy() *AzureEventGridSourceSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AzureEventGridSourceSpec.

func (*AzureEventGridSourceSpec) DeepCopyInto added in v1.10.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type AzureEventGridSourceStatus added in v1.10.0 

type AzureEventGridSourceStatus struct {
	EventSourceStatus `json:",inline"`

	// Resource ID of the Event Grid subscription that is currently
	// registered for the user-provided scope.
	EventSubscriptionID *AzureResourceID `json:"eventSubscriptionID,omitempty"`

	// Resource ID of the Event Hubs instance that is currently receiving
	// events from the Azure Event Grid subscription.
	EventHubID *EventHubResourceID `json:"eventHubID,omitempty"`
}

AzureEventGridSourceStatus defines the observed state of the event source.

func (*AzureEventGridSourceStatus) DeepCopy added in v1.10.0 

func (in *AzureEventGridSourceStatus) DeepCopy() *AzureEventGridSourceStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AzureEventGridSourceStatus.

func (*AzureEventGridSourceStatus) DeepCopyInto added in v1.10.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*AzureEventGridSourceStatus) MarkNotSubscribed added in v1.10.0 

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

MarkNotSubscribed sets the Subscribed condition to False with the given reason and message.

func (*AzureEventGridSourceStatus) MarkSubscribed added in v1.10.0 

func (s *AzureEventGridSourceStatus) MarkSubscribed()

MarkSubscribed sets the Subscribed condition to True.

type AzureEventHubSource 

type AzureEventHubSource struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   AzureEventHubSourceSpec `json:"spec,omitempty"`
	Status EventSourceStatus       `json:"status,omitempty"`
}

AzureEventHubSource is the Schema for the event source.

func (*AzureEventHubSource) AsEventSource added in v0.4.1 

func (s *AzureEventHubSource) AsEventSource() string

AsEventSource implements EventSource.

func (*AzureEventHubSource) DeepCopy 

func (in *AzureEventHubSource) DeepCopy() *AzureEventHubSource

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AzureEventHubSource.

func (*AzureEventHubSource) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*AzureEventHubSource) DeepCopyObject 

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*AzureEventHubSource) GetConditionSet 

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

GetConditionSet implements duckv1.KRShaped.

func (*AzureEventHubSource) GetEventTypes added in v0.4.1 

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

GetEventTypes returns the event types generated by the source.

func (*AzureEventHubSource) GetGroupVersionKind 

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

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*AzureEventHubSource) GetSink 

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

GetSink implements EventSource.

func (*AzureEventHubSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*AzureEventHubSource) GetStatusManager added in v0.6.0 

func (s *AzureEventHubSource) GetStatusManager() *EventSourceStatusManager

GetStatusManager implements EventSource.

type AzureEventHubSourceList 

type AzureEventHubSourceList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []AzureEventHubSource `json:"items"`
}

AzureEventHubSourceList contains a list of event sources.

func (*AzureEventHubSourceList) DeepCopy 

func (in *AzureEventHubSourceList) DeepCopy() *AzureEventHubSourceList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AzureEventHubSourceList.

func (*AzureEventHubSourceList) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*AzureEventHubSourceList) DeepCopyObject 

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type AzureEventHubSourceSpec 

type AzureEventHubSourceSpec struct {
	duckv1.SourceSpec `json:",inline"`

	// Resource ID of the Event Hubs instance.
	//
	// Expected format:
	// - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.EventHub/namespaces/{namespaceName}/eventhubs/{eventHubName}
	EventHubID EventHubResourceID `json:"eventHubID"`

	// Authentication method to interact with the Azure Event Hubs API.
	Auth AzureAuth `json:"auth"`
}

AzureEventHubSourceSpec defines the desired state of the event source.

func (*AzureEventHubSourceSpec) DeepCopy 

func (in *AzureEventHubSourceSpec) DeepCopy() *AzureEventHubSourceSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AzureEventHubSourceSpec.

func (*AzureEventHubSourceSpec) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type AzureQueueStorageSource added in v1.9.0 

type AzureQueueStorageSource struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   AzureQueueStorageSourceSpec `json:"spec,omitempty"`
	Status EventSourceStatus           `json:"status,omitempty"`
}

AzureQueueStorageSource is the Schema for the event source.

func (*AzureQueueStorageSource) AsEventSource added in v1.9.0 

func (s *AzureQueueStorageSource) AsEventSource() string

AsEventSource implements EventSource.

func (*AzureQueueStorageSource) DeepCopy added in v1.9.0 

func (in *AzureQueueStorageSource) DeepCopy() *AzureQueueStorageSource

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AzureQueueStorageSource.

func (*AzureQueueStorageSource) DeepCopyInto added in v1.9.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*AzureQueueStorageSource) DeepCopyObject added in v1.9.0 

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*AzureQueueStorageSource) GetConditionSet added in v1.9.0 

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

GetConditionSet implements duckv1.KRShaped.

func (*AzureQueueStorageSource) GetEventTypes added in v1.9.0 

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

GetEventTypes returns the event types generated by the source.

func (*AzureQueueStorageSource) GetGroupVersionKind added in v1.9.0 

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

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*AzureQueueStorageSource) GetSink added in v1.9.0 

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

GetSink implements EventSource.

func (*AzureQueueStorageSource) GetStatus added in v1.9.0 

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

GetStatus implements duckv1.KRShaped.

func (*AzureQueueStorageSource) GetStatusManager added in v1.9.0 

func (s *AzureQueueStorageSource) GetStatusManager() *EventSourceStatusManager

GetStatusManager implements EventSource.

type AzureQueueStorageSourceList added in v1.9.0 

type AzureQueueStorageSourceList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []AzureQueueStorageSource `json:"items"`
}

AzureQueueStorageSourceList contains a list of event sources.

func (*AzureQueueStorageSourceList) DeepCopy added in v1.9.0 

func (in *AzureQueueStorageSourceList) DeepCopy() *AzureQueueStorageSourceList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AzureQueueStorageSourceList.

func (*AzureQueueStorageSourceList) DeepCopyInto added in v1.9.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*AzureQueueStorageSourceList) DeepCopyObject added in v1.9.0 

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type AzureQueueStorageSourceSpec added in v1.9.0 

type AzureQueueStorageSourceSpec struct {
	duckv1.SourceSpec `json:",inline"`

	AccountName string         `json:"accountName"`
	QueueName   string         `json:"queueName"`
	AccountKey  ValueFromField `json:"accountKey"`
}

AzureQueueStorageSourceSpec defines the desired state of the event source.

func (*AzureQueueStorageSourceSpec) DeepCopy added in v1.9.0 

func (in *AzureQueueStorageSourceSpec) DeepCopy() *AzureQueueStorageSourceSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AzureQueueStorageSourceSpec.

func (*AzureQueueStorageSourceSpec) DeepCopyInto added in v1.9.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type AzureResourceID added in v1.10.0 

type AzureResourceID struct {
	SubscriptionID   string
	ResourceGroup    string
	ResourceProvider string
	ResourceType     string
	ResourceName     string
}

AzureResourceID represents a resource ID for an Azure resource.

func (*AzureResourceID) DeepCopy added in v1.10.0 

func (in *AzureResourceID) DeepCopy() *AzureResourceID

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AzureResourceID.

func (*AzureResourceID) DeepCopyInto added in v1.10.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (AzureResourceID) MarshalJSON added in v1.10.0 

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

MarshalJSON implements json.Marshaler

func (*AzureResourceID) String added in v1.10.0 

func (rID *AzureResourceID) String() string

String implements the fmt.Stringer interface.

func (*AzureResourceID) UnmarshalJSON added in v1.10.0 

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

UnmarshalJSON implements json.Unmarshaler

type AzureSASToken 

type AzureSASToken struct {
	KeyName          ValueFromField `json:"keyName"`
	KeyValue         ValueFromField `json:"keyValue"`
	ConnectionString ValueFromField `json:"connectionString"`
}

AzureSASToken represents an Azure SAS token.

func (*AzureSASToken) DeepCopy 

func (in *AzureSASToken) DeepCopy() *AzureSASToken

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AzureSASToken.

func (*AzureSASToken) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type AzureServiceBusQueueSource added in v1.10.0 

type AzureServiceBusQueueSource struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   AzureServiceBusQueueSourceSpec   `json:"spec,omitempty"`
	Status AzureServiceBusQueueSourceStatus `json:"status,omitempty"`
}

AzureServiceBusQueueSource is the Schema for the event source.

func (*AzureServiceBusQueueSource) AsEventSource added in v1.10.0 

func (s *AzureServiceBusQueueSource) AsEventSource() string

AsEventSource implements EventSource.

func (*AzureServiceBusQueueSource) DeepCopy added in v1.10.0 

func (in *AzureServiceBusQueueSource) DeepCopy() *AzureServiceBusQueueSource

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AzureServiceBusQueueSource.

func (*AzureServiceBusQueueSource) DeepCopyInto added in v1.10.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*AzureServiceBusQueueSource) DeepCopyObject added in v1.10.0 

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*AzureServiceBusQueueSource) GetConditionSet added in v1.10.0 

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

GetConditionSet implements duckv1.KRShaped.

func (*AzureServiceBusQueueSource) GetEventTypes added in v1.10.0 

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

GetEventTypes returns the event types generated by the source.

func (*AzureServiceBusQueueSource) GetGroupVersionKind added in v1.10.0 

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

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*AzureServiceBusQueueSource) GetSink added in v1.10.0 

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

GetSink implements EventSource.

func (*AzureServiceBusQueueSource) GetStatus added in v1.10.0 

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

GetStatus implements duckv1.KRShaped.

func (*AzureServiceBusQueueSource) GetStatusManager added in v1.10.0 

func (s *AzureServiceBusQueueSource) GetStatusManager() *EventSourceStatusManager

GetStatusManager implements EventSource.

type AzureServiceBusQueueSourceList added in v1.10.0 

type AzureServiceBusQueueSourceList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []AzureServiceBusQueueSource `json:"items"`
}

AzureServiceBusQueueSourceList contains a list of event sources.

func (*AzureServiceBusQueueSourceList) DeepCopy added in v1.10.0 

func (in *AzureServiceBusQueueSourceList) DeepCopy() *AzureServiceBusQueueSourceList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AzureServiceBusQueueSourceList.

func (*AzureServiceBusQueueSourceList) DeepCopyInto added in v1.10.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*AzureServiceBusQueueSourceList) DeepCopyObject added in v1.10.0 

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type AzureServiceBusQueueSourceSpec added in v1.10.0 

type AzureServiceBusQueueSourceSpec struct {
	duckv1.SourceSpec `json:",inline"`

	Auth AzureAuth `json:"auth,omitempty"`
}

AzureServiceBusQueueSourceSpec defines the desired state of the event source.

func (*AzureServiceBusQueueSourceSpec) DeepCopy added in v1.10.0 

func (in *AzureServiceBusQueueSourceSpec) DeepCopy() *AzureServiceBusQueueSourceSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AzureServiceBusQueueSourceSpec.

func (*AzureServiceBusQueueSourceSpec) DeepCopyInto added in v1.10.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type AzureServiceBusQueueSourceStatus added in v1.10.0 

type AzureServiceBusQueueSourceStatus struct {
	EventSourceStatus `json:",inline"`
}

AzureServiceBusQueueSourceStatus defines the observed state of the event source.

func (*AzureServiceBusQueueSourceStatus) DeepCopy added in v1.10.0 

func (in *AzureServiceBusQueueSourceStatus) DeepCopy() *AzureServiceBusQueueSourceStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AzureServiceBusQueueSourceStatus.

func (*AzureServiceBusQueueSourceStatus) DeepCopyInto added in v1.10.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type AzureServicePrincipal 

type AzureServicePrincipal struct {
	TenantID     ValueFromField `json:"tenantID"`
	ClientID     ValueFromField `json:"clientID"`
	ClientSecret ValueFromField `json:"clientSecret"`
}

AzureServicePrincipal represents an AAD Service Principal.

func (*AzureServicePrincipal) DeepCopy 

func (in *AzureServicePrincipal) DeepCopy() *AzureServicePrincipal

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AzureServicePrincipal.

func (*AzureServicePrincipal) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type EventHubResourceID added in v1.4.1 

type EventHubResourceID struct {
	SubscriptionID string
	ResourceGroup  string
	Namespace      string
	EventHub       string
}

EventHubResourceID represents a resource ID for an Event Hubs instance or namespace.

func (*EventHubResourceID) DeepCopy added in v1.4.1 

func (in *EventHubResourceID) DeepCopy() *EventHubResourceID

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EventHubResourceID.

func (*EventHubResourceID) DeepCopyInto added in v1.4.1 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (EventHubResourceID) MarshalJSON added in v1.4.1 

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

MarshalJSON implements json.Marshaler

func (*EventHubResourceID) String added in v1.4.1 

func (rID *EventHubResourceID) String() string

String implements the fmt.Stringer interface.

func (*EventHubResourceID) UnmarshalJSON added in v1.4.1 

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

UnmarshalJSON implements json.Unmarshaler

type EventSource 

type EventSource interface {
	metav1.Object
	runtime.Object
	// OwnerRefable is used to construct a generic reconciler for each
	// source type, and convert source objects to owner references.
	kmeta.OwnerRefable
	// KRShaped is used by generated reconcilers to perform pre and
	// post-reconcile status updates.
	duckv1.KRShaped
	// GetSink returns the source's event sink.
	GetSink() *duckv1.Destination
	// GetStatusManager returns a manager for the source's status.
	GetStatusManager() *EventSourceStatusManager
	// GetEventTypes returns the event types generated by the source.
	GetEventTypes() []string
	// AsEventSource returns a unique reference to the source suitable for
	// use as a CloudEvent source attribute.
	AsEventSource() string
}

EventSource is implemented by all event source types.

func SourceFromContext 

func SourceFromContext(ctx context.Context) EventSource

SourceFromContext returns the source stored in the context.

type EventSourceStatus 

type EventSourceStatus struct {
	duckv1.SourceStatus  `json:",inline"`
	duckv1.AddressStatus `json:",inline"`
}

EventSourceStatus defines the observed state of an event source.

func (*EventSourceStatus) DeepCopy 

func (in *EventSourceStatus) DeepCopy() *EventSourceStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EventSourceStatus.

func (*EventSourceStatus) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type EventSourceStatusManager added in v0.6.0 

type EventSourceStatusManager struct {
	apis.ConditionSet
	*EventSourceStatus
}

EventSourceStatusManager manages the status of event sources.

+k8s:deepcopy-gen=false

func (*EventSourceStatusManager) MarkNoSink added in v0.6.0 

func (m *EventSourceStatusManager) MarkNoSink()

MarkNoSink sets the SinkProvided condition to False.

func (*EventSourceStatusManager) MarkRBACNotBound added in v1.3.0 

func (m *EventSourceStatusManager) MarkRBACNotBound()

MarkRBACNotBound sets the Deployed condition to False, indicating that the adapter's ServiceAccount couldn't be bound.

func (*EventSourceStatusManager) MarkSink added in v0.6.0 

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

MarkSink sets the SinkProvided condition to True using the given URI.

func (*EventSourceStatusManager) PropagateDeploymentAvailability added in v0.6.0 

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

PropagateDeploymentAvailability uses the readiness of the provided Deployment to determine whether the Deployed condition should be marked as True or False. Given an optional PodInterface, the status of dependant Pods is inspected to generate a more meaningful failure reason in case of non-ready status of the Deployment.

func (*EventSourceStatusManager) PropagateServiceAvailability added in v0.6.0 

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

PropagateServiceAvailability uses the readiness of the provided Service to determine whether the Deployed condition should be marked as True or False.

func (*EventSourceStatusManager) SetRoute added in v1.4.0 

func (m *EventSourceStatusManager) SetRoute(urlPath string)

SetRoute appends the given URL path to the current source's URL.

type GCloudPubSubResourceName added in v1.5.0 

type GCloudPubSubResourceName struct {
	Project    string
	Collection string
	Resource   string
}

GCloudPubSubResourceName represents a fully qualified Pub/Sub resource name, as described at 

https://cloud.google.com/pubsub/docs/admin#resource_names

Examples of such resource names include:

  • projects/{project_name}/topics/{topic_name}
  • projects/{project_name}/subscriptions/{subscription_name}

func (*GCloudPubSubResourceName) DeepCopy added in v1.5.0 

func (in *GCloudPubSubResourceName) DeepCopy() *GCloudPubSubResourceName

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GCloudPubSubResourceName.

func (*GCloudPubSubResourceName) DeepCopyInto added in v1.5.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (GCloudPubSubResourceName) MarshalJSON added in v1.5.0 

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

MarshalJSON implements json.Marshaler

func (*GCloudPubSubResourceName) String added in v1.5.0 

func (n *GCloudPubSubResourceName) String() string

String implements the fmt.Stringer interface.

func (*GCloudPubSubResourceName) UnmarshalJSON added in v1.5.0 

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

UnmarshalJSON implements json.Unmarshaler

type GCloudResourceName added in v1.10.0 

type GCloudResourceName struct {
	Project    string
	Collection string
	Resource   string
}

GCloudResourceName represents a fully qualified resource name, as described at 

https://cloud.google.com/apis/design/resource_names

Examples of such resource names include:

  • projects/{project_name}/topics/{topic_name}
  • projects/{project_name}/repos/{repo_name}
  • projects/{project_name}/subscriptions/{subscription_name}

func (*GCloudResourceName) DeepCopy added in v1.10.0 

func (in *GCloudResourceName) DeepCopy() *GCloudResourceName

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GCloudResourceName.

func (*GCloudResourceName) DeepCopyInto added in v1.10.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (GCloudResourceName) MarshalJSON added in v1.10.0 

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

MarshalJSON implements json.Marshaler

func (*GCloudResourceName) String added in v1.10.0 

func (n *GCloudResourceName) String() string

String implements the fmt.Stringer interface.

func (*GCloudResourceName) UnmarshalJSON added in v1.10.0 

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

UnmarshalJSON implements json.Unmarshaler

type GoogleCloudAuditLogsSource added in v1.10.0 

type GoogleCloudAuditLogsSource struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   GoogleCloudAuditLogsSourceSpec   `json:"spec,omitempty"`
	Status GoogleCloudAuditLogsSourceStatus `json:"status,omitempty"`
}

GoogleCloudAuditLogsSource is the Schema for the event source.

func (*GoogleCloudAuditLogsSource) AsEventSource added in v1.10.0 

func (s *GoogleCloudAuditLogsSource) AsEventSource() string

AsEventSource implements EventSource.

func (*GoogleCloudAuditLogsSource) DeepCopy added in v1.10.0 

func (in *GoogleCloudAuditLogsSource) DeepCopy() *GoogleCloudAuditLogsSource

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GoogleCloudAuditLogsSource.

func (*GoogleCloudAuditLogsSource) DeepCopyInto added in v1.10.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*GoogleCloudAuditLogsSource) DeepCopyObject added in v1.10.0 

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*GoogleCloudAuditLogsSource) GetConditionSet added in v1.10.0 

func (*GoogleCloudAuditLogsSource) GetConditionSet() apis.ConditionSet

GetConditionSet implements duckv1.KRShaped.

func (*GoogleCloudAuditLogsSource) GetEventTypes added in v1.10.0 

func (*GoogleCloudAuditLogsSource) GetEventTypes() []string

GetEventTypes returns the event types generated by the source.

func (*GoogleCloudAuditLogsSource) GetGroupVersionKind added in v1.10.0 

func (*GoogleCloudAuditLogsSource) GetGroupVersionKind() schema.GroupVersionKind

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*GoogleCloudAuditLogsSource) GetSink added in v1.10.0 

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

GetSink implements EventSource.

func (*GoogleCloudAuditLogsSource) GetStatus added in v1.10.0 

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

GetStatus implements duckv1.KRShaped.

func (*GoogleCloudAuditLogsSource) GetStatusManager added in v1.10.0 

func (s *GoogleCloudAuditLogsSource) GetStatusManager() *EventSourceStatusManager

GetStatusManager implements EventSource.

type GoogleCloudAuditLogsSourceList added in v1.10.0 

type GoogleCloudAuditLogsSourceList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []GoogleCloudAuditLogsSource `json:"items"`
}

GoogleCloudAuditLogsSourceList contains a list of event sources.

func (*GoogleCloudAuditLogsSourceList) DeepCopy added in v1.10.0 

func (in *GoogleCloudAuditLogsSourceList) DeepCopy() *GoogleCloudAuditLogsSourceList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GoogleCloudAuditLogsSourceList.

func (*GoogleCloudAuditLogsSourceList) DeepCopyInto added in v1.10.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*GoogleCloudAuditLogsSourceList) DeepCopyObject added in v1.10.0 

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type GoogleCloudAuditLogsSourcePubSubSpec added in v1.10.0 

type GoogleCloudAuditLogsSourcePubSubSpec struct {

	// Full resource name of the Pub/Sub topic where change notifications
	// originating from the configured sink are sent to. If not supplied,
	// a topic is created on behalf of the user, in the GCP project
	// referenced by the Project attribute.
	//
	// The expected format is described at https://cloud.google.com/pubsub/docs/admin#resource_names:
	//   "projects/{project_name}/topics/{topic_name}"
	//
	// +optional
	Topic *GCloudPubSubResourceName `json:"topic,omitempty"`

	// Name of the GCP project where Pub/Sub resources associated with the
	// Cloud Audit log are to be created.
	//
	// Mutually exclusive with Topic which, if supplied, already contains
	// the project name.
	//
	// +optional
	Project *string `json:"project,omitempty"`
}

GoogleCloudAuditLogsSourcePubSubSpec defines the attributes related to the configuration of Pub/Sub resources.

func (*GoogleCloudAuditLogsSourcePubSubSpec) DeepCopy added in v1.10.0 

func (in *GoogleCloudAuditLogsSourcePubSubSpec) DeepCopy() *GoogleCloudAuditLogsSourcePubSubSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GoogleCloudAuditLogsSourcePubSubSpec.

func (*GoogleCloudAuditLogsSourcePubSubSpec) DeepCopyInto added in v1.10.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type GoogleCloudAuditLogsSourceSpec added in v1.10.0 

type GoogleCloudAuditLogsSourceSpec struct {
	duckv1.SourceSpec `json:",inline"`

	// The GCP service this instance should source audit logs from. Required.
	// example: compute.googleapis.com
	ServiceName string `json:"serviceName"`

	// The name of the service method or operation. For API calls,
	// this should be the name of the API method. Required.
	// beta.compute.instances.insert
	MethodName string `json:"methodName"`

	// The resource or collection that is the target of the
	// operation. The name is a scheme-less URI, not including the
	// API service name.
	// example: "projects/PROJECT_ID/zones/us-central1-a/instances"
	ResourceName *string `json:"resourceName,omitempty"`

	// Settings related to the Pub/Sub resources associated with the Audit Logs event sink.
	PubSub GoogleCloudAuditLogsSourcePubSubSpec `json:"pubsub"`

	// Service account key in JSON format.
	// https://cloud.google.com/iam/docs/creating-managing-service-account-keys
	ServiceAccountKey ValueFromField `json:"serviceAccountKey"`
}

GoogleCloudAuditLogsSourceSpec defines the desired state of the event source.

func (*GoogleCloudAuditLogsSourceSpec) DeepCopy added in v1.10.0 

func (in *GoogleCloudAuditLogsSourceSpec) DeepCopy() *GoogleCloudAuditLogsSourceSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GoogleCloudAuditLogsSourceSpec.

func (*GoogleCloudAuditLogsSourceSpec) DeepCopyInto added in v1.10.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type GoogleCloudAuditLogsSourceStatus added in v1.10.0 

type GoogleCloudAuditLogsSourceStatus struct {
	EventSourceStatus `json:",inline"`

	// ID of the AuditLogSink used to publish audit log messages.
	AuditLogsSink *string `json:"auditLogsSink,omitempty"`

	// Resource name of the target Pub/Sub topic.
	Topic *GCloudPubSubResourceName `json:"topic,omitempty"`

	// Resource name of the managed Pub/Sub subscription associated with
	// the managed topic.
	Subscription *GCloudPubSubResourceName `json:"subscription,omitempty"`
}

GoogleCloudAuditLogsSourceStatus defines the observed state of the event source.

func (*GoogleCloudAuditLogsSourceStatus) DeepCopy added in v1.10.0 

func (in *GoogleCloudAuditLogsSourceStatus) DeepCopy() *GoogleCloudAuditLogsSourceStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GoogleCloudAuditLogsSourceStatus.

func (*GoogleCloudAuditLogsSourceStatus) DeepCopyInto added in v1.10.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*GoogleCloudAuditLogsSourceStatus) MarkNotSubscribed added in v1.10.0 

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

MarkNotSubscribed sets the Subscribed condition to False with the given reason and message.

func (*GoogleCloudAuditLogsSourceStatus) MarkSubscribed added in v1.10.0 

func (s *GoogleCloudAuditLogsSourceStatus) MarkSubscribed()

MarkSubscribed sets the Subscribed condition to True.

type GoogleCloudBillingSource added in v1.10.0 

type GoogleCloudBillingSource struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   GoogleCloudBillingSourceSpec   `json:"spec,omitempty"`
	Status GoogleCloudBillingSourceStatus `json:"status,omitempty"`
}

GoogleCloudBillingSource is the Schema for the event source.

func (*GoogleCloudBillingSource) AsEventSource added in v1.10.0 

func (s *GoogleCloudBillingSource) AsEventSource() string

AsEventSource implements EventSource.

func (*GoogleCloudBillingSource) DeepCopy added in v1.10.0 

func (in *GoogleCloudBillingSource) DeepCopy() *GoogleCloudBillingSource

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GoogleCloudBillingSource.

func (*GoogleCloudBillingSource) DeepCopyInto added in v1.10.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*GoogleCloudBillingSource) DeepCopyObject added in v1.10.0 

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*GoogleCloudBillingSource) GetConditionSet added in v1.10.0 

func (*GoogleCloudBillingSource) GetConditionSet() apis.ConditionSet

GetConditionSet implements duckv1.KRShaped.

func (*GoogleCloudBillingSource) GetEventTypes added in v1.10.0 

func (*GoogleCloudBillingSource) GetEventTypes() []string

GetEventTypes returns the event types generated by the source.

func (*GoogleCloudBillingSource) GetGroupVersionKind added in v1.10.0 

func (*GoogleCloudBillingSource) GetGroupVersionKind() schema.GroupVersionKind

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*GoogleCloudBillingSource) GetSink added in v1.10.0 

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

GetSink implements EventSource.

func (*GoogleCloudBillingSource) GetStatus added in v1.10.0 

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

GetStatus implements duckv1.KRShaped.

func (*GoogleCloudBillingSource) GetStatusManager added in v1.10.0 

func (s *GoogleCloudBillingSource) GetStatusManager() *EventSourceStatusManager

GetStatusManager implements EventSource.

type GoogleCloudBillingSourceList added in v1.10.0 

type GoogleCloudBillingSourceList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []GoogleCloudBillingSource `json:"items"`
}

GoogleCloudBillingSourceList contains a list of event sources.

func (*GoogleCloudBillingSourceList) DeepCopy added in v1.10.0 

func (in *GoogleCloudBillingSourceList) DeepCopy() *GoogleCloudBillingSourceList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GoogleCloudBillingSourceList.

func (*GoogleCloudBillingSourceList) DeepCopyInto added in v1.10.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*GoogleCloudBillingSourceList) DeepCopyObject added in v1.10.0 

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type GoogleCloudBillingSourcePubSubSpec added in v1.10.0 

type GoogleCloudBillingSourcePubSubSpec struct {

	// Full resource name of the Pub/Sub topic where change notifications
	// originating from the configured sink are sent to. If not supplied,
	// a topic is created on behalf of the user, in the GCP project
	// referenced by the Project attribute.
	//
	// The expected format is described at https://cloud.google.com/pubsub/docs/admin#resource_names:
	//   "projects/{project_name}/topics/{topic_name}"
	//
	// +optional
	Topic *GCloudPubSubResourceName `json:"topic,omitempty"`

	// Name of the GCP project where Pub/Sub resources associated with the
	// Cloud Billing budget are to be created.
	//
	// Mutually exclusive with Topic which, if supplied, already contains
	// the project name.
	//
	// +optional
	Project *string `json:"project,omitempty"`
}

GoogleCloudBillingSourcePubSubSpec defines the attributes related to the configuration of Pub/Sub resources.

func (*GoogleCloudBillingSourcePubSubSpec) DeepCopy added in v1.10.0 

func (in *GoogleCloudBillingSourcePubSubSpec) DeepCopy() *GoogleCloudBillingSourcePubSubSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GoogleCloudBillingSourcePubSubSpec.

func (*GoogleCloudBillingSourcePubSubSpec) DeepCopyInto added in v1.10.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type GoogleCloudBillingSourceSpec added in v1.10.0 

type GoogleCloudBillingSourceSpec struct {
	duckv1.SourceSpec `json:",inline"`

	// The identifier for the Cloud Billing account owning the budget.
	BillingAccountId string `json:"billingAccountId"`

	// The identifier for the Cloud Billing budget.
	// You can locate the budget's ID in your budget under Manage notifications.
	// The ID is displayed after you select Connect a Pub/Sub topic to this budget.
	BudgetId string `json:"budgetId"`

	// Settings related to the Pub/Sub resources associated with the Billing budget event sink.
	PubSub GoogleCloudBillingSourcePubSubSpec `json:"pubsub"`

	// Service account key in JSON format.
	// https://cloud.google.com/iam/docs/creating-managing-service-account-keys
	ServiceAccountKey ValueFromField `json:"serviceAccountKey"`
}

GoogleCloudBillingSourceSpec defines the desired state of the event source.

func (*GoogleCloudBillingSourceSpec) DeepCopy added in v1.10.0 

func (in *GoogleCloudBillingSourceSpec) DeepCopy() *GoogleCloudBillingSourceSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GoogleCloudBillingSourceSpec.

func (*GoogleCloudBillingSourceSpec) DeepCopyInto added in v1.10.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type GoogleCloudBillingSourceStatus added in v1.10.0 

type GoogleCloudBillingSourceStatus struct {
	EventSourceStatus `json:",inline"`

	// Resource name of the target Pub/Sub topic.
	Topic *GCloudPubSubResourceName `json:"topic,omitempty"`

	// Resource name of the managed Pub/Sub subscription associated with
	// the managed topic.
	Subscription *GCloudPubSubResourceName `json:"subscription,omitempty"`
}

GoogleCloudBillingSourceStatus defines the observed state of the event source.

func (*GoogleCloudBillingSourceStatus) DeepCopy added in v1.10.0 

func (in *GoogleCloudBillingSourceStatus) DeepCopy() *GoogleCloudBillingSourceStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GoogleCloudBillingSourceStatus.

func (*GoogleCloudBillingSourceStatus) DeepCopyInto added in v1.10.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*GoogleCloudBillingSourceStatus) MarkNotSubscribed added in v1.10.0 

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

MarkNotSubscribed sets the Subscribed condition to False with the given reason and message.

func (*GoogleCloudBillingSourceStatus) MarkSubscribed added in v1.10.0 

func (s *GoogleCloudBillingSourceStatus) MarkSubscribed()

MarkSubscribed sets the Subscribed condition to True.

type GoogleCloudPubSubSource added in v1.5.0 

type GoogleCloudPubSubSource struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   GoogleCloudPubSubSourceSpec   `json:"spec,omitempty"`
	Status GoogleCloudPubSubSourceStatus `json:"status,omitempty"`
}

GoogleCloudPubSubSource is the Schema for the event source.

func (*GoogleCloudPubSubSource) AsEventSource added in v1.5.0 

func (s *GoogleCloudPubSubSource) AsEventSource() string

AsEventSource implements EventSource.

func (*GoogleCloudPubSubSource) DeepCopy added in v1.5.0 

func (in *GoogleCloudPubSubSource) DeepCopy() *GoogleCloudPubSubSource

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GoogleCloudPubSubSource.

func (*GoogleCloudPubSubSource) DeepCopyInto added in v1.5.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*GoogleCloudPubSubSource) DeepCopyObject added in v1.5.0 

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*GoogleCloudPubSubSource) GetConditionSet added in v1.5.0 

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

GetConditionSet implements duckv1.KRShaped.

func (*GoogleCloudPubSubSource) GetEventTypes added in v1.5.0 

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

GetEventTypes returns the event types generated by the source.

func (*GoogleCloudPubSubSource) GetGroupVersionKind added in v1.5.0 

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

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*GoogleCloudPubSubSource) GetSink added in v1.5.0 

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

GetSink implements EventSource.

func (*GoogleCloudPubSubSource) GetStatus added in v1.5.0 

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

GetStatus implements duckv1.KRShaped.

func (*GoogleCloudPubSubSource) GetStatusManager added in v1.5.0 

func (s *GoogleCloudPubSubSource) GetStatusManager() *EventSourceStatusManager

GetStatusManager implements EventSource.

type GoogleCloudPubSubSourceList added in v1.5.0 

type GoogleCloudPubSubSourceList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []GoogleCloudPubSubSource `json:"items"`
}

GoogleCloudPubSubSourceList contains a list of event sources.

func (*GoogleCloudPubSubSourceList) DeepCopy added in v1.5.0 

func (in *GoogleCloudPubSubSourceList) DeepCopy() *GoogleCloudPubSubSourceList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GoogleCloudPubSubSourceList.

func (*GoogleCloudPubSubSourceList) DeepCopyInto added in v1.5.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*GoogleCloudPubSubSourceList) DeepCopyObject added in v1.5.0 

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type GoogleCloudPubSubSourceSpec added in v1.5.0 

type GoogleCloudPubSubSourceSpec struct {
	duckv1.SourceSpec `json:",inline"`

	// Full resource name of the Pub/Sub topic to subscribe to, in the
	// format "projects/{project_name}/topics/{topic_name}".
	Topic GCloudPubSubResourceName `json:"topic"`

	// ID of the subscription to use to pull messages from the topic.
	//
	// If supplied, this subscription must 1) exist and 2) belong to the
	// provided topic. Otherwise, a pull subscription to that topic is
	// created on behalf of the user.
	//
	// +optional
	SubscriptionID *string `json:"subscriptionID,omitempty"`

	// Service account key in JSON format.
	// https://cloud.google.com/iam/docs/creating-managing-service-account-keys
	ServiceAccountKey ValueFromField `json:"serviceAccountKey"`
}

GoogleCloudPubSubSourceSpec defines the desired state of the event source.

func (*GoogleCloudPubSubSourceSpec) DeepCopy added in v1.5.0 

func (in *GoogleCloudPubSubSourceSpec) DeepCopy() *GoogleCloudPubSubSourceSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GoogleCloudPubSubSourceSpec.

func (*GoogleCloudPubSubSourceSpec) DeepCopyInto added in v1.5.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type GoogleCloudPubSubSourceStatus added in v1.5.0 

type GoogleCloudPubSubSourceStatus struct {
	EventSourceStatus `json:",inline"`
	Subscription      *GCloudPubSubResourceName `json:"subscription,omitempty"`
}

GoogleCloudPubSubSourceStatus defines the observed state of the event source.

func (*GoogleCloudPubSubSourceStatus) DeepCopy added in v1.5.0 

func (in *GoogleCloudPubSubSourceStatus) DeepCopy() *GoogleCloudPubSubSourceStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GoogleCloudPubSubSourceStatus.

func (*GoogleCloudPubSubSourceStatus) DeepCopyInto added in v1.5.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*GoogleCloudPubSubSourceStatus) MarkNotSubscribed added in v1.5.0 

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

MarkNotSubscribed sets the Subscribed condition to False with the given reason and message.

func (*GoogleCloudPubSubSourceStatus) MarkSubscribed added in v1.5.0 

func (s *GoogleCloudPubSubSourceStatus) MarkSubscribed()

MarkSubscribed sets the Subscribed condition to True.

type GoogleCloudRepositoriesSource added in v1.10.0 

type GoogleCloudRepositoriesSource struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   GoogleCloudRepositoriesSourceSpec   `json:"spec,omitempty"`
	Status GoogleCloudRepositoriesSourceStatus `json:"status,omitempty"`
}

GoogleCloudRepositoriesSource is the Schema for the event source.

func (*GoogleCloudRepositoriesSource) AsEventSource added in v1.10.0 

func (s *GoogleCloudRepositoriesSource) AsEventSource() string

AsEventSource implements EventSource.

func (*GoogleCloudRepositoriesSource) DeepCopy added in v1.10.0 

func (in *GoogleCloudRepositoriesSource) DeepCopy() *GoogleCloudRepositoriesSource

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GoogleCloudRepositoriesSource.

func (*GoogleCloudRepositoriesSource) DeepCopyInto added in v1.10.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*GoogleCloudRepositoriesSource) DeepCopyObject added in v1.10.0 

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*GoogleCloudRepositoriesSource) GetConditionSet added in v1.10.0 

func (*GoogleCloudRepositoriesSource) GetConditionSet() apis.ConditionSet

GetConditionSet implements duckv1.KRShaped.

func (*GoogleCloudRepositoriesSource) GetEventTypes added in v1.10.0 

func (*GoogleCloudRepositoriesSource) GetEventTypes() []string

GetEventTypes returns the event types generated by the source.

func (*GoogleCloudRepositoriesSource) GetGroupVersionKind added in v1.10.0 

func (*GoogleCloudRepositoriesSource) GetGroupVersionKind() schema.GroupVersionKind

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*GoogleCloudRepositoriesSource) GetSink added in v1.10.0 

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

GetSink implements EventSource.

func (*GoogleCloudRepositoriesSource) GetStatus added in v1.10.0 

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

GetStatus implements duckv1.KRShaped.

func (*GoogleCloudRepositoriesSource) GetStatusManager added in v1.10.0 

func (s *GoogleCloudRepositoriesSource) GetStatusManager() *EventSourceStatusManager

GetStatusManager implements EventSource.

type GoogleCloudRepositoriesSourceList added in v1.10.0 

type GoogleCloudRepositoriesSourceList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []GoogleCloudRepositoriesSource `json:"items"`
}

GoogleCloudRepositoriesSourceList contains a list of event sources.

func (*GoogleCloudRepositoriesSourceList) DeepCopy added in v1.10.0 

func (in *GoogleCloudRepositoriesSourceList) DeepCopy() *GoogleCloudRepositoriesSourceList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GoogleCloudRepositoriesSourceList.

func (*GoogleCloudRepositoriesSourceList) DeepCopyInto added in v1.10.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*GoogleCloudRepositoriesSourceList) DeepCopyObject added in v1.10.0 

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type GoogleCloudRepositoriesSourcePubSubSpec added in v1.10.0 

type GoogleCloudRepositoriesSourcePubSubSpec struct {

	// Full resource name of the Pub/Sub topic where change notifications
	// originating from the configured sink are sent to. If not supplied,
	// a topic is created on behalf of the user, in the GCP project
	// referenced by the Project attribute.
	//
	// The expected format is described at https://cloud.google.com/pubsub/docs/admin#resource_names:
	//   "projects/{project_name}/topics/{topic_name}"
	//
	// +optional
	Topic *GCloudResourceName `json:"topic,omitempty"`

	// Name of the GCP project where Pub/Sub resources associated with the
	// Cloud repo are to be created.
	//
	// Mutually exclusive with Topic which, if supplied, already contains
	// the project name.
	//
	// +optional
	Project *string `json:"project,omitempty"`
}

GoogleCloudRepositoriesSourcePubSubSpec defines the attributes related to the configuration of Pub/Sub resources.

func (*GoogleCloudRepositoriesSourcePubSubSpec) DeepCopy added in v1.10.0 

func (in *GoogleCloudRepositoriesSourcePubSubSpec) DeepCopy() *GoogleCloudRepositoriesSourcePubSubSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GoogleCloudRepositoriesSourcePubSubSpec.

func (*GoogleCloudRepositoriesSourcePubSubSpec) DeepCopyInto added in v1.10.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type GoogleCloudRepositoriesSourceSpec added in v1.10.0 

type GoogleCloudRepositoriesSourceSpec struct {
	duckv1.SourceSpec `json:",inline"`

	// Name of the Cloud repo to receive notifications from.
	Repository GCloudResourceName `json:"repository"`

	// Settings related to the Pub/Sub resources associated with the repo events.
	PubSub GoogleCloudRepositoriesSourcePubSubSpec `json:"pubsub"`

	// Service account key in JSON format.
	// https://cloud.google.com/iam/docs/creating-managing-service-account-keys
	ServiceAccountKey ValueFromField `json:"serviceAccountKey"`
}

GoogleCloudRepositoriesSourceSpec defines the desired state of the event source.

func (*GoogleCloudRepositoriesSourceSpec) DeepCopy added in v1.10.0 

func (in *GoogleCloudRepositoriesSourceSpec) DeepCopy() *GoogleCloudRepositoriesSourceSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GoogleCloudRepositoriesSourceSpec.

func (*GoogleCloudRepositoriesSourceSpec) DeepCopyInto added in v1.10.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type GoogleCloudRepositoriesSourceStatus added in v1.10.0 

type GoogleCloudRepositoriesSourceStatus struct {
	EventSourceStatus `json:",inline"`

	// Resource name of the target Pub/Sub topic.
	Topic *GCloudResourceName `json:"topic,omitempty"`

	// Resource name of the managed Pub/Sub subscription associated with
	// the managed topic.
	Subscription *GCloudResourceName `json:"subscription,omitempty"`
}

GoogleCloudRepositoriesSourceStatus defines the observed state of the event source.

func (*GoogleCloudRepositoriesSourceStatus) DeepCopy added in v1.10.0 

func (in *GoogleCloudRepositoriesSourceStatus) DeepCopy() *GoogleCloudRepositoriesSourceStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GoogleCloudRepositoriesSourceStatus.

func (*GoogleCloudRepositoriesSourceStatus) DeepCopyInto added in v1.10.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*GoogleCloudRepositoriesSourceStatus) MarkNotSubscribed added in v1.10.0 

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

MarkNotSubscribed sets the Subscribed condition to False with the given reason and message.

func (*GoogleCloudRepositoriesSourceStatus) MarkSubscribed added in v1.10.0 

func (s *GoogleCloudRepositoriesSourceStatus) MarkSubscribed()

MarkSubscribed sets the Subscribed condition to True.

type GoogleCloudStorageSource added in v1.4.1 

type GoogleCloudStorageSource struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   GoogleCloudStorageSourceSpec   `json:"spec,omitempty"`
	Status GoogleCloudStorageSourceStatus `json:"status,omitempty"`
}

GoogleCloudStorageSource is the Schema for the event source.

func (*GoogleCloudStorageSource) AsEventSource added in v1.4.1 

func (s *GoogleCloudStorageSource) AsEventSource() string

AsEventSource implements EventSource.

func (*GoogleCloudStorageSource) DeepCopy added in v1.4.1 

func (in *GoogleCloudStorageSource) DeepCopy() *GoogleCloudStorageSource

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GoogleCloudStorageSource.

func (*GoogleCloudStorageSource) DeepCopyInto added in v1.4.1 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*GoogleCloudStorageSource) DeepCopyObject added in v1.4.1 

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*GoogleCloudStorageSource) GetConditionSet added in v1.4.1 

func (*GoogleCloudStorageSource) GetConditionSet() apis.ConditionSet

GetConditionSet implements duckv1.KRShaped.

func (*GoogleCloudStorageSource) GetEventTypes added in v1.4.1 

func (*GoogleCloudStorageSource) GetEventTypes() []string

GetEventTypes returns the event types generated by the source.

func (*GoogleCloudStorageSource) GetGroupVersionKind added in v1.4.1 

func (*GoogleCloudStorageSource) GetGroupVersionKind() schema.GroupVersionKind

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*GoogleCloudStorageSource) GetSink added in v1.4.1 

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

GetSink implements EventSource.

func (*GoogleCloudStorageSource) GetStatus added in v1.4.1 

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

GetStatus implements duckv1.KRShaped.

func (*GoogleCloudStorageSource) GetStatusManager added in v1.4.1 

func (s *GoogleCloudStorageSource) GetStatusManager() *EventSourceStatusManager

GetStatusManager implements EventSource.

type GoogleCloudStorageSourceList added in v1.4.1 

type GoogleCloudStorageSourceList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []GoogleCloudStorageSource `json:"items"`
}

GoogleCloudStorageSourceList contains a list of event sources.

func (*GoogleCloudStorageSourceList) DeepCopy added in v1.4.1 

func (in *GoogleCloudStorageSourceList) DeepCopy() *GoogleCloudStorageSourceList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GoogleCloudStorageSourceList.

func (*GoogleCloudStorageSourceList) DeepCopyInto added in v1.4.1 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*GoogleCloudStorageSourceList) DeepCopyObject added in v1.4.1 

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type GoogleCloudStorageSourcePubSubSpec added in v1.10.0 

type GoogleCloudStorageSourcePubSubSpec struct {

	// Full resource name of the Pub/Sub topic where change notifications
	// originating from the configured bucket are sent to. If not supplied,
	// a topic is created on behalf of the user, in the GCP project
	// referenced by the Project attribute.
	//
	// The expected format is described at https://cloud.google.com/pubsub/docs/admin#resource_names:
	//   "projects/{project_name}/topics/{topic_name}"
	//
	// +optional
	Topic *GCloudPubSubResourceName `json:"topic,omitempty"`

	// Name of the GCP project where Pub/Sub resources associated with the
	// Cloud Storage bucket are to be created.
	//
	// Mutually exclusive with Topic which, if supplied, already contains
	// the project name.
	//
	// +optional
	Project *string `json:"project,omitempty"`
}

GoogleCloudStorageSourcePubSubSpec defines the attributes related to the configuration of Pub/Sub resources.

func (*GoogleCloudStorageSourcePubSubSpec) DeepCopy added in v1.10.0 

func (in *GoogleCloudStorageSourcePubSubSpec) DeepCopy() *GoogleCloudStorageSourcePubSubSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GoogleCloudStorageSourcePubSubSpec.

func (*GoogleCloudStorageSourcePubSubSpec) DeepCopyInto added in v1.10.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type GoogleCloudStorageSourceSpec added in v1.4.1 

type GoogleCloudStorageSourceSpec struct {
	duckv1.SourceSpec `json:",inline"`

	// Name of the Cloud Storage bucket to receive change notifications from.
	Bucket string `json:"bucket"`

	// Settings related to the Pub/Sub resources associated with the bucket.
	PubSub GoogleCloudStorageSourcePubSubSpec `json:"pubsub"`

	// Types of events to subscribe to.
	//
	// The list of available event types can be found at
	// https://cloud.google.com/storage/docs/pubsub-notifications#events
	//
	// All types are selected when this attribute is not set.
	//
	// +optional
	EventTypes []string `json:"eventTypes,omitempty"`

	// Service account key in JSON format.
	// https://cloud.google.com/iam/docs/creating-managing-service-account-keys
	ServiceAccountKey ValueFromField `json:"serviceAccountKey"`
}

GoogleCloudStorageSourceSpec defines the desired state of the event source.

func (*GoogleCloudStorageSourceSpec) DeepCopy added in v1.4.1 

func (in *GoogleCloudStorageSourceSpec) DeepCopy() *GoogleCloudStorageSourceSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GoogleCloudStorageSourceSpec.

func (*GoogleCloudStorageSourceSpec) DeepCopyInto added in v1.4.1 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type GoogleCloudStorageSourceStatus added in v1.10.0 

type GoogleCloudStorageSourceStatus struct {
	EventSourceStatus `json:",inline"`

	// ID of the managed Cloud Storage bucket notification configuration.
	NotificationID *string `json:"notificationID,omitempty"`

	// Resource name of the target Pub/Sub topic.
	Topic *GCloudPubSubResourceName `json:"topic,omitempty"`
	// Resource name of the managed Pub/Sub subscription associated with
	// the managed topic.
	Subscription *GCloudPubSubResourceName `json:"subscription,omitempty"`
}

GoogleCloudStorageSourceStatus defines the observed state of the event source.

func (*GoogleCloudStorageSourceStatus) DeepCopy added in v1.10.0 

func (in *GoogleCloudStorageSourceStatus) DeepCopy() *GoogleCloudStorageSourceStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GoogleCloudStorageSourceStatus.

func (*GoogleCloudStorageSourceStatus) DeepCopyInto added in v1.10.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*GoogleCloudStorageSourceStatus) MarkNotSubscribed added in v1.10.0 

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

MarkNotSubscribed sets the Subscribed condition to False with the given reason and message.

func (*GoogleCloudStorageSourceStatus) MarkSubscribed added in v1.10.0 

func (s *GoogleCloudStorageSourceStatus) MarkSubscribed()

MarkSubscribed sets the Subscribed condition to True.

type OCIMetrics added in v1.3.0 

type OCIMetrics struct {
	// Human description for the metrics entry
	Name string `json:"name"`

	// Namespace for the query metric to use
	MetricsNamespace string `json:"metricsNamespace"`

	// OCI Metrics Query See https://docs.cloud.oracle.com/en-us/iaas/api/#/en/monitoring/20180401/MetricData
	MetricsQuery string `json:"metricsQuery"`

	// Oracle Compartment OCID
	Compartment *string `json:"oracleCompartment,omitempty"`
}

func (*OCIMetrics) DeepCopy added in v1.3.0 

func (in *OCIMetrics) DeepCopy() *OCIMetrics

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OCIMetrics.

func (*OCIMetrics) DeepCopyInto added in v1.3.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type OCIMetricsDecodedList added in v1.3.0 

type OCIMetricsDecodedList []OCIMetrics

func (*OCIMetricsDecodedList) Decode added in v1.3.0 

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

func (OCIMetricsDecodedList) DeepCopy added in v1.3.0 

func (in OCIMetricsDecodedList) DeepCopy() OCIMetricsDecodedList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OCIMetricsDecodedList.

func (OCIMetricsDecodedList) DeepCopyInto added in v1.3.0 

func (in OCIMetricsDecodedList) DeepCopyInto(out *OCIMetricsDecodedList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type OCIMetricsSource added in v0.7.0 

type OCIMetricsSource struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   OCIMetricsSourceSpec `json:"spec,omitempty"`
	Status EventSourceStatus    `json:"status,omitempty"`
}

OCIMetricsSource is the schema for the event source.

func (*OCIMetricsSource) AsEventSource added in v0.7.0 

func (s *OCIMetricsSource) AsEventSource() string

AsEventSource implements EventSource.

func (*OCIMetricsSource) DeepCopy added in v0.7.0 

func (in *OCIMetricsSource) DeepCopy() *OCIMetricsSource

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OCIMetricsSource.

func (*OCIMetricsSource) DeepCopyInto added in v0.7.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*OCIMetricsSource) DeepCopyObject added in v0.7.0 

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*OCIMetricsSource) GetConditionSet added in v0.7.0 

func (*OCIMetricsSource) GetConditionSet() pkgapis.ConditionSet

GetConditionSet implements duckv1.KRShaped.

func (*OCIMetricsSource) GetEventTypes added in v0.7.0 

func (*OCIMetricsSource) GetEventTypes() []string

GetEventTypes implements EventSource.

func (*OCIMetricsSource) GetGroupVersionKind added in v0.7.0 

func (*OCIMetricsSource) GetGroupVersionKind() schema.GroupVersionKind

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*OCIMetricsSource) GetSink added in v0.7.0 

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

GetSink implements EventSource.

func (*OCIMetricsSource) GetStatus added in v0.7.0 

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

GetStatus implements duckv1.KRShaped.

func (*OCIMetricsSource) GetStatusManager added in v0.7.0 

func (s *OCIMetricsSource) GetStatusManager() *EventSourceStatusManager

GetStatusManager implements EventSource.

type OCIMetricsSourceList added in v0.7.0 

type OCIMetricsSourceList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []OCIMetricsSource `json:"items"`
}

OCIMetricsSourceList contains a list of event sources.

func (*OCIMetricsSourceList) DeepCopy added in v0.7.0 

func (in *OCIMetricsSourceList) DeepCopy() *OCIMetricsSourceList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OCIMetricsSourceList.

func (*OCIMetricsSourceList) DeepCopyInto added in v0.7.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*OCIMetricsSourceList) DeepCopyObject added in v0.7.0 

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type OCIMetricsSourceSpec added in v0.7.0 

type OCIMetricsSourceSpec struct {
	// inherits duck/v1 SourceSpec, which currently provides:
	// * Sink - a reference to an object that will resolve to a domain name or
	//   a URI directly to use as the sink.
	// * CloudEventOverrides - defines overrides to control the output format
	//   and modifications of the event sent to the sink.
	duckv1.SourceSpec `json:",inline"`

	// Oracle User API private key
	OracleApiPrivateKey ValueFromField `json:"oracleApiPrivateKey"`

	// Oracle User API private key passphrase
	OracleApiPrivateKeyPassphrase ValueFromField `json:"oracleApiPrivateKeyPassphrase"`

	// Oracle User API cert fingerprint
	OracleApiPrivateKeyFingerprint ValueFromField `json:"oracleApiPrivateKeyFingerprint"`

	// Oracle Tenancy OCID
	Tenancy string `json:"oracleTenancy"`

	// Oracle User OCID associated with the API key
	User string `json:"oracleUser"`

	// Oracle Cloud Region
	Region string `json:"oracleRegion"`

	// OCI Metrics Polling Frequency
	// +optional
	PollingFrequency *string `json:"metricsPollingFrequency,omitempty"`

	// Array of metrics
	Metrics []OCIMetrics `json:"metrics"`
}

OCIMetricsSourceSpec defines the desired state of the event source.

func (*OCIMetricsSourceSpec) DeepCopy added in v0.7.0 

func (in *OCIMetricsSourceSpec) DeepCopy() *OCIMetricsSourceSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OCIMetricsSourceSpec.

func (*OCIMetricsSourceSpec) DeepCopyInto added in v0.7.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type SalesforceAuth added in v0.6.0 

type SalesforceAuth struct {
	ClientID string         `json:"clientID"`
	Server   string         `json:"server"`
	User     string         `json:"user"`
	CertKey  ValueFromField `json:"certKey"`
}

SalesforceAuth contains Salesforce credentials.

func (*SalesforceAuth) DeepCopy added in v0.6.0 

func (in *SalesforceAuth) DeepCopy() *SalesforceAuth

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SalesforceAuth.

func (*SalesforceAuth) DeepCopyInto added in v0.6.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type SalesforceSource added in v0.6.0 

type SalesforceSource struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   SalesforceSourceSpec `json:"spec,omitempty"`
	Status EventSourceStatus    `json:"status,omitempty"`
}

SalesforceSource is the Schema for the event source.

func (*SalesforceSource) AsEventSource added in v0.6.0 

func (s *SalesforceSource) AsEventSource() string

AsEventSource implements EventSource.

func (*SalesforceSource) DeepCopy added in v0.6.0 

func (in *SalesforceSource) DeepCopy() *SalesforceSource

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SalesforceSource.

func (*SalesforceSource) DeepCopyInto added in v0.6.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*SalesforceSource) DeepCopyObject added in v0.6.0 

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*SalesforceSource) GetConditionSet added in v0.6.0 

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

GetConditionSet implements duckv1.KRShaped.

func (*SalesforceSource) GetEventTypes added in v0.6.0 

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

GetEventTypes returns the event types generated by the source.

func (*SalesforceSource) GetGroupVersionKind added in v0.6.0 

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

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*SalesforceSource) GetSink added in v0.6.0 

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

GetSink implements EventSource.

func (*SalesforceSource) GetStatus added in v0.6.0 

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

GetStatus implements duckv1.KRShaped.

func (*SalesforceSource) GetStatusManager added in v0.6.0 

func (s *SalesforceSource) GetStatusManager() *EventSourceStatusManager

GetStatusManager implements EventSource.

type SalesforceSourceList added in v0.6.0 

type SalesforceSourceList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []SalesforceSource `json:"items"`
}

SalesforceSourceList contains a list of event sources.

func (*SalesforceSourceList) DeepCopy added in v0.6.0 

func (in *SalesforceSourceList) DeepCopy() *SalesforceSourceList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SalesforceSourceList.

func (*SalesforceSourceList) DeepCopyInto added in v0.6.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*SalesforceSourceList) DeepCopyObject added in v0.6.0 

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type SalesforceSourceSpec added in v0.6.0 

type SalesforceSourceSpec struct {
	duckv1.SourceSpec `json:",inline"`

	// Authentication method to interact with the Salesforce API.
	Auth SalesforceAuth `json:"auth"`

	// APIVersion at Salesforce.
	// +optional
	APIVersion *string `json:"apiVersion"`

	// Subscription to a Salesforce channel
	Subscription SalesforceSubscription `json:"subscription"`
}

SalesforceSourceSpec defines the desired state of the event source.

func (*SalesforceSourceSpec) DeepCopy added in v0.6.0 

func (in *SalesforceSourceSpec) DeepCopy() *SalesforceSourceSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SalesforceSourceSpec.

func (*SalesforceSourceSpec) DeepCopyInto added in v0.6.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type SalesforceSubscription added in v0.6.0 

type SalesforceSubscription struct {
	Channel  string `json:"channel"`
	ReplayID *int   `json:"replayID,omitempty"`
}

SalesforceSubscription to connect to.

func (*SalesforceSubscription) DeepCopy added in v0.6.0 

func (in *SalesforceSubscription) DeepCopy() *SalesforceSubscription

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SalesforceSubscription.

func (*SalesforceSubscription) DeepCopyInto added in v0.6.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type StorageAccountResourceID added in v1.4.1 

type StorageAccountResourceID struct {
	SubscriptionID string
	ResourceGroup  string
	StorageAccount string
}

StorageAccountResourceID represents a resource ID for a Storage Account.

func (*StorageAccountResourceID) DeepCopy added in v1.4.1 

func (in *StorageAccountResourceID) DeepCopy() *StorageAccountResourceID

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StorageAccountResourceID.

func (*StorageAccountResourceID) DeepCopyInto added in v1.4.1 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (StorageAccountResourceID) MarshalJSON added in v1.4.1 

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

MarshalJSON implements json.Marshaler

func (*StorageAccountResourceID) String added in v1.4.1 

func (rID *StorageAccountResourceID) String() string

String implements the fmt.Stringer interface.

func (*StorageAccountResourceID) UnmarshalJSON added in v1.4.1 

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

UnmarshalJSON implements json.Unmarshaler

type TwilioSource added in v1.2.0 

type TwilioSource struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   TwilioSourceSpec  `json:"spec,omitempty"`
	Status EventSourceStatus `json:"status,omitempty"`
}

TwilioSource is the schema for the event source.

func (*TwilioSource) AsEventSource added in v1.2.0 

func (s *TwilioSource) AsEventSource() string

AsEventSource implements EventSource.

func (*TwilioSource) DeepCopy added in v1.2.0 

func (in *TwilioSource) DeepCopy() *TwilioSource

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TwilioSource.

func (*TwilioSource) DeepCopyInto added in v1.2.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*TwilioSource) DeepCopyObject added in v1.2.0 

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*TwilioSource) GetConditionSet added in v1.2.0 

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

GetConditionSet implements duckv1.KRShaped.

func (*TwilioSource) GetEventTypes added in v1.2.0 

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

GetEventTypes implements EventSource.

func (*TwilioSource) GetGroupVersionKind added in v1.2.0 

func (*TwilioSource) GetGroupVersionKind() schema.GroupVersionKind

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*TwilioSource) GetSink added in v1.2.0 

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

GetSink implements EventSource.

func (*TwilioSource) GetStatus added in v1.2.0 

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

GetStatus implements duckv1.KRShaped.

func (*TwilioSource) GetStatusManager added in v1.2.0 

func (s *TwilioSource) GetStatusManager() *EventSourceStatusManager

GetStatusManager implements EventSource.

type TwilioSourceList added in v1.2.0 

type TwilioSourceList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []TwilioSource `json:"items"`
}

TwilioSourceList contains a list of event sources.

func (*TwilioSourceList) DeepCopy added in v1.2.0 

func (in *TwilioSourceList) DeepCopy() *TwilioSourceList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TwilioSourceList.

func (*TwilioSourceList) DeepCopyInto added in v1.2.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*TwilioSourceList) DeepCopyObject added in v1.2.0 

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type TwilioSourceSpec added in v1.2.0 

type TwilioSourceSpec struct {
	duckv1.SourceSpec `json:",inline"`
}

TwilioSourceSpec defines the desired state of the event source.

func (*TwilioSourceSpec) DeepCopy added in v1.2.0 

func (in *TwilioSourceSpec) DeepCopy() *TwilioSourceSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TwilioSourceSpec.

func (*TwilioSourceSpec) DeepCopyInto added in v1.2.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ValueFromField 

type ValueFromField struct {

	// Field value.
	// +optional
	Value string `json:"value,omitempty"`
	// Field value from a Kubernetes Secret.
	// +optional
	ValueFromSecret *corev1.SecretKeySelector `json:"valueFromSecret,omitempty"`
}

ValueFromField is a struct field that can have its value either defined explicitly or sourced from another entity.

func (*ValueFromField) DeepCopy 

func (in *ValueFromField) DeepCopy() *ValueFromField

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ValueFromField.

func (*ValueFromField) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.