v1alpha1

package
v1.0.0 Latest Latest
Warning

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

 Go to latest Published: Nov 11, 2020 License: Apache-2.0 Imports: 19 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 (
	// 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"
	// AWSSNSReasonRejected is set on a Subscribed condition when the SNS API rejects a subscription request.
	AWSSNSReasonRejected = "SubscriptionRejected"
	// 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"

	// ReasonUnavailable is set on a Deployed condition when an adapter in unavailable.
	ReasonUnavailable = "AdapterUnavailable"
)

Reasons for status conditions

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 (
	// AWSSNSConditionSubscribed has status True when the event source's HTTP(S) endpoint has been subscribed to the
	// SNS subscription.
	AWSSNSConditionSubscribed apis.ConditionType = "Subscribed"
)

Status conditions

View Source 
const (
	AWSSNSGenericEventType = "notification"
)

Supported event types

View Source 
const (
	AWSSQSGenericEventType = "message"
)

Supported event types

Variables

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

Functions

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

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

MarkSubscribed sets the Subscribed condition to True.

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

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.