v1alpha1

package
v1.27.0 Latest Latest
Warning

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

 Go to latest Published: Oct 17, 2023 License: Apache-2.0 Imports: 17 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 (
	// AWSEventBridgeReasonNoClient is set on a Subscribed condition when an EventBridge/SQS API client cannot be obtained.
	AWSEventBridgeReasonNoClient = "NoClient"
	// AWSEventBridgeReasonNoEventBus is set on a Subscribed condition when the EventBridge event bus does not exist.
	AWSEventBridgeReasonNoEventBus = "EventBusNotFound"
	// AWSEventBridgeReasonInvalidEventPattern is set on a Subscribed condition when the provided event pattern is invalid.
	AWSEventBridgeReasonInvalidEventPattern = "InvalidEventPattern"
	// AWSEventBridgeReasonAPIError is set on a Subscribed condition when the EventBridge/SQS API returns any other error.
	AWSEventBridgeReasonAPIError = "APIError"
)

Reasons for status conditions

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 (
	// 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 (
	GoogleCloudStorageGenericEventType = "com.google.cloud.storage.notification"

	GoogleCloudStorageFinalizeEventType = "com.google.cloud.storage.objectfinalize"
	GoogleCloudStorageUpdateEventType   = "com.google.cloud.storage.objectmetadataupdate"
	GoogleCloudStorageDeleteEventType   = "com.google.cloud.storage.objectdelete"
	GoogleCloudStorageArchiveEventType  = "com.google.cloud.storage.objectarchive"
)

Supported event types

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 (
	// AWSEventBridgeConditionSubscribed has status True when events from an EventBridge
	// event bus have been successfully subscribed to via a rule.
	AWSEventBridgeConditionSubscribed apis.ConditionType = "Subscribed"
)

Status conditions

View Source 
const (
	AWSEventBridgeGenericEventType = "event"
)

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 (
	// AzureServiceBusConditionSubscribed has status True when the source has subscribed to a topic or queue.
	AzureServiceBusConditionSubscribed apis.ConditionType = "Subscribed"
)

Status conditions

View Source 
const (
	AzureServiceBusGenericEventType = "message"
)

Supported event types

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

Status conditions

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 (
	// GoogleCloudSourceRepoConditionSubscribed has status True when the source has subscribed to a topic.
	GoogleCloudSourceRepoConditionSubscribed apis.ConditionType = "Subscribed"
)

Status conditions

View Source 
const (
	GoogleCloudSourceRepoGenericEventType = "com.google.cloud.sourcerepo.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 (
	IBMMQSourceEventType = "io.triggermesh.ibm.mq.message"
)

Managed event types

View Source 
const (
	KafkaSourceEventType = "io.triggermesh.kafka.event"
)

Managed event types

View Source 
const (
	MongoDBSourceEventType = "io.triggermesh.mongodb.event"
)

Managed event types

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

Supported event types

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

Reasons for status conditions

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 (
	SolaceSourceEventType = "io.triggermesh.solace.event"
)

Managed event types

View Source 
const (
	TwilioSourceGenericEventType = "com.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 AllTypes = []v1alpha1.GroupObject{
	{Single: &AWSCloudWatchSource{}, List: &AWSCloudWatchSourceList{}},
	{Single: &AWSCloudWatchLogsSource{}, List: &AWSCloudWatchLogsSourceList{}},
	{Single: &AWSCodeCommitSource{}, List: &AWSCodeCommitSourceList{}},
	{Single: &AWSCognitoIdentitySource{}, List: &AWSCognitoIdentitySourceList{}},
	{Single: &AWSCognitoUserPoolSource{}, List: &AWSCognitoUserPoolSourceList{}},
	{Single: &AWSDynamoDBSource{}, List: &AWSDynamoDBSourceList{}},
	{Single: &AWSEventBridgeSource{}, List: &AWSEventBridgeSourceList{}},
	{Single: &AWSKinesisSource{}, List: &AWSKinesisSourceList{}},
	{Single: &AWSS3Source{}, List: &AWSS3SourceList{}},
	{Single: &AWSSNSSource{}, List: &AWSSNSSourceList{}},
	{Single: &AWSSQSSource{}, List: &AWSSQSSourceList{}},
	{Single: &AWSPerformanceInsightsSource{}, List: &AWSPerformanceInsightsSourceList{}},
	{Single: &AzureActivityLogsSource{}, List: &AzureActivityLogsSourceList{}},
	{Single: &AzureBlobStorageSource{}, List: &AzureBlobStorageSourceList{}},
	{Single: &AzureEventGridSource{}, List: &AzureEventGridSourceList{}},
	{Single: &AzureEventHubsSource{}, List: &AzureEventHubsSourceList{}},
	{Single: &AzureIOTHubSource{}, List: &AzureIOTHubSourceList{}},
	{Single: &AzureQueueStorageSource{}, List: &AzureQueueStorageSourceList{}},
	{Single: &AzureServiceBusQueueSource{}, List: &AzureServiceBusQueueSourceList{}},
	{Single: &AzureServiceBusSource{}, List: &AzureServiceBusSourceList{}},
	{Single: &AzureServiceBusTopicSource{}, List: &AzureServiceBusTopicSourceList{}},
	{Single: &CloudEventsSource{}, List: &CloudEventsSourceList{}},
	{Single: &MongoDBSource{}, List: &MongoDBSourceList{}},
	{Single: &KafkaSource{}, List: &KafkaSourceList{}},
	{Single: &GoogleCloudAuditLogsSource{}, List: &GoogleCloudAuditLogsSourceList{}},
	{Single: &GoogleCloudBillingSource{}, List: &GoogleCloudBillingSourceList{}},
	{Single: &GoogleCloudPubSubSource{}, List: &GoogleCloudPubSubSourceList{}},
	{Single: &GoogleCloudSourceRepositoriesSource{}, List: &GoogleCloudSourceRepositoriesSourceList{}},
	{Single: &GoogleCloudStorageSource{}, List: &GoogleCloudStorageSourceList{}},
	{Single: &HTTPPollerSource{}, List: &HTTPPollerSourceList{}},
	{Single: &IBMMQSource{}, List: &IBMMQSourceList{}},
	{Single: &OCIMetricsSource{}, List: &OCIMetricsSourceList{}},
	{Single: &SalesforceSource{}, List: &SalesforceSourceList{}},
	{Single: &SlackSource{}, List: &SlackSourceList{}},
	{Single: &SolaceSource{}, List: &SolaceSourceList{}},
	{Single: &TwilioSource{}, List: &TwilioSourceList{}},
	{Single: &WebhookSource{}, List: &WebhookSourceList{}},
	{Single: &ZendeskSource{}, List: &ZendeskSourceList{}},
}

AllTypes is a list of all the types defined in this package.

View Source 
var GoogleCloudAuditLogsSourceConditionSet = v1alpha1.NewConditionSet(
	GoogleCloudAuditLogsConditionSubscribed,
)

GoogleCloudAuditLogsSourceConditionSet is a set of conditions for GoogleCloudAuditLogsSource objects.

View Source 
var GoogleCloudBillingSourceConditionSet = v1alpha1.NewConditionSet(
	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 EventType 

func EventType(service, eventType string) string

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

func Kind 

func Kind(kind string) schema.GroupKind

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

func OCIGenerateEventSource 

func OCIGenerateEventSource(namespace, name string) string

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

func PubSubAttributeToCEType added in v1.26.0 

func PubSubAttributeToCEType(eventType string) string

PubSubAttributeToCEType translates Pub/Sub event type to CloudEvents type attribute.

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.

Types

type AWSCloudWatchLogsSource 

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

	Spec   AWSCloudWatchLogsSourceSpec `json:"spec,omitempty"`
	Status v1alpha1.Status             `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) GetAdapterOverrides added in v1.16.1 

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

GetAdapterOverrides implements AdapterConfigurable.

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 EventSender.

func (*AWSCloudWatchLogsSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*AWSCloudWatchLogsSource) GetStatusManager 

func (s *AWSCloudWatchLogsSource) GetStatusManager() *v1alpha1.StatusManager

GetStatusManager implements Reconcilable.

func (*AWSCloudWatchLogsSource) ServiceAccountOptions added in v1.18.0 

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

ServiceAccountOptions implements ServiceAccountProvider.

func (*AWSCloudWatchLogsSource) SetDefaults added in v1.25.0 

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

SetDefaults implements apis.Defaultable

func (*AWSCloudWatchLogsSource) Validate added in v1.25.0 

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

Validate implements apis.Validatable

func (*AWSCloudWatchLogsSource) WantsOwnServiceAccount added in v1.18.0 

func (s *AWSCloudWatchLogsSource) WantsOwnServiceAccount() bool

WantsOwnServiceAccount implements ServiceAccountProvider.

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

	// Authentication method to interact with the Amazon CloudWatch Logs API.
	Auth v1alpha1.AWSAuth `json:"auth"`

	// Adapter spec overrides parameters.
	// +optional
	AdapterOverrides *v1alpha1.AdapterOverrides `json:"adapterOverrides,omitempty"`
}

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 v1alpha1.Status         `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) GetAdapterOverrides added in v1.16.1 

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

GetAdapterOverrides implements AdapterConfigurable.

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 EventSender.

func (*AWSCloudWatchSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*AWSCloudWatchSource) GetStatusManager 

func (s *AWSCloudWatchSource) GetStatusManager() *v1alpha1.StatusManager

GetStatusManager implements Reconcilable.

func (*AWSCloudWatchSource) ServiceAccountOptions added in v1.18.0 

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

ServiceAccountOptions implements ServiceAccountProvider.

func (*AWSCloudWatchSource) SetDefaults added in v1.25.0 

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

SetDefaults implements apis.Defaultable

func (*AWSCloudWatchSource) Validate added in v1.25.0 

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

Validate implements apis.Validatable

func (*AWSCloudWatchSource) WantsOwnServiceAccount added in v1.18.0 

func (s *AWSCloudWatchSource) WantsOwnServiceAccount() bool

WantsOwnServiceAccount implements ServiceAccountProvider.

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

	// Authentication method to interact with the Amazon CloudWatch API.
	Auth v1alpha1.AWSAuth `json:"auth"`

	// Adapter spec overrides parameters.
	// +optional
	AdapterOverrides *v1alpha1.AdapterOverrides `json:"adapterOverrides,omitempty"`
}

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 v1alpha1.Status         `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) GetAdapterOverrides added in v1.16.1 

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

GetAdapterOverrides implements AdapterConfigurable.

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 EventSender.

func (*AWSCodeCommitSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*AWSCodeCommitSource) GetStatusManager 

func (s *AWSCodeCommitSource) GetStatusManager() *v1alpha1.StatusManager

GetStatusManager implements Reconcilable.

func (*AWSCodeCommitSource) ServiceAccountOptions added in v1.18.0 

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

ServiceAccountOptions implements ServiceAccountProvider.

func (*AWSCodeCommitSource) SetDefaults added in v1.25.0 

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

SetDefaults implements apis.Defaultable

func (*AWSCodeCommitSource) Validate added in v1.25.0 

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

Validate implements apis.Validatable

func (*AWSCodeCommitSource) WantsOwnServiceAccount added in v1.18.0 

func (s *AWSCodeCommitSource) WantsOwnServiceAccount() bool

WantsOwnServiceAccount implements ServiceAccountProvider.

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

	// Authentication method to interact with the Amazon CodeCommit API.
	Auth v1alpha1.AWSAuth `json:"auth"`

	// Adapter spec overrides parameters.
	// +optional
	AdapterOverrides *v1alpha1.AdapterOverrides `json:"adapterOverrides,omitempty"`
}

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 v1alpha1.Status              `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) GetAdapterOverrides added in v1.16.1 

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

GetAdapterOverrides implements AdapterConfigurable.

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 EventSender.

func (*AWSCognitoIdentitySource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*AWSCognitoIdentitySource) GetStatusManager 

func (s *AWSCognitoIdentitySource) GetStatusManager() *v1alpha1.StatusManager

GetStatusManager implements Reconcilable.

func (*AWSCognitoIdentitySource) ServiceAccountOptions added in v1.18.0 

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

ServiceAccountOptions implements ServiceAccountProvider.

func (*AWSCognitoIdentitySource) SetDefaults added in v1.25.0 

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

SetDefaults implements apis.Defaultable

func (*AWSCognitoIdentitySource) Validate added in v1.25.0 

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

Validate implements apis.Validatable

func (*AWSCognitoIdentitySource) WantsOwnServiceAccount added in v1.18.0 

func (s *AWSCognitoIdentitySource) WantsOwnServiceAccount() bool

WantsOwnServiceAccount implements ServiceAccountProvider.

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

	// Authentication method to interact with the Amazon Cognito API.
	Auth v1alpha1.AWSAuth `json:"auth"`

	// Adapter spec overrides parameters.
	// +optional
	AdapterOverrides *v1alpha1.AdapterOverrides `json:"adapterOverrides,omitempty"`
}

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 v1alpha1.Status              `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) GetAdapterOverrides added in v1.16.1 

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

GetAdapterOverrides implements AdapterConfigurable.

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 EventSender.

func (*AWSCognitoUserPoolSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*AWSCognitoUserPoolSource) GetStatusManager 

func (s *AWSCognitoUserPoolSource) GetStatusManager() *v1alpha1.StatusManager

GetStatusManager implements Reconcilable.

func (*AWSCognitoUserPoolSource) ServiceAccountOptions added in v1.18.0 

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

ServiceAccountOptions implements ServiceAccountProvider.

func (*AWSCognitoUserPoolSource) SetDefaults added in v1.25.0 

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

SetDefaults implements apis.Defaultable

func (*AWSCognitoUserPoolSource) Validate added in v1.25.0 

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

Validate implements apis.Validatable

func (*AWSCognitoUserPoolSource) WantsOwnServiceAccount added in v1.18.0 

func (s *AWSCognitoUserPoolSource) WantsOwnServiceAccount() bool

WantsOwnServiceAccount implements ServiceAccountProvider.

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

	// Authentication method to interact with the Amazon Cognito API.
	Auth v1alpha1.AWSAuth `json:"auth"`

	// Adapter spec overrides parameters.
	// +optional
	AdapterOverrides *v1alpha1.AdapterOverrides `json:"adapterOverrides,omitempty"`
}

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 v1alpha1.Status       `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) GetAdapterOverrides added in v1.16.1 

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

GetAdapterOverrides implements AdapterConfigurable.

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 EventSender.

func (*AWSDynamoDBSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*AWSDynamoDBSource) GetStatusManager 

func (s *AWSDynamoDBSource) GetStatusManager() *v1alpha1.StatusManager

GetStatusManager implements Reconcilable.

func (*AWSDynamoDBSource) ServiceAccountOptions added in v1.18.0 

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

ServiceAccountOptions implements ServiceAccountProvider.

func (*AWSDynamoDBSource) SetDefaults added in v1.25.0 

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

SetDefaults implements apis.Defaultable

func (*AWSDynamoDBSource) Validate added in v1.25.0 

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

Validate implements apis.Validatable

func (*AWSDynamoDBSource) WantsOwnServiceAccount added in v1.18.0 

func (s *AWSDynamoDBSource) WantsOwnServiceAccount() bool

WantsOwnServiceAccount implements ServiceAccountProvider.

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

	// Authentication method to interact with the Amazon DynamoDB API.
	Auth v1alpha1.AWSAuth `json:"auth"`

	// Adapter spec overrides parameters.
	// +optional
	AdapterOverrides *v1alpha1.AdapterOverrides `json:"adapterOverrides,omitempty"`
}

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 AWSEventBridgeSource added in v1.18.0 

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

	Spec   AWSEventBridgeSourceSpec   `json:"spec,omitempty"`
	Status AWSEventBridgeSourceStatus `json:"status,omitempty"`
}

AWSEventBridgeSource is the Schema for the event source.

func (*AWSEventBridgeSource) AsEventSource added in v1.18.0 

func (s *AWSEventBridgeSource) AsEventSource() string

AsEventSource implements EventSource.

func (*AWSEventBridgeSource) DeepCopy added in v1.18.0 

func (in *AWSEventBridgeSource) DeepCopy() *AWSEventBridgeSource

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

func (*AWSEventBridgeSource) DeepCopyInto added in v1.18.0 

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

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

func (*AWSEventBridgeSource) DeepCopyObject added in v1.18.0 

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

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

func (*AWSEventBridgeSource) GetAdapterOverrides added in v1.18.0 

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

GetAdapterOverrides implements AdapterConfigurable.

func (*AWSEventBridgeSource) GetConditionSet added in v1.18.0 

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

GetConditionSet implements duckv1.KRShaped.

func (*AWSEventBridgeSource) GetEventTypes added in v1.18.0 

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

GetEventTypes implements EventSource.

func (*AWSEventBridgeSource) GetGroupVersionKind added in v1.18.0 

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

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*AWSEventBridgeSource) GetSink added in v1.18.0 

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

GetSink implements EventSender.

func (*AWSEventBridgeSource) GetStatus added in v1.18.0 

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

GetStatus implements duckv1.KRShaped.

func (*AWSEventBridgeSource) GetStatusManager added in v1.18.0 

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

GetStatusManager implements Reconcilable.

func (*AWSEventBridgeSource) ServiceAccountOptions added in v1.18.0 

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

ServiceAccountOptions implements ServiceAccountProvider.

func (*AWSEventBridgeSource) SetDefaults added in v1.25.0 

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

SetDefaults implements apis.Defaultable

func (*AWSEventBridgeSource) Validate added in v1.25.0 

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

Validate implements apis.Validatable

func (*AWSEventBridgeSource) WantsOwnServiceAccount added in v1.18.0 

func (s *AWSEventBridgeSource) WantsOwnServiceAccount() bool

WantsOwnServiceAccount implements ServiceAccountProvider.

type AWSEventBridgeSourceDestination added in v1.18.0 

type AWSEventBridgeSourceDestination struct {
	// Amazon SQS destination.
	// +optional
	SQS *AWSEventBridgeSourceDestinationSQS `json:"sqs,omitempty"`
}

AWSEventBridgeSourceDestination contains possible intermediate destinations for the event bus' events.

func (*AWSEventBridgeSourceDestination) DeepCopy added in v1.18.0 

func (in *AWSEventBridgeSourceDestination) DeepCopy() *AWSEventBridgeSourceDestination

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

func (*AWSEventBridgeSourceDestination) DeepCopyInto added in v1.18.0 

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

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

type AWSEventBridgeSourceDestinationSQS added in v1.18.0 

type AWSEventBridgeSourceDestinationSQS struct {
	// SQS Queue ARN
	// https://docs.aws.amazon.com/IAM/latest/UserGuide/list_amazonsqs.html#amazonsqs-resources-for-iam-policies
	QueueARN apis.ARN `json:"queueARN"`
}

AWSEventBridgeSourceDestinationSQS contains properties of an Amazon SQS queue to use as destination for the event bus' events.

func (*AWSEventBridgeSourceDestinationSQS) DeepCopy added in v1.18.0 

func (in *AWSEventBridgeSourceDestinationSQS) DeepCopy() *AWSEventBridgeSourceDestinationSQS

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

func (*AWSEventBridgeSourceDestinationSQS) DeepCopyInto added in v1.18.0 

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

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

type AWSEventBridgeSourceList added in v1.18.0 

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

AWSEventBridgeSourceList contains a list of event sources.

func (*AWSEventBridgeSourceList) DeepCopy added in v1.18.0 

func (in *AWSEventBridgeSourceList) DeepCopy() *AWSEventBridgeSourceList

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

func (*AWSEventBridgeSourceList) DeepCopyInto added in v1.18.0 

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

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

func (*AWSEventBridgeSourceList) DeepCopyObject added in v1.18.0 

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

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

type AWSEventBridgeSourceSpec added in v1.18.0 

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

	// EventBridge event bus ARN
	// https://docs.aws.amazon.com/service-authorization/latest/reference/list_amazoneventbridge.html#amazoneventbridge-resources-for-iam-policies
	ARN apis.ARN `json:"arn"`

	// Event pattern used to select events that this source should subscribe to.
	// If not specified, the event rule is created with a catch-all pattern.
	// https://docs.aws.amazon.com/eventbridge/latest/userguide/eb-event-patterns.html
	// +optional
	EventPattern *string `json:"eventPattern,omitempty"`

	// The intermediate destination of notifications originating from the
	// Amazon EventBridge event bus, before they are retrieved by this
	// event source.
	// If omitted, an Amazon SQS queue is automatically created and
	// associated with the EventBridge event rule.
	// +optional
	Destination *AWSEventBridgeSourceDestination `json:"destination,omitempty"`

	// Authentication method to interact with the Amazon S3 and SQS APIs.
	Auth v1alpha1.AWSAuth `json:"auth"`

	// Adapter spec overrides parameters.
	// +optional
	AdapterOverrides *v1alpha1.AdapterOverrides `json:"adapterOverrides,omitempty"`
}

AWSEventBridgeSourceSpec defines the desired state of the event source.

func (*AWSEventBridgeSourceSpec) DeepCopy added in v1.18.0 

func (in *AWSEventBridgeSourceSpec) DeepCopy() *AWSEventBridgeSourceSpec

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

func (*AWSEventBridgeSourceSpec) DeepCopyInto added in v1.18.0 

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

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

type AWSEventBridgeSourceStatus added in v1.18.0 

type AWSEventBridgeSourceStatus struct {
	v1alpha1.Status `json:",inline"`
	EventRuleARN    *apis.ARN `json:"ruleARN,omitempty"`
	QueueARN        *apis.ARN `json:"queueARN,omitempty"`
}

AWSEventBridgeSourceStatus defines the observed state of the event source.

func (*AWSEventBridgeSourceStatus) DeepCopy added in v1.18.0 

func (in *AWSEventBridgeSourceStatus) DeepCopy() *AWSEventBridgeSourceStatus

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

func (*AWSEventBridgeSourceStatus) DeepCopyInto added in v1.18.0 

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

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

func (*AWSEventBridgeSourceStatus) MarkNotSubscribed added in v1.18.0 

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

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

func (*AWSEventBridgeSourceStatus) MarkSubscribed added in v1.18.0 

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

MarkSubscribed sets the Subscribed condition to True and reports the ARN of the EventBridge event rule.

type AWSKinesisSource 

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

	Spec   AWSKinesisSourceSpec `json:"spec,omitempty"`
	Status v1alpha1.Status      `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) GetAdapterOverrides added in v1.16.1 

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

GetAdapterOverrides implements AdapterConfigurable.

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 EventSender.

func (*AWSKinesisSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*AWSKinesisSource) GetStatusManager 

func (s *AWSKinesisSource) GetStatusManager() *v1alpha1.StatusManager

GetStatusManager implements Reconcilable.

func (*AWSKinesisSource) ServiceAccountOptions added in v1.18.0 

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

ServiceAccountOptions implements ServiceAccountProvider.

func (*AWSKinesisSource) SetDefaults added in v1.25.0 

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

SetDefaults implements apis.Defaultable

func (*AWSKinesisSource) Validate added in v1.25.0 

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

Validate implements apis.Validatable

func (*AWSKinesisSource) WantsOwnServiceAccount added in v1.18.0 

func (s *AWSKinesisSource) WantsOwnServiceAccount() bool

WantsOwnServiceAccount implements ServiceAccountProvider.

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

	// Authentication method to interact with the Amazon Kinesis API.
	Auth v1alpha1.AWSAuth `json:"auth"`

	// Adapter spec overrides parameters.
	// +optional
	AdapterOverrides *v1alpha1.AdapterOverrides `json:"adapterOverrides,omitempty"`
}

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 v1alpha1.Status                  `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) GetAdapterOverrides added in v1.16.1 

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

GetAdapterOverrides implements AdapterConfigurable.

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 EventSender.

func (*AWSPerformanceInsightsSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*AWSPerformanceInsightsSource) GetStatusManager 

func (s *AWSPerformanceInsightsSource) GetStatusManager() *v1alpha1.StatusManager

GetStatusManager implements Reconcilable.

func (*AWSPerformanceInsightsSource) ServiceAccountOptions added in v1.18.0 

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

ServiceAccountOptions implements ServiceAccountProvider.

func (*AWSPerformanceInsightsSource) SetDefaults added in v1.25.0 

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

SetDefaults implements apis.Defaultable

func (*AWSPerformanceInsightsSource) Validate added in v1.25.0 

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

Validate implements apis.Validatable

func (*AWSPerformanceInsightsSource) WantsOwnServiceAccount added in v1.18.0 

func (s *AWSPerformanceInsightsSource) WantsOwnServiceAccount() bool

WantsOwnServiceAccount implements ServiceAccountProvider.

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

	// Authentication method to interact with the Amazon RDS and Performance Insights APIs.
	Auth v1alpha1.AWSAuth `json:"auth"`

	// Adapter spec overrides parameters.
	// +optional
	AdapterOverrides *v1alpha1.AdapterOverrides `json:"adapterOverrides,omitempty"`
}

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) GetAdapterOverrides added in v1.16.1 

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

GetAdapterOverrides implements AdapterConfigurable.

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 EventSender.

func (*AWSS3Source) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*AWSS3Source) GetStatusManager 

func (s *AWSS3Source) GetStatusManager() *v1alpha1.StatusManager

GetStatusManager implements Reconcilable.

func (*AWSS3Source) ServiceAccountOptions added in v1.17.0 

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

ServiceAccountOptions implements ServiceAccountProvider.

func (*AWSS3Source) SetDefaults added in v1.25.0 

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

SetDefaults implements apis.Defaultable

func (*AWSS3Source) Validate added in v1.25.0 

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

Validate implements apis.Validatable

func (*AWSS3Source) WantsOwnServiceAccount added in v1.17.0 

func (s *AWSS3Source) WantsOwnServiceAccount() bool

WantsOwnServiceAccount implements ServiceAccountProvider.

type AWSS3SourceDestination added in v1.12.0 

type AWSS3SourceDestination struct {
	// Amazon SQS destination.
	// +optional
	SQS *AWSS3SourceDestinationSQS `json:"sqs,omitempty"`
}

AWSS3SourceDestination contains possible intermediate destinations for bucket notifications.

func (*AWSS3SourceDestination) DeepCopy added in v1.12.0 

func (in *AWSS3SourceDestination) DeepCopy() *AWSS3SourceDestination

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

func (*AWSS3SourceDestination) DeepCopyInto added in v1.12.0 

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

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

type AWSS3SourceDestinationSQS added in v1.12.0 

type AWSS3SourceDestinationSQS struct {
	// SQS Queue ARN
	// https://docs.aws.amazon.com/IAM/latest/UserGuide/list_amazonsqs.html#amazonsqs-resources-for-iam-policies
	QueueARN apis.ARN `json:"queueARN"`
}

AWSS3SourceDestinationSQS contains properties of an Amazon SQS queue to use as destination for bucket notifications.

func (*AWSS3SourceDestinationSQS) DeepCopy added in v1.12.0 

func (in *AWSS3SourceDestinationSQS) DeepCopy() *AWSS3SourceDestinationSQS

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

func (*AWSS3SourceDestinationSQS) DeepCopyInto added in v1.12.0 

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

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

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 supported by S3, the ARN provided via this
	// attribute may include a region and an account ID. When this
	// information is provided, it is used to set an accurate
	// identity-based access policy between the S3 bucket and the
	// reconciled SQS queue, unless an existing queue is provided via the
	// QueueARN attribute.
	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"`

	// The intermediate destination of notifications originating from the
	// Amazon S3 bucket, before they are retrieved by this event source.
	// If omitted, an Amazon SQS queue is automatically created and
	// associated with the bucket.
	// +optional
	Destination *AWSS3SourceDestination `json:"destination,omitempty"`

	// Authentication method to interact with the Amazon S3 and SQS APIs.
	Auth v1alpha1.AWSAuth `json:"auth"`

	// Adapter spec overrides parameters.
	// +optional
	AdapterOverrides *v1alpha1.AdapterOverrides `json:"adapterOverrides,omitempty"`
}

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 {
	v1alpha1.Status `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.

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) GetAdapterOverrides added in v1.16.1 

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

GetAdapterOverrides implements AdapterConfigurable.

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 EventSender.

func (*AWSSNSSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*AWSSNSSource) GetStatusManager 

func (s *AWSSNSSource) GetStatusManager() *v1alpha1.StatusManager

GetStatusManager implements Reconcilable.

func (*AWSSNSSource) IsMultiTenant 

func (*AWSSNSSource) IsMultiTenant() bool

IsMultiTenant implements MultiTenant.

func (*AWSSNSSource) SetDefaults added in v1.25.0 

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

SetDefaults implements apis.Defaultable

func (*AWSSNSSource) Validate added in v1.25.0 

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

Validate implements apis.Validatable

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

	// Authentication method to interact with the Amazon SNS API.
	Auth v1alpha1.AWSAuth `json:"auth"`

	// Adapter spec overrides parameters.
	// +optional
	AdapterOverrides *v1alpha1.AdapterOverrides `json:"adapterOverrides,omitempty"`
}

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 {
	v1alpha1.Status `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 v1alpha1.Status  `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) GetAdapterOverrides added in v1.16.1 

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

GetAdapterOverrides implements AdapterConfigurable.

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 EventSender.

func (*AWSSQSSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*AWSSQSSource) GetStatusManager 

func (s *AWSSQSSource) GetStatusManager() *v1alpha1.StatusManager

GetStatusManager implements Reconcilable.

func (*AWSSQSSource) ServiceAccountOptions added in v1.12.0 

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

ServiceAccountOptions implements ServiceAccountProvider.

func (*AWSSQSSource) SetDefaults added in v1.25.0 

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

SetDefaults implements apis.Defaultable

func (*AWSSQSSource) Validate added in v1.25.0 

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

Validate implements apis.Validatable

func (*AWSSQSSource) WantsOwnServiceAccount added in v1.12.0 

func (s *AWSSQSSource) WantsOwnServiceAccount() bool

WantsOwnServiceAccount implements ServiceAccountProvider.

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

	// Name of the message processor to use for converting SQS messages to CloudEvents.
	// Supported values are "default" and "s3".
	// +optional
	MessageProcessor *string `json:"messageProcessor,omitempty"`

	// Authentication method to interact with the Amazon SQS API.
	Auth v1alpha1.AWSAuth `json:"auth"`

	// Customizations of the AWS REST API endpoint.
	// +optional
	Endpoint *v1alpha1.AWSEndpoint `json:"endpoint,omitempty"`

	// Adapter spec overrides parameters.
	// +optional
	AdapterOverrides *v1alpha1.AdapterOverrides `json:"adapterOverrides,omitempty"`
}

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 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) GetAdapterOverrides added in v1.16.1 

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

GetAdapterOverrides implements AdapterConfigurable.

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 EventSender.

func (*AzureActivityLogsSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*AzureActivityLogsSource) GetStatusManager 

func (s *AzureActivityLogsSource) GetStatusManager() *v1alpha1.StatusManager

GetStatusManager implements Reconcilable.

func (*AzureActivityLogsSource) SetDefaults added in v1.25.0 

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

SetDefaults implements apis.Defaultable

func (*AzureActivityLogsSource) Validate added in v1.25.0 

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

Validate implements apis.Validatable

type AzureActivityLogsSourceDestination added in v1.12.0 

type AzureActivityLogsSourceDestination struct {
	EventHubs AzureActivityLogsSourceDestinationEventHubs `json:"eventHubs"`
}

AzureActivityLogsSourceDestination contains possible intermediate destinations for activity logs.

func (*AzureActivityLogsSourceDestination) DeepCopy added in v1.12.0 

func (in *AzureActivityLogsSourceDestination) DeepCopy() *AzureActivityLogsSourceDestination

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

func (*AzureActivityLogsSourceDestination) DeepCopyInto added in v1.12.0 

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

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

type AzureActivityLogsSourceDestinationEventHubs added in v1.12.0 

type AzureActivityLogsSourceDestinationEventHubs struct {
	// Resource ID of the Event Hubs namespace.
	//
	// The expected format is
	//   /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.EventHub/namespaces/{namespaceName}
	NamespaceID AzureResourceID `json:"namespaceID"`

	// Name of the Event Hubs instance within the selected namespace. If
	// omitted, Azure automatically creates an Event Hub with the name
	// 'insights-activity-logs' inside the selected namespace.
	//
	// +optional
	HubName *string `json:"hubName,omitempty"`

	// Name of the Event Hubs' Consumer Group that will be used by the source to read the event stream.
	ConsumerGroup *string `json:"consumerGroup,omitempty"`

	// 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
	SASPolicy *string `json:"sasPolicy,omitempty"`
}

AzureActivityLogsSourceDestinationEventHubs contains properties of an Event Hubs namespace to use as intermediate destination for events.

func (*AzureActivityLogsSourceDestinationEventHubs) DeepCopy added in v1.12.0 

func (in *AzureActivityLogsSourceDestinationEventHubs) DeepCopy() *AzureActivityLogsSourceDestinationEventHubs

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

func (*AzureActivityLogsSourceDestinationEventHubs) DeepCopyInto added in v1.12.0 

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

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

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

	// The ID of the Azure subscription which activity logs to subscribe to.
	SubscriptionID string `json:"subscriptionID"`

	// The intermediate destination of activity logs, before they are
	// retrieved by this event source.
	Destination AzureActivityLogsSourceDestination `json:"destination"`

	// 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.
	// If it not present, it will try to use Azure AKS Managed Identity
	Auth AzureAuth `json:"auth"`

	// Adapter spec overrides parameters.
	// +optional
	AdapterOverrides *v1alpha1.AdapterOverrides `json:"adapterOverrides,omitempty"`
}

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 {
	v1alpha1.Status `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) GetAdapterOverrides added in v1.16.1 

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

GetAdapterOverrides implements AdapterConfigurable.

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 EventSender.

func (*AzureBlobStorageSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*AzureBlobStorageSource) GetStatusManager 

func (s *AzureBlobStorageSource) GetStatusManager() *v1alpha1.StatusManager

GetStatusManager implements Reconcilable.

func (*AzureBlobStorageSource) SetDefaults added in v1.25.0 

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

SetDefaults implements apis.Defaultable

func (*AzureBlobStorageSource) Validate added in v1.25.0 

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

Validate implements apis.Validatable

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 AzureResourceID `json:"storageAccountID"`

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

	// The intermediate destination of events subscribed via Event Grid,
	// before they are retrieved by this event source.
	Endpoint AzureEventGridSourceEndpoint `json:"endpoint"`

	// Authentication method to interact with the Azure REST API.
	// This event source only supports the ServicePrincipal authentication.
	// If it not present, it will try to use Azure AKS Managed Identity
	Auth AzureAuth `json:"auth"`

	// Adapter spec overrides parameters.
	// +optional
	AdapterOverrides *v1alpha1.AdapterOverrides `json:"adapterOverrides,omitempty"`
}

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 {
	v1alpha1.Status `json:",inline"`

	// Resource ID of the Event Hubs instance that is currently receiving
	// events from the Azure Event Grid subscription.
	EventHubID *AzureResourceID `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) GetAdapterOverrides added in v1.16.1 

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

GetAdapterOverrides implements AdapterConfigurable.

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 EventSender.

func (*AzureEventGridSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*AzureEventGridSource) GetStatusManager 

func (s *AzureEventGridSource) GetStatusManager() *v1alpha1.StatusManager

GetStatusManager implements Reconcilable.

func (*AzureEventGridSource) SetDefaults added in v1.25.0 

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

SetDefaults implements apis.Defaultable

func (*AzureEventGridSource) Validate added in v1.25.0 

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

Validate implements apis.Validatable

type AzureEventGridSourceDestinationEventHubs added in v1.12.0 

type AzureEventGridSourceDestinationEventHubs struct {
	// Resource ID of the Event Hubs namespace.
	//
	// The expected format is
	//   /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.EventHub/namespaces/{namespaceName}
	NamespaceID AzureResourceID `json:"namespaceID"`

	// Name of the Event Hubs instance within the selected namespace. If
	// omitted, an Event Hubs instance is created on behalf of the user.
	// +optional
	HubName *string `json:"hubName,omitempty"`

	// Name of the Event Hubs' Consumer Group that will be used by the source to read the event stream.
	ConsumerGroup *string `json:"consumerGroup,omitempty"`
}

AzureEventGridSourceDestinationEventHubs contains properties of an Event Hubs namespace to use as intermediate destination for events.

func (*AzureEventGridSourceDestinationEventHubs) DeepCopy added in v1.12.0 

func (in *AzureEventGridSourceDestinationEventHubs) DeepCopy() *AzureEventGridSourceDestinationEventHubs

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

func (*AzureEventGridSourceDestinationEventHubs) DeepCopyInto added in v1.12.0 

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

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

type AzureEventGridSourceEndpoint added in v1.12.0 

type AzureEventGridSourceEndpoint struct {
	EventHubs AzureEventGridSourceDestinationEventHubs `json:"eventHubs"`
}

AzureEventGridSourceEndpoint contains possible intermediate destinations for events.

func (*AzureEventGridSourceEndpoint) DeepCopy added in v1.12.0 

func (in *AzureEventGridSourceEndpoint) DeepCopy() *AzureEventGridSourceEndpoint

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

func (*AzureEventGridSourceEndpoint) DeepCopyInto added in v1.12.0 

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

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

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

	// The intermediate destination of events subscribed via Event Grid,
	// before they are retrieved by this event source.
	Endpoint AzureEventGridSourceEndpoint `json:"endpoint"`

	// Authentication method to interact with the Azure REST API.
	// This event source only supports the ServicePrincipal authentication.
	// If it not present, it will try to use Azure AKS Managed Identity
	Auth AzureAuth `json:"auth"`

	// Adapter spec overrides parameters.
	// +optional
	AdapterOverrides *v1alpha1.AdapterOverrides `json:"adapterOverrides,omitempty"`
}

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 {
	v1alpha1.Status `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 *AzureResourceID `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 AzureEventHubsSource added in v1.22.0 

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

	Spec   AzureEventHubsSourceSpec `json:"spec,omitempty"`
	Status v1alpha1.Status          `json:"status,omitempty"`
}

AzureEventHubsSource is the Schema for the event source.

func (*AzureEventHubsSource) AsEventSource added in v1.22.0 

func (s *AzureEventHubsSource) AsEventSource() string

AsEventSource implements EventSource.

func (*AzureEventHubsSource) DeepCopy added in v1.22.0 

func (in *AzureEventHubsSource) DeepCopy() *AzureEventHubsSource

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

func (*AzureEventHubsSource) DeepCopyInto added in v1.22.0 

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

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

func (*AzureEventHubsSource) DeepCopyObject added in v1.22.0 

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

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

func (*AzureEventHubsSource) GetAdapterOverrides added in v1.22.0 

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

GetAdapterOverrides implements AdapterConfigurable.

func (*AzureEventHubsSource) GetConditionSet added in v1.22.0 

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

GetConditionSet implements duckv1.KRShaped.

func (*AzureEventHubsSource) GetEventTypes added in v1.22.0 

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

GetEventTypes returns the event types generated by the source.

func (*AzureEventHubsSource) GetGroupVersionKind added in v1.22.0 

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

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*AzureEventHubsSource) GetSink added in v1.22.0 

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

GetSink implements EventSender.

func (*AzureEventHubsSource) GetStatus added in v1.22.0 

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

GetStatus implements duckv1.KRShaped.

func (*AzureEventHubsSource) GetStatusManager added in v1.22.0 

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

GetStatusManager implements Reconcilable.

func (*AzureEventHubsSource) SetDefaults added in v1.25.0 

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

SetDefaults implements apis.Defaultable

func (*AzureEventHubsSource) Validate added in v1.25.0 

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

Validate implements apis.Validatable

type AzureEventHubsSourceList added in v1.22.0 

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

AzureEventHubsSourceList contains a list of event sources.

func (*AzureEventHubsSourceList) DeepCopy added in v1.22.0 

func (in *AzureEventHubsSourceList) DeepCopy() *AzureEventHubsSourceList

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

func (*AzureEventHubsSourceList) DeepCopyInto added in v1.22.0 

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

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

func (*AzureEventHubsSourceList) DeepCopyObject added in v1.22.0 

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

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

type AzureEventHubsSourceSpec added in v1.22.0 

type AzureEventHubsSourceSpec 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 AzureResourceID `json:"eventHubID"`

	// Name of the Event Hubs' Consumer Group that will be used by the source to read the event stream.
	ConsumerGroup *string `json:"consumerGroup,omitempty"`

	// Authentication method to interact with the Azure Event Hubs API.
	// If it not present, it will try to use Azure AKS Managed Identity
	Auth AzureAuth `json:"auth"`

	// MessageTimeout of the Event Hubs client in seconds.
	// +optional
	MessageTimeout *string `json:"messagesTimeout,omitempty"`

	// MessageCountSize of the Event Hubs client.
	// +optional
	MessageCountSize *string `json:"messagesCountSize,omitempty"`

	// Adapter spec overrides parameters.
	// +optional
	AdapterOverrides *v1alpha1.AdapterOverrides `json:"adapterOverrides,omitempty"`
}

AzureEventHubsSourceSpec defines the desired state of the event source.

func (*AzureEventHubsSourceSpec) DeepCopy added in v1.22.0 

func (in *AzureEventHubsSourceSpec) DeepCopy() *AzureEventHubsSourceSpec

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

func (*AzureEventHubsSourceSpec) DeepCopyInto added in v1.22.0 

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

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 v1alpha1.Status       `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) GetAdapterOverrides added in v1.16.1 

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

GetAdapterOverrides implements AdapterConfigurable.

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 EventSender.

func (*AzureIOTHubSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*AzureIOTHubSource) GetStatusManager 

func (s *AzureIOTHubSource) GetStatusManager() *v1alpha1.StatusManager

GetStatusManager implements Reconcilable.

func (*AzureIOTHubSource) SetDefaults added in v1.25.0 

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

SetDefaults implements apis.Defaultable

func (*AzureIOTHubSource) Validate added in v1.25.0 

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

Validate implements apis.Validatable

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

	// Adapter spec overrides parameters.
	// +optional
	AdapterOverrides *v1alpha1.AdapterOverrides `json:"adapterOverrides,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 AzureQueueStorageSource 

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

	Spec   AzureQueueStorageSourceSpec `json:"spec,omitempty"`
	Status v1alpha1.Status             `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) GetAdapterOverrides added in v1.16.1 

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

GetAdapterOverrides implements AdapterConfigurable.

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 EventSender.

func (*AzureQueueStorageSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*AzureQueueStorageSource) GetStatusManager 

func (s *AzureQueueStorageSource) GetStatusManager() *v1alpha1.StatusManager

GetStatusManager implements Reconcilable.

func (*AzureQueueStorageSource) SetDefaults added in v1.25.0 

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

SetDefaults implements apis.Defaultable

func (*AzureQueueStorageSource) Validate added in v1.25.0 

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

Validate implements apis.Validatable

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  v1alpha1.ValueFromField `json:"accountKey"`
	// +optional
	VisibilityTimeout *string `json:"visibilityTimeout,omitempty"`

	// Adapter spec overrides parameters.
	// +optional
	AdapterOverrides *v1alpha1.AdapterOverrides `json:"adapterOverrides,omitempty"`
}

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
	Namespace        string
	ResourceType     string
	ResourceName     string
	SubResourceType  string
	SubResourceName  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          v1alpha1.ValueFromField `json:"keyName"`
	KeyValue         v1alpha1.ValueFromField `json:"keyValue"`
	ConnectionString v1alpha1.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 v1alpha1.Status                `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) GetAdapterOverrides added in v1.16.1 

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

GetAdapterOverrides implements AdapterConfigurable.

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 EventSender.

func (*AzureServiceBusQueueSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*AzureServiceBusQueueSource) GetStatusManager 

func (s *AzureServiceBusQueueSource) GetStatusManager() *v1alpha1.StatusManager

GetStatusManager implements Reconcilable.

func (*AzureServiceBusQueueSource) SetDefaults added in v1.25.0 

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

SetDefaults implements apis.Defaultable

func (*AzureServiceBusQueueSource) Validate added in v1.25.0 

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

Validate implements apis.Validatable

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

	// The resource ID the Service Bus Queue to subscribe to.
	//
	// Expected format:
	// - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.ServiceBus/namespaces/{namespaceName}/queues/{queueName}
	QueueID AzureResourceID `json:"queueID"`

	// Authentication method to interact with Azure Service Bus.
	// If it not present, it will try to use Azure AKS Managed Identity
	Auth AzureAuth `json:"auth"`

	// Adapter spec overrides parameters.
	// +optional
	AdapterOverrides *v1alpha1.AdapterOverrides `json:"adapterOverrides,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 AzureServiceBusSource added in v1.25.0 

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

	Spec   AzureServiceBusSourceSpec   `json:"spec,omitempty"`
	Status AzureServiceBusSourceStatus `json:"status,omitempty"`
}

AzureServiceBusSource is the Schema for the event source.

func (*AzureServiceBusSource) AsEventSource added in v1.25.0 

func (s *AzureServiceBusSource) AsEventSource() string

AsEventSource implements EventSource.

func (*AzureServiceBusSource) DeepCopy added in v1.25.0 

func (in *AzureServiceBusSource) DeepCopy() *AzureServiceBusSource

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

func (*AzureServiceBusSource) DeepCopyInto added in v1.25.0 

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

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

func (*AzureServiceBusSource) DeepCopyObject added in v1.25.0 

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

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

func (*AzureServiceBusSource) GetAdapterOverrides added in v1.25.0 

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

GetAdapterOverrides implements AdapterConfigurable.

func (*AzureServiceBusSource) GetConditionSet added in v1.25.0 

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

GetConditionSet implements duckv1.KRShaped.

func (*AzureServiceBusSource) GetEventTypes added in v1.25.0 

func (*AzureServiceBusSource) GetEventTypes() []string

GetEventTypes returns the event types generated by the source.

func (*AzureServiceBusSource) GetGroupVersionKind added in v1.25.0 

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

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*AzureServiceBusSource) GetSink added in v1.25.0 

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

GetSink implements EventSender.

func (*AzureServiceBusSource) GetStatus added in v1.25.0 

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

GetStatus implements duckv1.KRShaped.

func (*AzureServiceBusSource) GetStatusManager added in v1.25.0 

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

GetStatusManager implements Reconcilable.

func (*AzureServiceBusSource) SetDefaults added in v1.25.0 

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

SetDefaults implements apis.Defaultable

func (*AzureServiceBusSource) Validate added in v1.25.0 

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

Validate implements apis.Validatable

type AzureServiceBusSourceList added in v1.25.0 

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

AzureServiceBusSourceList contains a list of event sources.

func (*AzureServiceBusSourceList) DeepCopy added in v1.25.0 

func (in *AzureServiceBusSourceList) DeepCopy() *AzureServiceBusSourceList

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

func (*AzureServiceBusSourceList) DeepCopyInto added in v1.25.0 

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

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

func (*AzureServiceBusSourceList) DeepCopyObject added in v1.25.0 

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

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

type AzureServiceBusSourceSpec added in v1.25.0 

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

	// The resource ID the Service Bus Topic to subscribe to.
	//
	// Expected format:
	// - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.ServiceBus/namespaces/{namespaceName}/topics/{topicName}
	// +optional
	TopicID *AzureResourceID `json:"topicID,omitempty"`

	// The resource ID the Service Bus Queue to subscribe to.
	//
	// Expected format:
	// - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.ServiceBus/namespaces/{namespaceName}/queues/{queueName}
	// +optional
	QueueID *AzureResourceID `json:"queueID,omitempty"`

	// Authentication method to interact with the Azure REST API.
	// This event source only supports the ServicePrincipal authentication.
	// If it not present, it will try to use Azure AKS Managed Identity
	Auth AzureAuth `json:"auth"`

	// WebSocketsEnable
	// +optional
	WebSocketsEnable *bool `json:"webSocketsEnable,omitempty"`

	// MaxConcurrent
	// +optional
	MaxConcurrent *int `json:"maxConcurrent,omitempty"`

	// Adapter spec overrides parameters.
	// +optional
	AdapterOverrides *v1alpha1.AdapterOverrides `json:"adapterOverrides,omitempty"`
}

AzureServiceBusSourceSpec defines the desired state of the event source.

func (*AzureServiceBusSourceSpec) DeepCopy added in v1.25.0 

func (in *AzureServiceBusSourceSpec) DeepCopy() *AzureServiceBusSourceSpec

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

func (*AzureServiceBusSourceSpec) DeepCopyInto added in v1.25.0 

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

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

type AzureServiceBusSourceStatus added in v1.25.0 

type AzureServiceBusSourceStatus struct {
	v1alpha1.Status `json:",inline"`

	// Resource ID of the Service Bus Subscription that is currently used
	// by the event source for consuming events from the configured Service
	// Bus.
	SubscriptionID *AzureResourceID `json:"subscriptionID,omitempty"`
}

AzureServiceBusSourceStatus defines the observed state of the event source.

func (*AzureServiceBusSourceStatus) DeepCopy added in v1.25.0 

func (in *AzureServiceBusSourceStatus) DeepCopy() *AzureServiceBusSourceStatus

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

func (*AzureServiceBusSourceStatus) DeepCopyInto added in v1.25.0 

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

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

func (*AzureServiceBusSourceStatus) MarkNotSubscribed added in v1.25.0 

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

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

func (*AzureServiceBusSourceStatus) MarkSubscribed added in v1.25.0 

func (s *AzureServiceBusSourceStatus) MarkSubscribed()

MarkSubscribed sets the Subscribed condition to True.

func (*AzureServiceBusSourceStatus) MarkSubscribedWithReason added in v1.25.0 

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

MarkSubscribedWithReason sets the Subscribed condition to True with reason.

type AzureServiceBusTopicSource added in v1.12.0 

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

	Spec   AzureServiceBusTopicSourceSpec   `json:"spec,omitempty"`
	Status AzureServiceBusTopicSourceStatus `json:"status,omitempty"`
}

AzureServiceBusTopicSource is the Schema for the event source.

func (*AzureServiceBusTopicSource) AsEventSource added in v1.12.0 

func (s *AzureServiceBusTopicSource) AsEventSource() string

AsEventSource implements EventSource.

func (*AzureServiceBusTopicSource) DeepCopy added in v1.12.0 

func (in *AzureServiceBusTopicSource) DeepCopy() *AzureServiceBusTopicSource

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

func (*AzureServiceBusTopicSource) DeepCopyInto added in v1.12.0 

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

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

func (*AzureServiceBusTopicSource) DeepCopyObject added in v1.12.0 

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

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

func (*AzureServiceBusTopicSource) GetAdapterOverrides added in v1.16.1 

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

GetAdapterOverrides implements AdapterConfigurable.

func (*AzureServiceBusTopicSource) GetConditionSet added in v1.12.0 

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

GetConditionSet implements duckv1.KRShaped.

func (*AzureServiceBusTopicSource) GetEventTypes added in v1.12.0 

func (*AzureServiceBusTopicSource) GetEventTypes() []string

GetEventTypes returns the event types generated by the source.

func (*AzureServiceBusTopicSource) GetGroupVersionKind added in v1.12.0 

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

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*AzureServiceBusTopicSource) GetSink added in v1.12.0 

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

GetSink implements EventSender.

func (*AzureServiceBusTopicSource) GetStatus added in v1.12.0 

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

GetStatus implements duckv1.KRShaped.

func (*AzureServiceBusTopicSource) GetStatusManager added in v1.12.0 

func (s *AzureServiceBusTopicSource) GetStatusManager() *v1alpha1.StatusManager

GetStatusManager implements Reconcilable.

func (*AzureServiceBusTopicSource) SetDefaults added in v1.25.0 

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

SetDefaults implements apis.Defaultable

func (*AzureServiceBusTopicSource) Validate added in v1.25.0 

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

Validate implements apis.Validatable

type AzureServiceBusTopicSourceList added in v1.12.0 

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

AzureServiceBusTopicSourceList contains a list of event sources.

func (*AzureServiceBusTopicSourceList) DeepCopy added in v1.12.0 

func (in *AzureServiceBusTopicSourceList) DeepCopy() *AzureServiceBusTopicSourceList

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

func (*AzureServiceBusTopicSourceList) DeepCopyInto added in v1.12.0 

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

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

func (*AzureServiceBusTopicSourceList) DeepCopyObject added in v1.12.0 

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

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

type AzureServiceBusTopicSourceSpec added in v1.12.0 

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

	// The resource ID the Service Bus Topic to subscribe to.
	//
	// Expected format:
	// - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.ServiceBus/namespaces/{namespaceName}/topics/{topicName}
	TopicID AzureResourceID `json:"topicID"`

	// Authentication method to interact with the Azure REST API.
	// This event source only supports the ServicePrincipal authentication.
	// If it not present, it will try to use Azure AKS Managed Identity
	Auth AzureAuth `json:"auth"`

	// WebSocketsEnable
	// +optional
	WebSocketsEnable *bool `json:"webSocketsEnable,omitempty"`

	// Adapter spec overrides parameters.
	// +optional
	AdapterOverrides *v1alpha1.AdapterOverrides `json:"adapterOverrides,omitempty"`
}

AzureServiceBusTopicSourceSpec defines the desired state of the event source.

func (*AzureServiceBusTopicSourceSpec) DeepCopy added in v1.12.0 

func (in *AzureServiceBusTopicSourceSpec) DeepCopy() *AzureServiceBusTopicSourceSpec

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

func (*AzureServiceBusTopicSourceSpec) DeepCopyInto added in v1.12.0 

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

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

type AzureServiceBusTopicSourceStatus added in v1.12.0 

type AzureServiceBusTopicSourceStatus struct {
	v1alpha1.Status `json:",inline"`

	// Resource ID of the Service Bus Subscription that is currently used
	// by the event source for consuming events from the configured Service
	// Bus Topic.
	SubscriptionID *AzureResourceID `json:"subscriptionID,omitempty"`
}

AzureServiceBusTopicSourceStatus defines the observed state of the event source.

func (*AzureServiceBusTopicSourceStatus) DeepCopy added in v1.12.0 

func (in *AzureServiceBusTopicSourceStatus) DeepCopy() *AzureServiceBusTopicSourceStatus

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

func (*AzureServiceBusTopicSourceStatus) DeepCopyInto added in v1.12.0 

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

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

func (*AzureServiceBusTopicSourceStatus) MarkNotSubscribed added in v1.12.0 

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

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

func (*AzureServiceBusTopicSourceStatus) MarkSubscribed added in v1.12.0 

func (s *AzureServiceBusTopicSourceStatus) MarkSubscribed()

MarkSubscribed sets the Subscribed condition to True.

type AzureServicePrincipal 

type AzureServicePrincipal struct {
	TenantID     v1alpha1.ValueFromField `json:"tenantID"`
	ClientID     v1alpha1.ValueFromField `json:"clientID"`
	ClientSecret v1alpha1.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 CloudEventsSource added in v1.17.0 

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

	Spec   CloudEventsSourceSpec `json:"spec,omitempty"`
	Status v1alpha1.Status       `json:"status,omitempty"`
}

CloudEventsSource is the Schema for the event source.

func (*CloudEventsSource) AsEventSource added in v1.19.2 

func (s *CloudEventsSource) AsEventSource() string

AsEventSource implements EventSource.

func (*CloudEventsSource) DeepCopy added in v1.17.0 

func (in *CloudEventsSource) DeepCopy() *CloudEventsSource

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

func (*CloudEventsSource) DeepCopyInto added in v1.17.0 

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

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

func (*CloudEventsSource) DeepCopyObject added in v1.17.0 

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

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

func (*CloudEventsSource) GetAdapterOverrides added in v1.19.2 

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

GetAdapterOverrides implements AdapterConfigurable.

func (*CloudEventsSource) GetConditionSet added in v1.17.0 

func (*CloudEventsSource) GetConditionSet() apis.ConditionSet

GetConditionSet implements duckv1.KRShaped.

func (*CloudEventsSource) GetEventTypes added in v1.19.2 

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

GetEventTypes implements EventSource.

func (*CloudEventsSource) GetGroupVersionKind added in v1.17.0 

func (*CloudEventsSource) GetGroupVersionKind() schema.GroupVersionKind

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*CloudEventsSource) GetSink added in v1.17.0 

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

GetSink implements EventSender.

func (*CloudEventsSource) GetStatus added in v1.17.0 

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

GetStatus implements duckv1.KRShaped.

func (*CloudEventsSource) GetStatusManager added in v1.17.0 

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

GetStatusManager implements Reconcilable.

func (*CloudEventsSource) SetDefaults added in v1.17.0 

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

SetDefaults implements apis.Defaultable

func (*CloudEventsSource) Validate added in v1.17.0 

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

Validate implements apis.Validatable

type CloudEventsSourceList added in v1.17.0 

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

CloudEventsSourceList contains a list of event sources.

func (*CloudEventsSourceList) DeepCopy added in v1.17.0 

func (in *CloudEventsSourceList) DeepCopy() *CloudEventsSourceList

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

func (*CloudEventsSourceList) DeepCopyInto added in v1.17.0 

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

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

func (*CloudEventsSourceList) DeepCopyObject added in v1.17.0 

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

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

type CloudEventsSourceSpec added in v1.17.0 

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

	// Credentials to connect to this source.
	// +optional
	Credentials *HTTPCredentials `json:"credentials,omitempty"`

	// Path under which requests are accepted.
	// +optional
	Path *string `json:"path,omitempty"`

	// RateLimiter for incoming events per adapter instance.
	// A single CloudEventsSource object can create multiple adapter instances,
	// the rate limiting configuration being applied to each of them individually.
	// +optional
	RateLimiter *RateLimiter `json:"rateLimiter,omitempty"`

	// Adapter spec overrides parameters.
	// +optional
	AdapterOverrides *v1alpha1.AdapterOverrides `json:"adapterOverrides,omitempty"`
}

CloudEventsSourceSpec defines the desired state of the event source.

func (*CloudEventsSourceSpec) DeepCopy added in v1.17.0 

func (in *CloudEventsSourceSpec) DeepCopy() *CloudEventsSourceSpec

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

func (*CloudEventsSourceSpec) DeepCopyInto added in v1.17.0 

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

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

func (*CloudEventsSourceSpec) Validate added in v1.17.0 

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

Validate CloudEventsSource spec

type Credentials added in v1.13.0 

type Credentials struct {
	User     v1alpha1.ValueFromField `json:"username,omitempty"`
	Password v1alpha1.ValueFromField `json:"password,omitempty"`
	TLS      *TLSSpec                `json:"tls,omitempty"`
}

Credentials holds the auth details.

func (*Credentials) DeepCopy added in v1.13.0 

func (in *Credentials) DeepCopy() *Credentials

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

func (*Credentials) DeepCopyInto added in v1.13.0 

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

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

type Delivery added in v1.13.0 

type Delivery struct {
	DeadLetterQueue string `json:"deadLetterQueue"`
	Retry           int    `json:"retry"`

	// currently not used
	DeadLetterQueueManager string `json:"deadLetterQueueManager,omitempty"`
	BackoffDelay           int    `json:"backoffDelay,omitempty"`
}

Delivery defines the source's message delivery behavior.

func (*Delivery) DeepCopy added in v1.13.0 

func (in *Delivery) DeepCopy() *Delivery

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

func (*Delivery) DeepCopyInto added in v1.13.0 

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

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

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) GetAdapterOverrides added in v1.16.1 

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

GetAdapterOverrides implements AdapterConfigurable.

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 EventSender.

func (*GoogleCloudAuditLogsSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*GoogleCloudAuditLogsSource) GetStatusManager 

func (s *GoogleCloudAuditLogsSource) GetStatusManager() *v1alpha1.StatusManager

GetStatusManager implements Reconcilable.

func (*GoogleCloudAuditLogsSource) ServiceAccountOptions added in v1.24.0 

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

ServiceAccountOptions implements ServiceAccountProvider.

func (*GoogleCloudAuditLogsSource) SetDefaults added in v1.25.0 

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

SetDefaults implements apis.Defaultable

func (*GoogleCloudAuditLogsSource) Validate added in v1.25.0 

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

Validate implements apis.Validatable

func (*GoogleCloudAuditLogsSource) WantsOwnServiceAccount added in v1.24.0 

func (s *GoogleCloudAuditLogsSource) WantsOwnServiceAccount() bool

WantsOwnServiceAccount implements ServiceAccountProvider.

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 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 GoogleCloudSourcePubSubSpec `json:"pubsub"`

	// Different authentication methods available in sources on GCP.
	Auth v1alpha1.GoogleCloudAuth `json:"auth"`

	// Adapter spec overrides parameters.
	// +optional
	AdapterOverrides *v1alpha1.AdapterOverrides `json:"adapterOverrides,omitempty"`
}

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 {
	v1alpha1.Status `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) GetAdapterOverrides added in v1.16.1 

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

GetAdapterOverrides implements AdapterConfigurable.

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 EventSender.

func (*GoogleCloudBillingSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*GoogleCloudBillingSource) GetStatusManager 

func (s *GoogleCloudBillingSource) GetStatusManager() *v1alpha1.StatusManager

GetStatusManager implements Reconcilable.

func (*GoogleCloudBillingSource) ServiceAccountOptions added in v1.24.0 

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

ServiceAccountOptions implements ServiceAccountProvider.

func (*GoogleCloudBillingSource) SetDefaults added in v1.25.0 

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

SetDefaults implements apis.Defaultable

func (*GoogleCloudBillingSource) Validate added in v1.25.0 

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

Validate implements apis.Validatable

func (*GoogleCloudBillingSource) WantsOwnServiceAccount added in v1.24.0 

func (s *GoogleCloudBillingSource) WantsOwnServiceAccount() bool

WantsOwnServiceAccount implements ServiceAccountProvider.

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 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 GoogleCloudSourcePubSubSpec `json:"pubsub"`

	// Different authentication methods available in sources on GCP.
	Auth v1alpha1.GoogleCloudAuth `json:"auth"`

	// Adapter spec overrides parameters.
	// +optional
	AdapterOverrides *v1alpha1.AdapterOverrides `json:"adapterOverrides,omitempty"`
}

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 {
	v1alpha1.Status `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) GetAdapterOverrides added in v1.16.1 

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

GetAdapterOverrides implements AdapterConfigurable.

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 EventSender.

func (*GoogleCloudPubSubSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*GoogleCloudPubSubSource) GetStatusManager 

func (s *GoogleCloudPubSubSource) GetStatusManager() *v1alpha1.StatusManager

GetStatusManager implements Reconcilable.

func (*GoogleCloudPubSubSource) ServiceAccountOptions added in v1.24.0 

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

ServiceAccountOptions implements ServiceAccountProvider.

func (*GoogleCloudPubSubSource) SetDefaults added in v1.25.0 

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

SetDefaults implements apis.Defaultable

func (*GoogleCloudPubSubSource) Validate added in v1.25.0 

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

Validate implements apis.Validatable

func (*GoogleCloudPubSubSource) WantsOwnServiceAccount added in v1.24.0 

func (s *GoogleCloudPubSubSource) WantsOwnServiceAccount() bool

WantsOwnServiceAccount implements ServiceAccountProvider.

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

	// Different authentication methods available in sources on GCP.
	Auth v1alpha1.GoogleCloudAuth `json:"auth"`

	// Adapter spec overrides parameters.
	// +optional
	AdapterOverrides *v1alpha1.AdapterOverrides `json:"adapterOverrides,omitempty"`
}

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 {
	v1alpha1.Status `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 GoogleCloudSourcePubSubSpec added in v1.18.0 

type GoogleCloudSourcePubSubSpec struct {

	// Full resource name of the Pub/Sub topic where messages/notifications
	// originating from the configured Google Cloud resource are sent to,
	// before being retrieved by this event source. 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
	// configured Google Cloud resource are to be created.
	//
	// Mutually exclusive with Topic which, if supplied, already contains
	// the project name.
	//
	// +optional
	Project *string `json:"project,omitempty"`
}

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

func (*GoogleCloudSourcePubSubSpec) DeepCopy added in v1.18.0 

func (in *GoogleCloudSourcePubSubSpec) DeepCopy() *GoogleCloudSourcePubSubSpec

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

func (*GoogleCloudSourcePubSubSpec) DeepCopyInto added in v1.18.0 

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

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

type GoogleCloudSourceRepositoriesSource added in v1.13.0 

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

	Spec   GoogleCloudSourceRepositoriesSourceSpec   `json:"spec,omitempty"`
	Status GoogleCloudSourceRepositoriesSourceStatus `json:"status,omitempty"`
}

GoogleCloudSourceRepositoriesSource is the Schema for the event source.

func (*GoogleCloudSourceRepositoriesSource) AsEventSource added in v1.13.0 

func (s *GoogleCloudSourceRepositoriesSource) AsEventSource() string

AsEventSource implements EventSource.

func (*GoogleCloudSourceRepositoriesSource) DeepCopy added in v1.13.0 

func (in *GoogleCloudSourceRepositoriesSource) DeepCopy() *GoogleCloudSourceRepositoriesSource

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

func (*GoogleCloudSourceRepositoriesSource) DeepCopyInto added in v1.13.0 

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

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

func (*GoogleCloudSourceRepositoriesSource) DeepCopyObject added in v1.13.0 

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

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

func (*GoogleCloudSourceRepositoriesSource) GetAdapterOverrides added in v1.16.1 

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

GetAdapterOverrides implements AdapterConfigurable.

func (*GoogleCloudSourceRepositoriesSource) GetConditionSet added in v1.13.0 

func (*GoogleCloudSourceRepositoriesSource) GetConditionSet() apis.ConditionSet

GetConditionSet implements duckv1.KRShaped.

func (*GoogleCloudSourceRepositoriesSource) GetEventTypes added in v1.13.0 

func (*GoogleCloudSourceRepositoriesSource) GetEventTypes() []string

GetEventTypes returns the event types generated by the source.

func (*GoogleCloudSourceRepositoriesSource) GetGroupVersionKind added in v1.13.0 

func (*GoogleCloudSourceRepositoriesSource) GetGroupVersionKind() schema.GroupVersionKind

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*GoogleCloudSourceRepositoriesSource) GetSink added in v1.13.0 

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

GetSink implements EventSender.

func (*GoogleCloudSourceRepositoriesSource) GetStatus added in v1.13.0 

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

GetStatus implements duckv1.KRShaped.

func (*GoogleCloudSourceRepositoriesSource) GetStatusManager added in v1.13.0 

func (s *GoogleCloudSourceRepositoriesSource) GetStatusManager() *v1alpha1.StatusManager

GetStatusManager implements Reconcilable.

func (*GoogleCloudSourceRepositoriesSource) ServiceAccountOptions added in v1.24.0 

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

ServiceAccountOptions implements ServiceAccountProvider.

func (*GoogleCloudSourceRepositoriesSource) SetDefaults added in v1.25.0 

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

SetDefaults implements apis.Defaultable

func (*GoogleCloudSourceRepositoriesSource) Validate added in v1.25.0 

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

Validate implements apis.Validatable

func (*GoogleCloudSourceRepositoriesSource) WantsOwnServiceAccount added in v1.24.0 

func (s *GoogleCloudSourceRepositoriesSource) WantsOwnServiceAccount() bool

WantsOwnServiceAccount implements ServiceAccountProvider.

type GoogleCloudSourceRepositoriesSourceList added in v1.13.0 

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

GoogleCloudSourceRepositoriesSourceList contains a list of event sources.

func (*GoogleCloudSourceRepositoriesSourceList) DeepCopy added in v1.13.0 

func (in *GoogleCloudSourceRepositoriesSourceList) DeepCopy() *GoogleCloudSourceRepositoriesSourceList

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

func (*GoogleCloudSourceRepositoriesSourceList) DeepCopyInto added in v1.13.0 

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

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

func (*GoogleCloudSourceRepositoriesSourceList) DeepCopyObject added in v1.13.0 

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

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

type GoogleCloudSourceRepositoriesSourceSpec added in v1.13.0 

type GoogleCloudSourceRepositoriesSourceSpec 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 GoogleCloudSourcePubSubSpec `json:"pubsub"`

	// Email address of the service account used for publishing
	// notifications to Pub/Sub. This service account needs to be in the
	// same project as the repo, and to have the 'pubsub.topics.publish'
	// IAM permission associated with it. It can (but doesn't have to) be
	// the same service account as the 'ServiceAccountKey' attribute.
	//
	// If unspecified, it defaults to the Compute Engine default service
	// account.
	//
	// +optional
	PublishServiceAccount *string `json:"publishServiceAccount,omitempty"`

	// Different authentication methods available in sources on GCP.
	Auth v1alpha1.GoogleCloudAuth `json:"auth"`

	// Adapter spec overrides parameters.
	// +optional
	AdapterOverrides *v1alpha1.AdapterOverrides `json:"adapterOverrides,omitempty"`
}

GoogleCloudSourceRepositoriesSourceSpec defines the desired state of the event source.

func (*GoogleCloudSourceRepositoriesSourceSpec) DeepCopy added in v1.13.0 

func (in *GoogleCloudSourceRepositoriesSourceSpec) DeepCopy() *GoogleCloudSourceRepositoriesSourceSpec

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

func (*GoogleCloudSourceRepositoriesSourceSpec) DeepCopyInto added in v1.13.0 

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

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

type GoogleCloudSourceRepositoriesSourceStatus added in v1.13.0 

type GoogleCloudSourceRepositoriesSourceStatus struct {
	v1alpha1.Status `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"`
}

GoogleCloudSourceRepositoriesSourceStatus defines the observed state of the event source.

func (*GoogleCloudSourceRepositoriesSourceStatus) DeepCopy added in v1.13.0 

func (in *GoogleCloudSourceRepositoriesSourceStatus) DeepCopy() *GoogleCloudSourceRepositoriesSourceStatus

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

func (*GoogleCloudSourceRepositoriesSourceStatus) DeepCopyInto added in v1.13.0 

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

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

func (*GoogleCloudSourceRepositoriesSourceStatus) MarkNotSubscribed added in v1.13.0 

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

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

func (*GoogleCloudSourceRepositoriesSourceStatus) MarkSubscribed added in v1.13.0 

func (s *GoogleCloudSourceRepositoriesSourceStatus) 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) GetAdapterOverrides added in v1.16.1 

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

GetAdapterOverrides implements AdapterConfigurable.

func (*GoogleCloudStorageSource) GetConditionSet 

func (*GoogleCloudStorageSource) GetConditionSet() apis.ConditionSet

GetConditionSet implements duckv1.KRShaped.

func (*GoogleCloudStorageSource) GetEventTypes 

func (s *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 EventSender.

func (*GoogleCloudStorageSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*GoogleCloudStorageSource) GetStatusManager 

func (s *GoogleCloudStorageSource) GetStatusManager() *v1alpha1.StatusManager

GetStatusManager implements Reconcilable.

func (*GoogleCloudStorageSource) ServiceAccountOptions added in v1.24.0 

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

ServiceAccountOptions implements ServiceAccountProvider.

func (*GoogleCloudStorageSource) SetDefaults added in v1.25.0 

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

SetDefaults implements apis.Defaultable

func (*GoogleCloudStorageSource) Validate added in v1.25.0 

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

Validate implements apis.Validatable

func (*GoogleCloudStorageSource) WantsOwnServiceAccount added in v1.24.0 

func (s *GoogleCloudStorageSource) WantsOwnServiceAccount() bool

WantsOwnServiceAccount implements ServiceAccountProvider.

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

	// Object name prefix filter
	//
	// If present, will only receive notifications for objects whose names that begin with this prefix.
	//
	// If not set, notifications are received for all objects.
	//
	// +optional
	ObjectNamePrefix string `json:"objectNamePrefix,omitempty"`

	// Different authentication methods available in sources on GCP.
	Auth v1alpha1.GoogleCloudAuth `json:"auth"`

	// Adapter spec overrides parameters.
	// +optional
	AdapterOverrides *v1alpha1.AdapterOverrides `json:"adapterOverrides,omitempty"`
}

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 {
	v1alpha1.Status `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 HTTPBasicAuth added in v1.17.0 

type HTTPBasicAuth struct {
	Username string                  `json:"username"`
	Password v1alpha1.ValueFromField `json:"password"`
}

HTTPBasicAuth credentials.

func (*HTTPBasicAuth) DeepCopy added in v1.17.0 

func (in *HTTPBasicAuth) DeepCopy() *HTTPBasicAuth

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

func (*HTTPBasicAuth) DeepCopyInto added in v1.17.0 

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

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

type HTTPCredentials added in v1.17.0 

type HTTPCredentials struct {
	BasicAuths []HTTPBasicAuth `json:"basicAuths,omitempty"`
}

HTTPCredentials to be used when receiving requests.

func (*HTTPCredentials) DeepCopy added in v1.17.0 

func (in *HTTPCredentials) DeepCopy() *HTTPCredentials

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

func (*HTTPCredentials) DeepCopyInto added in v1.17.0 

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

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

func (*HTTPCredentials) Validate added in v1.17.0 

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

type HTTPPollerSource 

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

	Spec   HTTPPollerSourceSpec `json:"spec,omitempty"`
	Status v1alpha1.Status      `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) GetAdapterOverrides added in v1.16.1 

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

GetAdapterOverrides implements AdapterConfigurable.

func (*HTTPPollerSource) GetConditionSet 

func (s *HTTPPollerSource) GetConditionSet() apis.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 EventSender.

func (*HTTPPollerSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*HTTPPollerSource) GetStatusManager 

func (s *HTTPPollerSource) GetStatusManager() *v1alpha1.StatusManager

GetStatusManager implements Reconcilable.

func (*HTTPPollerSource) SetDefaults added in v1.25.0 

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

SetDefaults implements apis.Defaultable

func (*HTTPPollerSource) Validate added in v1.25.0 

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

Validate implements apis.Validatable

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 pkgapis.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 *v1alpha1.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 apis.Duration `json:"interval"`

	// Adapter spec overrides parameters.
	// +optional
	AdapterOverrides *v1alpha1.AdapterOverrides `json:"adapterOverrides,omitempty"`
}

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 IBMMQSource added in v1.13.0 

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

	Spec   IBMMQSourceSpec `json:"spec"`
	Status v1alpha1.Status `json:"status,omitempty"`
}

IBMMQSource is the Schema the event source.

func (*IBMMQSource) AsEventSource added in v1.13.0 

func (s *IBMMQSource) AsEventSource() string

AsEventSource implements EventSource.

func (*IBMMQSource) DeepCopy added in v1.13.0 

func (in *IBMMQSource) DeepCopy() *IBMMQSource

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

func (*IBMMQSource) DeepCopyInto added in v1.13.0 

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

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

func (*IBMMQSource) DeepCopyObject added in v1.13.0 

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

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

func (*IBMMQSource) GetAdapterOverrides added in v1.16.1 

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

GetAdapterOverrides implements AdapterConfigurable.

func (*IBMMQSource) GetConditionSet added in v1.13.0 

func (*IBMMQSource) GetConditionSet() apis.ConditionSet

GetConditionSet implements duckv1.KRShaped.

func (*IBMMQSource) GetEventTypes added in v1.13.0 

func (*IBMMQSource) GetEventTypes() []string

GetEventTypes implements EventSource.

func (*IBMMQSource) GetGroupVersionKind added in v1.13.0 

func (*IBMMQSource) GetGroupVersionKind() schema.GroupVersionKind

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*IBMMQSource) GetSink added in v1.13.0 

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

GetSink implements EventSender.

func (*IBMMQSource) GetStatus added in v1.13.0 

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

GetStatus implements duckv1.KRShaped.

func (*IBMMQSource) GetStatusManager added in v1.13.0 

func (s *IBMMQSource) GetStatusManager() *v1alpha1.StatusManager

GetStatusManager implements Reconcilable.

func (*IBMMQSource) SetDefaults added in v1.25.0 

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

SetDefaults implements apis.Defaultable

func (*IBMMQSource) Validate added in v1.25.0 

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

Validate implements apis.Validatable

type IBMMQSourceList added in v1.13.0 

type IBMMQSourceList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata"`
	Items           []IBMMQSource `json:"items"`
}

IBMMQSourceList is a list of event source instances.

func (*IBMMQSourceList) DeepCopy added in v1.13.0 

func (in *IBMMQSourceList) DeepCopy() *IBMMQSourceList

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

func (*IBMMQSourceList) DeepCopyInto added in v1.13.0 

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

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

func (*IBMMQSourceList) DeepCopyObject added in v1.13.0 

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

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

type IBMMQSourceSpec added in v1.13.0 

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

	ConnectionName string `json:"connectionName"`
	QueueManager   string `json:"queueManager"`
	QueueName      string `json:"queueName"`
	ChannelName    string `json:"channelName"`

	Delivery Delivery `json:"delivery,omitempty"`

	Auth Credentials `json:"credentials"`

	// Adapter spec overrides parameters.
	// +optional
	AdapterOverrides *v1alpha1.AdapterOverrides `json:"adapterOverrides,omitempty"`
}

IBMMQSourceSpec defines the desired state of the event source.

func (*IBMMQSourceSpec) DeepCopy added in v1.13.0 

func (in *IBMMQSourceSpec) DeepCopy() *IBMMQSourceSpec

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

func (*IBMMQSourceSpec) DeepCopyInto added in v1.13.0 

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

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

type KafkaSource added in v1.19.0 

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

	Spec   KafkaSourceSpec `json:"spec,omitempty"`
	Status v1alpha1.Status `json:"status,omitempty"`
}

KafkaSource is the Schema for the KafkaSource.

func (*KafkaSource) AsEventSource added in v1.22.0 

func (s *KafkaSource) AsEventSource() string

AsEventSource implements EventSource.

func (*KafkaSource) DeepCopy added in v1.19.0 

func (in *KafkaSource) DeepCopy() *KafkaSource

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

func (*KafkaSource) DeepCopyInto added in v1.19.0 

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

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

func (*KafkaSource) DeepCopyObject added in v1.19.0 

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

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

func (*KafkaSource) GetAdapterOverrides added in v1.22.0 

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

GetAdapterOverrides implements AdapterConfigurable.

func (*KafkaSource) GetConditionSet added in v1.19.0 

func (*KafkaSource) GetConditionSet() apis.ConditionSet

GetConditionSet implements duckv1.KRShaped.

func (*KafkaSource) GetEventTypes added in v1.22.0 

func (*KafkaSource) GetEventTypes() []string

GetEventTypes implements EventSource.

func (*KafkaSource) GetGroupVersionKind added in v1.19.0 

func (*KafkaSource) GetGroupVersionKind() schema.GroupVersionKind

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*KafkaSource) GetSink added in v1.19.0 

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

GetSink implements EventSender.

func (*KafkaSource) GetStatus added in v1.19.0 

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

GetStatus implements duckv1.KRShaped.

func (*KafkaSource) GetStatusManager added in v1.19.0 

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

GetStatusManager implements Reconcilable.

func (*KafkaSource) SetDefaults added in v1.25.0 

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

SetDefaults implements apis.Defaultable

func (*KafkaSource) Validate added in v1.25.0 

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

Validate implements apis.Validatable

type KafkaSourceAuth added in v1.19.0 

type KafkaSourceAuth struct {
	Kerberos *KafkaSourceKerberos `json:"kerberos,omitempty"`
	TLS      *KafkaSourceTLSAuth  `json:"tls,omitempty"`

	// SASL Enable
	SASLEnable bool `json:"saslEnable"`

	// TLS Enable
	// +optional
	TLSEnable *bool `json:"tlsEnable,omitempty"`

	// SecurityMechanisms holds the assignment of the specific SASL mechanisms.
	// +optional
	SecurityMechanisms *string `json:"securityMechanism,omitempty"`

	// Username Kafka account User
	// +optional
	Username *string `json:"username,omitempty"`

	// Password Kafka account Password
	// +optional
	Password *v1alpha1.ValueFromField `json:"password,omitempty"`
}

KafkaSourceAuth contains Authentication method used to interact with Kafka.

func (*KafkaSourceAuth) DeepCopy added in v1.19.0 

func (in *KafkaSourceAuth) DeepCopy() *KafkaSourceAuth

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

func (*KafkaSourceAuth) DeepCopyInto added in v1.19.0 

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

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

type KafkaSourceKerberos added in v1.19.0 

type KafkaSourceKerberos struct {
	Username    *string                  `json:"username,omitempty"`
	Password    *v1alpha1.ValueFromField `json:"password,omitempty"`
	Realm       *string                  `json:"realm,omitempty"`
	ServiceName *string                  `json:"serviceName,omitempty"`
	ConfigPath  *string                  `json:"configPath,omitempty"`
	KeytabPath  *string                  `json:"keytabPath,omitempty"`
	Config      *v1alpha1.ValueFromField `json:"config,omitempty"`
	Keytab      *v1alpha1.ValueFromField `json:"keytab,omitempty"`
}

KafkaSourceKerberos contains kerberos credentials.

func (*KafkaSourceKerberos) DeepCopy added in v1.19.0 

func (in *KafkaSourceKerberos) DeepCopy() *KafkaSourceKerberos

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

func (*KafkaSourceKerberos) DeepCopyInto added in v1.19.0 

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

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

type KafkaSourceList added in v1.19.0 

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

KafkaSourceList contains a list of event sources.

func (*KafkaSourceList) DeepCopy added in v1.19.0 

func (in *KafkaSourceList) DeepCopy() *KafkaSourceList

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

func (*KafkaSourceList) DeepCopyInto added in v1.19.0 

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

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

func (*KafkaSourceList) DeepCopyObject added in v1.19.0 

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

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

type KafkaSourceSpec added in v1.19.0 

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

	// BootstrapServers holds the name of the Kafka Bootstrap server.
	BootstrapServers []string `json:"bootstrapServers"`

	// Topic holds the name of the Kafka Topic.
	Topic string `json:"topic"`

	// GroupID holds the name of the Kafka Group ID.
	GroupID string `json:"groupID"`

	// Auth contains Authentication method used to interact with Kafka.
	// +optional
	Auth KafkaSourceAuth `json:"auth"`

	// Adapter spec overrides parameters.
	// +optional
	AdapterOverrides *v1alpha1.AdapterOverrides `json:"adapterOverrides,omitempty"`
}

KafkaSourceSpec defines the desired state of the event source.

func (*KafkaSourceSpec) DeepCopy added in v1.19.0 

func (in *KafkaSourceSpec) DeepCopy() *KafkaSourceSpec

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

func (*KafkaSourceSpec) DeepCopyInto added in v1.19.0 

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

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

type KafkaSourceTLSAuth added in v1.19.0 

type KafkaSourceTLSAuth struct {
	CA         *v1alpha1.ValueFromField `json:"ca,omitempty"`
	ClientCert *v1alpha1.ValueFromField `json:"clientCert,omitempty"`
	ClientKey  *v1alpha1.ValueFromField `json:"clientKey,omitempty"`
	SkipVerify *bool                    `json:"skipVerify,omitempty"`
}

KafkaSourceTLSAuth contains kerberos credentials.

func (*KafkaSourceTLSAuth) DeepCopy added in v1.19.0 

func (in *KafkaSourceTLSAuth) DeepCopy() *KafkaSourceTLSAuth

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

func (*KafkaSourceTLSAuth) DeepCopyInto added in v1.19.0 

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

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

type Keystore added in v1.14.0 

type Keystore struct {
	KeyDatabase   v1alpha1.ValueFromField `json:"keyDatabase"`
	PasswordStash v1alpha1.ValueFromField `json:"passwordStash"`
}

Keystore represents Key Database components.

func (*Keystore) DeepCopy added in v1.14.0 

func (in *Keystore) DeepCopy() *Keystore

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

func (*Keystore) DeepCopyInto added in v1.14.0 

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

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

type MongoDBSource added in v1.25.0 

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

	Spec   MongoDBSourceSpec `json:"spec,omitempty"`
	Status v1alpha1.Status   `json:"status,omitempty"`
}

MongoDBSource is the Schema for the event source.

func (*MongoDBSource) AsEventSource added in v1.25.0 

func (s *MongoDBSource) AsEventSource() string

AsEventSource implements EventSender.

func (*MongoDBSource) DeepCopy added in v1.25.0 

func (in *MongoDBSource) DeepCopy() *MongoDBSource

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

func (*MongoDBSource) DeepCopyInto added in v1.25.0 

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

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

func (*MongoDBSource) DeepCopyObject added in v1.25.0 

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

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

func (*MongoDBSource) GetConditionSet added in v1.25.0 

func (*MongoDBSource) GetConditionSet() apis.ConditionSet

GetConditionSet implements duckv1.KRShaped.

func (*MongoDBSource) GetEventTypes added in v1.25.0 

func (*MongoDBSource) GetEventTypes() []string

GetEventTypes implements EventSource.

func (*MongoDBSource) GetGroupVersionKind added in v1.25.0 

func (*MongoDBSource) GetGroupVersionKind() schema.GroupVersionKind

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*MongoDBSource) GetSink added in v1.25.0 

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

GetSink implements EventSender.

func (*MongoDBSource) GetStatus added in v1.25.0 

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

GetStatus implements duckv1.KRShaped.

func (*MongoDBSource) GetStatusManager added in v1.25.0 

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

GetStatusManager impleemnts Reconcialable.

func (*MongoDBSource) SetDefaults added in v1.25.0 

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

SetDefaults implements apis.Defaultable

func (*MongoDBSource) Validate added in v1.25.0 

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

Validate implements apis.Validatable

type MongoDBSourceList added in v1.25.0 

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

MongoDBSourceList contains a list of event sources.

func (*MongoDBSourceList) DeepCopy added in v1.25.0 

func (in *MongoDBSourceList) DeepCopy() *MongoDBSourceList

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

func (*MongoDBSourceList) DeepCopyInto added in v1.25.0 

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

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

func (*MongoDBSourceList) DeepCopyObject added in v1.25.0 

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

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

type MongoDBSourceSpec added in v1.25.0 

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

	// ConnectionString holds the connection string to the MongoDB server.
	ConnectionString string `json:"connectionString"`

	// Database holds the name of the MongoDB database.
	Database string `json:"database"`

	// Collection holds the name of the MongoDB collection.
	Collection string `json:"collection"`
}

MongoDBSourceSpec defines the desired state of the event source.

func (*MongoDBSourceSpec) DeepCopy added in v1.25.0 

func (in *MongoDBSourceSpec) DeepCopy() *MongoDBSourceSpec

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

func (*MongoDBSourceSpec) DeepCopyInto added in v1.25.0 

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

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 v1alpha1.Status      `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) GetAdapterOverrides added in v1.16.1 

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

GetAdapterOverrides implements AdapterConfigurable.

func (*OCIMetricsSource) GetConditionSet 

func (*OCIMetricsSource) GetConditionSet() apis.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 EventSender.

func (*OCIMetricsSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*OCIMetricsSource) GetStatusManager 

func (s *OCIMetricsSource) GetStatusManager() *v1alpha1.StatusManager

GetStatusManager implements Reconcilable.

func (*OCIMetricsSource) SetDefaults added in v1.25.0 

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

SetDefaults implements apis.Defaultable

func (*OCIMetricsSource) Validate added in v1.25.0 

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

Validate implements apis.Validatable

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 v1alpha1.ValueFromField `json:"oracleApiPrivateKey"`

	// Oracle User API private key passphrase
	OracleAPIPrivateKeyPassphrase v1alpha1.ValueFromField `json:"oracleApiPrivateKeyPassphrase"`

	// Oracle User API cert fingerprint
	OracleAPIPrivateKeyFingerprint v1alpha1.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"`

	// Adapter spec overrides parameters.
	// +optional
	AdapterOverrides *v1alpha1.AdapterOverrides `json:"adapterOverrides,omitempty"`
}

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 RateLimiter added in v1.17.0 

type RateLimiter struct {
	// RequestsPerSecond is used to limit the number of requests that a
	// single instance of the CloudEventsSource adapter can accept.
	RequestsPerSecond int `json:"requestsPerSecond"`
}

RateLimiter parameters.

func (*RateLimiter) DeepCopy added in v1.17.0 

func (in *RateLimiter) DeepCopy() *RateLimiter

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

func (*RateLimiter) DeepCopyInto added in v1.17.0 

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

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  v1alpha1.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 v1alpha1.Status      `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) GetAdapterOverrides added in v1.16.1 

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

GetAdapterOverrides implements AdapterConfigurable.

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 EventSender.

func (*SalesforceSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*SalesforceSource) GetStatusManager 

func (s *SalesforceSource) GetStatusManager() *v1alpha1.StatusManager

GetStatusManager implements Reconcilable.

func (*SalesforceSource) SetDefaults added in v1.25.0 

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

SetDefaults implements apis.Defaultable

func (*SalesforceSource) Validate added in v1.25.0 

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

Validate implements apis.Validatable

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

	// Adapter spec overrides parameters.
	// +optional
	AdapterOverrides *v1alpha1.AdapterOverrides `json:"adapterOverrides,omitempty"`
}

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 v1alpha1.Status `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) GetAdapterOverrides added in v1.16.1 

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

GetAdapterOverrides implements AdapterConfigurable.

func (*SlackSource) GetConditionSet 

func (*SlackSource) GetConditionSet() apis.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 EventSender.

func (*SlackSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*SlackSource) GetStatusManager 

func (s *SlackSource) GetStatusManager() *v1alpha1.StatusManager

GetStatusManager implements Reconcilable.

func (*SlackSource) SetDefaults added in v1.25.0 

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

SetDefaults implements apis.Defaultable

func (*SlackSource) Validate added in v1.25.0 

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

Validate implements apis.Validatable

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 *v1alpha1.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"`

	// Adapter spec overrides parameters.
	// +optional
	AdapterOverrides *v1alpha1.AdapterOverrides `json:"adapterOverrides,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 SolaceSource added in v1.24.0 

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

	Spec   SolaceSourceSpec `json:"spec,omitempty"`
	Status v1alpha1.Status  `json:"status,omitempty"`
}

SolaceSource is the Schema for the event source.

func (*SolaceSource) AsEventSource added in v1.24.0 

func (s *SolaceSource) AsEventSource() string

AsEventSource implements EventSource.

func (*SolaceSource) DeepCopy added in v1.24.0 

func (in *SolaceSource) DeepCopy() *SolaceSource

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

func (*SolaceSource) DeepCopyInto added in v1.24.0 

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

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

func (*SolaceSource) DeepCopyObject added in v1.24.0 

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

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

func (*SolaceSource) GetAdapterOverrides added in v1.24.0 

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

GetAdapterOverrides implements AdapterConfigurable.

func (*SolaceSource) GetConditionSet added in v1.24.0 

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

GetConditionSet implements duckv1.KRShaped.

func (*SolaceSource) GetEventTypes added in v1.24.0 

func (*SolaceSource) GetEventTypes() []string

GetEventTypes implements EventSource.

func (*SolaceSource) GetGroupVersionKind added in v1.24.0 

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

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*SolaceSource) GetSink added in v1.24.0 

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

GetSink implements EventSender.

func (*SolaceSource) GetStatus added in v1.24.0 

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

GetStatus implements duckv1.KRShaped.

func (*SolaceSource) GetStatusManager added in v1.24.0 

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

GetStatusManager implements Reconcilable.

func (*SolaceSource) SetDefaults added in v1.25.0 

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

SetDefaults implements apis.Defaultable

func (*SolaceSource) Validate added in v1.25.0 

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

Validate implements apis.Validatable

type SolaceSourceAuth added in v1.24.0 

type SolaceSourceAuth struct {
	// TLS
	// +optional
	TLS *SolaceSourceTLSAuth `json:"tls,omitempty"`

	// SASL Enable
	// +optional
	SASLEnable *bool `json:"saslEnable"`

	// TLS Enable
	// +optional
	TLSEnable *bool `json:"tlsEnable,omitempty"`

	// Username Solace
	// +optional
	Username *string `json:"username,omitempty"`

	// Password Solace
	// +optional
	Password *v1alpha1.ValueFromField `json:"password,omitempty"`
}

SolaceSourceAuth contains Authentication method used to interact with Solace.

func (*SolaceSourceAuth) DeepCopy added in v1.24.0 

func (in *SolaceSourceAuth) DeepCopy() *SolaceSourceAuth

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

func (*SolaceSourceAuth) DeepCopyInto added in v1.24.0 

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

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

type SolaceSourceList added in v1.24.0 

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

SolaceSourceList contains a list of event sources.

func (*SolaceSourceList) DeepCopy added in v1.24.0 

func (in *SolaceSourceList) DeepCopy() *SolaceSourceList

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

func (*SolaceSourceList) DeepCopyInto added in v1.24.0 

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

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

func (*SolaceSourceList) DeepCopyObject added in v1.24.0 

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

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

type SolaceSourceSpec added in v1.24.0 

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

	// URL
	URL string `json:"url"`

	// QueueName
	QueueName string `json:"queueName"`

	// Auth contains Authentication method used to interact with Solace.
	// +optional
	Auth *SolaceSourceAuth `json:"auth,omitempty"`

	// Adapter spec overrides parameters.
	// +optional
	AdapterOverrides *v1alpha1.AdapterOverrides `json:"adapterOverrides,omitempty"`
}

SolaceSourceSpec defines the desired state of the event source.

func (*SolaceSourceSpec) DeepCopy added in v1.24.0 

func (in *SolaceSourceSpec) DeepCopy() *SolaceSourceSpec

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

func (*SolaceSourceSpec) DeepCopyInto added in v1.24.0 

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

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

type SolaceSourceTLSAuth added in v1.24.0 

type SolaceSourceTLSAuth struct {
	CA         *v1alpha1.ValueFromField `json:"ca,omitempty"`
	ClientCert *v1alpha1.ValueFromField `json:"clientCert,omitempty"`
	ClientKey  *v1alpha1.ValueFromField `json:"clientKey,omitempty"`
	SkipVerify *bool                    `json:"skipVerify,omitempty"`
}

SolaceSourceTLSAuth contains kerberos credentials.

func (*SolaceSourceTLSAuth) DeepCopy added in v1.24.0 

func (in *SolaceSourceTLSAuth) DeepCopy() *SolaceSourceTLSAuth

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

func (*SolaceSourceTLSAuth) DeepCopyInto added in v1.24.0 

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

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

type TLSSpec added in v1.14.0 

type TLSSpec struct {
	Cipher             string   `json:"cipher"`
	ClientAuthRequired bool     `json:"clientAuthRequired"`
	CertLabel          *string  `json:"certLabel,omitempty"`
	KeyRepository      Keystore `json:"keyRepository"`
}

TLSSpec holds the IBM MQ TLS authentication parameters.

func (*TLSSpec) DeepCopy added in v1.14.0 

func (in *TLSSpec) DeepCopy() *TLSSpec

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

func (*TLSSpec) DeepCopyInto added in v1.14.0 

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

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

type TwilioSource 

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

	Spec   TwilioSourceSpec `json:"spec,omitempty"`
	Status v1alpha1.Status  `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) GetAdapterOverrides added in v1.16.1 

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

GetAdapterOverrides implements AdapterConfigurable.

func (*TwilioSource) GetConditionSet 

func (s *TwilioSource) GetConditionSet() apis.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 EventSender.

func (*TwilioSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*TwilioSource) GetStatusManager 

func (s *TwilioSource) GetStatusManager() *v1alpha1.StatusManager

GetStatusManager implements Reconcilable.

func (*TwilioSource) SetDefaults added in v1.25.0 

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

SetDefaults implements apis.Defaultable

func (*TwilioSource) Validate added in v1.25.0 

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

Validate implements apis.Validatable

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

	// Adapter spec overrides parameters.
	// +optional
	AdapterOverrides *v1alpha1.AdapterOverrides `json:"adapterOverrides,omitempty"`
}

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 WebhookEventExtensionAttributes added in v1.19.2 

type WebhookEventExtensionAttributes struct {
	// From informs HTTP elements that will be converted into CloudEvents attributes
	// +optional
	From []string `json:"from,omitempty"`
}

WebhookEventExtensionAttributes sets the policy for converting HTTP data into.

func (*WebhookEventExtensionAttributes) DeepCopy added in v1.19.2 

func (in *WebhookEventExtensionAttributes) DeepCopy() *WebhookEventExtensionAttributes

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

func (*WebhookEventExtensionAttributes) DeepCopyInto added in v1.19.2 

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

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 v1alpha1.Status   `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) GetAdapterOverrides added in v1.16.1 

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

GetAdapterOverrides implements AdapterConfigurable.

func (*WebhookSource) GetConditionSet 

func (s *WebhookSource) GetConditionSet() apis.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 EventSender.

func (*WebhookSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*WebhookSource) GetStatusManager 

func (s *WebhookSource) GetStatusManager() *v1alpha1.StatusManager

GetStatusManager implements Reconcilable.

func (*WebhookSource) SetDefaults added in v1.25.0 

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

SetDefaults implements apis.Defaultable

func (*WebhookSource) Validate added in v1.25.0 

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

Validate implements apis.Validatable

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

	// Options to transform HTTP request data into CloudEvent extensions.
	// https://github.com/cloudevents/spec/blob/main/cloudevents/spec.md#extension-context-attributes
	// +optional
	EventExtensionAttributes *WebhookEventExtensionAttributes `json:"eventExtensionAttributes,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 *v1alpha1.ValueFromField `json:"basicAuthPassword,omitempty"`

	// Specifies the CORS Origin to use in pre-flight headers.
	// +optional
	CORSAllowOrigin *string `json:"corsAllowOrigin,omitempty"`

	// Adapter spec overrides parameters.
	// +optional
	AdapterOverrides *v1alpha1.AdapterOverrides `json:"adapterOverrides,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) GetAdapterOverrides added in v1.16.1 

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

GetAdapterOverrides implements AdapterConfigurable.

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 EventSender.

func (*ZendeskSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*ZendeskSource) GetStatusManager 

func (s *ZendeskSource) GetStatusManager() *v1alpha1.StatusManager

GetStatusManager implements Reconcilable.

func (*ZendeskSource) IsMultiTenant 

func (*ZendeskSource) IsMultiTenant() bool

IsMultiTenant implements MultiTenant.

func (*ZendeskSource) SetDefaults added in v1.25.0 

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

SetDefaults implements apis.Defaultable

func (*ZendeskSource) Validate added in v1.25.0 

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

Validate implements apis.Validatable

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 v1alpha1.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 v1alpha1.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"`

	// Adapter spec overrides parameters.
	// +optional
	AdapterOverrides *v1alpha1.AdapterOverrides `json:"adapterOverrides,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 {
	v1alpha1.Status `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.