v1alpha1

package
v1.10.0 Latest Latest
Warning

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

 Go to latest Published: Sep 30, 2021 License: Apache-2.0 Imports: 21 Imported by: 0

Documentation

Overview

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

Index

Constants

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

Status conditions

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

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

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

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

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
)

Functions

func AWSCloudWatchSourceName added in v1.2.0 

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 IsMultiTenant added in v1.3.0 

func IsMultiTenant(src EventSource) bool

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

func Kind 

func Kind(kind string) schema.GroupKind

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

func NewEventSourceConditionSet added in v0.6.0 

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

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

func Resource 

func Resource(resource string) schema.GroupResource

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

func WithSource 

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

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

Types

type AWSCloudWatchLogsSource added in v1.2.0 

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

func (s *AWSCloudWatchLogsSource) AsEventSource() string

AsEventSource implements EventSource.

func (*AWSCloudWatchLogsSource) DeepCopy added in v1.2.0 

func (in *AWSCloudWatchLogsSource) DeepCopy() *AWSCloudWatchLogsSource

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

func (*AWSCloudWatchLogsSource) DeepCopyInto added in v1.2.0 

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

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

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

func (*AWSCloudWatchLogsSource) GetConditionSet added in v1.2.0 

func (*AWSCloudWatchLogsSource) GetConditionSet() apis.ConditionSet

GetConditionSet implements duckv1.KRShaped.

func (*AWSCloudWatchLogsSource) GetEventTypes added in v1.2.0 

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

GetEventTypes implements EventSource.

func (*AWSCloudWatchLogsSource) GetGroupVersionKind added in v1.2.0 

func (*AWSCloudWatchLogsSource) GetGroupVersionKind() schema.GroupVersionKind

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*AWSCloudWatchLogsSource) GetSink added in v1.2.0 

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

GetSink implements EventSource.

func (*AWSCloudWatchLogsSource) GetStatus added in v1.2.0 

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

GetStatus implements duckv1.KRShaped.

func (*AWSCloudWatchLogsSource) GetStatusManager added in v1.2.0 

func (s *AWSCloudWatchLogsSource) GetStatusManager() *EventSourceStatusManager

GetStatusManager implements EventSource.

type AWSCloudWatchLogsSourceList added in v1.2.0 

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

func (in *AWSCloudWatchLogsSourceList) DeepCopy() *AWSCloudWatchLogsSourceList

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

func (*AWSCloudWatchLogsSourceList) DeepCopyInto added in v1.2.0 

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

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

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

type AWSCloudWatchLogsSourceSpec added in v1.2.0 

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

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

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

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

AWSCloudWatchSourceSpec defines the desired state of the event source.

func (*AWSCloudWatchLogsSourceSpec) DeepCopy added in v1.2.0 

func (in *AWSCloudWatchLogsSourceSpec) DeepCopy() *AWSCloudWatchLogsSourceSpec

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

func (*AWSCloudWatchLogsSourceSpec) DeepCopyInto added in v1.2.0 

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

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

func (*AWSCloudWatchMetric) DeepCopy added in v1.2.0 

func (in *AWSCloudWatchMetric) DeepCopy() *AWSCloudWatchMetric

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

func (*AWSCloudWatchMetric) DeepCopyInto added in v1.2.0 

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

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

func (*AWSCloudWatchMetricDimension) DeepCopy added in v1.2.0 

func (in *AWSCloudWatchMetricDimension) DeepCopy() *AWSCloudWatchMetricDimension

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

func (*AWSCloudWatchMetricDimension) DeepCopyInto added in v1.2.0 

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

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

func (in *AWSCloudWatchMetricQuery) DeepCopy() *AWSCloudWatchMetricQuery

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

func (*AWSCloudWatchMetricQuery) DeepCopyInto added in v1.2.0 

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

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
}

func (*AWSCloudWatchMetricStat) DeepCopy added in v1.2.0 

func (in *AWSCloudWatchMetricStat) DeepCopy() *AWSCloudWatchMetricStat

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

func (*AWSCloudWatchMetricStat) DeepCopyInto added in v1.2.0 

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

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

func (s *AWSCloudWatchSource) AsEventSource() string

AsEventSource implements EventSource.

func (*AWSCloudWatchSource) DeepCopy added in v1.2.0 

func (in *AWSCloudWatchSource) DeepCopy() *AWSCloudWatchSource

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

func (*AWSCloudWatchSource) DeepCopyInto added in v1.2.0 

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

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

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

func (*AWSCloudWatchSource) GetConditionSet added in v1.2.0 

func (*AWSCloudWatchSource) GetConditionSet() apis.ConditionSet

GetConditionSet implements duckv1.KRShaped.

func (*AWSCloudWatchSource) GetEventTypes added in v1.2.0 

func (*AWSCloudWatchSource) GetEventTypes() []string

GetEventTypes implements EventSource.

func (*AWSCloudWatchSource) GetGroupVersionKind added in v1.2.0 

func (*AWSCloudWatchSource) GetGroupVersionKind() schema.GroupVersionKind

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*AWSCloudWatchSource) GetSink added in v1.2.0 

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

GetSink implements EventSource.

func (*AWSCloudWatchSource) GetStatus added in v1.2.0 

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

GetStatus implements duckv1.KRShaped.

func (*AWSCloudWatchSource) GetStatusManager added in v1.2.0 

func (s *AWSCloudWatchSource) GetStatusManager() *EventSourceStatusManager

GetStatusManager implements EventSource.

type AWSCloudWatchSourceList added in v1.2.0 

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

func (in *AWSCloudWatchSourceList) DeepCopy() *AWSCloudWatchSourceList

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

func (*AWSCloudWatchSourceList) DeepCopyInto added in v1.2.0 

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

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

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

type AWSCloudWatchSourceSpec added in v1.2.0 

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

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

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

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

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

AWSCloudWatchSourceSpec defines the desired state of the event source.

func (*AWSCloudWatchSourceSpec) DeepCopy added in v1.2.0 

func (in *AWSCloudWatchSourceSpec) DeepCopy() *AWSCloudWatchSourceSpec

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

func (*AWSCloudWatchSourceSpec) DeepCopyInto added in v1.2.0 

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 added in v0.5.0 

func (s *AWSCodeCommitSource) AsEventSource() string

AsEventSource implements EventSource.

func (*AWSCodeCommitSource) DeepCopy 

func (in *AWSCodeCommitSource) DeepCopy() *AWSCodeCommitSource

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

func (*AWSCodeCommitSource) DeepCopyInto 

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

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

func (*AWSCodeCommitSource) DeepCopyObject 

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

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

func (*AWSCodeCommitSource) GetConditionSet added in v0.3.0 

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

GetConditionSet implements duckv1.KRShaped.

func (*AWSCodeCommitSource) GetEventTypes 

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

GetEventTypes implements EventSource.

func (*AWSCodeCommitSource) GetGroupVersionKind 

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

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*AWSCodeCommitSource) GetSink 

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

GetSink implements EventSource.

func (*AWSCodeCommitSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*AWSCodeCommitSource) GetStatusManager added in v0.6.0 

func (s *AWSCodeCommitSource) GetStatusManager() *EventSourceStatusManager

GetStatusManager implements EventSource.

type AWSCodeCommitSourceList 

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

AWSCodeCommitSourceList contains a list of event sources.

func (*AWSCodeCommitSourceList) DeepCopy 

func (in *AWSCodeCommitSourceList) DeepCopy() *AWSCodeCommitSourceList

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

func (*AWSCodeCommitSourceList) DeepCopyInto 

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

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

func (*AWSCodeCommitSourceList) DeepCopyObject 

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

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

type AWSCodeCommitSourceSpec 

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

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

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

AWSCodeCommitSourceSpec defines the desired state of the event source.

func (*AWSCodeCommitSourceSpec) DeepCopy 

func (in *AWSCodeCommitSourceSpec) DeepCopy() *AWSCodeCommitSourceSpec

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

func (*AWSCodeCommitSourceSpec) DeepCopyInto 

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

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

type AWSCognitoIdentitySource 

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

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

AWSCognitoIdentitySource is the Schema for the event source.

func (*AWSCognitoIdentitySource) AsEventSource added in v0.5.0 

func (s *AWSCognitoIdentitySource) AsEventSource() string

AsEventSource implements EventSource.

func (*AWSCognitoIdentitySource) DeepCopy 

func (in *AWSCognitoIdentitySource) DeepCopy() *AWSCognitoIdentitySource

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

func (*AWSCognitoIdentitySource) DeepCopyInto 

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

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

func (*AWSCognitoIdentitySource) DeepCopyObject 

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

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

func (*AWSCognitoIdentitySource) GetConditionSet added in v0.3.0 

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

GetConditionSet implements duckv1.KRShaped.

func (*AWSCognitoIdentitySource) GetEventTypes 

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

GetEventTypes implements EventSource.

func (*AWSCognitoIdentitySource) GetGroupVersionKind 

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

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*AWSCognitoIdentitySource) GetSink 

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

GetSink implements EventSource.

func (*AWSCognitoIdentitySource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*AWSCognitoIdentitySource) GetStatusManager added in v0.6.0 

func (s *AWSCognitoIdentitySource) GetStatusManager() *EventSourceStatusManager

GetStatusManager implements EventSource.

type AWSCognitoIdentitySourceList 

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

AWSCognitoIdentitySourceList contains a list of event sources.

func (*AWSCognitoIdentitySourceList) DeepCopy 

func (in *AWSCognitoIdentitySourceList) DeepCopy() *AWSCognitoIdentitySourceList

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

func (*AWSCognitoIdentitySourceList) DeepCopyInto 

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

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

func (*AWSCognitoIdentitySourceList) DeepCopyObject 

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

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

type AWSCognitoIdentitySourceSpec 

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

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

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

AWSCognitoIdentitySourceSpec defines the desired state of the event source.

func (*AWSCognitoIdentitySourceSpec) DeepCopy 

func (in *AWSCognitoIdentitySourceSpec) DeepCopy() *AWSCognitoIdentitySourceSpec

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

func (*AWSCognitoIdentitySourceSpec) DeepCopyInto 

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

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

type AWSCognitoUserPoolSource 

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

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

AWSCognitoUserPoolSource is the Schema for the event source.

func (*AWSCognitoUserPoolSource) AsEventSource added in v0.5.0 

func (s *AWSCognitoUserPoolSource) AsEventSource() string

AsEventSource implements EventSource.

func (*AWSCognitoUserPoolSource) DeepCopy 

func (in *AWSCognitoUserPoolSource) DeepCopy() *AWSCognitoUserPoolSource

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

func (*AWSCognitoUserPoolSource) DeepCopyInto 

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

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

func (*AWSCognitoUserPoolSource) DeepCopyObject 

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

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

func (*AWSCognitoUserPoolSource) GetConditionSet added in v0.3.0 

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

GetConditionSet implements duckv1.KRShaped.

func (*AWSCognitoUserPoolSource) GetEventTypes 

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

GetEventTypes implements EventSource.

func (*AWSCognitoUserPoolSource) GetGroupVersionKind 

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

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*AWSCognitoUserPoolSource) GetSink 

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

GetSink implements EventSource.

func (*AWSCognitoUserPoolSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*AWSCognitoUserPoolSource) GetStatusManager added in v0.6.0 

func (s *AWSCognitoUserPoolSource) GetStatusManager() *EventSourceStatusManager

GetStatusManager implements EventSource.

type AWSCognitoUserPoolSourceList 

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

AWSCognitoUserPoolSourceList contains a list of event sources.

func (*AWSCognitoUserPoolSourceList) DeepCopy 

func (in *AWSCognitoUserPoolSourceList) DeepCopy() *AWSCognitoUserPoolSourceList

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

func (*AWSCognitoUserPoolSourceList) DeepCopyInto 

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

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

func (*AWSCognitoUserPoolSourceList) DeepCopyObject 

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

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

type AWSCognitoUserPoolSourceSpec 

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

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

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

AWSCognitoUserPoolSourceSpec defines the desired state of the event source.

func (*AWSCognitoUserPoolSourceSpec) DeepCopy 

func (in *AWSCognitoUserPoolSourceSpec) DeepCopy() *AWSCognitoUserPoolSourceSpec

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

func (*AWSCognitoUserPoolSourceSpec) DeepCopyInto 

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

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

type AWSDynamoDBSource 

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

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

AWSDynamoDBSource is the Schema for the event source.

func (*AWSDynamoDBSource) AsEventSource added in v0.5.0 

func (s *AWSDynamoDBSource) AsEventSource() string

AsEventSource implements EventSource.

func (*AWSDynamoDBSource) DeepCopy 

func (in *AWSDynamoDBSource) DeepCopy() *AWSDynamoDBSource

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

func (*AWSDynamoDBSource) DeepCopyInto 

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

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

func (*AWSDynamoDBSource) DeepCopyObject 

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

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

func (*AWSDynamoDBSource) GetConditionSet added in v0.3.0 

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

GetConditionSet implements duckv1.KRShaped.

func (*AWSDynamoDBSource) GetEventTypes 

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

GetEventTypes implements EventSource.

func (*AWSDynamoDBSource) GetGroupVersionKind 

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

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*AWSDynamoDBSource) GetSink 

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

GetSink implements EventSource.

func (*AWSDynamoDBSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*AWSDynamoDBSource) GetStatusManager added in v0.6.0 

func (s *AWSDynamoDBSource) GetStatusManager() *EventSourceStatusManager

GetStatusManager implements EventSource.

type AWSDynamoDBSourceList 

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

AWSDynamoDBSourceList contains a list of event sources.

func (*AWSDynamoDBSourceList) DeepCopy 

func (in *AWSDynamoDBSourceList) DeepCopy() *AWSDynamoDBSourceList

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

func (*AWSDynamoDBSourceList) DeepCopyInto 

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

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

func (*AWSDynamoDBSourceList) DeepCopyObject 

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

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

type AWSDynamoDBSourceSpec 

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

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

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

AWSDynamoDBSourceSpec defines the desired state of the event source.

func (*AWSDynamoDBSourceSpec) DeepCopy 

func (in *AWSDynamoDBSourceSpec) DeepCopy() *AWSDynamoDBSourceSpec

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

func (*AWSDynamoDBSourceSpec) DeepCopyInto 

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

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

type AWSKinesisSource 

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

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

AWSKinesisSource is the Schema for the event source.

func (*AWSKinesisSource) AsEventSource added in v0.5.0 

func (s *AWSKinesisSource) AsEventSource() string

AsEventSource implements EventSource.

func (*AWSKinesisSource) DeepCopy 

func (in *AWSKinesisSource) DeepCopy() *AWSKinesisSource

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

func (*AWSKinesisSource) DeepCopyInto 

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

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

func (*AWSKinesisSource) DeepCopyObject 

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

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

func (*AWSKinesisSource) GetConditionSet added in v0.3.0 

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

GetConditionSet implements duckv1.KRShaped.

func (*AWSKinesisSource) GetEventTypes 

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

GetEventTypes implements EventSource.

func (*AWSKinesisSource) GetGroupVersionKind 

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

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*AWSKinesisSource) GetSink 

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

GetSink implements EventSource.

func (*AWSKinesisSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*AWSKinesisSource) GetStatusManager added in v0.6.0 

func (s *AWSKinesisSource) GetStatusManager() *EventSourceStatusManager

GetStatusManager implements EventSource.

type AWSKinesisSourceList 

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

AWSKinesisSourceList contains a list of event sources.

func (*AWSKinesisSourceList) DeepCopy 

func (in *AWSKinesisSourceList) DeepCopy() *AWSKinesisSourceList

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

func (*AWSKinesisSourceList) DeepCopyInto 

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

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

func (*AWSKinesisSourceList) DeepCopyObject 

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

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

type AWSKinesisSourceSpec 

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

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

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

AWSKinesisSourceSpec defines the desired state of the event source.

func (*AWSKinesisSourceSpec) DeepCopy 

func (in *AWSKinesisSourceSpec) DeepCopy() *AWSKinesisSourceSpec

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

func (*AWSKinesisSourceSpec) DeepCopyInto 

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

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

type AWSPerformanceInsightsSource added in v1.6.0 

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

func (s *AWSPerformanceInsightsSource) AsEventSource() string

AsEventSource implements EventSource.

func (*AWSPerformanceInsightsSource) DeepCopy added in v1.6.0 

func (in *AWSPerformanceInsightsSource) DeepCopy() *AWSPerformanceInsightsSource

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

func (*AWSPerformanceInsightsSource) DeepCopyInto added in v1.6.0 

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

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

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

func (*AWSPerformanceInsightsSource) GetConditionSet added in v1.6.0 

func (*AWSPerformanceInsightsSource) GetConditionSet() apis.ConditionSet

GetConditionSet implements duckv1.KRShaped.

func (*AWSPerformanceInsightsSource) GetEventTypes added in v1.6.0 

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

GetEventTypes implements EventSource.

func (*AWSPerformanceInsightsSource) GetGroupVersionKind added in v1.6.0 

func (*AWSPerformanceInsightsSource) GetGroupVersionKind() schema.GroupVersionKind

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*AWSPerformanceInsightsSource) GetSink added in v1.6.0 

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

GetSink implements EventSource.

func (*AWSPerformanceInsightsSource) GetStatus added in v1.6.0 

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

GetStatus implements duckv1.KRShaped.

func (*AWSPerformanceInsightsSource) GetStatusManager added in v1.6.0 

func (s *AWSPerformanceInsightsSource) GetStatusManager() *EventSourceStatusManager

GetStatusManager implements EventSource.

type AWSPerformanceInsightsSourceList added in v1.6.0 

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

func (in *AWSPerformanceInsightsSourceList) DeepCopy() *AWSPerformanceInsightsSourceList

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

func (*AWSPerformanceInsightsSourceList) DeepCopyInto added in v1.6.0 

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

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

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

type AWSPerformanceInsightsSourceSpec added in v1.6.0 

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

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

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

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

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

AWSPerformanceInsightsSourceSpec defines the desired state of the event source.

func (*AWSPerformanceInsightsSourceSpec) DeepCopy added in v1.6.0 

func (in *AWSPerformanceInsightsSourceSpec) DeepCopy() *AWSPerformanceInsightsSourceSpec

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

func (*AWSPerformanceInsightsSourceSpec) DeepCopyInto added in v1.6.0 

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

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

func (s *AWSS3Source) AsEventSource() string

AsEventSource implements EventSource.

func (*AWSS3Source) DeepCopy added in v1.4.0 

func (in *AWSS3Source) DeepCopy() *AWSS3Source

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

func (*AWSS3Source) DeepCopyInto added in v1.4.0 

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

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

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

func (*AWSS3Source) GetConditionSet added in v1.4.0 

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

GetConditionSet implements duckv1.KRShaped.

func (*AWSS3Source) GetEventTypes added in v1.4.0 

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

GetEventTypes implements EventSource.

func (*AWSS3Source) GetGroupVersionKind added in v1.4.0 

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

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*AWSS3Source) GetSink added in v1.4.0 

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

GetSink implements EventSource.

func (*AWSS3Source) GetStatus added in v1.4.0 

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

GetStatus implements duckv1.KRShaped.

func (*AWSS3Source) GetStatusManager added in v1.4.0 

func (s *AWSS3Source) GetStatusManager() *EventSourceStatusManager

GetStatusManager implements EventSource.

type AWSS3SourceList added in v1.4.0 

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

func (in *AWSS3SourceList) DeepCopy() *AWSS3SourceList

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

func (*AWSS3SourceList) DeepCopyInto added in v1.4.0 

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

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

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

type AWSS3SourceSpec added in v1.4.0 

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

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

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

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

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

AWSS3SourceSpec defines the desired state of the event source.

func (*AWSS3SourceSpec) DeepCopy added in v1.4.0 

func (in *AWSS3SourceSpec) DeepCopy() *AWSS3SourceSpec

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

func (*AWSS3SourceSpec) DeepCopyInto added in v1.4.0 

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

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

AWSS3SourceStatus defines the observed state of the event source.

func (*AWSS3SourceStatus) DeepCopy added in v1.4.0 

func (in *AWSS3SourceStatus) DeepCopy() *AWSS3SourceStatus

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

func (*AWSS3SourceStatus) DeepCopyInto added in v1.4.0 

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

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

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

func (*AWSS3SourceStatus) MarkSubscribed added in v1.4.0 

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 added in v0.5.0 

func (s *AWSSNSSource) AsEventSource() string

AsEventSource implements EventSource.

func (*AWSSNSSource) DeepCopy 

func (in *AWSSNSSource) DeepCopy() *AWSSNSSource

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

func (*AWSSNSSource) DeepCopyInto 

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

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

func (*AWSSNSSource) DeepCopyObject 

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

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

func (*AWSSNSSource) GetConditionSet added in v0.3.0 

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

GetConditionSet implements duckv1.KRShaped.

func (*AWSSNSSource) GetEventTypes 

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

GetEventTypes implements EventSource.

func (*AWSSNSSource) GetGroupVersionKind 

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

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*AWSSNSSource) GetSink 

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

GetSink implements EventSource.

func (*AWSSNSSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*AWSSNSSource) GetStatusManager added in v0.6.0 

func (s *AWSSNSSource) GetStatusManager() *EventSourceStatusManager

GetStatusManager implements EventSource.

func (*AWSSNSSource) GetUntypedSpec 

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

GetUntypedSpec implements apis.HasSpec.

func (*AWSSNSSource) IsMultiTenant added in v1.3.0 

func (*AWSSNSSource) IsMultiTenant() bool

IsMultiTenant implements MultiTenant.

type AWSSNSSourceList 

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

AWSSNSSourceList contains a list of event sources.

func (*AWSSNSSourceList) DeepCopy 

func (in *AWSSNSSourceList) DeepCopy() *AWSSNSSourceList

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

func (*AWSSNSSourceList) DeepCopyInto 

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

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

func (*AWSSNSSourceList) DeepCopyObject 

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

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

type AWSSNSSourceSpec 

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

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

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

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

AWSSNSSourceSpec defines the desired state of the event source.

func (*AWSSNSSourceSpec) DeepCopy 

func (in *AWSSNSSourceSpec) DeepCopy() *AWSSNSSourceSpec

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

func (*AWSSNSSourceSpec) DeepCopyInto 

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

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

type AWSSNSSourceStatus added in v0.6.0 

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

AWSSNSSourceStatus defines the observed state of the event source.

func (*AWSSNSSourceStatus) DeepCopy added in v0.6.0 

func (in *AWSSNSSourceStatus) DeepCopy() *AWSSNSSourceStatus

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

func (*AWSSNSSourceStatus) DeepCopyInto added in v0.6.0 

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 added in v0.6.0 

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

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

func (*AWSSNSSourceStatus) MarkSubscribed added in v0.6.0 

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 added in v0.5.0 

func (s *AWSSQSSource) AsEventSource() string

AsEventSource implements EventSource.

func (*AWSSQSSource) DeepCopy 

func (in *AWSSQSSource) DeepCopy() *AWSSQSSource

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

func (*AWSSQSSource) DeepCopyInto 

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

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

func (*AWSSQSSource) DeepCopyObject 

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

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

func (*AWSSQSSource) GetConditionSet added in v0.3.0 

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

GetConditionSet implements duckv1.KRShaped.

func (*AWSSQSSource) GetEventTypes 

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

GetEventTypes implements EventSource.

func (*AWSSQSSource) GetGroupVersionKind 

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

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*AWSSQSSource) GetSink 

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

GetSink implements EventSource.

func (*AWSSQSSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*AWSSQSSource) GetStatusManager added in v0.6.0 

func (s *AWSSQSSource) GetStatusManager() *EventSourceStatusManager

GetStatusManager implements EventSource.

type AWSSQSSourceList 

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

AWSSQSSourceList contains a list of event sources.

func (*AWSSQSSourceList) DeepCopy 

func (in *AWSSQSSourceList) DeepCopy() *AWSSQSSourceList

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

func (*AWSSQSSourceList) DeepCopyInto 

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

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

func (*AWSSQSSourceList) DeepCopyObject 

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

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

type AWSSQSSourceReceiveOptions added in v1.10.0 

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

func (in *AWSSQSSourceReceiveOptions) DeepCopy() *AWSSQSSourceReceiveOptions

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

func (*AWSSQSSourceReceiveOptions) DeepCopyInto added in v1.10.0 

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

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

type AWSSQSSourceSpec 

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

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

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

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

AWSSQSSourceSpec defines the desired state of the event source.

func (*AWSSQSSourceSpec) DeepCopy 

func (in *AWSSQSSourceSpec) DeepCopy() *AWSSQSSourceSpec

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

func (*AWSSQSSourceSpec) DeepCopyInto 

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

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

type AWSSecurityCredentials 

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

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

func (*AWSSecurityCredentials) DeepCopy 

func (in *AWSSecurityCredentials) DeepCopy() *AWSSecurityCredentials

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

func (*AWSSecurityCredentials) DeepCopyInto 

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

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

type EventSource added in v0.5.0 

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

EventSource is implemented by all event source types.

func SourceFromContext 

func SourceFromContext(ctx context.Context) EventSource

SourceFromContext returns the source stored in the context.

type EventSourceStatus added in v0.5.0 

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

EventSourceStatus defines the observed state of an event source.

func (*EventSourceStatus) DeepCopy added in v0.5.0 

func (in *EventSourceStatus) DeepCopy() *EventSourceStatus

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

func (*EventSourceStatus) DeepCopyInto added in v0.5.0 

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

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

type EventSourceStatusManager added in v0.6.0 

type EventSourceStatusManager struct {
	apis.ConditionSet
	*EventSourceStatus
}

EventSourceStatusManager manages the status of event sources.

+k8s:deepcopy-gen=false

func (*EventSourceStatusManager) MarkNoSink added in v0.6.0 

func (m *EventSourceStatusManager) MarkNoSink()

MarkNoSink sets the SinkProvided condition to False.

func (*EventSourceStatusManager) MarkRBACNotBound added in v1.3.0 

func (m *EventSourceStatusManager) MarkRBACNotBound()

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

func (*EventSourceStatusManager) MarkSink added in v0.6.0 

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

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

func (*EventSourceStatusManager) PropagateDeploymentAvailability added in v0.6.0 

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

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

func (*EventSourceStatusManager) PropagateServiceAvailability added in v0.6.0 

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

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

func (*EventSourceStatusManager) SetRoute added in v1.3.0 

func (m *EventSourceStatusManager) SetRoute(urlPath string)

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

type ValueFromField 

type ValueFromField struct {

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

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

func (*ValueFromField) DeepCopy 

func (in *ValueFromField) DeepCopy() *ValueFromField

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

func (*ValueFromField) DeepCopyInto 

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

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

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