v1alpha1

package
v1.10.1 Latest Latest
Warning

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

 Go to latest Published: Oct 11, 2021 License: Apache-2.0 Imports: 25 Imported by: 6

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 (
	AWSCloudWatchMetricEventType  = "metrics.metric"
	AWSCloudWatchMessageEventType = "metrics.message"
)

Supported event types

View Source 
const (
	AWSS3ObjCreatedEventType               = "objectcreated"
	AWSS3ObjRemovedEventType               = "objectremoved"
	AWSS3ObjRestoreEventType               = "objectrestore"
	AWSS3ReducedRedundancyLostObjEventType = "reducedredundancylostobject"
	AWSS3ReplicationEventType              = "replication"
	AWSS3TestEventType                     = "testevent"
)

Supported event types (see AWSS3SourceSpec)

View Source 
const (
	// AWSS3ReasonNoClient is set on a Subscribed condition when a S3/SQS API client cannot be obtained.
	AWSS3ReasonNoClient = "NoClient"
	// AWSS3ReasonNoBucket is set on a Subscribed condition when the S3 bucket does not exist.
	AWSS3ReasonNoBucket = "BucketNotFound"
	// AWSS3ReasonAPIError is set on a Subscribed condition when the S3/SQS API returns any other error.
	AWSS3ReasonAPIError = "APIError"
)

Reasons for status conditions

View Source 
const (
	// AWSSNSConditionSubscribed has status True when the event source's HTTP(S) endpoint has been subscribed to the
	// SNS subscription.
	AWSSNSConditionSubscribed apis.ConditionType = "Subscribed"

	// AWSSNSConditionHandlerRegistered indicates that a HTTP handler was registered for the source object.
	// It is not part of the ConditionSet registered for the AWSSNSSource
	// type, and will therefore automatically be propagated by Knative with
	// a severity of "Info".
	AWSSNSConditionHandlerRegistered = "HandlerRegistered"
)

Status conditions

View Source 
const (
	// AWSSNSReasonNoURL is set on a Subscribed condition when the adapter URL is empty.
	AWSSNSReasonNoURL = "MissingAdapterURL"
	// AWSSNSReasonNoClient is set on a Subscribed condition when a SNS API client cannot be obtained.
	AWSSNSReasonNoClient = "NoClient"
	// AWSSNSReasonPending is set on a Subscribed condition when the SNS subscription is pending confirmation.
	AWSSNSReasonPending = "PendingConfirmation"
	// AWSSNSReasonRejected is set on a Subscribed condition when the SNS API rejects a subscription request.
	AWSSNSReasonRejected = "SubscriptionRejected"
	// AWSSNSReasonAPIError is set on a Subscribed condition when the SNS API returns any other error.
	AWSSNSReasonAPIError = "APIError"
	// AWSSNSReasonFailedSync is set on a Subscribed condition when other synchronization errors occur.
	AWSSNSReasonFailedSync = "FailedSync"
)

Reasons for status conditions

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 (
	// ZendeskReasonNoURL is set on a TargetSynced condition when the adapter URL is empty.
	ZendeskReasonNoURL = "MissingAdapterURL"
	// ZendeskReasonNoSecret is set on a TargetSynced condition when required secrets can't be obtained.
	ZendeskReasonNoSecret = "MissingSecret"
	// ZendeskReasonFailedSync is set on a TargetSynced condition when a CRUD API call returns an error.
	ZendeskReasonFailedSync = "FailedSync"
)

Reasons for status conditions

View Source 
const (
	AWSCloudWatchLogsGenericEventType = "log"
)

Supported event types

View Source 
const (
	AWSCognitoIdentityGenericEventType = "sync_trigger"
)

Supported event types

View Source 
const (
	AWSCognitoUserPoolGenericEventType = "sync_trigger"
)

Supported event types

View Source 
const (
	AWSDynamoDBGenericEventType = "stream_record"
)

Supported event types

View Source 
const (
	AWSKinesisGenericEventType = "stream_record"
)

Supported event types

View Source 
const (
	AWSPerformanceInsightsGenericEventType = "com.amazon.rds.pi.metric"
)

Supported event types

View Source 
const (
	// AWSS3ConditionSubscribed has status True when event notifications
	// have been successfully enabled on a S3 bucket.
	AWSS3ConditionSubscribed apis.ConditionType = "Subscribed"
)

Status conditions

View Source 
const (
	AWSSNSGenericEventType = "notification"
)

Supported event types

View Source 
const (
	AWSSQSGenericEventType = "message"
)

Supported event types

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 (
	AzureIOTHubGenericEventType = "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 ServiceCloudWatch = "cloudwatch"

ServiceCloudWatch is the name of the CloudWatch service, as exposed in ARNs. https://docs.aws.amazon.com/service-authorization/latest/reference/list_amazoncloudwatch.html#amazoncloudwatch-resources-for-iam-policies

View Source 
const (
	SlackGenericEventType = "com.slack.events"
)

Supported event types

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

Supported event types.

View Source 
const (
	// ZendeskConditionTargetSynced has status True when the Zendesk Target and Trigger have been synced.
	ZendeskConditionTargetSynced apis.ConditionType = "TargetSynced"
)

Status conditions

View Source 
const (
	// ZendeskTicketCreatedEventType is generated upon creation of a Ticket.
	ZendeskTicketCreatedEventType = "com.zendesk.ticket.created"
)

Supported event types

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 AWSCloudWatchSourceName 

func AWSCloudWatchSourceName(ns, name string) string

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

func AWSEventType 

func AWSEventType(awsService, eventType string) string

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

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 AzureIOTHubSourceName 

func AzureIOTHubSourceName(namespace, name string) string

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

func AzureQueueStorageSourceName 

func AzureQueueStorageSourceName(namespace, name string) string

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

func AzureServiceBusQueueSourceName 

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 

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 

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 

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 

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 AWSCloudWatchLogsSource 

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

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

AWSCloudWatchLogsSource is the Schema for the event source.

func (*AWSCloudWatchLogsSource) AsEventSource 

func (s *AWSCloudWatchLogsSource) AsEventSource() string

AsEventSource implements EventSource.

func (*AWSCloudWatchLogsSource) DeepCopy 

func (in *AWSCloudWatchLogsSource) DeepCopy() *AWSCloudWatchLogsSource

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

func (*AWSCloudWatchLogsSource) DeepCopyInto 

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

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

func (*AWSCloudWatchLogsSource) DeepCopyObject 

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

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

func (*AWSCloudWatchLogsSource) GetConditionSet 

func (*AWSCloudWatchLogsSource) GetConditionSet() apis.ConditionSet

GetConditionSet implements duckv1.KRShaped.

func (*AWSCloudWatchLogsSource) GetEventTypes 

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

GetEventTypes implements EventSource.

func (*AWSCloudWatchLogsSource) GetGroupVersionKind 

func (*AWSCloudWatchLogsSource) GetGroupVersionKind() schema.GroupVersionKind

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*AWSCloudWatchLogsSource) GetSink 

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

GetSink implements EventSource.

func (*AWSCloudWatchLogsSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*AWSCloudWatchLogsSource) GetStatusManager 

func (s *AWSCloudWatchLogsSource) GetStatusManager() *EventSourceStatusManager

GetStatusManager implements EventSource.

type AWSCloudWatchLogsSourceList 

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

AWSCloudWatchLogsSourceList contains a list of event sources.

func (*AWSCloudWatchLogsSourceList) DeepCopy 

func (in *AWSCloudWatchLogsSourceList) DeepCopy() *AWSCloudWatchLogsSourceList

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

func (*AWSCloudWatchLogsSourceList) DeepCopyInto 

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

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

func (*AWSCloudWatchLogsSourceList) DeepCopyObject 

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

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

type AWSCloudWatchLogsSourceSpec 

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

	// ARN of the Log Group to source data from.
	// https://docs.aws.amazon.com/service-authorization/latest/reference/list_amazoncloudwatchlogs.html#amazoncloudwatchlogs-resources-for-iam-policies
	ARN apis.ARN `json:"arn"`

	// Duration which defines how often logs should be pulled from Amazon CloudWatch Logs.
	// Expressed as a duration string, which format is documented at https://pkg.go.dev/time#ParseDuration.
	//
	// Defaults to 5m
	//
	// +optional
	PollingInterval *apis.Duration `json:"pollingInterval,omitempty"`

	// Credentials to interact with the Amazon CloudWatch Logs API.
	Credentials AWSSecurityCredentials `json:"credentials"`
}

AWSCloudWatchLogsSourceSpec defines the desired state of the event source.

func (*AWSCloudWatchLogsSourceSpec) DeepCopy 

func (in *AWSCloudWatchLogsSourceSpec) DeepCopy() *AWSCloudWatchLogsSourceSpec

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

func (*AWSCloudWatchLogsSourceSpec) DeepCopyInto 

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

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

type AWSCloudWatchMetric 

type AWSCloudWatchMetric struct {
	Dimensions []AWSCloudWatchMetricDimension `json:"dimensions"`
	MetricName string                         `json:"metricName"`
	Namespace  string                         `json:"namespace"`
}

AWSCloudWatchMetric is a metric definition.

func (*AWSCloudWatchMetric) DeepCopy 

func (in *AWSCloudWatchMetric) DeepCopy() *AWSCloudWatchMetric

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

func (*AWSCloudWatchMetric) DeepCopyInto 

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

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

type AWSCloudWatchMetricDimension 

type AWSCloudWatchMetricDimension struct {
	Name  string `json:"name"`
	Value string `json:"value"`
}

AWSCloudWatchMetricDimension represents the dimensions of a metric.

func (*AWSCloudWatchMetricDimension) DeepCopy 

func (in *AWSCloudWatchMetricDimension) DeepCopy() *AWSCloudWatchMetricDimension

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

func (*AWSCloudWatchMetricDimension) DeepCopyInto 

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

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

type AWSCloudWatchMetricQuery 

type AWSCloudWatchMetricQuery struct {
	// Unique short name that identifies the query.
	Name string `json:"name"`

	// Math expression to be performed on the metric data.
	// +optional
	Expression *string `json:"expression,omitempty"`
	// Representation of a metric with statistics, period, and units, but no math expression.
	// +optional
	Metric *AWSCloudWatchMetricStat `json:"metric,omitempty"`
}

AWSCloudWatchMetricQuery represents a CloudWatch MetricDataQuery. https://docs.aws.amazon.com/AmazonCloudWatch/latest/APIReference/API_MetricDataQuery.html

func (*AWSCloudWatchMetricQuery) DeepCopy 

func (in *AWSCloudWatchMetricQuery) DeepCopy() *AWSCloudWatchMetricQuery

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

func (*AWSCloudWatchMetricQuery) DeepCopyInto 

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

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

type AWSCloudWatchMetricStat 

type AWSCloudWatchMetricStat struct {
	Metric AWSCloudWatchMetric `json:"metric"`         // Definition of the metric
	Period int64               `json:"period"`         // metric resolution in seconds
	Stat   string              `json:"stat"`           // statistic type to use
	Unit   string              `json:"unit,omitempty"` // The unit of the metric being returned
}

AWSCloudWatchMetricStat is a representation of a metric with statistics, period, and units, but no math expression.

func (*AWSCloudWatchMetricStat) DeepCopy 

func (in *AWSCloudWatchMetricStat) DeepCopy() *AWSCloudWatchMetricStat

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

func (*AWSCloudWatchMetricStat) DeepCopyInto 

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

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

type AWSCloudWatchSource 

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

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

AWSCloudWatchSource is the Schema for the event source.

func (*AWSCloudWatchSource) AsEventSource 

func (s *AWSCloudWatchSource) AsEventSource() string

AsEventSource implements EventSource.

func (*AWSCloudWatchSource) DeepCopy 

func (in *AWSCloudWatchSource) DeepCopy() *AWSCloudWatchSource

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

func (*AWSCloudWatchSource) DeepCopyInto 

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

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

func (*AWSCloudWatchSource) DeepCopyObject 

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

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

func (*AWSCloudWatchSource) GetConditionSet 

func (*AWSCloudWatchSource) GetConditionSet() apis.ConditionSet

GetConditionSet implements duckv1.KRShaped.

func (*AWSCloudWatchSource) GetEventTypes 

func (*AWSCloudWatchSource) GetEventTypes() []string

GetEventTypes implements EventSource.

func (*AWSCloudWatchSource) GetGroupVersionKind 

func (*AWSCloudWatchSource) GetGroupVersionKind() schema.GroupVersionKind

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*AWSCloudWatchSource) GetSink 

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

GetSink implements EventSource.

func (*AWSCloudWatchSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*AWSCloudWatchSource) GetStatusManager 

func (s *AWSCloudWatchSource) GetStatusManager() *EventSourceStatusManager

GetStatusManager implements EventSource.

type AWSCloudWatchSourceList 

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

AWSCloudWatchSourceList contains a list of event sources.

func (*AWSCloudWatchSourceList) DeepCopy 

func (in *AWSCloudWatchSourceList) DeepCopy() *AWSCloudWatchSourceList

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

func (*AWSCloudWatchSourceList) DeepCopyInto 

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

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

func (*AWSCloudWatchSourceList) DeepCopyObject 

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

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

type AWSCloudWatchSourceSpec 

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

	// Code of the AWS region to source metrics from.
	// Available region codes are documented at
	// https://docs.aws.amazon.com/general/latest/gr/rande.html#regional-endpoints.
	Region string `json:"region"`

	// Duration which defines how often metrics should be pulled from Amazon CloudWatch.
	// Expressed as a duration string, which format is documented at https://pkg.go.dev/time#ParseDuration.
	//
	// Defaults to 5m
	//
	// +optional
	PollingInterval *apis.Duration `json:"pollingInterval,omitempty"`

	// List of queries that determine what metrics will be sourced from Amazon CloudWatch.
	// +optional
	MetricQueries []AWSCloudWatchMetricQuery `json:"metricQueries,omitempty"`

	// Credentials to interact with the Amazon CloudWatch API.
	Credentials AWSSecurityCredentials `json:"credentials"`
}

AWSCloudWatchSourceSpec defines the desired state of the event source.

func (*AWSCloudWatchSourceSpec) DeepCopy 

func (in *AWSCloudWatchSourceSpec) DeepCopy() *AWSCloudWatchSourceSpec

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

func (*AWSCloudWatchSourceSpec) DeepCopyInto 

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

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

type AWSCodeCommitSource 

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

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

AWSCodeCommitSource is the Schema for the event source.

func (*AWSCodeCommitSource) AsEventSource 

func (s *AWSCodeCommitSource) AsEventSource() string

AsEventSource implements EventSource.

func (*AWSCodeCommitSource) DeepCopy 

func (in *AWSCodeCommitSource) DeepCopy() *AWSCodeCommitSource

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

func (*AWSCodeCommitSource) DeepCopyInto 

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

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

func (*AWSCodeCommitSource) DeepCopyObject 

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

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

func (*AWSCodeCommitSource) GetConditionSet 

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

GetConditionSet implements duckv1.KRShaped.

func (*AWSCodeCommitSource) GetEventTypes 

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

GetEventTypes implements EventSource.

func (*AWSCodeCommitSource) GetGroupVersionKind 

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

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*AWSCodeCommitSource) GetSink 

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

GetSink implements EventSource.

func (*AWSCodeCommitSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*AWSCodeCommitSource) GetStatusManager 

func (s *AWSCodeCommitSource) GetStatusManager() *EventSourceStatusManager

GetStatusManager implements EventSource.

type AWSCodeCommitSourceList 

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

AWSCodeCommitSourceList contains a list of event sources.

func (*AWSCodeCommitSourceList) DeepCopy 

func (in *AWSCodeCommitSourceList) DeepCopy() *AWSCodeCommitSourceList

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

func (*AWSCodeCommitSourceList) DeepCopyInto 

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

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

func (*AWSCodeCommitSourceList) DeepCopyObject 

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

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

type AWSCodeCommitSourceSpec 

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

	// Repository ARN
	// https://docs.aws.amazon.com/IAM/latest/UserGuide/list_awscodecommit.html#awscodecommit-resources-for-iam-policies
	ARN apis.ARN `json:"arn"`
	// Name of the Git branch this source observes.
	Branch string `json:"branch"`
	// List of event types that should be processed by the source.
	// Valid values: [push, pull_request]
	EventTypes []string `json:"eventTypes"`

	// Credentials to interact with the Amazon CodeCommit API.
	Credentials AWSSecurityCredentials `json:"credentials"`
}

AWSCodeCommitSourceSpec defines the desired state of the event source.

func (*AWSCodeCommitSourceSpec) DeepCopy 

func (in *AWSCodeCommitSourceSpec) DeepCopy() *AWSCodeCommitSourceSpec

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

func (*AWSCodeCommitSourceSpec) DeepCopyInto 

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

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

type AWSCognitoIdentitySource 

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

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

AWSCognitoIdentitySource is the Schema for the event source.

func (*AWSCognitoIdentitySource) AsEventSource 

func (s *AWSCognitoIdentitySource) AsEventSource() string

AsEventSource implements EventSource.

func (*AWSCognitoIdentitySource) DeepCopy 

func (in *AWSCognitoIdentitySource) DeepCopy() *AWSCognitoIdentitySource

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

func (*AWSCognitoIdentitySource) DeepCopyInto 

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

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

func (*AWSCognitoIdentitySource) DeepCopyObject 

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

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

func (*AWSCognitoIdentitySource) GetConditionSet 

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

GetConditionSet implements duckv1.KRShaped.

func (*AWSCognitoIdentitySource) GetEventTypes 

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

GetEventTypes implements EventSource.

func (*AWSCognitoIdentitySource) GetGroupVersionKind 

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

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*AWSCognitoIdentitySource) GetSink 

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

GetSink implements EventSource.

func (*AWSCognitoIdentitySource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*AWSCognitoIdentitySource) GetStatusManager 

func (s *AWSCognitoIdentitySource) GetStatusManager() *EventSourceStatusManager

GetStatusManager implements EventSource.

type AWSCognitoIdentitySourceList 

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

AWSCognitoIdentitySourceList contains a list of event sources.

func (*AWSCognitoIdentitySourceList) DeepCopy 

func (in *AWSCognitoIdentitySourceList) DeepCopy() *AWSCognitoIdentitySourceList

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

func (*AWSCognitoIdentitySourceList) DeepCopyInto 

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

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

func (*AWSCognitoIdentitySourceList) DeepCopyObject 

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

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

type AWSCognitoIdentitySourceSpec 

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

	// Identity Pool ARN
	// https://docs.aws.amazon.com/IAM/latest/UserGuide/list_amazoncognitoidentity.html#amazoncognitoidentity-resources-for-iam-policies
	ARN apis.ARN `json:"arn"`

	// Credentials to interact with the Amazon Cognito API.
	Credentials AWSSecurityCredentials `json:"credentials"`
}

AWSCognitoIdentitySourceSpec defines the desired state of the event source.

func (*AWSCognitoIdentitySourceSpec) DeepCopy 

func (in *AWSCognitoIdentitySourceSpec) DeepCopy() *AWSCognitoIdentitySourceSpec

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

func (*AWSCognitoIdentitySourceSpec) DeepCopyInto 

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

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

type AWSCognitoUserPoolSource 

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

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

AWSCognitoUserPoolSource is the Schema for the event source.

func (*AWSCognitoUserPoolSource) AsEventSource 

func (s *AWSCognitoUserPoolSource) AsEventSource() string

AsEventSource implements EventSource.

func (*AWSCognitoUserPoolSource) DeepCopy 

func (in *AWSCognitoUserPoolSource) DeepCopy() *AWSCognitoUserPoolSource

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

func (*AWSCognitoUserPoolSource) DeepCopyInto 

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

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

func (*AWSCognitoUserPoolSource) DeepCopyObject 

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

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

func (*AWSCognitoUserPoolSource) GetConditionSet 

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

GetConditionSet implements duckv1.KRShaped.

func (*AWSCognitoUserPoolSource) GetEventTypes 

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

GetEventTypes implements EventSource.

func (*AWSCognitoUserPoolSource) GetGroupVersionKind 

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

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*AWSCognitoUserPoolSource) GetSink 

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

GetSink implements EventSource.

func (*AWSCognitoUserPoolSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*AWSCognitoUserPoolSource) GetStatusManager 

func (s *AWSCognitoUserPoolSource) GetStatusManager() *EventSourceStatusManager

GetStatusManager implements EventSource.

type AWSCognitoUserPoolSourceList 

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

AWSCognitoUserPoolSourceList contains a list of event sources.

func (*AWSCognitoUserPoolSourceList) DeepCopy 

func (in *AWSCognitoUserPoolSourceList) DeepCopy() *AWSCognitoUserPoolSourceList

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

func (*AWSCognitoUserPoolSourceList) DeepCopyInto 

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

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

func (*AWSCognitoUserPoolSourceList) DeepCopyObject 

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

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

type AWSCognitoUserPoolSourceSpec 

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

	// User Pool ARN
	// https://docs.aws.amazon.com/service-authorization/latest/reference/list_amazoncognitouserpools.html#amazoncognitouserpools-resources-for-iam-policies
	ARN apis.ARN `json:"arn"`

	// Credentials to interact with the Amazon Cognito API.
	Credentials AWSSecurityCredentials `json:"credentials"`
}

AWSCognitoUserPoolSourceSpec defines the desired state of the event source.

func (*AWSCognitoUserPoolSourceSpec) DeepCopy 

func (in *AWSCognitoUserPoolSourceSpec) DeepCopy() *AWSCognitoUserPoolSourceSpec

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

func (*AWSCognitoUserPoolSourceSpec) DeepCopyInto 

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

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

type AWSDynamoDBSource 

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

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

AWSDynamoDBSource is the Schema for the event source.

func (*AWSDynamoDBSource) AsEventSource 

func (s *AWSDynamoDBSource) AsEventSource() string

AsEventSource implements EventSource.

func (*AWSDynamoDBSource) DeepCopy 

func (in *AWSDynamoDBSource) DeepCopy() *AWSDynamoDBSource

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

func (*AWSDynamoDBSource) DeepCopyInto 

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

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

func (*AWSDynamoDBSource) DeepCopyObject 

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

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

func (*AWSDynamoDBSource) GetConditionSet 

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

GetConditionSet implements duckv1.KRShaped.

func (*AWSDynamoDBSource) GetEventTypes 

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

GetEventTypes implements EventSource.

func (*AWSDynamoDBSource) GetGroupVersionKind 

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

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*AWSDynamoDBSource) GetSink 

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

GetSink implements EventSource.

func (*AWSDynamoDBSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*AWSDynamoDBSource) GetStatusManager 

func (s *AWSDynamoDBSource) GetStatusManager() *EventSourceStatusManager

GetStatusManager implements EventSource.

type AWSDynamoDBSourceList 

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

AWSDynamoDBSourceList contains a list of event sources.

func (*AWSDynamoDBSourceList) DeepCopy 

func (in *AWSDynamoDBSourceList) DeepCopy() *AWSDynamoDBSourceList

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

func (*AWSDynamoDBSourceList) DeepCopyInto 

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

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

func (*AWSDynamoDBSourceList) DeepCopyObject 

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

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

type AWSDynamoDBSourceSpec 

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

	// Table ARN
	// https://docs.aws.amazon.com/IAM/latest/UserGuide/list_amazondynamodb.html#amazondynamodb-resources-for-iam-policies
	ARN apis.ARN `json:"arn"`

	// Credentials to interact with the Amazon DynamoDB API.
	Credentials AWSSecurityCredentials `json:"credentials"`
}

AWSDynamoDBSourceSpec defines the desired state of the event source.

func (*AWSDynamoDBSourceSpec) DeepCopy 

func (in *AWSDynamoDBSourceSpec) DeepCopy() *AWSDynamoDBSourceSpec

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

func (*AWSDynamoDBSourceSpec) DeepCopyInto 

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

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

type AWSKinesisSource 

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

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

AWSKinesisSource is the Schema for the event source.

func (*AWSKinesisSource) AsEventSource 

func (s *AWSKinesisSource) AsEventSource() string

AsEventSource implements EventSource.

func (*AWSKinesisSource) DeepCopy 

func (in *AWSKinesisSource) DeepCopy() *AWSKinesisSource

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

func (*AWSKinesisSource) DeepCopyInto 

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

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

func (*AWSKinesisSource) DeepCopyObject 

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

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

func (*AWSKinesisSource) GetConditionSet 

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

GetConditionSet implements duckv1.KRShaped.

func (*AWSKinesisSource) GetEventTypes 

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

GetEventTypes implements EventSource.

func (*AWSKinesisSource) GetGroupVersionKind 

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

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*AWSKinesisSource) GetSink 

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

GetSink implements EventSource.

func (*AWSKinesisSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*AWSKinesisSource) GetStatusManager 

func (s *AWSKinesisSource) GetStatusManager() *EventSourceStatusManager

GetStatusManager implements EventSource.

type AWSKinesisSourceList 

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

AWSKinesisSourceList contains a list of event sources.

func (*AWSKinesisSourceList) DeepCopy 

func (in *AWSKinesisSourceList) DeepCopy() *AWSKinesisSourceList

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

func (*AWSKinesisSourceList) DeepCopyInto 

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

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

func (*AWSKinesisSourceList) DeepCopyObject 

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

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

type AWSKinesisSourceSpec 

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

	// Stream ARN
	// https://docs.aws.amazon.com/IAM/latest/UserGuide/list_amazonkinesis.html#amazonkinesis-resources-for-iam-policies
	ARN apis.ARN `json:"arn"`

	// Credentials to interact with the Amazon Kinesis API.
	Credentials AWSSecurityCredentials `json:"credentials"`
}

AWSKinesisSourceSpec defines the desired state of the event source.

func (*AWSKinesisSourceSpec) DeepCopy 

func (in *AWSKinesisSourceSpec) DeepCopy() *AWSKinesisSourceSpec

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

func (*AWSKinesisSourceSpec) DeepCopyInto 

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

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

type AWSPerformanceInsightsSource 

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

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

AWSPerformanceInsightsSource is the Schema for the event source.

func (*AWSPerformanceInsightsSource) AsEventSource 

func (s *AWSPerformanceInsightsSource) AsEventSource() string

AsEventSource implements EventSource.

func (*AWSPerformanceInsightsSource) DeepCopy 

func (in *AWSPerformanceInsightsSource) DeepCopy() *AWSPerformanceInsightsSource

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

func (*AWSPerformanceInsightsSource) DeepCopyInto 

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

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

func (*AWSPerformanceInsightsSource) DeepCopyObject 

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

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

func (*AWSPerformanceInsightsSource) GetConditionSet 

func (*AWSPerformanceInsightsSource) GetConditionSet() apis.ConditionSet

GetConditionSet implements duckv1.KRShaped.

func (*AWSPerformanceInsightsSource) GetEventTypes 

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

GetEventTypes implements EventSource.

func (*AWSPerformanceInsightsSource) GetGroupVersionKind 

func (*AWSPerformanceInsightsSource) GetGroupVersionKind() schema.GroupVersionKind

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*AWSPerformanceInsightsSource) GetSink 

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

GetSink implements EventSource.

func (*AWSPerformanceInsightsSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*AWSPerformanceInsightsSource) GetStatusManager 

func (s *AWSPerformanceInsightsSource) GetStatusManager() *EventSourceStatusManager

GetStatusManager implements EventSource.

type AWSPerformanceInsightsSourceList 

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

AWSPerformanceInsightsSourceList contains a list of event sources.

func (*AWSPerformanceInsightsSourceList) DeepCopy 

func (in *AWSPerformanceInsightsSourceList) DeepCopy() *AWSPerformanceInsightsSourceList

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

func (*AWSPerformanceInsightsSourceList) DeepCopyInto 

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

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

func (*AWSPerformanceInsightsSourceList) DeepCopyObject 

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

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

type AWSPerformanceInsightsSourceSpec 

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

	// ARN of the RDS instance to receive metrics for.
	// https://docs.aws.amazon.com/service-authorization/latest/reference/list_amazonrds.html#amazonrds-resources-for-iam-policies
	ARN apis.ARN `json:"arn"`

	// Duration which defines how often metrics should be pulled from Amazon Performance Insights.
	// Expressed as a duration string, which format is documented at https://pkg.go.dev/time#ParseDuration.
	PollingInterval apis.Duration `json:"pollingInterval"`

	// List of queries that determine what metrics will be sourced from Amazon Performance Insights.
	//
	// Each item represents the 'metric' attribute of a MetricQuery.
	// https://docs.aws.amazon.com/performance-insights/latest/APIReference/API_MetricQuery.html
	Metrics []string `json:"metrics"`

	// Credentials to interact with the Amazon RDS and Performance Insights APIs.
	Credentials AWSSecurityCredentials `json:"credentials"`
}

AWSPerformanceInsightsSourceSpec defines the desired state of the event source.

func (*AWSPerformanceInsightsSourceSpec) DeepCopy 

func (in *AWSPerformanceInsightsSourceSpec) DeepCopy() *AWSPerformanceInsightsSourceSpec

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

func (*AWSPerformanceInsightsSourceSpec) DeepCopyInto 

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

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

type AWSS3Source 

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

	Spec   AWSS3SourceSpec   `json:"spec,omitempty"`
	Status AWSS3SourceStatus `json:"status,omitempty"`
}

AWSS3Source is the Schema for the event source.

func (*AWSS3Source) AsEventSource 

func (s *AWSS3Source) AsEventSource() string

AsEventSource implements EventSource.

func (*AWSS3Source) DeepCopy 

func (in *AWSS3Source) DeepCopy() *AWSS3Source

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

func (*AWSS3Source) DeepCopyInto 

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

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

func (*AWSS3Source) DeepCopyObject 

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

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

func (*AWSS3Source) GetConditionSet 

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

GetConditionSet implements duckv1.KRShaped.

func (*AWSS3Source) GetEventTypes 

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

GetEventTypes implements EventSource.

func (*AWSS3Source) GetGroupVersionKind 

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

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*AWSS3Source) GetSink 

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

GetSink implements EventSource.

func (*AWSS3Source) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*AWSS3Source) GetStatusManager 

func (s *AWSS3Source) GetStatusManager() *EventSourceStatusManager

GetStatusManager implements EventSource.

type AWSS3SourceList 

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

AWSS3SourceList contains a list of event sources.

func (*AWSS3SourceList) DeepCopy 

func (in *AWSS3SourceList) DeepCopy() *AWSS3SourceList

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

func (*AWSS3SourceList) DeepCopyInto 

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

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

func (*AWSS3SourceList) DeepCopyObject 

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

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

type AWSS3SourceSpec 

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

	// Bucket ARN
	// https://docs.aws.amazon.com/service-authorization/latest/reference/list_amazons3.html#amazons3-resources-for-iam-policies
	//
	// Although not technically required by S3, we enforce that bucket ARNs
	// include a region and an account ID, because this information is
	// required by the reconciler to operate properly.
	ARN apis.ARN `json:"arn"`

	// List of event types that the source should subscribe to.
	// Accepted values:
	// https://docs.aws.amazon.com/AmazonS3/latest/API/API_QueueConfiguration.html
	// https://docs.aws.amazon.com/AmazonS3/latest/userguide/notification-how-to-event-types-and-destinations.html
	EventTypes []string `json:"eventTypes"`

	// SQS Queue ARN
	// https://docs.aws.amazon.com/IAM/latest/UserGuide/list_amazonsqs.html#amazonsqs-resources-for-iam-policies
	//
	// When not provided, a SQS queue for receiving event notifications
	// from the S3 bucket is automatically created and configured.
	//
	// +optional
	QueueARN *apis.ARN `json:"queueARN,omitempty"`

	// Credentials to interact with the Amazon S3 and SQS APIs.
	Credentials AWSSecurityCredentials `json:"credentials"`
}

AWSS3SourceSpec defines the desired state of the event source.

func (*AWSS3SourceSpec) DeepCopy 

func (in *AWSS3SourceSpec) DeepCopy() *AWSS3SourceSpec

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

func (*AWSS3SourceSpec) DeepCopyInto 

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

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

type AWSS3SourceStatus 

type AWSS3SourceStatus struct {
	EventSourceStatus `json:",inline"`
	QueueARN          *apis.ARN `json:"queueARN,omitempty"`
}

AWSS3SourceStatus defines the observed state of the event source.

func (*AWSS3SourceStatus) DeepCopy 

func (in *AWSS3SourceStatus) DeepCopy() *AWSS3SourceStatus

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

func (*AWSS3SourceStatus) DeepCopyInto 

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

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

func (*AWSS3SourceStatus) MarkNotSubscribed 

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

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

func (*AWSS3SourceStatus) MarkSubscribed 

func (s *AWSS3SourceStatus) MarkSubscribed()

MarkSubscribed sets the Subscribed condition to True and reports the ARN of the S3 subscription.

type AWSSNSSource 

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

	Spec   AWSSNSSourceSpec   `json:"spec,omitempty"`
	Status AWSSNSSourceStatus `json:"status,omitempty"`
}

AWSSNSSource is the Schema for the event source.

func (*AWSSNSSource) AsEventSource 

func (s *AWSSNSSource) AsEventSource() string

AsEventSource implements EventSource.

func (*AWSSNSSource) DeepCopy 

func (in *AWSSNSSource) DeepCopy() *AWSSNSSource

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

func (*AWSSNSSource) DeepCopyInto 

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

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

func (*AWSSNSSource) DeepCopyObject 

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

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

func (*AWSSNSSource) GetConditionSet 

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

GetConditionSet implements duckv1.KRShaped.

func (*AWSSNSSource) GetEventTypes 

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

GetEventTypes implements EventSource.

func (*AWSSNSSource) GetGroupVersionKind 

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

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*AWSSNSSource) GetSink 

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

GetSink implements EventSource.

func (*AWSSNSSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*AWSSNSSource) GetStatusManager 

func (s *AWSSNSSource) GetStatusManager() *EventSourceStatusManager

GetStatusManager implements EventSource.

func (*AWSSNSSource) GetUntypedSpec 

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

GetUntypedSpec implements apis.HasSpec.

func (*AWSSNSSource) IsMultiTenant 

func (*AWSSNSSource) IsMultiTenant() bool

IsMultiTenant implements MultiTenant.

type AWSSNSSourceList 

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

AWSSNSSourceList contains a list of event sources.

func (*AWSSNSSourceList) DeepCopy 

func (in *AWSSNSSourceList) DeepCopy() *AWSSNSSourceList

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

func (*AWSSNSSourceList) DeepCopyInto 

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

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

func (*AWSSNSSourceList) DeepCopyObject 

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

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

type AWSSNSSourceSpec 

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

	// Topic ARN
	// https://docs.aws.amazon.com/IAM/latest/UserGuide/list_amazonsns.html#amazonsns-resources-for-iam-policies
	ARN apis.ARN `json:"arn"`

	// Attributes to set on the Subscription that is used for receiving messages from the topic.
	// For a list of supported subscription attributes, please refer to the following resources:
	//  * https://docs.aws.amazon.com/sns/latest/api/API_SetSubscriptionAttributes.html
	//  * https://docs.aws.amazon.com/sns/latest/dg/sns-how-it-works.html
	// +optional
	SubscriptionAttributes map[string]*string `json:"subscriptionAttributes,omitempty"`

	// Credentials to interact with the Amazon SNS API.
	Credentials AWSSecurityCredentials `json:"credentials"`
}

AWSSNSSourceSpec defines the desired state of the event source.

func (*AWSSNSSourceSpec) DeepCopy 

func (in *AWSSNSSourceSpec) DeepCopy() *AWSSNSSourceSpec

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

func (*AWSSNSSourceSpec) DeepCopyInto 

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

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

type AWSSNSSourceStatus 

type AWSSNSSourceStatus struct {
	EventSourceStatus `json:",inline"`
	SubscriptionARN   *string `json:"subscriptionARN,omitempty"`
}

AWSSNSSourceStatus defines the observed state of the event source.

func (*AWSSNSSourceStatus) DeepCopy 

func (in *AWSSNSSourceStatus) DeepCopy() *AWSSNSSourceStatus

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

func (*AWSSNSSourceStatus) DeepCopyInto 

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

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

func (*AWSSNSSourceStatus) MarkNotSubscribed 

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

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

func (*AWSSNSSourceStatus) MarkSubscribed 

func (s *AWSSNSSourceStatus) MarkSubscribed(subARN string)

MarkSubscribed sets the Subscribed condition to True and reports the ARN of the SNS subscription.

type AWSSQSSource 

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

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

AWSSQSSource is the Schema for the event source.

func (*AWSSQSSource) AsEventSource 

func (s *AWSSQSSource) AsEventSource() string

AsEventSource implements EventSource.

func (*AWSSQSSource) DeepCopy 

func (in *AWSSQSSource) DeepCopy() *AWSSQSSource

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

func (*AWSSQSSource) DeepCopyInto 

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

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

func (*AWSSQSSource) DeepCopyObject 

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

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

func (*AWSSQSSource) GetConditionSet 

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

GetConditionSet implements duckv1.KRShaped.

func (*AWSSQSSource) GetEventTypes 

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

GetEventTypes implements EventSource.

func (*AWSSQSSource) GetGroupVersionKind 

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

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*AWSSQSSource) GetSink 

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

GetSink implements EventSource.

func (*AWSSQSSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*AWSSQSSource) GetStatusManager 

func (s *AWSSQSSource) GetStatusManager() *EventSourceStatusManager

GetStatusManager implements EventSource.

type AWSSQSSourceList 

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

AWSSQSSourceList contains a list of event sources.

func (*AWSSQSSourceList) DeepCopy 

func (in *AWSSQSSourceList) DeepCopy() *AWSSQSSourceList

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

func (*AWSSQSSourceList) DeepCopyInto 

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

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

func (*AWSSQSSourceList) DeepCopyObject 

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

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

type AWSSQSSourceReceiveOptions 

type AWSSQSSourceReceiveOptions struct {
	// Period of time during which Amazon SQS prevents other consumers from
	// receiving and processing a message that has been received via ReceiveMessage.
	// Expressed as a duration string, which format is documented at https://pkg.go.dev/time#ParseDuration.
	//
	// If not defined, the overall visibility timeout for the queue is used.
	//
	// For more details, please refer to the Amazon SQS Developer Guide at
	// https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/sqs-visibility-timeout.html.
	//
	// +optional
	VisibilityTimeout *apis.Duration `json:"visibilityTimeout,omitempty"`
}

AWSSQSSourceReceiveOptions defines options that control the behavior of Amazon SQS message receivers.

func (*AWSSQSSourceReceiveOptions) DeepCopy 

func (in *AWSSQSSourceReceiveOptions) DeepCopy() *AWSSQSSourceReceiveOptions

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

func (*AWSSQSSourceReceiveOptions) DeepCopyInto 

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

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

type AWSSQSSourceSpec 

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

	// Queue ARN
	// https://docs.aws.amazon.com/IAM/latest/UserGuide/list_amazonsqs.html#amazonsqs-resources-for-iam-policies
	ARN apis.ARN `json:"arn"`

	// Options that control the behavior of message receivers.
	// +optional
	ReceiveOptions *AWSSQSSourceReceiveOptions `json:"receiveOptions,omitempty"`

	// Credentials to interact with the Amazon SQS API.
	Credentials AWSSecurityCredentials `json:"credentials"`
}

AWSSQSSourceSpec defines the desired state of the event source.

func (*AWSSQSSourceSpec) DeepCopy 

func (in *AWSSQSSourceSpec) DeepCopy() *AWSSQSSourceSpec

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

func (*AWSSQSSourceSpec) DeepCopyInto 

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

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

type AWSSecurityCredentials 

type AWSSecurityCredentials struct {
	AccessKeyID     ValueFromField `json:"accessKeyID"`
	SecretAccessKey ValueFromField `json:"secretAccessKey"`
}

AWSSecurityCredentials represents a set of AWS security credentials. See https://docs.aws.amazon.com/general/latest/gr/aws-security-credentials.html

func (*AWSSecurityCredentials) DeepCopy 

func (in *AWSSecurityCredentials) DeepCopy() *AWSSecurityCredentials

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

func (*AWSSecurityCredentials) DeepCopyInto 

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

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

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 

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 

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 

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

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

func (*AzureActivityLogsSourceStatus) MarkSubscribed 

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 

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 

func (s *AzureBlobStorageSource) AsEventSource() string

AsEventSource implements EventSource.

func (*AzureBlobStorageSource) DeepCopy 

func (in *AzureBlobStorageSource) DeepCopy() *AzureBlobStorageSource

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

func (*AzureBlobStorageSource) DeepCopyInto 

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 

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

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

func (*AzureBlobStorageSource) GetConditionSet 

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

GetConditionSet implements duckv1.KRShaped.

func (*AzureBlobStorageSource) GetEventTypes 

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

GetEventTypes returns the event types generated by the source.

func (*AzureBlobStorageSource) GetGroupVersionKind 

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

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*AzureBlobStorageSource) GetSink 

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

GetSink implements EventSource.

func (*AzureBlobStorageSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*AzureBlobStorageSource) GetStatusManager 

func (s *AzureBlobStorageSource) GetStatusManager() *EventSourceStatusManager

GetStatusManager implements EventSource.

type AzureBlobStorageSourceList 

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 

func (in *AzureBlobStorageSourceList) DeepCopy() *AzureBlobStorageSourceList

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

func (*AzureBlobStorageSourceList) DeepCopyInto 

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 

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

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

type AzureBlobStorageSourceSpec 

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 

func (in *AzureBlobStorageSourceSpec) DeepCopy() *AzureBlobStorageSourceSpec

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

func (*AzureBlobStorageSourceSpec) DeepCopyInto 

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 

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 

func (in *AzureBlobStorageSourceStatus) DeepCopy() *AzureBlobStorageSourceStatus

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

func (*AzureBlobStorageSourceStatus) DeepCopyInto 

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 

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

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

func (*AzureBlobStorageSourceStatus) MarkSubscribed 

func (s *AzureBlobStorageSourceStatus) MarkSubscribed()

MarkSubscribed sets the Subscribed condition to True.

type AzureEventGridSource 

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 

func (s *AzureEventGridSource) AsEventSource() string

AsEventSource implements EventSource.

func (*AzureEventGridSource) DeepCopy 

func (in *AzureEventGridSource) DeepCopy() *AzureEventGridSource

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

func (*AzureEventGridSource) DeepCopyInto 

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 

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

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

func (*AzureEventGridSource) GetConditionSet 

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

GetConditionSet implements duckv1.KRShaped.

func (*AzureEventGridSource) GetEventTypes 

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

GetEventTypes returns the event types generated by the source.

func (*AzureEventGridSource) GetGroupVersionKind 

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

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*AzureEventGridSource) GetSink 

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

GetSink implements EventSource.

func (*AzureEventGridSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*AzureEventGridSource) GetStatusManager 

func (s *AzureEventGridSource) GetStatusManager() *EventSourceStatusManager

GetStatusManager implements EventSource.

type AzureEventGridSourceList 

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 

func (in *AzureEventGridSourceList) DeepCopy() *AzureEventGridSourceList

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

func (*AzureEventGridSourceList) DeepCopyInto 

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 

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

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

type AzureEventGridSourceSpec 

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 

func (in *AzureEventGridSourceSpec) DeepCopy() *AzureEventGridSourceSpec

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

func (*AzureEventGridSourceSpec) DeepCopyInto 

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 

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 

func (in *AzureEventGridSourceStatus) DeepCopy() *AzureEventGridSourceStatus

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

func (*AzureEventGridSourceStatus) DeepCopyInto 

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 

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

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

func (*AzureEventGridSourceStatus) MarkSubscribed 

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 

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 

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 

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 AzureIOTHubSource 

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

	Spec   AzureIOTHubSourceSpec   `json:"spec,omitempty"`
	Status AzureIOTHubSourceStatus `json:"status,omitempty"`
}

AzureIOTHubSource is the Schema for the event source.

func (*AzureIOTHubSource) AsEventSource 

func (s *AzureIOTHubSource) AsEventSource() string

AsEventSource implements EventSource.

func (*AzureIOTHubSource) DeepCopy 

func (in *AzureIOTHubSource) DeepCopy() *AzureIOTHubSource

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

func (*AzureIOTHubSource) DeepCopyInto 

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

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

func (*AzureIOTHubSource) DeepCopyObject 

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

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

func (*AzureIOTHubSource) GetConditionSet 

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

GetConditionSet implements duckv1.KRShaped.

func (*AzureIOTHubSource) GetEventTypes 

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

GetEventTypes returns the event types generated by the source.

func (*AzureIOTHubSource) GetGroupVersionKind 

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

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*AzureIOTHubSource) GetSink 

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

GetSink implements EventSource.

func (*AzureIOTHubSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*AzureIOTHubSource) GetStatusManager 

func (s *AzureIOTHubSource) GetStatusManager() *EventSourceStatusManager

GetStatusManager implements EventSource.

type AzureIOTHubSourceList 

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

AzureIOTHubSourceList contains a list of event sources.

func (*AzureIOTHubSourceList) DeepCopy 

func (in *AzureIOTHubSourceList) DeepCopy() *AzureIOTHubSourceList

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

func (*AzureIOTHubSourceList) DeepCopyInto 

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

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

func (*AzureIOTHubSourceList) DeepCopyObject 

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

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

type AzureIOTHubSourceSpec 

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

	// AzureAuth contains multiple authentication methods for Azure services.
	Auth AzureAuth `json:"auth,omitempty"`
}

AzureIOTHubSourceSpec defines the desired state of the event source.

func (*AzureIOTHubSourceSpec) DeepCopy 

func (in *AzureIOTHubSourceSpec) DeepCopy() *AzureIOTHubSourceSpec

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

func (*AzureIOTHubSourceSpec) DeepCopyInto 

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

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

type AzureIOTHubSourceStatus 

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

AzureIOTHubSourceStatus defines the observed state of the event source.

func (*AzureIOTHubSourceStatus) DeepCopy 

func (in *AzureIOTHubSourceStatus) DeepCopy() *AzureIOTHubSourceStatus

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

func (*AzureIOTHubSourceStatus) DeepCopyInto 

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

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

type AzureQueueStorageSource 

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 

func (s *AzureQueueStorageSource) AsEventSource() string

AsEventSource implements EventSource.

func (*AzureQueueStorageSource) DeepCopy 

func (in *AzureQueueStorageSource) DeepCopy() *AzureQueueStorageSource

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

func (*AzureQueueStorageSource) DeepCopyInto 

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 

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

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

func (*AzureQueueStorageSource) GetConditionSet 

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

GetConditionSet implements duckv1.KRShaped.

func (*AzureQueueStorageSource) GetEventTypes 

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

GetEventTypes returns the event types generated by the source.

func (*AzureQueueStorageSource) GetGroupVersionKind 

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

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*AzureQueueStorageSource) GetSink 

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

GetSink implements EventSource.

func (*AzureQueueStorageSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*AzureQueueStorageSource) GetStatusManager 

func (s *AzureQueueStorageSource) GetStatusManager() *EventSourceStatusManager

GetStatusManager implements EventSource.

type AzureQueueStorageSourceList 

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 

func (in *AzureQueueStorageSourceList) DeepCopy() *AzureQueueStorageSourceList

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

func (*AzureQueueStorageSourceList) DeepCopyInto 

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 

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

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

type AzureQueueStorageSourceSpec 

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 

func (in *AzureQueueStorageSourceSpec) DeepCopy() *AzureQueueStorageSourceSpec

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

func (*AzureQueueStorageSourceSpec) DeepCopyInto 

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 

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 

func (in *AzureResourceID) DeepCopy() *AzureResourceID

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

func (*AzureResourceID) DeepCopyInto 

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 

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

MarshalJSON implements json.Marshaler

func (*AzureResourceID) String 

func (rID *AzureResourceID) String() string

String implements the fmt.Stringer interface.

func (*AzureResourceID) UnmarshalJSON 

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 

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 

func (s *AzureServiceBusQueueSource) AsEventSource() string

AsEventSource implements EventSource.

func (*AzureServiceBusQueueSource) DeepCopy 

func (in *AzureServiceBusQueueSource) DeepCopy() *AzureServiceBusQueueSource

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

func (*AzureServiceBusQueueSource) DeepCopyInto 

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 

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

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

func (*AzureServiceBusQueueSource) GetConditionSet 

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

GetConditionSet implements duckv1.KRShaped.

func (*AzureServiceBusQueueSource) GetEventTypes 

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

GetEventTypes returns the event types generated by the source.

func (*AzureServiceBusQueueSource) GetGroupVersionKind 

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

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*AzureServiceBusQueueSource) GetSink 

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

GetSink implements EventSource.

func (*AzureServiceBusQueueSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*AzureServiceBusQueueSource) GetStatusManager 

func (s *AzureServiceBusQueueSource) GetStatusManager() *EventSourceStatusManager

GetStatusManager implements EventSource.

type AzureServiceBusQueueSourceList 

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 

func (in *AzureServiceBusQueueSourceList) DeepCopy() *AzureServiceBusQueueSourceList

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

func (*AzureServiceBusQueueSourceList) DeepCopyInto 

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 

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

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

type AzureServiceBusQueueSourceSpec 

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

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

AzureServiceBusQueueSourceSpec defines the desired state of the event source.

func (*AzureServiceBusQueueSourceSpec) DeepCopy 

func (in *AzureServiceBusQueueSourceSpec) DeepCopy() *AzureServiceBusQueueSourceSpec

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

func (*AzureServiceBusQueueSourceSpec) DeepCopyInto 

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 

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

AzureServiceBusQueueSourceStatus defines the observed state of the event source.

func (*AzureServiceBusQueueSourceStatus) DeepCopy 

func (in *AzureServiceBusQueueSourceStatus) DeepCopy() *AzureServiceBusQueueSourceStatus

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

func (*AzureServiceBusQueueSourceStatus) DeepCopyInto 

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 

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 

func (in *EventHubResourceID) DeepCopy() *EventHubResourceID

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

func (*EventHubResourceID) DeepCopyInto 

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 

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

MarshalJSON implements json.Marshaler

func (*EventHubResourceID) String 

func (rID *EventHubResourceID) String() string

String implements the fmt.Stringer interface.

func (*EventHubResourceID) UnmarshalJSON 

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 

type EventSourceStatusManager struct {
	apis.ConditionSet
	*EventSourceStatus
}

EventSourceStatusManager manages the status of event sources.

+k8s:deepcopy-gen=false

func (*EventSourceStatusManager) MarkNoSink 

func (m *EventSourceStatusManager) MarkNoSink()

MarkNoSink sets the SinkProvided condition to False.

func (*EventSourceStatusManager) MarkRBACNotBound 

func (m *EventSourceStatusManager) MarkRBACNotBound()

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

func (*EventSourceStatusManager) MarkSink 

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

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

func (*EventSourceStatusManager) PropagateDeploymentAvailability 

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 

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 

func (m *EventSourceStatusManager) SetRoute(urlPath string)

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

type GCloudResourceName 

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 

func (in *GCloudResourceName) DeepCopy() *GCloudResourceName

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

func (*GCloudResourceName) DeepCopyInto 

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 

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

MarshalJSON implements json.Marshaler

func (*GCloudResourceName) String 

func (n *GCloudResourceName) String() string

String implements the fmt.Stringer interface.

func (*GCloudResourceName) UnmarshalJSON 

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

UnmarshalJSON implements json.Unmarshaler

type GoogleCloudAuditLogsSource 

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 

func (s *GoogleCloudAuditLogsSource) AsEventSource() string

AsEventSource implements EventSource.

func (*GoogleCloudAuditLogsSource) DeepCopy 

func (in *GoogleCloudAuditLogsSource) DeepCopy() *GoogleCloudAuditLogsSource

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

func (*GoogleCloudAuditLogsSource) DeepCopyInto 

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 

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

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

func (*GoogleCloudAuditLogsSource) GetConditionSet 

func (*GoogleCloudAuditLogsSource) GetConditionSet() apis.ConditionSet

GetConditionSet implements duckv1.KRShaped.

func (*GoogleCloudAuditLogsSource) GetEventTypes 

func (*GoogleCloudAuditLogsSource) GetEventTypes() []string

GetEventTypes returns the event types generated by the source.

func (*GoogleCloudAuditLogsSource) GetGroupVersionKind 

func (*GoogleCloudAuditLogsSource) GetGroupVersionKind() schema.GroupVersionKind

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*GoogleCloudAuditLogsSource) GetSink 

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

GetSink implements EventSource.

func (*GoogleCloudAuditLogsSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*GoogleCloudAuditLogsSource) GetStatusManager 

func (s *GoogleCloudAuditLogsSource) GetStatusManager() *EventSourceStatusManager

GetStatusManager implements EventSource.

type GoogleCloudAuditLogsSourceList 

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 

func (in *GoogleCloudAuditLogsSourceList) DeepCopy() *GoogleCloudAuditLogsSourceList

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

func (*GoogleCloudAuditLogsSourceList) DeepCopyInto 

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 

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

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

type GoogleCloudAuditLogsSourcePubSubSpec 

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 *GCloudResourceName `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 

func (in *GoogleCloudAuditLogsSourcePubSubSpec) DeepCopy() *GoogleCloudAuditLogsSourcePubSubSpec

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

func (*GoogleCloudAuditLogsSourcePubSubSpec) DeepCopyInto 

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 

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 

func (in *GoogleCloudAuditLogsSourceSpec) DeepCopy() *GoogleCloudAuditLogsSourceSpec

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

func (*GoogleCloudAuditLogsSourceSpec) DeepCopyInto 

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 

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 *GCloudResourceName `json:"topic,omitempty"`

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

GoogleCloudAuditLogsSourceStatus defines the observed state of the event source.

func (*GoogleCloudAuditLogsSourceStatus) DeepCopy 

func (in *GoogleCloudAuditLogsSourceStatus) DeepCopy() *GoogleCloudAuditLogsSourceStatus

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

func (*GoogleCloudAuditLogsSourceStatus) DeepCopyInto 

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 

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

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

func (*GoogleCloudAuditLogsSourceStatus) MarkSubscribed 

func (s *GoogleCloudAuditLogsSourceStatus) MarkSubscribed()

MarkSubscribed sets the Subscribed condition to True.

type GoogleCloudBillingSource 

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 

func (s *GoogleCloudBillingSource) AsEventSource() string

AsEventSource implements EventSource.

func (*GoogleCloudBillingSource) DeepCopy 

func (in *GoogleCloudBillingSource) DeepCopy() *GoogleCloudBillingSource

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

func (*GoogleCloudBillingSource) DeepCopyInto 

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 

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

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

func (*GoogleCloudBillingSource) GetConditionSet 

func (*GoogleCloudBillingSource) GetConditionSet() apis.ConditionSet

GetConditionSet implements duckv1.KRShaped.

func (*GoogleCloudBillingSource) GetEventTypes 

func (*GoogleCloudBillingSource) GetEventTypes() []string

GetEventTypes returns the event types generated by the source.

func (*GoogleCloudBillingSource) GetGroupVersionKind 

func (*GoogleCloudBillingSource) GetGroupVersionKind() schema.GroupVersionKind

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*GoogleCloudBillingSource) GetSink 

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

GetSink implements EventSource.

func (*GoogleCloudBillingSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*GoogleCloudBillingSource) GetStatusManager 

func (s *GoogleCloudBillingSource) GetStatusManager() *EventSourceStatusManager

GetStatusManager implements EventSource.

type GoogleCloudBillingSourceList 

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 

func (in *GoogleCloudBillingSourceList) DeepCopy() *GoogleCloudBillingSourceList

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

func (*GoogleCloudBillingSourceList) DeepCopyInto 

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 

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

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

type GoogleCloudBillingSourcePubSubSpec 

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 *GCloudResourceName `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 

func (in *GoogleCloudBillingSourcePubSubSpec) DeepCopy() *GoogleCloudBillingSourcePubSubSpec

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

func (*GoogleCloudBillingSourcePubSubSpec) DeepCopyInto 

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 

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 

func (in *GoogleCloudBillingSourceSpec) DeepCopy() *GoogleCloudBillingSourceSpec

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

func (*GoogleCloudBillingSourceSpec) DeepCopyInto 

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 

type GoogleCloudBillingSourceStatus 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"`
}

GoogleCloudBillingSourceStatus defines the observed state of the event source.

func (*GoogleCloudBillingSourceStatus) DeepCopy 

func (in *GoogleCloudBillingSourceStatus) DeepCopy() *GoogleCloudBillingSourceStatus

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

func (*GoogleCloudBillingSourceStatus) DeepCopyInto 

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 

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

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

func (*GoogleCloudBillingSourceStatus) MarkSubscribed 

func (s *GoogleCloudBillingSourceStatus) MarkSubscribed()

MarkSubscribed sets the Subscribed condition to True.

type GoogleCloudPubSubSource 

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 

func (s *GoogleCloudPubSubSource) AsEventSource() string

AsEventSource implements EventSource.

func (*GoogleCloudPubSubSource) DeepCopy 

func (in *GoogleCloudPubSubSource) DeepCopy() *GoogleCloudPubSubSource

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

func (*GoogleCloudPubSubSource) DeepCopyInto 

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 

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

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

func (*GoogleCloudPubSubSource) GetConditionSet 

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

GetConditionSet implements duckv1.KRShaped.

func (*GoogleCloudPubSubSource) GetEventTypes 

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

GetEventTypes returns the event types generated by the source.

func (*GoogleCloudPubSubSource) GetGroupVersionKind 

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

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*GoogleCloudPubSubSource) GetSink 

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

GetSink implements EventSource.

func (*GoogleCloudPubSubSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*GoogleCloudPubSubSource) GetStatusManager 

func (s *GoogleCloudPubSubSource) GetStatusManager() *EventSourceStatusManager

GetStatusManager implements EventSource.

type GoogleCloudPubSubSourceList 

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 

func (in *GoogleCloudPubSubSourceList) DeepCopy() *GoogleCloudPubSubSourceList

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

func (*GoogleCloudPubSubSourceList) DeepCopyInto 

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 

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

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

type GoogleCloudPubSubSourceSpec 

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 GCloudResourceName `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 

func (in *GoogleCloudPubSubSourceSpec) DeepCopy() *GoogleCloudPubSubSourceSpec

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

func (*GoogleCloudPubSubSourceSpec) DeepCopyInto 

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 

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

GoogleCloudPubSubSourceStatus defines the observed state of the event source.

func (*GoogleCloudPubSubSourceStatus) DeepCopy 

func (in *GoogleCloudPubSubSourceStatus) DeepCopy() *GoogleCloudPubSubSourceStatus

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

func (*GoogleCloudPubSubSourceStatus) DeepCopyInto 

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 

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

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

func (*GoogleCloudPubSubSourceStatus) MarkSubscribed 

func (s *GoogleCloudPubSubSourceStatus) MarkSubscribed()

MarkSubscribed sets the Subscribed condition to True.

type GoogleCloudRepositoriesSource 

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 

func (s *GoogleCloudRepositoriesSource) AsEventSource() string

AsEventSource implements EventSource.

func (*GoogleCloudRepositoriesSource) DeepCopy 

func (in *GoogleCloudRepositoriesSource) DeepCopy() *GoogleCloudRepositoriesSource

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

func (*GoogleCloudRepositoriesSource) DeepCopyInto 

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 

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

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

func (*GoogleCloudRepositoriesSource) GetConditionSet 

func (*GoogleCloudRepositoriesSource) GetConditionSet() apis.ConditionSet

GetConditionSet implements duckv1.KRShaped.

func (*GoogleCloudRepositoriesSource) GetEventTypes 

func (*GoogleCloudRepositoriesSource) GetEventTypes() []string

GetEventTypes returns the event types generated by the source.

func (*GoogleCloudRepositoriesSource) GetGroupVersionKind 

func (*GoogleCloudRepositoriesSource) GetGroupVersionKind() schema.GroupVersionKind

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*GoogleCloudRepositoriesSource) GetSink 

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

GetSink implements EventSource.

func (*GoogleCloudRepositoriesSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*GoogleCloudRepositoriesSource) GetStatusManager 

func (s *GoogleCloudRepositoriesSource) GetStatusManager() *EventSourceStatusManager

GetStatusManager implements EventSource.

type GoogleCloudRepositoriesSourceList 

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 

func (in *GoogleCloudRepositoriesSourceList) DeepCopy() *GoogleCloudRepositoriesSourceList

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

func (*GoogleCloudRepositoriesSourceList) DeepCopyInto 

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 

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

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

type GoogleCloudRepositoriesSourcePubSubSpec 

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 

func (in *GoogleCloudRepositoriesSourcePubSubSpec) DeepCopy() *GoogleCloudRepositoriesSourcePubSubSpec

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

func (*GoogleCloudRepositoriesSourcePubSubSpec) DeepCopyInto 

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 

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 

func (in *GoogleCloudRepositoriesSourceSpec) DeepCopy() *GoogleCloudRepositoriesSourceSpec

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

func (*GoogleCloudRepositoriesSourceSpec) DeepCopyInto 

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 

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 

func (in *GoogleCloudRepositoriesSourceStatus) DeepCopy() *GoogleCloudRepositoriesSourceStatus

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

func (*GoogleCloudRepositoriesSourceStatus) DeepCopyInto 

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 

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

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

func (*GoogleCloudRepositoriesSourceStatus) MarkSubscribed 

func (s *GoogleCloudRepositoriesSourceStatus) MarkSubscribed()

MarkSubscribed sets the Subscribed condition to True.

type GoogleCloudStorageSource 

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 

func (s *GoogleCloudStorageSource) AsEventSource() string

AsEventSource implements EventSource.

func (*GoogleCloudStorageSource) DeepCopy 

func (in *GoogleCloudStorageSource) DeepCopy() *GoogleCloudStorageSource

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

func (*GoogleCloudStorageSource) DeepCopyInto 

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 

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

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

func (*GoogleCloudStorageSource) GetConditionSet 

func (*GoogleCloudStorageSource) GetConditionSet() apis.ConditionSet

GetConditionSet implements duckv1.KRShaped.

func (*GoogleCloudStorageSource) GetEventTypes 

func (*GoogleCloudStorageSource) GetEventTypes() []string

GetEventTypes returns the event types generated by the source.

func (*GoogleCloudStorageSource) GetGroupVersionKind 

func (*GoogleCloudStorageSource) GetGroupVersionKind() schema.GroupVersionKind

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*GoogleCloudStorageSource) GetSink 

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

GetSink implements EventSource.

func (*GoogleCloudStorageSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*GoogleCloudStorageSource) GetStatusManager 

func (s *GoogleCloudStorageSource) GetStatusManager() *EventSourceStatusManager

GetStatusManager implements EventSource.

type GoogleCloudStorageSourceList 

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 

func (in *GoogleCloudStorageSourceList) DeepCopy() *GoogleCloudStorageSourceList

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

func (*GoogleCloudStorageSourceList) DeepCopyInto 

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 

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

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

type GoogleCloudStorageSourcePubSubSpec 

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 *GCloudResourceName `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 

func (in *GoogleCloudStorageSourcePubSubSpec) DeepCopy() *GoogleCloudStorageSourcePubSubSpec

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

func (*GoogleCloudStorageSourcePubSubSpec) DeepCopyInto 

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 

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 

func (in *GoogleCloudStorageSourceSpec) DeepCopy() *GoogleCloudStorageSourceSpec

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

func (*GoogleCloudStorageSourceSpec) DeepCopyInto 

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 

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 *GCloudResourceName `json:"topic,omitempty"`
	// Resource name of the managed Pub/Sub subscription associated with
	// the managed topic.
	Subscription *GCloudResourceName `json:"subscription,omitempty"`
}

GoogleCloudStorageSourceStatus defines the observed state of the event source.

func (*GoogleCloudStorageSourceStatus) DeepCopy 

func (in *GoogleCloudStorageSourceStatus) DeepCopy() *GoogleCloudStorageSourceStatus

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

func (*GoogleCloudStorageSourceStatus) DeepCopyInto 

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 

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

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

func (*GoogleCloudStorageSourceStatus) MarkSubscribed 

func (s *GoogleCloudStorageSourceStatus) MarkSubscribed()

MarkSubscribed sets the Subscribed condition to True.

type HTTPPollerSource 

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

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

HTTPPollerSource is the schema for the event source.

func (*HTTPPollerSource) AsEventSource 

func (s *HTTPPollerSource) AsEventSource() string

AsEventSource implements EventSource.

func (*HTTPPollerSource) DeepCopy 

func (in *HTTPPollerSource) DeepCopy() *HTTPPollerSource

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

func (*HTTPPollerSource) DeepCopyInto 

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

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

func (*HTTPPollerSource) DeepCopyObject 

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

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

func (*HTTPPollerSource) GetConditionSet 

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

GetConditionSet implements duckv1.KRShaped.

func (*HTTPPollerSource) GetEventTypes 

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

GetEventTypes implements EventSource.

func (*HTTPPollerSource) GetGroupVersionKind 

func (*HTTPPollerSource) GetGroupVersionKind() schema.GroupVersionKind

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*HTTPPollerSource) GetSink 

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

GetSink implements EventSource.

func (*HTTPPollerSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*HTTPPollerSource) GetStatusManager 

func (s *HTTPPollerSource) GetStatusManager() *EventSourceStatusManager

GetStatusManager implements EventSource.

type HTTPPollerSourceList 

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

HTTPPollerSourceList contains a list of event sources.

func (*HTTPPollerSourceList) DeepCopy 

func (in *HTTPPollerSourceList) DeepCopy() *HTTPPollerSourceList

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

func (*HTTPPollerSourceList) DeepCopyInto 

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

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

func (*HTTPPollerSourceList) DeepCopyObject 

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

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

type HTTPPollerSourceSpec 

type HTTPPollerSourceSpec 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"`

	// Value of the CloudEvents 'type' attribute to set on ingested events.
	// https://github.com/cloudevents/spec/blob/v1.0.1/spec.md#type
	EventType string `json:"eventType"`

	// Value of the CloudEvents 'source' attribute to set on ingested events.
	// https://github.com/cloudevents/spec/blob/v1.0.1/spec.md#source-1
	// +optional
	EventSource *string `json:"eventSource,omitempty"`

	// HTTP/S URL of the endpoint to poll data from.
	Endpoint apis.URL `json:"endpoint"`

	// HTTP request method to use in requests to the specified 'endpoint'.
	// https://developer.mozilla.org/en-US/docs/Web/HTTP/Methods
	Method string `json:"method"`

	// Controls whether the HTTP client verifies the server's certificate
	// chain and host name when communicating over TLS.
	// +optional
	SkipVerify *bool `json:"skipVerify,omitempty"`

	// CA certificate in X.509 format the HTTP client should use to verify
	// the identity of remote servers when communicating over TLS.
	// +optional
	CACertificate *string `json:"caCertificate,omitempty"`

	// User name to set in HTTP requests that require HTTP Basic authentication.
	// +optional
	BasicAuthUsername *string `json:"basicAuthUsername,omitempty"`

	// Password to set in HTTP requests that require HTTP Basic authentication.
	// +optional
	BasicAuthPassword *ValueFromField `json:"basicAuthPassword,omitempty"`

	// HTTP headers to include in HTTP requests.
	// +optional
	Headers map[string]string `json:"headers,omitempty"`

	// Duration which defines how often the HTTP/S endpoint should be polled.
	// Expressed as a duration string, which format is documented at https://pkg.go.dev/time#ParseDuration.
	Interval tmapis.Duration `json:"interval"`
}

HTTPPollerSourceSpec defines the desired state of the event source.

func (*HTTPPollerSourceSpec) DeepCopy 

func (in *HTTPPollerSourceSpec) DeepCopy() *HTTPPollerSourceSpec

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

func (*HTTPPollerSourceSpec) DeepCopyInto 

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

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

type OCIMetrics 

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"`
}

OCIMetrics represents OCI metrics structure.

func (*OCIMetrics) DeepCopy 

func (in *OCIMetrics) DeepCopy() *OCIMetrics

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

func (*OCIMetrics) DeepCopyInto 

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 

type OCIMetricsDecodedList []OCIMetrics

OCIMetricsDecodedList is a list of OCI metrics.

func (*OCIMetricsDecodedList) Decode 

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

Decode deserializes a list of OCI metrics.

func (OCIMetricsDecodedList) DeepCopy 

func (in OCIMetricsDecodedList) DeepCopy() OCIMetricsDecodedList

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

func (OCIMetricsDecodedList) DeepCopyInto 

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 

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 

func (s *OCIMetricsSource) AsEventSource() string

AsEventSource implements EventSource.

func (*OCIMetricsSource) DeepCopy 

func (in *OCIMetricsSource) DeepCopy() *OCIMetricsSource

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

func (*OCIMetricsSource) DeepCopyInto 

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 

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

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

func (*OCIMetricsSource) GetConditionSet 

func (*OCIMetricsSource) GetConditionSet() pkgapis.ConditionSet

GetConditionSet implements duckv1.KRShaped.

func (*OCIMetricsSource) GetEventTypes 

func (*OCIMetricsSource) GetEventTypes() []string

GetEventTypes implements EventSource.

func (*OCIMetricsSource) GetGroupVersionKind 

func (*OCIMetricsSource) GetGroupVersionKind() schema.GroupVersionKind

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*OCIMetricsSource) GetSink 

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

GetSink implements EventSource.

func (*OCIMetricsSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*OCIMetricsSource) GetStatusManager 

func (s *OCIMetricsSource) GetStatusManager() *EventSourceStatusManager

GetStatusManager implements EventSource.

type OCIMetricsSourceList 

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 

func (in *OCIMetricsSourceList) DeepCopy() *OCIMetricsSourceList

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

func (*OCIMetricsSourceList) DeepCopyInto 

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 

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

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

type OCIMetricsSourceSpec 

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 

func (in *OCIMetricsSourceSpec) DeepCopy() *OCIMetricsSourceSpec

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

func (*OCIMetricsSourceSpec) DeepCopyInto 

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 

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 

func (in *SalesforceAuth) DeepCopy() *SalesforceAuth

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

func (*SalesforceAuth) DeepCopyInto 

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 

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 

func (s *SalesforceSource) AsEventSource() string

AsEventSource implements EventSource.

func (*SalesforceSource) DeepCopy 

func (in *SalesforceSource) DeepCopy() *SalesforceSource

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

func (*SalesforceSource) DeepCopyInto 

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 

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

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

func (*SalesforceSource) GetConditionSet 

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

GetConditionSet implements duckv1.KRShaped.

func (*SalesforceSource) GetEventTypes 

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

GetEventTypes returns the event types generated by the source.

func (*SalesforceSource) GetGroupVersionKind 

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

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*SalesforceSource) GetSink 

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

GetSink implements EventSource.

func (*SalesforceSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*SalesforceSource) GetStatusManager 

func (s *SalesforceSource) GetStatusManager() *EventSourceStatusManager

GetStatusManager implements EventSource.

type SalesforceSourceList 

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 

func (in *SalesforceSourceList) DeepCopy() *SalesforceSourceList

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

func (*SalesforceSourceList) DeepCopyInto 

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 

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

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

type SalesforceSourceSpec 

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 

func (in *SalesforceSourceSpec) DeepCopy() *SalesforceSourceSpec

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

func (*SalesforceSourceSpec) DeepCopyInto 

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 

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

SalesforceSubscription to connect to.

func (*SalesforceSubscription) DeepCopy 

func (in *SalesforceSubscription) DeepCopy() *SalesforceSubscription

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

func (*SalesforceSubscription) DeepCopyInto 

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

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

type SlackSource 

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

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

SlackSource is the schema for the event source.

func (*SlackSource) AsEventSource 

func (s *SlackSource) AsEventSource() string

AsEventSource implements EventSource.

func (*SlackSource) DeepCopy 

func (in *SlackSource) DeepCopy() *SlackSource

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

func (*SlackSource) DeepCopyInto 

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

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

func (*SlackSource) DeepCopyObject 

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

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

func (*SlackSource) GetConditionSet 

func (*SlackSource) GetConditionSet() pkgapis.ConditionSet

GetConditionSet implements duckv1.KRShaped.

func (*SlackSource) GetEventTypes 

func (*SlackSource) GetEventTypes() []string

GetEventTypes implements EventSource.

func (*SlackSource) GetGroupVersionKind 

func (*SlackSource) GetGroupVersionKind() schema.GroupVersionKind

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*SlackSource) GetSink 

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

GetSink implements EventSource.

func (*SlackSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*SlackSource) GetStatusManager 

func (s *SlackSource) GetStatusManager() *EventSourceStatusManager

GetStatusManager implements EventSource.

type SlackSourceList 

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

SlackSourceList contains a list of event sources.

func (*SlackSourceList) DeepCopy 

func (in *SlackSourceList) DeepCopy() *SlackSourceList

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

func (*SlackSourceList) DeepCopyInto 

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

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

func (*SlackSourceList) DeepCopyObject 

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

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

type SlackSourceSpec 

type SlackSourceSpec 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"`

	// SigningSecret can be set to the value of Slack request signing secret
	// to authenticate callbacks.
	// See: https://api.slack.com/authentication/verifying-requests-from-slack
	// +optional
	SigningSecret *ValueFromField `json:"signingSecret,omitempty"`

	// AppID identifies the Slack application generating this event.
	// It helps identifying the App sourcing events when multiple Slack
	// applications shared an endpoint. See: https://api.slack.com/events-api
	// +optional
	AppID *string `json:"appID,omitempty"`
}

SlackSourceSpec defines the desired state of the event source.

func (*SlackSourceSpec) DeepCopy 

func (in *SlackSourceSpec) DeepCopy() *SlackSourceSpec

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

func (*SlackSourceSpec) DeepCopyInto 

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

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

type StorageAccountResourceID 

type StorageAccountResourceID struct {
	SubscriptionID string
	ResourceGroup  string
	StorageAccount string
}

StorageAccountResourceID represents a resource ID for a Storage Account.

func (*StorageAccountResourceID) DeepCopy 

func (in *StorageAccountResourceID) DeepCopy() *StorageAccountResourceID

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

func (*StorageAccountResourceID) DeepCopyInto 

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 

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

MarshalJSON implements json.Marshaler

func (*StorageAccountResourceID) String 

func (rID *StorageAccountResourceID) String() string

String implements the fmt.Stringer interface.

func (*StorageAccountResourceID) UnmarshalJSON 

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

UnmarshalJSON implements json.Unmarshaler

type TwilioSource 

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 

func (s *TwilioSource) AsEventSource() string

AsEventSource implements EventSource.

func (*TwilioSource) DeepCopy 

func (in *TwilioSource) DeepCopy() *TwilioSource

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

func (*TwilioSource) DeepCopyInto 

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 

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

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

func (*TwilioSource) GetConditionSet 

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

GetConditionSet implements duckv1.KRShaped.

func (*TwilioSource) GetEventTypes 

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

GetEventTypes implements EventSource.

func (*TwilioSource) GetGroupVersionKind 

func (*TwilioSource) GetGroupVersionKind() schema.GroupVersionKind

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*TwilioSource) GetSink 

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

GetSink implements EventSource.

func (*TwilioSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*TwilioSource) GetStatusManager 

func (s *TwilioSource) GetStatusManager() *EventSourceStatusManager

GetStatusManager implements EventSource.

type TwilioSourceList 

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 

func (in *TwilioSourceList) DeepCopy() *TwilioSourceList

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

func (*TwilioSourceList) DeepCopyInto 

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 

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

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

type TwilioSourceSpec 

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

TwilioSourceSpec defines the desired state of the event source.

func (*TwilioSourceSpec) DeepCopy 

func (in *TwilioSourceSpec) DeepCopy() *TwilioSourceSpec

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

func (*TwilioSourceSpec) DeepCopyInto 

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.

type WebhookSource 

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

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

WebhookSource is the schema for the event source.

func (*WebhookSource) AsEventSource 

func (s *WebhookSource) AsEventSource() string

AsEventSource implements EventSource.

func (*WebhookSource) DeepCopy 

func (in *WebhookSource) DeepCopy() *WebhookSource

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

func (*WebhookSource) DeepCopyInto 

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

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

func (*WebhookSource) DeepCopyObject 

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

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

func (*WebhookSource) GetConditionSet 

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

GetConditionSet implements duckv1.KRShaped.

func (*WebhookSource) GetEventTypes 

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

GetEventTypes implements EventSource.

func (*WebhookSource) GetGroupVersionKind 

func (*WebhookSource) GetGroupVersionKind() schema.GroupVersionKind

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*WebhookSource) GetSink 

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

GetSink implements EventSource.

func (*WebhookSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*WebhookSource) GetStatusManager 

func (s *WebhookSource) GetStatusManager() *EventSourceStatusManager

GetStatusManager implements EventSource.

type WebhookSourceList 

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

WebhookSourceList contains a list of event sources.

func (*WebhookSourceList) DeepCopy 

func (in *WebhookSourceList) DeepCopy() *WebhookSourceList

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

func (*WebhookSourceList) DeepCopyInto 

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

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

func (*WebhookSourceList) DeepCopyObject 

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

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

type WebhookSourceSpec 

type WebhookSourceSpec 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"`

	// Value of the CloudEvents 'type' attribute to set on ingested events.
	// https://github.com/cloudevents/spec/blob/v1.0.1/spec.md#type
	EventType string `json:"eventType"`

	// Value of the CloudEvents 'source' attribute to set on ingested events.
	// https://github.com/cloudevents/spec/blob/v1.0.1/spec.md#source-1
	// +optional
	EventSource *string `json:"eventSource,omitempty"`

	// User name HTTP clients must set to authenticate with the webhook using HTTP Basic authentication.
	// +optional
	BasicAuthUsername *string `json:"basicAuthUsername,omitempty"`

	// Password HTTP clients must set to authenticate with the webhook using HTTP Basic authentication.
	// +optional
	BasicAuthPassword *ValueFromField `json:"basicAuthPassword,omitempty"`
}

WebhookSourceSpec defines the desired state of the event source.

func (*WebhookSourceSpec) DeepCopy 

func (in *WebhookSourceSpec) DeepCopy() *WebhookSourceSpec

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

func (*WebhookSourceSpec) DeepCopyInto 

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

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

type ZendeskSource 

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

	Spec   ZendeskSourceSpec   `json:"spec,omitempty"`
	Status ZendeskSourceStatus `json:"status,omitempty"`
}

ZendeskSource is the schema for the event source.

func (*ZendeskSource) AsEventSource 

func (s *ZendeskSource) AsEventSource() string

AsEventSource implements EventSource.

func (*ZendeskSource) DeepCopy 

func (in *ZendeskSource) DeepCopy() *ZendeskSource

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

func (*ZendeskSource) DeepCopyInto 

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

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

func (*ZendeskSource) DeepCopyObject 

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

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

func (*ZendeskSource) GetConditionSet 

func (*ZendeskSource) GetConditionSet() apis.ConditionSet

GetConditionSet implements duckv1.KRShaped.

func (*ZendeskSource) GetEventTypes 

func (*ZendeskSource) GetEventTypes() []string

GetEventTypes implements EventSource.

func (*ZendeskSource) GetGroupVersionKind 

func (*ZendeskSource) GetGroupVersionKind() schema.GroupVersionKind

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*ZendeskSource) GetSink 

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

GetSink implements EventSource.

func (*ZendeskSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*ZendeskSource) GetStatusManager 

func (s *ZendeskSource) GetStatusManager() *EventSourceStatusManager

GetStatusManager implements EventSource.

func (*ZendeskSource) GetUntypedSpec 

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

GetUntypedSpec implements apis.HasSpec.

func (*ZendeskSource) IsMultiTenant 

func (*ZendeskSource) IsMultiTenant() bool

IsMultiTenant implements MultiTenant.

type ZendeskSourceList 

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

ZendeskSourceList contains a list of event sources.

func (*ZendeskSourceList) DeepCopy 

func (in *ZendeskSourceList) DeepCopy() *ZendeskSourceList

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

func (*ZendeskSourceList) DeepCopyInto 

func (in *ZendeskSourceList) DeepCopyInto(out *ZendeskSourceList)

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

func (*ZendeskSourceList) DeepCopyObject 

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

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

type ZendeskSourceSpec 

type ZendeskSourceSpec 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"`

	// Token identifies the API token used for creating the proper credentials to interface with Zendesk
	// allowing the source to auto-register the webhook to authenticate callbacks.
	Token ValueFromField `json:"token,omitempty"`

	// Email identifies the email used for creating the proper credentials to interface with Zendesk
	// allowing the source to auto-register the webhook to authenticate callbacks.
	Email string `json:"email,omitempty"`

	// WebhookPassword used for basic authentication for events sent from Zendesk
	// to the adapter.
	WebhookPassword ValueFromField `json:"webhookPassword,omitempty"`

	// WebhookUsername used for basic authentication for events sent from Zendesk
	// to the adapter.
	WebhookUsername string `json:"webhookUsername,omitempty"`

	// Subdomain identifies Zendesk subdomain
	Subdomain string `json:"subdomain,omitempty"`
}

ZendeskSourceSpec defines the desired state of the event source.

func (*ZendeskSourceSpec) DeepCopy 

func (in *ZendeskSourceSpec) DeepCopy() *ZendeskSourceSpec

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

func (*ZendeskSourceSpec) DeepCopyInto 

func (in *ZendeskSourceSpec) DeepCopyInto(out *ZendeskSourceSpec)

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

type ZendeskSourceStatus 

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

ZendeskSourceStatus defines the observed state of the event source.

func (*ZendeskSourceStatus) DeepCopy 

func (in *ZendeskSourceStatus) DeepCopy() *ZendeskSourceStatus

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

func (*ZendeskSourceStatus) DeepCopyInto 

func (in *ZendeskSourceStatus) DeepCopyInto(out *ZendeskSourceStatus)

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

func (*ZendeskSourceStatus) MarkTargetNotSynced 

func (s *ZendeskSourceStatus) MarkTargetNotSynced(reason, msg string)

MarkTargetNotSynced sets the TargetSynced condition to False with the given reason and associated message.

func (*ZendeskSourceStatus) MarkTargetSynced 

func (s *ZendeskSourceStatus) MarkTargetSynced()

MarkTargetSynced sets the TargetSynced condition to True.

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.