v1alpha1

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

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

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

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

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

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

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

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
}

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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