v1alpha1

package
v0.4.1 Latest Latest
Warning

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

 Go to latest Published: Jul 25, 2020 License: Apache-2.0 Imports: 13 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 (
	AWSDynamoDBAddEventType    = "insert"
	AWSDynamoDBModifyEventType = "modify"
	AWSDynamoDBRemoveEventType = "remove"
)

Supported event types

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 (
	AWSCognitoGenericEventType = "sync_trigger"
)

Supported event types

View Source 
const (
	AWSCognitoIdentityGenericEventType = "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

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

AWSCodeCommitSource is the Schema for the event source.

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

func (s *AWSCodeCommitSource) GetARN() apis.ARN

GetARN implements AWSEventSource.

func (*AWSCodeCommitSource) GetConditionSet added in v0.3.0 

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

GetConditionSet implements duckv1.KRShaped.

func (*AWSCodeCommitSource) GetEventTypes 

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

GetEventTypes implements AWSEventSource.

func (*AWSCodeCommitSource) GetGroupVersionKind 

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

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*AWSCodeCommitSource) GetSink 

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

GetSink implements AWSEventSource.

func (*AWSCodeCommitSource) GetSourceStatus added in v0.3.0 

func (s *AWSCodeCommitSource) GetSourceStatus() *AWSEventSourceStatus

GetSourceStatus implements AWSEventSource.

func (*AWSCodeCommitSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*AWSCodeCommitSource) GetUntypedSpec 

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

GetUntypedSpec implements apis.HasSpec.

func (*AWSCodeCommitSource) SetDefaults 

func (s *AWSCodeCommitSource) SetDefaults(_ context.Context)

SetDefaults implements apis.Defaultable.

func (*AWSCodeCommitSource) Validate 

func (s *AWSCodeCommitSource) Validate(_ context.Context) *apis.FieldError

Validate implements apis.Validatable.

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

AWSCognitoIdentitySource is the Schema for the event source.

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

func (s *AWSCognitoIdentitySource) GetARN() apis.ARN

GetARN implements AWSEventSource.

func (*AWSCognitoIdentitySource) GetConditionSet added in v0.3.0 

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

GetConditionSet implements duckv1.KRShaped.

func (*AWSCognitoIdentitySource) GetEventTypes 

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

GetEventTypes implements AWSEventSource.

func (*AWSCognitoIdentitySource) GetGroupVersionKind 

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

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*AWSCognitoIdentitySource) GetSink 

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

GetSink implements AWSEventSource.

func (*AWSCognitoIdentitySource) GetSourceStatus added in v0.3.0 

func (s *AWSCognitoIdentitySource) GetSourceStatus() *AWSEventSourceStatus

GetSourceStatus implements AWSEventSource.

func (*AWSCognitoIdentitySource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*AWSCognitoIdentitySource) GetUntypedSpec 

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

GetUntypedSpec implements apis.HasSpec.

func (*AWSCognitoIdentitySource) SetDefaults 

func (s *AWSCognitoIdentitySource) SetDefaults(_ context.Context)

SetDefaults implements apis.Defaultable.

func (*AWSCognitoIdentitySource) Validate 

func (s *AWSCognitoIdentitySource) Validate(_ context.Context) *apis.FieldError

Validate implements apis.Validatable.

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

AWSCognitoUserPoolSource is the Schema for the event source.

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

func (s *AWSCognitoUserPoolSource) GetARN() apis.ARN

GetARN implements AWSEventSource.

func (*AWSCognitoUserPoolSource) GetConditionSet added in v0.3.0 

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

GetConditionSet implements duckv1.KRShaped.

func (*AWSCognitoUserPoolSource) GetEventTypes 

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

GetEventTypes implements AWSEventSource.

func (*AWSCognitoUserPoolSource) GetGroupVersionKind 

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

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*AWSCognitoUserPoolSource) GetSink 

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

GetSink implements AWSEventSource.

func (*AWSCognitoUserPoolSource) GetSourceStatus added in v0.3.0 

func (s *AWSCognitoUserPoolSource) GetSourceStatus() *AWSEventSourceStatus

GetSourceStatus implements AWSEventSource.

func (*AWSCognitoUserPoolSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*AWSCognitoUserPoolSource) GetUntypedSpec 

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

GetUntypedSpec implements apis.HasSpec.

func (*AWSCognitoUserPoolSource) SetDefaults 

func (s *AWSCognitoUserPoolSource) SetDefaults(_ context.Context)

SetDefaults implements apis.Defaultable.

func (*AWSCognitoUserPoolSource) Validate 

func (s *AWSCognitoUserPoolSource) Validate(_ context.Context) *apis.FieldError

Validate implements apis.Validatable.

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

AWSDynamoDBSource is the Schema for the event source.

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

func (s *AWSDynamoDBSource) GetARN() apis.ARN

GetARN implements AWSEventSource.

func (*AWSDynamoDBSource) GetConditionSet added in v0.3.0 

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

GetConditionSet implements duckv1.KRShaped.

func (*AWSDynamoDBSource) GetEventTypes 

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

GetEventTypes implements AWSEventSource.

func (*AWSDynamoDBSource) GetGroupVersionKind 

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

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*AWSDynamoDBSource) GetSink 

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

GetSink implements AWSEventSource.

func (*AWSDynamoDBSource) GetSourceStatus added in v0.3.0 

func (s *AWSDynamoDBSource) GetSourceStatus() *AWSEventSourceStatus

GetSourceStatus implements AWSEventSource.

func (*AWSDynamoDBSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*AWSDynamoDBSource) GetUntypedSpec 

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

GetUntypedSpec implements apis.HasSpec.

func (*AWSDynamoDBSource) SetDefaults 

func (s *AWSDynamoDBSource) SetDefaults(_ context.Context)

SetDefaults implements apis.Defaultable.

func (*AWSDynamoDBSource) Validate 

func (s *AWSDynamoDBSource) Validate(_ context.Context) *apis.FieldError

Validate implements apis.Validatable.

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 AWSEventSource 

type AWSEventSource interface {
	metav1.Object
	runtime.Object
	// GetSink returns the source's event sink.
	GetSink() *duckv1.Destination
	// GetARN returns the source's AWS ARN.
	GetARN() apis.ARN
	// GetSourceStatus returns the source's status.
	GetSourceStatus() *AWSEventSourceStatus
	// GetEventTypes returns the event types generated by the source.
	GetEventTypes() []string
}

AWSEventSource is implemented by all AWS event source types.

func SourceFromContext 

func SourceFromContext(ctx context.Context) AWSEventSource

SourceFromContext returns the source stored in the context.

type AWSEventSourceStatus 

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

AWSEventSourceStatus defines the observed state of an event source.

func (*AWSEventSourceStatus) DeepCopy 

func (in *AWSEventSourceStatus) DeepCopy() *AWSEventSourceStatus

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

func (*AWSEventSourceStatus) DeepCopyInto 

func (in *AWSEventSourceStatus) DeepCopyInto(out *AWSEventSourceStatus)

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

func (*AWSEventSourceStatus) InitializeConditions 

func (s *AWSEventSourceStatus) InitializeConditions()

InitializeConditions sets relevant unset conditions to Unknown state.

func (*AWSEventSourceStatus) MarkNoSink 

func (s *AWSEventSourceStatus) MarkNoSink()

MarkNoSink sets the SinkProvided condition to False.

func (*AWSEventSourceStatus) MarkSink 

func (s *AWSEventSourceStatus) MarkSink(uri *apis.URL)

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

func (*AWSEventSourceStatus) PropagateAvailability 

func (s *AWSEventSourceStatus) PropagateAvailability(obj interface{})

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

type AWSIoTSource 

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

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

AWSIoTSource is the Schema for the event source.

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

func (s *AWSIoTSource) GetARN() apis.ARN

GetARN implements AWSEventSource.

func (*AWSIoTSource) GetConditionSet added in v0.3.0 

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

GetConditionSet implements duckv1.KRShaped.

func (*AWSIoTSource) GetEventTypes 

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

GetEventTypes implements AWSEventSource.

func (*AWSIoTSource) GetGroupVersionKind 

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

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*AWSIoTSource) GetSink 

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

GetSink implements AWSEventSource.

func (*AWSIoTSource) GetSourceStatus added in v0.3.0 

func (s *AWSIoTSource) GetSourceStatus() *AWSEventSourceStatus

GetSourceStatus implements AWSEventSource.

func (*AWSIoTSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*AWSIoTSource) GetUntypedSpec 

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

GetUntypedSpec implements apis.HasSpec.

func (*AWSIoTSource) SetDefaults 

func (s *AWSIoTSource) SetDefaults(_ context.Context)

SetDefaults implements apis.Defaultable.

func (*AWSIoTSource) Validate 

func (s *AWSIoTSource) Validate(_ context.Context) *apis.FieldError

Validate implements apis.Validatable.

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

AWSKinesisSource is the Schema for the event source.

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

func (s *AWSKinesisSource) GetARN() apis.ARN

GetARN implements AWSEventSource.

func (*AWSKinesisSource) GetConditionSet added in v0.3.0 

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

GetConditionSet implements duckv1.KRShaped.

func (*AWSKinesisSource) GetEventTypes 

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

GetEventTypes implements AWSEventSource.

func (*AWSKinesisSource) GetGroupVersionKind 

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

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*AWSKinesisSource) GetSink 

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

GetSink implements AWSEventSource.

func (*AWSKinesisSource) GetSourceStatus added in v0.3.0 

func (s *AWSKinesisSource) GetSourceStatus() *AWSEventSourceStatus

GetSourceStatus implements AWSEventSource.

func (*AWSKinesisSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*AWSKinesisSource) GetUntypedSpec 

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

GetUntypedSpec implements apis.HasSpec.

func (*AWSKinesisSource) SetDefaults 

func (s *AWSKinesisSource) SetDefaults(_ context.Context)

SetDefaults implements apis.Defaultable.

func (*AWSKinesisSource) Validate 

func (s *AWSKinesisSource) Validate(_ context.Context) *apis.FieldError

Validate implements apis.Validatable.

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

AWSSNSSource is the Schema for the event source.

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

func (s *AWSSNSSource) GetARN() apis.ARN

GetARN implements AWSEventSource.

func (*AWSSNSSource) GetConditionSet added in v0.3.0 

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

GetConditionSet implements duckv1.KRShaped.

func (*AWSSNSSource) GetEventTypes 

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

GetEventTypes implements AWSEventSource.

func (*AWSSNSSource) GetGroupVersionKind 

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

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*AWSSNSSource) GetSink 

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

GetSink implements AWSEventSource.

func (*AWSSNSSource) GetSourceStatus added in v0.3.0 

func (s *AWSSNSSource) GetSourceStatus() *AWSEventSourceStatus

GetSourceStatus implements AWSEventSource.

func (*AWSSNSSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*AWSSNSSource) GetUntypedSpec 

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

GetUntypedSpec implements apis.HasSpec.

func (*AWSSNSSource) SetDefaults 

func (s *AWSSNSSource) SetDefaults(_ context.Context)

SetDefaults implements apis.Defaultable.

func (*AWSSNSSource) Validate 

func (s *AWSSNSSource) Validate(_ context.Context) *apis.FieldError

Validate implements apis.Validatable.

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 AWSSQSSource 

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

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

AWSSQSSource is the Schema for the event source.

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

func (s *AWSSQSSource) GetARN() apis.ARN

GetARN implements AWSEventSource.

func (*AWSSQSSource) GetConditionSet added in v0.3.0 

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

GetConditionSet implements duckv1.KRShaped.

func (*AWSSQSSource) GetEventTypes 

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

GetEventTypes implements AWSEventSource.

func (*AWSSQSSource) GetGroupVersionKind 

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

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*AWSSQSSource) GetSink 

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

GetSink implements AWSEventSource.

func (*AWSSQSSource) GetSourceStatus added in v0.3.0 

func (s *AWSSQSSource) GetSourceStatus() *AWSEventSourceStatus

GetSourceStatus implements AWSEventSource.

func (*AWSSQSSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*AWSSQSSource) GetUntypedSpec 

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

GetUntypedSpec implements apis.HasSpec.

func (*AWSSQSSource) SetDefaults 

func (s *AWSSQSSource) SetDefaults(_ context.Context)

SetDefaults implements apis.Defaultable.

func (*AWSSQSSource) Validate 

func (s *AWSSQSSource) Validate(_ context.Context) *apis.FieldError

Validate implements apis.Validatable.

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