v1alpha1

package
v1.16.0 Latest Latest
Warning

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

 Go to latest Published: Mar 31, 2022 License: Apache-2.0 Imports: 26 Imported by: 6

Documentation

Overview

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

Index

Constants

View Source 
const (
	AWSCloudWatchMetricEventType  = "metrics.metric"
	AWSCloudWatchMessageEventType = "metrics.message"
)

Supported event types

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

Supported event types (see AWSS3SourceSpec)

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

Reasons for status conditions

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

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

Status conditions

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

Reasons for status conditions

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

Reasons for status conditions

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

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

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

Status conditions

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

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

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

Reasons for status conditions

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

Reasons for status conditions

View Source 
const (
	// ZendeskReasonNoURL is set on a TargetSynced condition when the adapter URL is empty.
	ZendeskReasonNoURL = "MissingAdapterURL"
	// ZendeskReasonNoSecret is set on a TargetSynced condition when required secrets can't be obtained.
	ZendeskReasonNoSecret = "MissingSecret"
	// ZendeskReasonFailedSync is set on a TargetSynced condition when a CRUD API call returns an error.
	ZendeskReasonFailedSync = "FailedSync"
)

Reasons for status conditions

View Source 
const (
	AWSCloudWatchLogsGenericEventType = "log"
)

Supported event types

View Source 
const (
	AWSCognitoIdentityGenericEventType = "sync_trigger"
)

Supported event types

View Source 
const (
	AWSCognitoUserPoolGenericEventType = "sync_trigger"
)

Supported event types

View Source 
const (
	AWSDynamoDBGenericEventType = "stream_record"
)

Supported event types

View Source 
const (
	AWSKinesisGenericEventType = "stream_record"
)

Supported event types

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

Supported event types

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

Status conditions

View Source 
const (
	AWSSNSGenericEventType = "notification"
)

Supported event types

View Source 
const (
	AWSSQSGenericEventType = "message"
)

Supported event types

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

Supported event types

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

Status conditions

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

Status conditions

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

Status conditions

View Source 
const (
	AzureEventHubGenericEventType = "message"
)

Supported event types

View Source 
const (
	AzureIOTHubGenericEventType = "message"
)

Supported event types

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

Supported event types

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

Status conditions

View Source 
const (
	GoogleCloudIoTGenericEventType = "com.google.cloud.iot.message"
)

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

Supported event types

View Source 
const (
	IBMMQSourceEventType = "io.triggermesh.ibm.mq.message"
)

Managed event types

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

Supported event types

View Source 
const ServiceCloudWatch = "cloudwatch"

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

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

Supported event types

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

Supported event types.

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

Status conditions

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

Supported event types

Variables

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

GoogleCloudAuditLogsSourceConditionSet is a set of conditions for GoogleCloudAuditLogsSource objects.

View Source 
var GoogleCloudBillingSourceConditionSet = NewEventSourceConditionSet(
	GoogleCloudBillingConditionSubscribed,
)

GoogleCloudBillingSourceConditionSet is a set of conditions for GoogleCloudBillingSource objects.

View Source 
var IBMMQSourceCondSet = apis.NewLivingConditionSet(
	ConditionDeployed,
)

IBMMQSourceCondSet is the group of possible conditions

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 IsMultiTenant 

func IsMultiTenant(r Reconcilable) bool

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

func Kind 

func Kind(kind string) schema.GroupKind

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

func NewEventSourceConditionSet 

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

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

func OCIGenerateEventSource 

func OCIGenerateEventSource(namespace, name string) string

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

func Resource 

func Resource(resource string) schema.GroupResource

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

func ServiceAccountOptions added in v1.12.0 

func ServiceAccountOptions(r Reconcilable) []resource.ServiceAccountOption

ServiceAccountOptions returns functional options for mutating the ServiceAccount associated with a given component instance.

func TwilioSourceName 

func TwilioSourceName(namespace, name string) string

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

func WantsOwnServiceAccount added in v1.12.0 

func WantsOwnServiceAccount(r Reconcilable) bool

WantsOwnServiceAccount returns whether the given component instance should have a dedicated ServiceAccount associated with its receive adapter.

func WithReconcilable added in v1.16.0 

func WithReconcilable(ctx context.Context, r Reconcilable) context.Context

WithReconcilable returns a copy of the parent context in which the value associated with the reconcilableInstanceKey is the given component instance.

Types

type AWSAuth added in v1.12.0 

type AWSAuth struct {
	// Security credentials allow AWS to authenticate and authorize
	// requests based on a signature composed of an access key ID and a
	// corresponding secret access key.
	// See https://docs.aws.amazon.com/general/latest/gr/aws-security-credentials.html
	Credentials *AWSSecurityCredentials `json:"credentials,omitempty"`

	// (Amazon EKS only) The ARN of an IAM role which can be impersonated
	// to obtain AWS permissions.
	// See https://docs.aws.amazon.com/eks/latest/userguide/iam-roles-for-service-accounts.html
	EksIAMRole *apis.ARN `json:"iamRole"`
}

AWSAuth contains multiple authentication methods for AWS services.

func (*AWSAuth) DeepCopy added in v1.12.0 

func (in *AWSAuth) DeepCopy() *AWSAuth

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

func (*AWSAuth) DeepCopyInto added in v1.12.0 

func (in *AWSAuth) DeepCopyInto(out *AWSAuth)

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

type AWSCloudWatchLogsSource 

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

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

AWSCloudWatchLogsSource is the Schema for the event source.

func (*AWSCloudWatchLogsSource) AsEventSource 

func (s *AWSCloudWatchLogsSource) AsEventSource() string

AsEventSource implements Reconcilable.

func (*AWSCloudWatchLogsSource) DeepCopy 

func (in *AWSCloudWatchLogsSource) DeepCopy() *AWSCloudWatchLogsSource

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

func (*AWSCloudWatchLogsSource) DeepCopyInto 

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

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

func (*AWSCloudWatchLogsSource) DeepCopyObject 

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

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

func (*AWSCloudWatchLogsSource) GetConditionSet 

func (*AWSCloudWatchLogsSource) GetConditionSet() apis.ConditionSet

GetConditionSet implements duckv1.KRShaped.

func (*AWSCloudWatchLogsSource) GetEventTypes 

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

GetEventTypes implements Reconcilable.

func (*AWSCloudWatchLogsSource) GetGroupVersionKind 

func (*AWSCloudWatchLogsSource) GetGroupVersionKind() schema.GroupVersionKind

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*AWSCloudWatchLogsSource) GetSink 

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

GetSink implements Reconcilable.

func (*AWSCloudWatchLogsSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*AWSCloudWatchLogsSource) GetStatusManager 

func (s *AWSCloudWatchLogsSource) GetStatusManager() *StatusManager

GetStatusManager implements Reconcilable.

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 AWSAuth `json:"auth"`
}

AWSCloudWatchLogsSourceSpec defines the desired state of the event source.

func (*AWSCloudWatchLogsSourceSpec) DeepCopy 

func (in *AWSCloudWatchLogsSourceSpec) DeepCopy() *AWSCloudWatchLogsSourceSpec

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

func (*AWSCloudWatchLogsSourceSpec) DeepCopyInto 

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

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

type AWSCloudWatchMetric 

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

AWSCloudWatchMetric is a metric definition.

func (*AWSCloudWatchMetric) DeepCopy 

func (in *AWSCloudWatchMetric) DeepCopy() *AWSCloudWatchMetric

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

func (*AWSCloudWatchMetric) DeepCopyInto 

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

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

type AWSCloudWatchMetricDimension 

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

AWSCloudWatchMetricDimension represents the dimensions of a metric.

func (*AWSCloudWatchMetricDimension) DeepCopy 

func (in *AWSCloudWatchMetricDimension) DeepCopy() *AWSCloudWatchMetricDimension

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

func (*AWSCloudWatchMetricDimension) DeepCopyInto 

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

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

type AWSCloudWatchMetricQuery 

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

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

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

func (*AWSCloudWatchMetricQuery) DeepCopy 

func (in *AWSCloudWatchMetricQuery) DeepCopy() *AWSCloudWatchMetricQuery

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

func (*AWSCloudWatchMetricQuery) DeepCopyInto 

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

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

type AWSCloudWatchMetricStat 

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

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

func (*AWSCloudWatchMetricStat) DeepCopy 

func (in *AWSCloudWatchMetricStat) DeepCopy() *AWSCloudWatchMetricStat

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

func (*AWSCloudWatchMetricStat) DeepCopyInto 

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

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

type AWSCloudWatchSource 

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

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

AWSCloudWatchSource is the Schema for the event source.

func (*AWSCloudWatchSource) AsEventSource 

func (s *AWSCloudWatchSource) AsEventSource() string

AsEventSource implements Reconcilable.

func (*AWSCloudWatchSource) DeepCopy 

func (in *AWSCloudWatchSource) DeepCopy() *AWSCloudWatchSource

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

func (*AWSCloudWatchSource) DeepCopyInto 

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

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

func (*AWSCloudWatchSource) DeepCopyObject 

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

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

func (*AWSCloudWatchSource) GetConditionSet 

func (*AWSCloudWatchSource) GetConditionSet() apis.ConditionSet

GetConditionSet implements duckv1.KRShaped.

func (*AWSCloudWatchSource) GetEventTypes 

func (*AWSCloudWatchSource) GetEventTypes() []string

GetEventTypes implements Reconcilable.

func (*AWSCloudWatchSource) GetGroupVersionKind 

func (*AWSCloudWatchSource) GetGroupVersionKind() schema.GroupVersionKind

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*AWSCloudWatchSource) GetSink 

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

GetSink implements Reconcilable.

func (*AWSCloudWatchSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*AWSCloudWatchSource) GetStatusManager 

func (s *AWSCloudWatchSource) GetStatusManager() *StatusManager

GetStatusManager implements Reconcilable.

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 AWSAuth `json:"auth"`
}

AWSCloudWatchSourceSpec defines the desired state of the event source.

func (*AWSCloudWatchSourceSpec) DeepCopy 

func (in *AWSCloudWatchSourceSpec) DeepCopy() *AWSCloudWatchSourceSpec

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

func (*AWSCloudWatchSourceSpec) DeepCopyInto 

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

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

type AWSCodeCommitSource 

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

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

AWSCodeCommitSource is the Schema for the event source.

func (*AWSCodeCommitSource) AsEventSource 

func (s *AWSCodeCommitSource) AsEventSource() string

AsEventSource implements Reconcilable.

func (*AWSCodeCommitSource) DeepCopy 

func (in *AWSCodeCommitSource) DeepCopy() *AWSCodeCommitSource

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

func (*AWSCodeCommitSource) DeepCopyInto 

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

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

func (*AWSCodeCommitSource) DeepCopyObject 

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

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

func (*AWSCodeCommitSource) GetConditionSet 

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

GetConditionSet implements duckv1.KRShaped.

func (*AWSCodeCommitSource) GetEventTypes 

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

GetEventTypes implements Reconcilable.

func (*AWSCodeCommitSource) GetGroupVersionKind 

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

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*AWSCodeCommitSource) GetSink 

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

GetSink implements Reconcilable.

func (*AWSCodeCommitSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*AWSCodeCommitSource) GetStatusManager 

func (s *AWSCodeCommitSource) GetStatusManager() *StatusManager

GetStatusManager implements Reconcilable.

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 AWSAuth `json:"auth"`
}

AWSCodeCommitSourceSpec defines the desired state of the event source.

func (*AWSCodeCommitSourceSpec) DeepCopy 

func (in *AWSCodeCommitSourceSpec) DeepCopy() *AWSCodeCommitSourceSpec

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

func (*AWSCodeCommitSourceSpec) DeepCopyInto 

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

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

type AWSCognitoIdentitySource 

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

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

AWSCognitoIdentitySource is the Schema for the event source.

func (*AWSCognitoIdentitySource) AsEventSource 

func (s *AWSCognitoIdentitySource) AsEventSource() string

AsEventSource implements Reconcilable.

func (*AWSCognitoIdentitySource) DeepCopy 

func (in *AWSCognitoIdentitySource) DeepCopy() *AWSCognitoIdentitySource

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

func (*AWSCognitoIdentitySource) DeepCopyInto 

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

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

func (*AWSCognitoIdentitySource) DeepCopyObject 

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

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

func (*AWSCognitoIdentitySource) GetConditionSet 

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

GetConditionSet implements duckv1.KRShaped.

func (*AWSCognitoIdentitySource) GetEventTypes 

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

GetEventTypes implements Reconcilable.

func (*AWSCognitoIdentitySource) GetGroupVersionKind 

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

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*AWSCognitoIdentitySource) GetSink 

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

GetSink implements Reconcilable.

func (*AWSCognitoIdentitySource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*AWSCognitoIdentitySource) GetStatusManager 

func (s *AWSCognitoIdentitySource) GetStatusManager() *StatusManager

GetStatusManager implements Reconcilable.

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 AWSAuth `json:"auth"`
}

AWSCognitoIdentitySourceSpec defines the desired state of the event source.

func (*AWSCognitoIdentitySourceSpec) DeepCopy 

func (in *AWSCognitoIdentitySourceSpec) DeepCopy() *AWSCognitoIdentitySourceSpec

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

func (*AWSCognitoIdentitySourceSpec) DeepCopyInto 

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

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

type AWSCognitoUserPoolSource 

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

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

AWSCognitoUserPoolSource is the Schema for the event source.

func (*AWSCognitoUserPoolSource) AsEventSource 

func (s *AWSCognitoUserPoolSource) AsEventSource() string

AsEventSource implements Reconcilable.

func (*AWSCognitoUserPoolSource) DeepCopy 

func (in *AWSCognitoUserPoolSource) DeepCopy() *AWSCognitoUserPoolSource

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

func (*AWSCognitoUserPoolSource) DeepCopyInto 

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

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

func (*AWSCognitoUserPoolSource) DeepCopyObject 

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

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

func (*AWSCognitoUserPoolSource) GetConditionSet 

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

GetConditionSet implements duckv1.KRShaped.

func (*AWSCognitoUserPoolSource) GetEventTypes 

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

GetEventTypes implements Reconcilable.

func (*AWSCognitoUserPoolSource) GetGroupVersionKind 

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

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*AWSCognitoUserPoolSource) GetSink 

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

GetSink implements Reconcilable.

func (*AWSCognitoUserPoolSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*AWSCognitoUserPoolSource) GetStatusManager 

func (s *AWSCognitoUserPoolSource) GetStatusManager() *StatusManager

GetStatusManager implements Reconcilable.

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 AWSAuth `json:"auth"`
}

AWSCognitoUserPoolSourceSpec defines the desired state of the event source.

func (*AWSCognitoUserPoolSourceSpec) DeepCopy 

func (in *AWSCognitoUserPoolSourceSpec) DeepCopy() *AWSCognitoUserPoolSourceSpec

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

func (*AWSCognitoUserPoolSourceSpec) DeepCopyInto 

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

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

type AWSDynamoDBSource 

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

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

AWSDynamoDBSource is the Schema for the event source.

func (*AWSDynamoDBSource) AsEventSource 

func (s *AWSDynamoDBSource) AsEventSource() string

AsEventSource implements Reconcilable.

func (*AWSDynamoDBSource) DeepCopy 

func (in *AWSDynamoDBSource) DeepCopy() *AWSDynamoDBSource

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

func (*AWSDynamoDBSource) DeepCopyInto 

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

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

func (*AWSDynamoDBSource) DeepCopyObject 

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

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

func (*AWSDynamoDBSource) GetConditionSet 

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

GetConditionSet implements duckv1.KRShaped.

func (*AWSDynamoDBSource) GetEventTypes 

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

GetEventTypes implements Reconcilable.

func (*AWSDynamoDBSource) GetGroupVersionKind 

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

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*AWSDynamoDBSource) GetSink 

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

GetSink implements Reconcilable.

func (*AWSDynamoDBSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*AWSDynamoDBSource) GetStatusManager 

func (s *AWSDynamoDBSource) GetStatusManager() *StatusManager

GetStatusManager implements Reconcilable.

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 AWSAuth `json:"auth"`
}

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 AWSEndpoint added in v1.12.0 

type AWSEndpoint struct {
	// URL of the endpoint.
	URL *pkgapis.URL `json:"url,omitempty"`
}

AWSEndpoint contains parameters which are used to override the destination of REST API calls to AWS services. It allows, for example, to target API-compatible alternatives to the public AWS cloud (Localstack, Minio, ElasticMQ, ...).

func (*AWSEndpoint) DeepCopy added in v1.12.0 

func (in *AWSEndpoint) DeepCopy() *AWSEndpoint

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

func (*AWSEndpoint) DeepCopyInto added in v1.12.0 

func (in *AWSEndpoint) DeepCopyInto(out *AWSEndpoint)

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

type AWSKinesisSource 

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

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

AWSKinesisSource is the Schema for the event source.

func (*AWSKinesisSource) AsEventSource 

func (s *AWSKinesisSource) AsEventSource() string

AsEventSource implements Reconcilable.

func (*AWSKinesisSource) DeepCopy 

func (in *AWSKinesisSource) DeepCopy() *AWSKinesisSource

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

func (*AWSKinesisSource) DeepCopyInto 

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

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

func (*AWSKinesisSource) DeepCopyObject 

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

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

func (*AWSKinesisSource) GetConditionSet 

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

GetConditionSet implements duckv1.KRShaped.

func (*AWSKinesisSource) GetEventTypes 

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

GetEventTypes implements Reconcilable.

func (*AWSKinesisSource) GetGroupVersionKind 

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

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*AWSKinesisSource) GetSink 

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

GetSink implements Reconcilable.

func (*AWSKinesisSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*AWSKinesisSource) GetStatusManager 

func (s *AWSKinesisSource) GetStatusManager() *StatusManager

GetStatusManager implements Reconcilable.

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 AWSAuth `json:"auth"`
}

AWSKinesisSourceSpec defines the desired state of the event source.

func (*AWSKinesisSourceSpec) DeepCopy 

func (in *AWSKinesisSourceSpec) DeepCopy() *AWSKinesisSourceSpec

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

func (*AWSKinesisSourceSpec) DeepCopyInto 

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

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

type AWSPerformanceInsightsSource 

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

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

AWSPerformanceInsightsSource is the Schema for the event source.

func (*AWSPerformanceInsightsSource) AsEventSource 

func (s *AWSPerformanceInsightsSource) AsEventSource() string

AsEventSource implements Reconcilable.

func (*AWSPerformanceInsightsSource) DeepCopy 

func (in *AWSPerformanceInsightsSource) DeepCopy() *AWSPerformanceInsightsSource

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

func (*AWSPerformanceInsightsSource) DeepCopyInto 

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

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

func (*AWSPerformanceInsightsSource) DeepCopyObject 

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

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

func (*AWSPerformanceInsightsSource) GetConditionSet 

func (*AWSPerformanceInsightsSource) GetConditionSet() apis.ConditionSet

GetConditionSet implements duckv1.KRShaped.

func (*AWSPerformanceInsightsSource) GetEventTypes 

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

GetEventTypes implements Reconcilable.

func (*AWSPerformanceInsightsSource) GetGroupVersionKind 

func (*AWSPerformanceInsightsSource) GetGroupVersionKind() schema.GroupVersionKind

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*AWSPerformanceInsightsSource) GetSink 

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

GetSink implements Reconcilable.

func (*AWSPerformanceInsightsSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*AWSPerformanceInsightsSource) GetStatusManager 

func (s *AWSPerformanceInsightsSource) GetStatusManager() *StatusManager

GetStatusManager implements Reconcilable.

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 AWSAuth `json:"auth"`
}

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

func (*AWSS3Source) DeepCopy 

func (in *AWSS3Source) DeepCopy() *AWSS3Source

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

func (*AWSS3Source) DeepCopyInto 

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

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

func (*AWSS3Source) DeepCopyObject 

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

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

func (*AWSS3Source) GetConditionSet 

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

GetConditionSet implements duckv1.KRShaped.

func (*AWSS3Source) GetEventTypes 

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

GetEventTypes implements Reconcilable.

func (*AWSS3Source) GetGroupVersionKind 

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

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*AWSS3Source) GetSink 

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

GetSink implements Reconcilable.

func (*AWSS3Source) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*AWSS3Source) GetStatusManager 

func (s *AWSS3Source) GetStatusManager() *StatusManager

GetStatusManager implements Reconcilable.

type AWSS3SourceDestination added in v1.12.0 

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

AWSS3SourceDestination contains possible 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 destination of notifications originating from the Amazon S3 bucket.
	//
	// 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 AWSAuth `json:"auth"`
}

AWSS3SourceSpec defines the desired state of the event source.

func (*AWSS3SourceSpec) DeepCopy 

func (in *AWSS3SourceSpec) DeepCopy() *AWSS3SourceSpec

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

func (*AWSS3SourceSpec) DeepCopyInto 

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

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

type AWSS3SourceStatus 

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

AWSS3SourceStatus defines the observed state of the event source.

func (*AWSS3SourceStatus) DeepCopy 

func (in *AWSS3SourceStatus) DeepCopy() *AWSS3SourceStatus

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

func (*AWSS3SourceStatus) DeepCopyInto 

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

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

func (*AWSS3SourceStatus) MarkNotSubscribed 

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

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

func (*AWSS3SourceStatus) MarkSubscribed 

func (s *AWSS3SourceStatus) MarkSubscribed()

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

type AWSSNSSource 

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

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

AWSSNSSource is the Schema for the event source.

func (*AWSSNSSource) AsEventSource 

func (s *AWSSNSSource) AsEventSource() string

AsEventSource implements Reconcilable.

func (*AWSSNSSource) DeepCopy 

func (in *AWSSNSSource) DeepCopy() *AWSSNSSource

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

func (*AWSSNSSource) DeepCopyInto 

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

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

func (*AWSSNSSource) DeepCopyObject 

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

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

func (*AWSSNSSource) GetConditionSet 

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

GetConditionSet implements duckv1.KRShaped.

func (*AWSSNSSource) GetEventTypes 

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

GetEventTypes implements Reconcilable.

func (*AWSSNSSource) GetGroupVersionKind 

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

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*AWSSNSSource) GetSink 

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

GetSink implements Reconcilable.

func (*AWSSNSSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*AWSSNSSource) GetStatusManager 

func (s *AWSSNSSource) GetStatusManager() *StatusManager

GetStatusManager implements Reconcilable.

func (*AWSSNSSource) IsMultiTenant 

func (*AWSSNSSource) IsMultiTenant() bool

IsMultiTenant implements MultiTenant.

type AWSSNSSourceList 

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

AWSSNSSourceList contains a list of event sources.

func (*AWSSNSSourceList) DeepCopy 

func (in *AWSSNSSourceList) DeepCopy() *AWSSNSSourceList

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

func (*AWSSNSSourceList) DeepCopyInto 

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

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

func (*AWSSNSSourceList) DeepCopyObject 

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

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

type AWSSNSSourceSpec 

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

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

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

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

AWSSNSSourceSpec defines the desired state of the event source.

func (*AWSSNSSourceSpec) DeepCopy 

func (in *AWSSNSSourceSpec) DeepCopy() *AWSSNSSourceSpec

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

func (*AWSSNSSourceSpec) DeepCopyInto 

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

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

type AWSSNSSourceStatus 

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

AWSSNSSourceStatus defines the observed state of the event source.

func (*AWSSNSSourceStatus) DeepCopy 

func (in *AWSSNSSourceStatus) DeepCopy() *AWSSNSSourceStatus

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

func (*AWSSNSSourceStatus) DeepCopyInto 

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

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

func (*AWSSNSSourceStatus) MarkNotSubscribed 

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

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

func (*AWSSNSSourceStatus) MarkSubscribed 

func (s *AWSSNSSourceStatus) MarkSubscribed(subARN string)

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

type AWSSQSSource 

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

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

AWSSQSSource is the Schema for the event source.

func (*AWSSQSSource) AsEventSource 

func (s *AWSSQSSource) AsEventSource() string

AsEventSource implements Reconcilable.

func (*AWSSQSSource) DeepCopy 

func (in *AWSSQSSource) DeepCopy() *AWSSQSSource

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

func (*AWSSQSSource) DeepCopyInto 

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

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

func (*AWSSQSSource) DeepCopyObject 

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

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

func (*AWSSQSSource) GetConditionSet 

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

GetConditionSet implements duckv1.KRShaped.

func (*AWSSQSSource) GetEventTypes 

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

GetEventTypes implements Reconcilable.

func (*AWSSQSSource) GetGroupVersionKind 

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

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*AWSSQSSource) GetSink 

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

GetSink implements Reconcilable.

func (*AWSSQSSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*AWSSQSSource) GetStatusManager 

func (s *AWSSQSSource) GetStatusManager() *StatusManager

GetStatusManager implements Reconcilable.

func (*AWSSQSSource) ServiceAccountOptions added in v1.12.0 

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

ServiceAccountOptions implements serviceAccountProvider.

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

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

	// Customizations of the AWS REST API endpoint.
	// +optional
	Endpoint *AWSEndpoint `json:"endpoint,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 AWSSecurityCredentials 

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

AWSSecurityCredentials represents a set of AWS security credentials.

func (*AWSSecurityCredentials) DeepCopy 

func (in *AWSSecurityCredentials) DeepCopy() *AWSSecurityCredentials

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

func (*AWSSecurityCredentials) DeepCopyInto 

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

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

type AzureActivityLogsSource 

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

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

AzureActivityLogsSource is the Schema for the event source.

func (*AzureActivityLogsSource) AsEventSource 

func (s *AzureActivityLogsSource) AsEventSource() string

AsEventSource implements Reconcilable.

func (*AzureActivityLogsSource) DeepCopy 

func (in *AzureActivityLogsSource) DeepCopy() *AzureActivityLogsSource

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

func (*AzureActivityLogsSource) DeepCopyInto 

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

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

func (*AzureActivityLogsSource) DeepCopyObject 

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

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

func (*AzureActivityLogsSource) GetConditionSet 

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

GetConditionSet implements duckv1.KRShaped.

func (*AzureActivityLogsSource) GetEventTypes 

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

GetEventTypes returns the event types generated by the source.

func (*AzureActivityLogsSource) GetGroupVersionKind 

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

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*AzureActivityLogsSource) GetSink 

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

GetSink implements Reconcilable.

func (*AzureActivityLogsSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*AzureActivityLogsSource) GetStatusManager 

func (s *AzureActivityLogsSource) GetStatusManager() *StatusManager

GetStatusManager implements Reconcilable.

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 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 TriggerMesh.
	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.
	Auth AzureAuth `json:"auth"`
}

AzureActivityLogsSourceSpec defines the desired state of the event source.

func (*AzureActivityLogsSourceSpec) DeepCopy 

func (in *AzureActivityLogsSourceSpec) DeepCopy() *AzureActivityLogsSourceSpec

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

func (*AzureActivityLogsSourceSpec) DeepCopyInto 

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

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

type AzureActivityLogsSourceStatus 

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

AzureActivityLogsSourceStatus defines the observed state of the event source.

func (*AzureActivityLogsSourceStatus) DeepCopy 

func (in *AzureActivityLogsSourceStatus) DeepCopy() *AzureActivityLogsSourceStatus

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

func (*AzureActivityLogsSourceStatus) DeepCopyInto 

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

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

func (*AzureActivityLogsSourceStatus) MarkNotSubscribed 

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

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

func (*AzureActivityLogsSourceStatus) MarkSubscribed 

func (s *AzureActivityLogsSourceStatus) MarkSubscribed()

MarkSubscribed sets the Subscribed condition to True.

type AzureAuth 

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

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

AzureAuth contains multiple authentication methods for Azure services.

func (*AzureAuth) DeepCopy 

func (in *AzureAuth) DeepCopy() *AzureAuth

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

func (*AzureAuth) DeepCopyInto 

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

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

type AzureBlobStorageSource 

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

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

AzureBlobStorageSource is the Schema for the event source.

func (*AzureBlobStorageSource) AsEventSource 

func (s *AzureBlobStorageSource) AsEventSource() string

AsEventSource implements Reconcilable.

func (*AzureBlobStorageSource) DeepCopy 

func (in *AzureBlobStorageSource) DeepCopy() *AzureBlobStorageSource

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

func (*AzureBlobStorageSource) DeepCopyInto 

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

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

func (*AzureBlobStorageSource) DeepCopyObject 

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

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

func (*AzureBlobStorageSource) GetConditionSet 

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

GetConditionSet implements duckv1.KRShaped.

func (*AzureBlobStorageSource) GetEventTypes 

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

GetEventTypes returns the event types generated by the source.

func (*AzureBlobStorageSource) GetGroupVersionKind 

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

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*AzureBlobStorageSource) GetSink 

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

GetSink implements Reconcilable.

func (*AzureBlobStorageSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*AzureBlobStorageSource) GetStatusManager 

func (s *AzureBlobStorageSource) GetStatusManager() *StatusManager

GetStatusManager implements Reconcilable.

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 TriggerMesh.
	Endpoint AzureEventGridSourceEndpoint `json:"endpoint"`

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

AzureBlobStorageSourceSpec defines the desired state of the event source.

func (*AzureBlobStorageSourceSpec) DeepCopy 

func (in *AzureBlobStorageSourceSpec) DeepCopy() *AzureBlobStorageSourceSpec

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

func (*AzureBlobStorageSourceSpec) DeepCopyInto 

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

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

type AzureBlobStorageSourceStatus 

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

	// Resource ID of the Event Hubs instance that is currently receiving
	// events from the Azure Event Grid subscription.
	EventHubID *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 Reconcilable.

func (*AzureEventGridSource) DeepCopy 

func (in *AzureEventGridSource) DeepCopy() *AzureEventGridSource

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

func (*AzureEventGridSource) DeepCopyInto 

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

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

func (*AzureEventGridSource) DeepCopyObject 

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

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

func (*AzureEventGridSource) GetConditionSet 

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

GetConditionSet implements duckv1.KRShaped.

func (*AzureEventGridSource) GetEventTypes 

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

GetEventTypes returns the event types generated by the source.

func (*AzureEventGridSource) GetGroupVersionKind 

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

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*AzureEventGridSource) GetSink 

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

GetSink implements Reconcilable.

func (*AzureEventGridSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*AzureEventGridSource) GetStatusManager 

func (s *AzureEventGridSource) GetStatusManager() *StatusManager

GetStatusManager implements Reconcilable.

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

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 TriggerMesh.
	Endpoint AzureEventGridSourceEndpoint `json:"endpoint"`

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

AzureEventGridSourceSpec defines the desired state of the event source.

func (*AzureEventGridSourceSpec) DeepCopy 

func (in *AzureEventGridSourceSpec) DeepCopy() *AzureEventGridSourceSpec

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

func (*AzureEventGridSourceSpec) DeepCopyInto 

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

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

type AzureEventGridSourceStatus 

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

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

	// Resource ID of the Event Hubs instance that is currently receiving
	// events from the Azure Event Grid subscription.
	EventHubID *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 AzureEventHubSource 

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

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

AzureEventHubSource is the Schema for the event source.

func (*AzureEventHubSource) AsEventSource 

func (s *AzureEventHubSource) AsEventSource() string

AsEventSource implements Reconcilable.

func (*AzureEventHubSource) DeepCopy 

func (in *AzureEventHubSource) DeepCopy() *AzureEventHubSource

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

func (*AzureEventHubSource) DeepCopyInto 

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

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

func (*AzureEventHubSource) DeepCopyObject 

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

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

func (*AzureEventHubSource) GetConditionSet 

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

GetConditionSet implements duckv1.KRShaped.

func (*AzureEventHubSource) GetEventTypes 

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

GetEventTypes returns the event types generated by the source.

func (*AzureEventHubSource) GetGroupVersionKind 

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

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*AzureEventHubSource) GetSink 

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

GetSink implements Reconcilable.

func (*AzureEventHubSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*AzureEventHubSource) GetStatusManager 

func (s *AzureEventHubSource) GetStatusManager() *StatusManager

GetStatusManager implements Reconcilable.

type AzureEventHubSourceList 

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

AzureEventHubSourceList contains a list of event sources.

func (*AzureEventHubSourceList) DeepCopy 

func (in *AzureEventHubSourceList) DeepCopy() *AzureEventHubSourceList

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

func (*AzureEventHubSourceList) DeepCopyInto 

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

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

func (*AzureEventHubSourceList) DeepCopyObject 

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

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

type AzureEventHubSourceSpec 

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

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

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

AzureEventHubSourceSpec defines the desired state of the event source.

func (*AzureEventHubSourceSpec) DeepCopy 

func (in *AzureEventHubSourceSpec) DeepCopy() *AzureEventHubSourceSpec

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

func (*AzureEventHubSourceSpec) DeepCopyInto 

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

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

type AzureIOTHubSource 

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

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

AzureIOTHubSource is the Schema for the event source.

func (*AzureIOTHubSource) AsEventSource 

func (s *AzureIOTHubSource) AsEventSource() string

AsEventSource implements Reconcilable.

func (*AzureIOTHubSource) DeepCopy 

func (in *AzureIOTHubSource) DeepCopy() *AzureIOTHubSource

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

func (*AzureIOTHubSource) DeepCopyInto 

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

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

func (*AzureIOTHubSource) DeepCopyObject 

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

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

func (*AzureIOTHubSource) GetConditionSet 

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

GetConditionSet implements duckv1.KRShaped.

func (*AzureIOTHubSource) GetEventTypes 

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

GetEventTypes returns the event types generated by the source.

func (*AzureIOTHubSource) GetGroupVersionKind 

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

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*AzureIOTHubSource) GetSink 

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

GetSink implements Reconcilable.

func (*AzureIOTHubSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*AzureIOTHubSource) GetStatusManager 

func (s *AzureIOTHubSource) GetStatusManager() *StatusManager

GetStatusManager implements Reconcilable.

type AzureIOTHubSourceList 

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

AzureIOTHubSourceList contains a list of event sources.

func (*AzureIOTHubSourceList) DeepCopy 

func (in *AzureIOTHubSourceList) DeepCopy() *AzureIOTHubSourceList

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

func (*AzureIOTHubSourceList) DeepCopyInto 

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

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

func (*AzureIOTHubSourceList) DeepCopyObject 

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

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

type AzureIOTHubSourceSpec 

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

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

AzureIOTHubSourceSpec defines the desired state of the event source.

func (*AzureIOTHubSourceSpec) DeepCopy 

func (in *AzureIOTHubSourceSpec) DeepCopy() *AzureIOTHubSourceSpec

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

func (*AzureIOTHubSourceSpec) DeepCopyInto 

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

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

type AzureIOTHubSourceStatus 

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

AzureIOTHubSourceStatus defines the observed state of the event source.

func (*AzureIOTHubSourceStatus) DeepCopy 

func (in *AzureIOTHubSourceStatus) DeepCopy() *AzureIOTHubSourceStatus

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

func (*AzureIOTHubSourceStatus) DeepCopyInto 

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

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

type AzureQueueStorageSource 

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

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

AzureQueueStorageSource is the Schema for the event source.

func (*AzureQueueStorageSource) AsEventSource 

func (s *AzureQueueStorageSource) AsEventSource() string

AsEventSource implements Reconcilable.

func (*AzureQueueStorageSource) DeepCopy 

func (in *AzureQueueStorageSource) DeepCopy() *AzureQueueStorageSource

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

func (*AzureQueueStorageSource) DeepCopyInto 

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

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

func (*AzureQueueStorageSource) DeepCopyObject 

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

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

func (*AzureQueueStorageSource) GetConditionSet 

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

GetConditionSet implements duckv1.KRShaped.

func (*AzureQueueStorageSource) GetEventTypes 

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

GetEventTypes returns the event types generated by the source.

func (*AzureQueueStorageSource) GetGroupVersionKind 

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

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*AzureQueueStorageSource) GetSink 

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

GetSink implements Reconcilable.

func (*AzureQueueStorageSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*AzureQueueStorageSource) GetStatusManager 

func (s *AzureQueueStorageSource) GetStatusManager() *StatusManager

GetStatusManager implements Reconcilable.

type AzureQueueStorageSourceList 

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

AzureQueueStorageSourceList contains a list of event sources.

func (*AzureQueueStorageSourceList) DeepCopy 

func (in *AzureQueueStorageSourceList) DeepCopy() *AzureQueueStorageSourceList

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

func (*AzureQueueStorageSourceList) DeepCopyInto 

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

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

func (*AzureQueueStorageSourceList) DeepCopyObject 

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

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

type AzureQueueStorageSourceSpec 

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

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

AzureQueueStorageSourceSpec defines the desired state of the event source.

func (*AzureQueueStorageSourceSpec) DeepCopy 

func (in *AzureQueueStorageSourceSpec) DeepCopy() *AzureQueueStorageSourceSpec

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

func (*AzureQueueStorageSourceSpec) DeepCopyInto 

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

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

type AzureResourceID 

type AzureResourceID struct {
	SubscriptionID   string
	ResourceGroup    string
	ResourceProvider string
	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          ValueFromField `json:"keyName"`
	KeyValue         ValueFromField `json:"keyValue"`
	ConnectionString ValueFromField `json:"connectionString"`
}

AzureSASToken represents an Azure SAS token.

func (*AzureSASToken) DeepCopy 

func (in *AzureSASToken) DeepCopy() *AzureSASToken

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

func (*AzureSASToken) DeepCopyInto 

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

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

type AzureServiceBusQueueSource 

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

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

AzureServiceBusQueueSource is the Schema for the event source.

func (*AzureServiceBusQueueSource) AsEventSource 

func (s *AzureServiceBusQueueSource) AsEventSource() string

AsEventSource implements Reconcilable.

func (*AzureServiceBusQueueSource) DeepCopy 

func (in *AzureServiceBusQueueSource) DeepCopy() *AzureServiceBusQueueSource

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

func (*AzureServiceBusQueueSource) DeepCopyInto 

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

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

func (*AzureServiceBusQueueSource) DeepCopyObject 

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

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

func (*AzureServiceBusQueueSource) GetConditionSet 

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

GetConditionSet implements duckv1.KRShaped.

func (*AzureServiceBusQueueSource) GetEventTypes 

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

GetEventTypes returns the event types generated by the source.

func (*AzureServiceBusQueueSource) GetGroupVersionKind 

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

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*AzureServiceBusQueueSource) GetSink 

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

GetSink implements Reconcilable.

func (*AzureServiceBusQueueSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*AzureServiceBusQueueSource) GetStatusManager 

func (s *AzureServiceBusQueueSource) GetStatusManager() *StatusManager

GetStatusManager implements Reconcilable.

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.
	Auth AzureAuth `json:"auth"`
}

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

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) 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 Reconcilable.

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() *StatusManager

GetStatusManager implements Reconcilable.

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.
	Auth AzureAuth `json:"auth"`
}

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 {
	EventSourceStatus `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     ValueFromField `json:"tenantID"`
	ClientID     ValueFromField `json:"clientID"`
	ClientSecret ValueFromField `json:"clientSecret"`
}

AzureServicePrincipal represents an AAD Service Principal.

func (*AzureServicePrincipal) DeepCopy 

func (in *AzureServicePrincipal) DeepCopy() *AzureServicePrincipal

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

func (*AzureServicePrincipal) DeepCopyInto 

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

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

type Credentials added in v1.13.0 

type Credentials struct {
	User     ValueFromField `json:"username,omitempty"`
	Password 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 EventSourceStatus 

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

EventSourceStatus defines the observed state of an event source.

func (*EventSourceStatus) DeepCopy 

func (in *EventSourceStatus) DeepCopy() *EventSourceStatus

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

func (*EventSourceStatus) DeepCopyInto 

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

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

type GCloudIoTResourceName added in v1.11.0 

type GCloudIoTResourceName struct {
	Project    string
	Location   string
	Collection string
	Resource   string
}

GCloudIoTResourceName represents a fully qualified IoT resource name, as described at 

https://pkg.go.dev/google.golang.org/api/cloudiot/v1#DeviceRegistry.Name

Examples of such resource names include:

  • projects/{project_name}/locations/{location_name}/registries/{registry_name}

func (*GCloudIoTResourceName) DeepCopy added in v1.11.0 

func (in *GCloudIoTResourceName) DeepCopy() *GCloudIoTResourceName

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

func (*GCloudIoTResourceName) DeepCopyInto added in v1.11.0 

func (in *GCloudIoTResourceName) DeepCopyInto(out *GCloudIoTResourceName)

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

func (GCloudIoTResourceName) MarshalJSON added in v1.11.0 

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

MarshalJSON implements json.Marshaler

func (*GCloudIoTResourceName) String added in v1.11.0 

func (n *GCloudIoTResourceName) String() string

String implements the fmt.Stringer interface.

func (*GCloudIoTResourceName) UnmarshalJSON added in v1.11.0 

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

UnmarshalJSON implements json.Unmarshaler

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

func (*GoogleCloudAuditLogsSource) DeepCopy 

func (in *GoogleCloudAuditLogsSource) DeepCopy() *GoogleCloudAuditLogsSource

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

func (*GoogleCloudAuditLogsSource) DeepCopyInto 

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

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

func (*GoogleCloudAuditLogsSource) DeepCopyObject 

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

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

func (*GoogleCloudAuditLogsSource) GetConditionSet 

func (*GoogleCloudAuditLogsSource) GetConditionSet() apis.ConditionSet

GetConditionSet implements duckv1.KRShaped.

func (*GoogleCloudAuditLogsSource) GetEventTypes 

func (*GoogleCloudAuditLogsSource) GetEventTypes() []string

GetEventTypes returns the event types generated by the source.

func (*GoogleCloudAuditLogsSource) GetGroupVersionKind 

func (*GoogleCloudAuditLogsSource) GetGroupVersionKind() schema.GroupVersionKind

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*GoogleCloudAuditLogsSource) GetSink 

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

GetSink implements Reconcilable.

func (*GoogleCloudAuditLogsSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*GoogleCloudAuditLogsSource) GetStatusManager 

func (s *GoogleCloudAuditLogsSource) GetStatusManager() *StatusManager

GetStatusManager implements Reconcilable.

type GoogleCloudAuditLogsSourceList 

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

GoogleCloudAuditLogsSourceList contains a list of event sources.

func (*GoogleCloudAuditLogsSourceList) DeepCopy 

func (in *GoogleCloudAuditLogsSourceList) DeepCopy() *GoogleCloudAuditLogsSourceList

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

func (*GoogleCloudAuditLogsSourceList) DeepCopyInto 

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

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

func (*GoogleCloudAuditLogsSourceList) DeepCopyObject 

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

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

type GoogleCloudAuditLogsSourcePubSubSpec 

type GoogleCloudAuditLogsSourcePubSubSpec struct {

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

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

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

func (*GoogleCloudAuditLogsSourcePubSubSpec) DeepCopy 

func (in *GoogleCloudAuditLogsSourcePubSubSpec) DeepCopy() *GoogleCloudAuditLogsSourcePubSubSpec

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

func (*GoogleCloudAuditLogsSourcePubSubSpec) DeepCopyInto 

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

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

type GoogleCloudAuditLogsSourceSpec 

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

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

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

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

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

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

GoogleCloudAuditLogsSourceSpec defines the desired state of the event source.

func (*GoogleCloudAuditLogsSourceSpec) DeepCopy 

func (in *GoogleCloudAuditLogsSourceSpec) DeepCopy() *GoogleCloudAuditLogsSourceSpec

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

func (*GoogleCloudAuditLogsSourceSpec) DeepCopyInto 

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

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

type GoogleCloudAuditLogsSourceStatus 

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

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

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

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

GoogleCloudAuditLogsSourceStatus defines the observed state of the event source.

func (*GoogleCloudAuditLogsSourceStatus) DeepCopy 

func (in *GoogleCloudAuditLogsSourceStatus) DeepCopy() *GoogleCloudAuditLogsSourceStatus

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

func (*GoogleCloudAuditLogsSourceStatus) DeepCopyInto 

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

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

func (*GoogleCloudAuditLogsSourceStatus) MarkNotSubscribed 

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

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

func (*GoogleCloudAuditLogsSourceStatus) MarkSubscribed 

func (s *GoogleCloudAuditLogsSourceStatus) MarkSubscribed()

MarkSubscribed sets the Subscribed condition to True.

type GoogleCloudBillingSource 

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

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

GoogleCloudBillingSource is the Schema for the event source.

func (*GoogleCloudBillingSource) AsEventSource 

func (s *GoogleCloudBillingSource) AsEventSource() string

AsEventSource implements Reconcilable.

func (*GoogleCloudBillingSource) DeepCopy 

func (in *GoogleCloudBillingSource) DeepCopy() *GoogleCloudBillingSource

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

func (*GoogleCloudBillingSource) DeepCopyInto 

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

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

func (*GoogleCloudBillingSource) DeepCopyObject 

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

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

func (*GoogleCloudBillingSource) GetConditionSet 

func (*GoogleCloudBillingSource) GetConditionSet() apis.ConditionSet

GetConditionSet implements duckv1.KRShaped.

func (*GoogleCloudBillingSource) GetEventTypes 

func (*GoogleCloudBillingSource) GetEventTypes() []string

GetEventTypes returns the event types generated by the source.

func (*GoogleCloudBillingSource) GetGroupVersionKind 

func (*GoogleCloudBillingSource) GetGroupVersionKind() schema.GroupVersionKind

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*GoogleCloudBillingSource) GetSink 

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

GetSink implements Reconcilable.

func (*GoogleCloudBillingSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*GoogleCloudBillingSource) GetStatusManager 

func (s *GoogleCloudBillingSource) GetStatusManager() *StatusManager

GetStatusManager implements Reconcilable.

type GoogleCloudBillingSourceList 

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

GoogleCloudBillingSourceList contains a list of event sources.

func (*GoogleCloudBillingSourceList) DeepCopy 

func (in *GoogleCloudBillingSourceList) DeepCopy() *GoogleCloudBillingSourceList

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

func (*GoogleCloudBillingSourceList) DeepCopyInto 

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

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

func (*GoogleCloudBillingSourceList) DeepCopyObject 

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

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

type GoogleCloudBillingSourcePubSubSpec 

type GoogleCloudBillingSourcePubSubSpec struct {

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

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

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

func (*GoogleCloudBillingSourcePubSubSpec) DeepCopy 

func (in *GoogleCloudBillingSourcePubSubSpec) DeepCopy() *GoogleCloudBillingSourcePubSubSpec

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

func (*GoogleCloudBillingSourcePubSubSpec) DeepCopyInto 

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

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

type GoogleCloudBillingSourceSpec 

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

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

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

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

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

GoogleCloudBillingSourceSpec defines the desired state of the event source.

func (*GoogleCloudBillingSourceSpec) DeepCopy 

func (in *GoogleCloudBillingSourceSpec) DeepCopy() *GoogleCloudBillingSourceSpec

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

func (*GoogleCloudBillingSourceSpec) DeepCopyInto 

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

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

type GoogleCloudBillingSourceStatus 

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

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

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

GoogleCloudBillingSourceStatus defines the observed state of the event source.

func (*GoogleCloudBillingSourceStatus) DeepCopy 

func (in *GoogleCloudBillingSourceStatus) DeepCopy() *GoogleCloudBillingSourceStatus

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

func (*GoogleCloudBillingSourceStatus) DeepCopyInto 

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

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

func (*GoogleCloudBillingSourceStatus) MarkNotSubscribed 

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

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

func (*GoogleCloudBillingSourceStatus) MarkSubscribed 

func (s *GoogleCloudBillingSourceStatus) MarkSubscribed()

MarkSubscribed sets the Subscribed condition to True.

type GoogleCloudIoTSource added in v1.11.0 

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

	Spec   GoogleCloudIoTSourceSpec   `json:"spec,omitempty"`
	Status GoogleCloudIoTSourceStatus `json:"status,omitempty"`
}

GoogleCloudIoTSource is the Schema for the event source.

func (*GoogleCloudIoTSource) AsEventSource added in v1.11.0 

func (s *GoogleCloudIoTSource) AsEventSource() string

AsEventSource implements Reconcilable.

func (*GoogleCloudIoTSource) DeepCopy added in v1.11.0 

func (in *GoogleCloudIoTSource) DeepCopy() *GoogleCloudIoTSource

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

func (*GoogleCloudIoTSource) DeepCopyInto added in v1.11.0 

func (in *GoogleCloudIoTSource) DeepCopyInto(out *GoogleCloudIoTSource)

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

func (*GoogleCloudIoTSource) DeepCopyObject added in v1.11.0 

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

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

func (*GoogleCloudIoTSource) GetConditionSet added in v1.11.0 

func (*GoogleCloudIoTSource) GetConditionSet() apis.ConditionSet

GetConditionSet implements duckv1.KRShaped.

func (*GoogleCloudIoTSource) GetEventTypes added in v1.11.0 

func (*GoogleCloudIoTSource) GetEventTypes() []string

GetEventTypes returns the event types generated by the source.

func (*GoogleCloudIoTSource) GetGroupVersionKind added in v1.11.0 

func (*GoogleCloudIoTSource) GetGroupVersionKind() schema.GroupVersionKind

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*GoogleCloudIoTSource) GetSink added in v1.11.0 

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

GetSink implements Reconcilable.

func (*GoogleCloudIoTSource) GetStatus added in v1.11.0 

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

GetStatus implements duckv1.KRShaped.

func (*GoogleCloudIoTSource) GetStatusManager added in v1.11.0 

func (s *GoogleCloudIoTSource) GetStatusManager() *StatusManager

GetStatusManager implements Reconcilable.

type GoogleCloudIoTSourceList added in v1.11.0 

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

GoogleCloudIoTSourceList contains a list of event sources.

func (*GoogleCloudIoTSourceList) DeepCopy added in v1.11.0 

func (in *GoogleCloudIoTSourceList) DeepCopy() *GoogleCloudIoTSourceList

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

func (*GoogleCloudIoTSourceList) DeepCopyInto added in v1.11.0 

func (in *GoogleCloudIoTSourceList) DeepCopyInto(out *GoogleCloudIoTSourceList)

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

func (*GoogleCloudIoTSourceList) DeepCopyObject added in v1.11.0 

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

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

type GoogleCloudIoTSourcePubSubSpec added in v1.11.0 

type GoogleCloudIoTSourcePubSubSpec struct {

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

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

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

func (*GoogleCloudIoTSourcePubSubSpec) DeepCopy added in v1.11.0 

func (in *GoogleCloudIoTSourcePubSubSpec) DeepCopy() *GoogleCloudIoTSourcePubSubSpec

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

func (*GoogleCloudIoTSourcePubSubSpec) DeepCopyInto added in v1.11.0 

func (in *GoogleCloudIoTSourcePubSubSpec) DeepCopyInto(out *GoogleCloudIoTSourcePubSubSpec)

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

type GoogleCloudIoTSourceSpec added in v1.11.0 

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

	// Resource name of the Cloud IoT Registry to receive messages from.
	Registry GCloudIoTResourceName `json:"registry"`

	// Settings related to the Pub/Sub resources associated with the Cloud IoT Registry.
	PubSub GoogleCloudIoTSourcePubSubSpec `json:"pubsub"`

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

GoogleCloudIoTSourceSpec defines the desired state of the event source.

func (*GoogleCloudIoTSourceSpec) DeepCopy added in v1.11.0 

func (in *GoogleCloudIoTSourceSpec) DeepCopy() *GoogleCloudIoTSourceSpec

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

func (*GoogleCloudIoTSourceSpec) DeepCopyInto added in v1.11.0 

func (in *GoogleCloudIoTSourceSpec) DeepCopyInto(out *GoogleCloudIoTSourceSpec)

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

type GoogleCloudIoTSourceStatus added in v1.11.0 

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

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

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

GoogleCloudIoTSourceStatus defines the observed state of the event source.

func (*GoogleCloudIoTSourceStatus) DeepCopy added in v1.11.0 

func (in *GoogleCloudIoTSourceStatus) DeepCopy() *GoogleCloudIoTSourceStatus

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

func (*GoogleCloudIoTSourceStatus) DeepCopyInto added in v1.11.0 

func (in *GoogleCloudIoTSourceStatus) DeepCopyInto(out *GoogleCloudIoTSourceStatus)

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

func (*GoogleCloudIoTSourceStatus) MarkNotSubscribed added in v1.11.0 

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

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

func (*GoogleCloudIoTSourceStatus) MarkSubscribed added in v1.11.0 

func (s *GoogleCloudIoTSourceStatus) 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 Reconcilable.

func (*GoogleCloudPubSubSource) DeepCopy 

func (in *GoogleCloudPubSubSource) DeepCopy() *GoogleCloudPubSubSource

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

func (*GoogleCloudPubSubSource) DeepCopyInto 

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

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

func (*GoogleCloudPubSubSource) DeepCopyObject 

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

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

func (*GoogleCloudPubSubSource) GetConditionSet 

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

GetConditionSet implements duckv1.KRShaped.

func (*GoogleCloudPubSubSource) GetEventTypes 

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

GetEventTypes returns the event types generated by the source.

func (*GoogleCloudPubSubSource) GetGroupVersionKind 

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

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*GoogleCloudPubSubSource) GetSink 

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

GetSink implements Reconcilable.

func (*GoogleCloudPubSubSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*GoogleCloudPubSubSource) GetStatusManager 

func (s *GoogleCloudPubSubSource) GetStatusManager() *StatusManager

GetStatusManager implements Reconcilable.

type GoogleCloudPubSubSourceList 

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

GoogleCloudPubSubSourceList contains a list of event sources.

func (*GoogleCloudPubSubSourceList) DeepCopy 

func (in *GoogleCloudPubSubSourceList) DeepCopy() *GoogleCloudPubSubSourceList

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

func (*GoogleCloudPubSubSourceList) DeepCopyInto 

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

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

func (*GoogleCloudPubSubSourceList) DeepCopyObject 

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

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

type GoogleCloudPubSubSourceSpec 

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

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

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

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

GoogleCloudPubSubSourceSpec defines the desired state of the event source.

func (*GoogleCloudPubSubSourceSpec) DeepCopy 

func (in *GoogleCloudPubSubSourceSpec) DeepCopy() *GoogleCloudPubSubSourceSpec

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

func (*GoogleCloudPubSubSourceSpec) DeepCopyInto 

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

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

type GoogleCloudPubSubSourceStatus 

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

GoogleCloudPubSubSourceStatus defines the observed state of the event source.

func (*GoogleCloudPubSubSourceStatus) DeepCopy 

func (in *GoogleCloudPubSubSourceStatus) DeepCopy() *GoogleCloudPubSubSourceStatus

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

func (*GoogleCloudPubSubSourceStatus) DeepCopyInto 

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

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

func (*GoogleCloudPubSubSourceStatus) MarkNotSubscribed 

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

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

func (*GoogleCloudPubSubSourceStatus) MarkSubscribed 

func (s *GoogleCloudPubSubSourceStatus) MarkSubscribed()

MarkSubscribed sets the Subscribed condition to True.

type 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 Reconcilable.

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) 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 Reconcilable.

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() *StatusManager

GetStatusManager implements Reconcilable.

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

type GoogleCloudSourceRepositoriesSourcePubSubSpec struct {

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

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

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

func (*GoogleCloudSourceRepositoriesSourcePubSubSpec) DeepCopy added in v1.13.0 

func (in *GoogleCloudSourceRepositoriesSourcePubSubSpec) DeepCopy() *GoogleCloudSourceRepositoriesSourcePubSubSpec

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

func (*GoogleCloudSourceRepositoriesSourcePubSubSpec) DeepCopyInto added in v1.13.0 

func (in *GoogleCloudSourceRepositoriesSourcePubSubSpec) DeepCopyInto(out *GoogleCloudSourceRepositoriesSourcePubSubSpec)

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

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

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

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 {
	EventSourceStatus `json:",inline"`

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

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

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

func (*GoogleCloudStorageSource) DeepCopy 

func (in *GoogleCloudStorageSource) DeepCopy() *GoogleCloudStorageSource

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

func (*GoogleCloudStorageSource) DeepCopyInto 

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

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

func (*GoogleCloudStorageSource) DeepCopyObject 

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

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

func (*GoogleCloudStorageSource) GetConditionSet 

func (*GoogleCloudStorageSource) GetConditionSet() apis.ConditionSet

GetConditionSet implements duckv1.KRShaped.

func (*GoogleCloudStorageSource) GetEventTypes 

func (*GoogleCloudStorageSource) GetEventTypes() []string

GetEventTypes returns the event types generated by the source.

func (*GoogleCloudStorageSource) GetGroupVersionKind 

func (*GoogleCloudStorageSource) GetGroupVersionKind() schema.GroupVersionKind

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*GoogleCloudStorageSource) GetSink 

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

GetSink implements Reconcilable.

func (*GoogleCloudStorageSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*GoogleCloudStorageSource) GetStatusManager 

func (s *GoogleCloudStorageSource) GetStatusManager() *StatusManager

GetStatusManager implements Reconcilable.

type GoogleCloudStorageSourceList 

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

GoogleCloudStorageSourceList contains a list of event sources.

func (*GoogleCloudStorageSourceList) DeepCopy 

func (in *GoogleCloudStorageSourceList) DeepCopy() *GoogleCloudStorageSourceList

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

func (*GoogleCloudStorageSourceList) DeepCopyInto 

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

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

func (*GoogleCloudStorageSourceList) DeepCopyObject 

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

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

type GoogleCloudStorageSourcePubSubSpec 

type GoogleCloudStorageSourcePubSubSpec struct {

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

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

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

func (*GoogleCloudStorageSourcePubSubSpec) DeepCopy 

func (in *GoogleCloudStorageSourcePubSubSpec) DeepCopy() *GoogleCloudStorageSourcePubSubSpec

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

func (*GoogleCloudStorageSourcePubSubSpec) DeepCopyInto 

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

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

type GoogleCloudStorageSourceSpec 

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

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

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

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

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

GoogleCloudStorageSourceSpec defines the desired state of the event source.

func (*GoogleCloudStorageSourceSpec) DeepCopy 

func (in *GoogleCloudStorageSourceSpec) DeepCopy() *GoogleCloudStorageSourceSpec

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

func (*GoogleCloudStorageSourceSpec) DeepCopyInto 

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

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

type GoogleCloudStorageSourceStatus 

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

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

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

GoogleCloudStorageSourceStatus defines the observed state of the event source.

func (*GoogleCloudStorageSourceStatus) DeepCopy 

func (in *GoogleCloudStorageSourceStatus) DeepCopy() *GoogleCloudStorageSourceStatus

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

func (*GoogleCloudStorageSourceStatus) DeepCopyInto 

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

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

func (*GoogleCloudStorageSourceStatus) MarkNotSubscribed 

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

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

func (*GoogleCloudStorageSourceStatus) MarkSubscribed 

func (s *GoogleCloudStorageSourceStatus) MarkSubscribed()

MarkSubscribed sets the Subscribed condition to True.

type HTTPPollerSource 

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

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

HTTPPollerSource is the schema for the event source.

func (*HTTPPollerSource) AsEventSource 

func (s *HTTPPollerSource) AsEventSource() string

AsEventSource implements Reconcilable.

func (*HTTPPollerSource) DeepCopy 

func (in *HTTPPollerSource) DeepCopy() *HTTPPollerSource

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

func (*HTTPPollerSource) DeepCopyInto 

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

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

func (*HTTPPollerSource) DeepCopyObject 

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

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

func (*HTTPPollerSource) GetConditionSet 

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

GetConditionSet implements duckv1.KRShaped.

func (*HTTPPollerSource) GetEventTypes 

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

GetEventTypes implements Reconcilable.

func (*HTTPPollerSource) GetGroupVersionKind 

func (*HTTPPollerSource) GetGroupVersionKind() schema.GroupVersionKind

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*HTTPPollerSource) GetSink 

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

GetSink implements Reconcilable.

func (*HTTPPollerSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*HTTPPollerSource) GetStatusManager 

func (s *HTTPPollerSource) GetStatusManager() *StatusManager

GetStatusManager implements Reconcilable.

type HTTPPollerSourceList 

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

HTTPPollerSourceList contains a list of event sources.

func (*HTTPPollerSourceList) DeepCopy 

func (in *HTTPPollerSourceList) DeepCopy() *HTTPPollerSourceList

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

func (*HTTPPollerSourceList) DeepCopyInto 

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

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

func (*HTTPPollerSourceList) DeepCopyObject 

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

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

type HTTPPollerSourceSpec 

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

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

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

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

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

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

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

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

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

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

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

HTTPPollerSourceSpec defines the desired state of the event source.

func (*HTTPPollerSourceSpec) DeepCopy 

func (in *HTTPPollerSourceSpec) DeepCopy() *HTTPPollerSourceSpec

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

func (*HTTPPollerSourceSpec) DeepCopyInto 

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

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

type IBMMQSource added in v1.13.0 

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

	Spec   IBMMQSourceSpec   `json:"spec"`
	Status IBMMQSourceStatus `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 Reconcilable.

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

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

GetConditionSet retrieves the condition set for this resource. Implements the KRShaped interface.

func (*IBMMQSource) GetEventTypes added in v1.13.0 

func (*IBMMQSource) GetEventTypes() []string

GetEventTypes implements Reconcilable.

func (*IBMMQSource) GetGroupVersionKind added in v1.13.0 

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

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*IBMMQSource) GetSink added in v1.13.0 

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

GetSink implements Reconcilable.

func (*IBMMQSource) GetStatus added in v1.13.0 

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

GetStatus retrieves the status of the resource. Implements the KRShaped interface.

func (*IBMMQSource) GetStatusManager added in v1.13.0 

func (s *IBMMQSource) GetStatusManager() *StatusManager

GetStatusManager implements Reconcilable.

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

IBMMQSourceSpec holds 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 IBMMQSourceStatus added in v1.13.0 

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

IBMMQSourceStatus defines the observed state of the event source.

func (*IBMMQSourceStatus) DeepCopy added in v1.13.0 

func (in *IBMMQSourceStatus) DeepCopy() *IBMMQSourceStatus

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

func (*IBMMQSourceStatus) DeepCopyInto added in v1.13.0 

func (in *IBMMQSourceStatus) DeepCopyInto(out *IBMMQSourceStatus)

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   ValueFromField `json:"keyDatabase"`
	PasswordStash 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 OCIMetrics 

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

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

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

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

OCIMetrics represents OCI metrics structure.

func (*OCIMetrics) DeepCopy 

func (in *OCIMetrics) DeepCopy() *OCIMetrics

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

func (*OCIMetrics) DeepCopyInto 

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

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

type OCIMetricsDecodedList 

type OCIMetricsDecodedList []OCIMetrics

OCIMetricsDecodedList is a list of OCI metrics.

func (*OCIMetricsDecodedList) Decode 

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

Decode deserializes a list of OCI metrics.

func (OCIMetricsDecodedList) DeepCopy 

func (in OCIMetricsDecodedList) DeepCopy() OCIMetricsDecodedList

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

func (OCIMetricsDecodedList) DeepCopyInto 

func (in OCIMetricsDecodedList) DeepCopyInto(out *OCIMetricsDecodedList)

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

type OCIMetricsSource 

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

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

OCIMetricsSource is the schema for the event source.

func (*OCIMetricsSource) AsEventSource 

func (s *OCIMetricsSource) AsEventSource() string

AsEventSource implements Reconcilable.

func (*OCIMetricsSource) DeepCopy 

func (in *OCIMetricsSource) DeepCopy() *OCIMetricsSource

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

func (*OCIMetricsSource) DeepCopyInto 

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

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

func (*OCIMetricsSource) DeepCopyObject 

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

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

func (*OCIMetricsSource) GetConditionSet 

func (*OCIMetricsSource) GetConditionSet() pkgapis.ConditionSet

GetConditionSet implements duckv1.KRShaped.

func (*OCIMetricsSource) GetEventTypes 

func (*OCIMetricsSource) GetEventTypes() []string

GetEventTypes implements Reconcilable.

func (*OCIMetricsSource) GetGroupVersionKind 

func (*OCIMetricsSource) GetGroupVersionKind() schema.GroupVersionKind

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*OCIMetricsSource) GetSink 

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

GetSink implements Reconcilable.

func (*OCIMetricsSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*OCIMetricsSource) GetStatusManager 

func (s *OCIMetricsSource) GetStatusManager() *StatusManager

GetStatusManager implements Reconcilable.

type OCIMetricsSourceList 

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

OCIMetricsSourceList contains a list of event sources.

func (*OCIMetricsSourceList) DeepCopy 

func (in *OCIMetricsSourceList) DeepCopy() *OCIMetricsSourceList

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

func (*OCIMetricsSourceList) DeepCopyInto 

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

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

func (*OCIMetricsSourceList) DeepCopyObject 

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

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

type OCIMetricsSourceSpec 

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

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

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

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

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

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

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

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

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

OCIMetricsSourceSpec defines the desired state of the event source.

func (*OCIMetricsSourceSpec) DeepCopy 

func (in *OCIMetricsSourceSpec) DeepCopy() *OCIMetricsSourceSpec

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

func (*OCIMetricsSourceSpec) DeepCopyInto 

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

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

type Reconcilable added in v1.16.0 

type Reconcilable interface {
	metav1.Object
	runtime.Object
	// OwnerRefable is used to construct a generic reconciler for each
	// component type, and convert custom objects to owner references.
	kmeta.OwnerRefable
	// KRShaped is used by generated reconcilers to perform pre and
	// post-reconcile status updates.
	duckv1.KRShaped

	// GetSink returns the component's event sink.
	GetSink() *duckv1.Destination
	// GetStatusManager returns a manager for the component's status.
	GetStatusManager() *StatusManager
	// GetEventTypes returns the event types generated by the component.
	GetEventTypes() []string
	// AsEventSource returns a unique reference to the component suitable
	// for use as a CloudEvent 'source' attribute.
	AsEventSource() string
}

Reconcilable is implemented by all TriggerMesh components.

func ReconcilableFromContext added in v1.16.0 

func ReconcilableFromContext(ctx context.Context) Reconcilable

ReconcilableFromContext returns the component instance stored in the context.

type SalesforceAuth 

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

SalesforceAuth contains Salesforce credentials.

func (*SalesforceAuth) DeepCopy 

func (in *SalesforceAuth) DeepCopy() *SalesforceAuth

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

func (*SalesforceAuth) DeepCopyInto 

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

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

type SalesforceSource 

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

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

SalesforceSource is the Schema for the event source.

func (*SalesforceSource) AsEventSource 

func (s *SalesforceSource) AsEventSource() string

AsEventSource implements Reconcilable.

func (*SalesforceSource) DeepCopy 

func (in *SalesforceSource) DeepCopy() *SalesforceSource

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

func (*SalesforceSource) DeepCopyInto 

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

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

func (*SalesforceSource) DeepCopyObject 

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

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

func (*SalesforceSource) GetConditionSet 

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

GetConditionSet implements duckv1.KRShaped.

func (*SalesforceSource) GetEventTypes 

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

GetEventTypes returns the event types generated by the source.

func (*SalesforceSource) GetGroupVersionKind 

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

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*SalesforceSource) GetSink 

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

GetSink implements Reconcilable.

func (*SalesforceSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*SalesforceSource) GetStatusManager 

func (s *SalesforceSource) GetStatusManager() *StatusManager

GetStatusManager implements Reconcilable.

type SalesforceSourceList 

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

SalesforceSourceList contains a list of event sources.

func (*SalesforceSourceList) DeepCopy 

func (in *SalesforceSourceList) DeepCopy() *SalesforceSourceList

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

func (*SalesforceSourceList) DeepCopyInto 

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

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

func (*SalesforceSourceList) DeepCopyObject 

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

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

type SalesforceSourceSpec 

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

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

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

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

SalesforceSourceSpec defines the desired state of the event source.

func (*SalesforceSourceSpec) DeepCopy 

func (in *SalesforceSourceSpec) DeepCopy() *SalesforceSourceSpec

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

func (*SalesforceSourceSpec) DeepCopyInto 

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

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

type SalesforceSubscription 

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

SalesforceSubscription to connect to.

func (*SalesforceSubscription) DeepCopy 

func (in *SalesforceSubscription) DeepCopy() *SalesforceSubscription

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

func (*SalesforceSubscription) DeepCopyInto 

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

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

type SlackSource 

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

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

SlackSource is the schema for the event source.

func (*SlackSource) AsEventSource 

func (s *SlackSource) AsEventSource() string

AsEventSource implements Reconcilable.

func (*SlackSource) DeepCopy 

func (in *SlackSource) DeepCopy() *SlackSource

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

func (*SlackSource) DeepCopyInto 

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

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

func (*SlackSource) DeepCopyObject 

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

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

func (*SlackSource) GetConditionSet 

func (*SlackSource) GetConditionSet() pkgapis.ConditionSet

GetConditionSet implements duckv1.KRShaped.

func (*SlackSource) GetEventTypes 

func (*SlackSource) GetEventTypes() []string

GetEventTypes implements Reconcilable.

func (*SlackSource) GetGroupVersionKind 

func (*SlackSource) GetGroupVersionKind() schema.GroupVersionKind

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*SlackSource) GetSink 

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

GetSink implements Reconcilable.

func (*SlackSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*SlackSource) GetStatusManager 

func (s *SlackSource) GetStatusManager() *StatusManager

GetStatusManager implements Reconcilable.

type SlackSourceList 

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

SlackSourceList contains a list of event sources.

func (*SlackSourceList) DeepCopy 

func (in *SlackSourceList) DeepCopy() *SlackSourceList

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

func (*SlackSourceList) DeepCopyInto 

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

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

func (*SlackSourceList) DeepCopyObject 

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

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

type SlackSourceSpec 

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

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

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

SlackSourceSpec defines the desired state of the event source.

func (*SlackSourceSpec) DeepCopy 

func (in *SlackSourceSpec) DeepCopy() *SlackSourceSpec

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

func (*SlackSourceSpec) DeepCopyInto 

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

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

type StatusManager added in v1.16.0 

type StatusManager struct {
	apis.ConditionSet
	*EventSourceStatus
}

StatusManager manages the status of a TriggerMesh component.

+k8s:deepcopy-gen=false

func (*StatusManager) MarkNoSink added in v1.16.0 

func (m *StatusManager) MarkNoSink()

MarkNoSink sets the SinkProvided condition to False.

func (*StatusManager) MarkRBACNotBound added in v1.16.0 

func (m *StatusManager) MarkRBACNotBound()

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

func (*StatusManager) MarkSink added in v1.16.0 

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

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

func (*StatusManager) PropagateDeploymentAvailability added in v1.16.0 

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

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

func (*StatusManager) PropagateServiceAvailability added in v1.16.0 

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

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

func (*StatusManager) SetRoute added in v1.16.0 

func (m *StatusManager) SetRoute(urlPath string)

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

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 EventSourceStatus `json:"status,omitempty"`
}

TwilioSource is the schema for the event source.

func (*TwilioSource) AsEventSource 

func (s *TwilioSource) AsEventSource() string

AsEventSource implements Reconcilable.

func (*TwilioSource) DeepCopy 

func (in *TwilioSource) DeepCopy() *TwilioSource

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

func (*TwilioSource) DeepCopyInto 

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

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

func (*TwilioSource) DeepCopyObject 

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

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

func (*TwilioSource) GetConditionSet 

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

GetConditionSet implements duckv1.KRShaped.

func (*TwilioSource) GetEventTypes 

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

GetEventTypes implements Reconcilable.

func (*TwilioSource) GetGroupVersionKind 

func (*TwilioSource) GetGroupVersionKind() schema.GroupVersionKind

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*TwilioSource) GetSink 

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

GetSink implements Reconcilable.

func (*TwilioSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*TwilioSource) GetStatusManager 

func (s *TwilioSource) GetStatusManager() *StatusManager

GetStatusManager implements Reconcilable.

type TwilioSourceList 

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

TwilioSourceList contains a list of event sources.

func (*TwilioSourceList) DeepCopy 

func (in *TwilioSourceList) DeepCopy() *TwilioSourceList

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

func (*TwilioSourceList) DeepCopyInto 

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

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

func (*TwilioSourceList) DeepCopyObject 

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

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

type TwilioSourceSpec 

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

TwilioSourceSpec defines the desired state of the event source.

func (*TwilioSourceSpec) DeepCopy 

func (in *TwilioSourceSpec) DeepCopy() *TwilioSourceSpec

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

func (*TwilioSourceSpec) DeepCopyInto 

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

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

type ValueFromField 

type ValueFromField struct {

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

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

func (*ValueFromField) DeepCopy 

func (in *ValueFromField) DeepCopy() *ValueFromField

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

func (*ValueFromField) DeepCopyInto 

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

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

type WebhookSource 

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

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

WebhookSource is the schema for the event source.

func (*WebhookSource) AsEventSource 

func (s *WebhookSource) AsEventSource() string

AsEventSource implements Reconcilable.

func (*WebhookSource) DeepCopy 

func (in *WebhookSource) DeepCopy() *WebhookSource

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

func (*WebhookSource) DeepCopyInto 

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

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

func (*WebhookSource) DeepCopyObject 

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

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

func (*WebhookSource) GetConditionSet 

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

GetConditionSet implements duckv1.KRShaped.

func (*WebhookSource) GetEventTypes 

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

GetEventTypes implements Reconcilable.

func (*WebhookSource) GetGroupVersionKind 

func (*WebhookSource) GetGroupVersionKind() schema.GroupVersionKind

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*WebhookSource) GetSink 

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

GetSink implements Reconcilable.

func (*WebhookSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*WebhookSource) GetStatusManager 

func (s *WebhookSource) GetStatusManager() *StatusManager

GetStatusManager implements Reconcilable.

type WebhookSourceList 

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

WebhookSourceList contains a list of event sources.

func (*WebhookSourceList) DeepCopy 

func (in *WebhookSourceList) DeepCopy() *WebhookSourceList

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

func (*WebhookSourceList) DeepCopyInto 

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

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

func (*WebhookSourceList) DeepCopyObject 

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

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

type WebhookSourceSpec 

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

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

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

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

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

	// Specifies the CORS Origin to use in pre-flight headers.
	// +optional
	CORSAllowOrigin *string `json:"corsAllowOrigin,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 Reconcilable.

func (*ZendeskSource) DeepCopy 

func (in *ZendeskSource) DeepCopy() *ZendeskSource

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

func (*ZendeskSource) DeepCopyInto 

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

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

func (*ZendeskSource) DeepCopyObject 

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

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

func (*ZendeskSource) GetConditionSet 

func (*ZendeskSource) GetConditionSet() apis.ConditionSet

GetConditionSet implements duckv1.KRShaped.

func (*ZendeskSource) GetEventTypes 

func (*ZendeskSource) GetEventTypes() []string

GetEventTypes implements Reconcilable.

func (*ZendeskSource) GetGroupVersionKind 

func (*ZendeskSource) GetGroupVersionKind() schema.GroupVersionKind

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*ZendeskSource) GetSink 

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

GetSink implements Reconcilable.

func (*ZendeskSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*ZendeskSource) GetStatusManager 

func (s *ZendeskSource) GetStatusManager() *StatusManager

GetStatusManager implements Reconcilable.

func (*ZendeskSource) IsMultiTenant 

func (*ZendeskSource) IsMultiTenant() bool

IsMultiTenant implements MultiTenant.

type ZendeskSourceList 

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

ZendeskSourceList contains a list of event sources.

func (*ZendeskSourceList) DeepCopy 

func (in *ZendeskSourceList) DeepCopy() *ZendeskSourceList

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

func (*ZendeskSourceList) DeepCopyInto 

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

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

func (*ZendeskSourceList) DeepCopyObject 

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

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

type ZendeskSourceSpec 

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

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

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

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

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

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

ZendeskSourceSpec defines the desired state of the event source.

func (*ZendeskSourceSpec) DeepCopy 

func (in *ZendeskSourceSpec) DeepCopy() *ZendeskSourceSpec

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

func (*ZendeskSourceSpec) DeepCopyInto 

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

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

type ZendeskSourceStatus 

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

ZendeskSourceStatus defines the observed state of the event source.

func (*ZendeskSourceStatus) DeepCopy 

func (in *ZendeskSourceStatus) DeepCopy() *ZendeskSourceStatus

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

func (*ZendeskSourceStatus) DeepCopyInto 

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

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

func (*ZendeskSourceStatus) MarkTargetNotSynced 

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

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

func (*ZendeskSourceStatus) MarkTargetSynced 

func (s *ZendeskSourceStatus) MarkTargetSynced()

MarkTargetSynced sets the TargetSynced condition to True.

Source Files

View all Source files

Jump to

Keyboard shortcuts

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