v1alpha1

package
v0.44.2 Latest Latest
Warning

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

 Go to latest Published: Feb 3, 2025 License: Apache-2.0 Imports: 12 Imported by: 129

Documentation

Overview

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

Index

Constants

View Source 
const (
	// IntegrationSourceConditionReady has status True when the IntegrationSource is ready to send events.
	IntegrationSourceConditionReady = apis.ConditionReady

	// IntegrationSourceConditionContainerSourceReady has status True when the IntegrationSource's ContainerSource is ready.
	IntegrationSourceConditionContainerSourceReady apis.ConditionType = "ContainerSourceReady"
)

Variables

View Source 
var (
	SchemeBuilder = runtime.NewSchemeBuilder(addKnownTypes)
	AddToScheme   = SchemeBuilder.AddToScheme
)
View Source 
var IntegrationCondSet = apis.NewLivingConditionSet(
	IntegrationSourceConditionContainerSourceReady,
)
View Source 
var SchemeGroupVersion = schema.GroupVersion{Group: sources.GroupName, Version: "v1alpha1"}

SchemeGroupVersion is group version used to register these objects

Functions

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

Types

type Aws added in v0.44.0 

type Aws struct {
	S3         *v1alpha1.AWSS3         `json:"s3,omitempty"`         // S3 source configuration
	SQS        *v1alpha1.AWSSQS        `json:"sqs,omitempty"`        // SQS source configuration
	DDBStreams *v1alpha1.AWSDDBStreams `json:"ddbStreams,omitempty"` // DynamoDB Streams source configuration
	Auth       *v1alpha1.Auth          `json:"auth,omitempty"`
}

func (*Aws) DeepCopy added in v0.44.0 

func (in *Aws) DeepCopy() *Aws

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

func (*Aws) DeepCopyInto added in v0.44.0 

func (in *Aws) DeepCopyInto(out *Aws)

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

type IntegrationSource added in v0.44.0 

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

	Spec   IntegrationSourceSpec   `json:"spec,omitempty"`
	Status IntegrationSourceStatus `json:"status,omitempty"`
}

IntegrationSource is the Schema for the Integrationsources API

func (*IntegrationSource) ConvertFrom added in v0.44.0 

func (source *IntegrationSource) ConvertFrom(ctx context.Context, obj apis.Convertible) error

ConvertFrom implements apis.Convertible Converts source from a higher version into v1beta2.IntegrationSource

func (*IntegrationSource) ConvertTo added in v0.44.0 

func (source *IntegrationSource) ConvertTo(ctx context.Context, obj apis.Convertible) error

ConvertTo implements apis.Convertible Converts source from v1alpha1.IntegrationSource into a higher version.

func (*IntegrationSource) DeepCopy added in v0.44.0 

func (in *IntegrationSource) DeepCopy() *IntegrationSource

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

func (*IntegrationSource) DeepCopyInto added in v0.44.0 

func (in *IntegrationSource) DeepCopyInto(out *IntegrationSource)

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

func (*IntegrationSource) DeepCopyObject added in v0.44.0 

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

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

func (*IntegrationSource) GetConditionSet added in v0.44.0 

func (*IntegrationSource) GetConditionSet() apis.ConditionSet

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

func (*IntegrationSource) GetGroupVersionKind added in v0.44.0 

func (*IntegrationSource) GetGroupVersionKind() schema.GroupVersionKind

GetGroupVersionKind returns the GroupVersionKind.

func (*IntegrationSource) GetStatus added in v0.44.0 

func (c *IntegrationSource) GetStatus() *duckv1.Status

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

func (*IntegrationSource) GetUntypedSpec added in v0.44.0 

func (c *IntegrationSource) GetUntypedSpec() interface{}

GetUntypedSpec returns the spec of the IntegrationSource.

func (*IntegrationSource) SetDefaults added in v0.44.0 

func (source *IntegrationSource) SetDefaults(ctx context.Context)

func (*IntegrationSource) Validate added in v0.44.0 

func (source *IntegrationSource) Validate(ctx context.Context) *apis.FieldError

type IntegrationSourceList added in v0.44.0 

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

IntegrationSourceList contains a list of IntegrationSource

func (*IntegrationSourceList) DeepCopy added in v0.44.0 

func (in *IntegrationSourceList) DeepCopy() *IntegrationSourceList

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

func (*IntegrationSourceList) DeepCopyInto added in v0.44.0 

func (in *IntegrationSourceList) DeepCopyInto(out *IntegrationSourceList)

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

func (*IntegrationSourceList) DeepCopyObject added in v0.44.0 

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

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

type IntegrationSourceSpec added in v0.44.0 

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

	Aws   *Aws   `json:"aws,omitempty"`   // AWS source configuration
	Timer *Timer `json:"timer,omitempty"` // Timer configuration
}

IntegrationSourceSpec defines the desired state of IntegrationSource

func (*IntegrationSourceSpec) DeepCopy added in v0.44.0 

func (in *IntegrationSourceSpec) DeepCopy() *IntegrationSourceSpec

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

func (*IntegrationSourceSpec) DeepCopyInto added in v0.44.0 

func (in *IntegrationSourceSpec) DeepCopyInto(out *IntegrationSourceSpec)

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

func (*IntegrationSourceSpec) SetDefaults added in v0.44.0 

func (source *IntegrationSourceSpec) SetDefaults(ctx context.Context)

func (*IntegrationSourceSpec) Validate added in v0.44.0 

func (spec *IntegrationSourceSpec) Validate(ctx context.Context) *apis.FieldError

type IntegrationSourceStatus added in v0.44.0 

type IntegrationSourceStatus struct {
	// inherits duck/v1 SourceStatus, which currently provides:
	// * ObservedGeneration - the 'Generation' of the Service that was last
	//   processed by the controller.
	// * Conditions - the latest available observations of a resource's current
	//   state.
	// * SinkURI - the current active sink URI that has been configured for the
	//   Source.
	duckv1.SourceStatus `json:",inline"`
}

IntegrationSourceStatus defines the observed state of IntegrationSource

func (*IntegrationSourceStatus) DeepCopy added in v0.44.0 

func (in *IntegrationSourceStatus) DeepCopy() *IntegrationSourceStatus

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

func (*IntegrationSourceStatus) DeepCopyInto added in v0.44.0 

func (in *IntegrationSourceStatus) DeepCopyInto(out *IntegrationSourceStatus)

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

func (*IntegrationSourceStatus) GetTopLevelCondition added in v0.44.0 

func (s *IntegrationSourceStatus) GetTopLevelCondition() *apis.Condition

GetTopLevelCondition returns the top level condition.

func (*IntegrationSourceStatus) InitializeConditions added in v0.44.0 

func (s *IntegrationSourceStatus) InitializeConditions()

InitializeConditions sets relevant unset conditions to Unknown state.

func (*IntegrationSourceStatus) IsReady added in v0.44.0 

func (iss *IntegrationSourceStatus) IsReady() bool

func (*IntegrationSourceStatus) PropagateContainerSourceStatus added in v0.44.0 

func (s *IntegrationSourceStatus) PropagateContainerSourceStatus(status *v1.ContainerSourceStatus)

type Timer added in v0.44.0 

type Timer struct {
	Period      int    `json:"period" default:"1000"`            // Interval (in milliseconds) between producing messages
	Message     string `json:"message"`                          // Message to generate
	ContentType string `json:"contentType" default:"text/plain"` // Content type of generated message
	RepeatCount int    `json:"repeatCount,omitempty"`            // Max number of fires (optional)
}

func (*Timer) DeepCopy added in v0.44.0 

func (in *Timer) DeepCopy() *Timer

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

func (*Timer) DeepCopyInto added in v0.44.0 

func (in *Timer) DeepCopyInto(out *Timer)

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.