v1alpha1

package
v1.3.0 Latest Latest
Warning

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

 Go to latest Published: Feb 3, 2021 License: Apache-2.0 Imports: 20 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 (
	// 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 (
	AWSIoTGenericEventType = "greetings"
)

Supported event types

View Source 
const (
	AWSKinesisGenericEventType = "stream_record"
)

Supported event types

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 for Log Group
	// https://docs.aws.amazon.com/service-authorization/latest/reference/list_amazoncloudwatchlogs.html#amazoncloudwatchlogs-resources-for-iam-policies
	ARN apis.ARN `json:"arn"`
	// PollingInterval in a duration format for how often to pull metrics data from. Default is 5m
	// +optional
	PollingInterval *apis.Duration `json:"pollingInterval,omitempty"`

	// Credentials to interact with the AWS 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 identify the query
	Name string `json:"name"`

	// Math expression for calculating metrics
	// +optional
	Expression *string `json:"expression,omitempty"`
	// Metric for retrieving specific metrics
	// +optional
	Metric *AWSCloudWatchMetricStat `json:"metric,omitempty"`
}

Define the metric to return. Consult the AWS CloudWatch API Guide for details: https://docs.aws.amazon.com/AmazonCloudWatch/latest/APIReference/Welcome.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"`

	// AWS Region for metrics
	Region string `json:"region"`
	// List of metric queries
	// +optional
	MetricQueries []AWSCloudWatchMetricQuery `json:"metricQueries,omitempty"`
	// PollingInterval in a duration format for how often to pull metrics data from. Default is 5m
	// +optional
	PollingInterval *apis.Duration `json:"pollingInterval,omitempty"`

	// Credentials to interact with the AWS 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 AWS 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 AWS 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"`

	// 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 AWS 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 AWS Cognito 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 AWSIoTSource 

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

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

AWSIoTSource is the Schema for the event source.

func (*AWSIoTSource) AsEventSource added in v0.5.0 

func (s *AWSIoTSource) AsEventSource() string

AsEventSource implements EventSource.

func (*AWSIoTSource) DeepCopy 

func (in *AWSIoTSource) DeepCopy() *AWSIoTSource

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

func (*AWSIoTSource) DeepCopyInto 

func (in *AWSIoTSource) DeepCopyInto(out *AWSIoTSource)

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

func (*AWSIoTSource) DeepCopyObject 

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

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

func (*AWSIoTSource) GetConditionSet added in v0.3.0 

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

GetConditionSet implements duckv1.KRShaped.

func (*AWSIoTSource) GetEventTypes 

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

GetEventTypes implements EventSource.

func (*AWSIoTSource) GetGroupVersionKind 

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

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*AWSIoTSource) GetSink 

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

GetSink implements EventSource.

func (*AWSIoTSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*AWSIoTSource) GetStatusManager added in v0.6.0 

func (s *AWSIoTSource) GetStatusManager() *EventSourceStatusManager

GetStatusManager implements EventSource.

type AWSIoTSourceList 

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

AWSIoTSourceList contains a list of event sources.

func (*AWSIoTSourceList) DeepCopy 

func (in *AWSIoTSourceList) DeepCopy() *AWSIoTSourceList

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

func (*AWSIoTSourceList) DeepCopyInto 

func (in *AWSIoTSourceList) DeepCopyInto(out *AWSIoTSourceList)

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

func (*AWSIoTSourceList) DeepCopyObject 

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

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

type AWSIoTSourceSpec 

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

	// Host name of the endpoint the client connects to
	Endpoint string `json:"endpoint"`
	// Topic ARN
	// https://docs.aws.amazon.com/IAM/latest/UserGuide/list_awsiot.html#awsiot-resources-for-iam-policies
	ARN apis.ARN `json:"arn"`

	// Contents of the root CA
	RootCA ValueFromField `json:"rootCA"`
	// Path where the root CA gets written
	// +optional
	RootCAPath *string `json:"rootCAPath,omitempty"`

	// Contents of the client certificate
	Certificate ValueFromField `json:"certificate"`
	// Path where the client certificate gets written
	// +optional
	CertificatePath *string `json:"certificatePath,omitempty"`

	// Contents of the client private key
	PrivateKey ValueFromField `json:"privateKey"`
	// Path where the client private key gets written
	// +optional
	PrivateKeyPath *string `json:"privateKeyPath,omitempty"`
}

AWSIoTSourceSpec defines the desired state of the event source.

func (*AWSIoTSourceSpec) DeepCopy 

func (in *AWSIoTSourceSpec) DeepCopy() *AWSIoTSourceSpec

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

func (*AWSIoTSourceSpec) DeepCopyInto 

func (in *AWSIoTSourceSpec) DeepCopyInto(out *AWSIoTSourceSpec)

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

	// Credentials to interact with the AWS 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.