v1alpha1

package
v0.31.0 Latest Latest
Warning

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

 Go to latest Published: Apr 19, 2022 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Overview

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

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 (
	RabbitmqConditionReady = apis.ConditionReady

	RabbitmqConditionSinkProvided apis.ConditionType = "SinkProvided"

	RabbitmqConditionDeployed apis.ConditionType = "Deployed"

	RabbitmqConditionResources apis.ConditionType = "ResourcesReady"
)
View Source 
const (
	RabbitmqEventType = "dev.knative.rabbitmq.event"
)

Variables

View Source 
var (
	// SchemeBuilder is used to add go types to the GroupVersionKind scheme
	SchemeBuilder = runtime.NewSchemeBuilder(addKnownTypes)

	AddToScheme = SchemeBuilder.AddToScheme
)
View Source 
var RabbitmqSourceCondSet = apis.NewLivingConditionSet(
	RabbitmqConditionSinkProvided,
	RabbitmqConditionDeployed)
View Source 
var SchemeGroupVersion = schema.GroupVersion{Group: sources.GroupName, Version: "v1alpha1"}

SchemeGroupVersion is group version used to register these objects

Functions

func DeploymentIsAvailable 

func DeploymentIsAvailable(d *appsv1.DeploymentStatus, def bool) bool

func Kind 

func Kind(kind string) schema.GroupKind

func RabbitmqEventSource 

func RabbitmqEventSource(namespace, rabbitmqSourceName, qName string) string

RabbitmqEventSource returns cloud event attribute 'source' for messages published by a rabbitmqsource format is '/apis/v1/namespace/NAMESPACE/rabbitmqsources/NAME#QUEUE_NAME'

func Resource 

func Resource(resource string) schema.GroupResource

Resource takes an unqualified resource and returns a Group qualified GroupResource

Types

type RabbitmqChannelConfigSpec 

type RabbitmqChannelConfigSpec struct {
	// Sets the Channel's Prefetch count and number of Workers to consume simultaneously from it
	// +optional
	// +kubebuilder:validation:Minimum:=1
	// +kubebuilder:validation:Maximum:=1000
	// +kubebuilder:default:=1
	Parallelism *int `json:"parallelism,omitempty"`
	// Channel Qos global property
	// +optional
	GlobalQos bool `json:"globalQos,omitempty"`
}

func (*RabbitmqChannelConfigSpec) DeepCopy 

func (in *RabbitmqChannelConfigSpec) DeepCopy() *RabbitmqChannelConfigSpec

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

func (*RabbitmqChannelConfigSpec) DeepCopyInto 

func (in *RabbitmqChannelConfigSpec) DeepCopyInto(out *RabbitmqChannelConfigSpec)

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

type RabbitmqSource 

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

	Spec   RabbitmqSourceSpec   `json:"spec,omitempty"`
	Status RabbitmqSourceStatus `json:"status,omitempty"`
}

RabbitmqSource is the Schema for the rabbitmqsources API. +k8s:openapi-gen=true

func (*RabbitmqSource) DeepCopy 

func (in *RabbitmqSource) DeepCopy() *RabbitmqSource

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

func (*RabbitmqSource) DeepCopyInto 

func (in *RabbitmqSource) DeepCopyInto(out *RabbitmqSource)

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

func (*RabbitmqSource) DeepCopyObject 

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

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

func (*RabbitmqSource) GetConditionSet 

func (in *RabbitmqSource) GetConditionSet() apis.ConditionSet

func (*RabbitmqSource) GetGroupVersionKind 

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

func (*RabbitmqSource) GetStatus 

func (in *RabbitmqSource) GetStatus() *duckv1.Status

func (*RabbitmqSource) SetDefaults 

func (r *RabbitmqSource) SetDefaults(ctx context.Context)

func (*RabbitmqSource) Validate 

func (current *RabbitmqSource) Validate(ctx context.Context) *apis.FieldError

type RabbitmqSourceExchangeConfigSpec 

type RabbitmqSourceExchangeConfigSpec struct {
	// Name of the exchange; Required when predeclared is false.
	// +optional
	Name string `json:"name,omitempty"`
	// Type of exchange e.g. direct, topic, headers, fanout
	// +required
	Type string `json:"type,omitempty"`
	// Exchange is Durable or not
	// +optional
	Durable bool `json:"durable,omitempty"`
	// Exchange can be AutoDelete or not
	// +optional
	AutoDelete bool `json:"autoDelete,omitempty"`
}

func (*RabbitmqSourceExchangeConfigSpec) DeepCopy 

func (in *RabbitmqSourceExchangeConfigSpec) DeepCopy() *RabbitmqSourceExchangeConfigSpec

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

func (*RabbitmqSourceExchangeConfigSpec) DeepCopyInto 

func (in *RabbitmqSourceExchangeConfigSpec) DeepCopyInto(out *RabbitmqSourceExchangeConfigSpec)

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

type RabbitmqSourceList 

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

RabbitmqSourceList contains a list of RabbitmqSources.

func (*RabbitmqSourceList) DeepCopy 

func (in *RabbitmqSourceList) DeepCopy() *RabbitmqSourceList

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

func (*RabbitmqSourceList) DeepCopyInto 

func (in *RabbitmqSourceList) DeepCopyInto(out *RabbitmqSourceList)

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

func (*RabbitmqSourceList) DeepCopyObject 

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

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

type RabbitmqSourceQueueConfigSpec 

type RabbitmqSourceQueueConfigSpec struct {
	// Name of the queue to bind to; required value.
	// +required
	Name string `json:"name"`
	// Routing key of the messages to be received.
	// Multiple routing keys can be specified separated by commas. e.g. key1,key2
	// +optional
	RoutingKey string `json:"routingKey,omitempty"`
	// Queue is Durable or not
	// +optional
	Durable bool `json:"durable,omitempty"`
	// +optional
	AutoDelete bool `json:"autoDelete,omitempty"`
}

func (*RabbitmqSourceQueueConfigSpec) DeepCopy 

func (in *RabbitmqSourceQueueConfigSpec) DeepCopy() *RabbitmqSourceQueueConfigSpec

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

func (*RabbitmqSourceQueueConfigSpec) DeepCopyInto 

func (in *RabbitmqSourceQueueConfigSpec) DeepCopyInto(out *RabbitmqSourceQueueConfigSpec)

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

type RabbitmqSourceSpec 

type RabbitmqSourceSpec struct {
	// Broker are the Rabbitmq servers the consumer will connect to.
	// +required
	Broker string `json:"broker"`
	// User for rabbitmq connection
	// +optional
	User SecretValueFromSource `json:"user,omitempty"`
	// Password for rabbitmq connection
	// +optional
	Password SecretValueFromSource `json:"password,omitempty"`
	// Predeclared defines if channels and queues are already predeclared and shouldn't be recreated.
	// This should be used in case the user does not have permission to declare new queues and channels in
	// RabbitMQ cluster
	// +optional
	Predeclared bool `json:"predeclared,omitempty"`
	// Retry is the minimum number of retries the sender should attempt when
	// sending an event before moving it to the dead letter sink.
	// +optional
	Retry *int32 `json:"retry,omitempty"`
	// BackoffPolicy is the retry backoff policy (linear, exponential).
	// +optional
	BackoffPolicy *eventingduckv1.BackoffPolicyType `json:"backoffPolicy,omitempty"`
	// BackoffDelay is the delay before retrying in time.Duration format.
	// For linear policy, backoff delay is backoffDelay*<numberOfRetries>.
	// For exponential policy, backoff delay is backoffDelay*2^<numberOfRetries>.
	// +optional
	BackoffDelay *string `json:"backoffDelay,omitempty"`
	// Secret contains the http management uri for the RabbitMQ cluster.
	// Used when queue and exchange are not predeclared.
	// The Secret must contain the key `uri`, `username` and `password`.
	// +optional
	ConnectionSecret *corev1.LocalObjectReference `json:"connectionSecret,omitempty"`
	// ChannelConfig config for rabbitmq exchange
	// +optional
	ChannelConfig RabbitmqChannelConfigSpec `json:"channelConfig,omitempty"`
	// ExchangeConfig config for rabbitmq exchange
	// +optional
	ExchangeConfig RabbitmqSourceExchangeConfigSpec `json:"exchangeConfig,omitempty"`
	// QueueConfig config for rabbitmq queues
	// +required
	QueueConfig RabbitmqSourceQueueConfigSpec `json:"queueConfig,omitempty"`
	// Sink is a reference to an object that will resolve to a domain name to use as the sink.
	// Required property.
	// +required
	Sink *duckv1.Destination `json:"sink"`
	// ServiceAccountName is the name of the ServiceAccount that will be used to run the Receive
	// Adapter Deployment.
	ServiceAccountName string `json:"serviceAccountName,omitempty"`
	// VHost is the name of the VHost that will be used to set up our sources
	// +optional
	Vhost string `json:"vhost,omitempty"`
}

func (*RabbitmqSourceSpec) DeepCopy 

func (in *RabbitmqSourceSpec) DeepCopy() *RabbitmqSourceSpec

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

func (*RabbitmqSourceSpec) DeepCopyInto 

func (in *RabbitmqSourceSpec) DeepCopyInto(out *RabbitmqSourceSpec)

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

type RabbitmqSourceStatus 

type RabbitmqSourceStatus struct {
	// inherits duck/v1 Status, 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.
	duckv1.SourceStatus `json:",inline"`
}

func (*RabbitmqSourceStatus) DeepCopy 

func (in *RabbitmqSourceStatus) DeepCopy() *RabbitmqSourceStatus

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

func (*RabbitmqSourceStatus) DeepCopyInto 

func (in *RabbitmqSourceStatus) DeepCopyInto(out *RabbitmqSourceStatus)

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

func (*RabbitmqSourceStatus) GetCondition 

func (s *RabbitmqSourceStatus) GetCondition(t apis.ConditionType) *apis.Condition

func (*RabbitmqSourceStatus) GetTopLevelCondition 

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

func (*RabbitmqSourceStatus) InitializeConditions 

func (s *RabbitmqSourceStatus) InitializeConditions()

func (*RabbitmqSourceStatus) IsReady 

func (s *RabbitmqSourceStatus) IsReady() bool

func (*RabbitmqSourceStatus) MarkDeployed 

func (s *RabbitmqSourceStatus) MarkDeployed(d *appsv1.Deployment)

func (*RabbitmqSourceStatus) MarkDeploying 

func (s *RabbitmqSourceStatus) MarkDeploying(reason, messageFormat string, messageA ...interface{})

func (*RabbitmqSourceStatus) MarkNoSink 

func (s *RabbitmqSourceStatus) MarkNoSink(reason, messageFormat string, messageA ...interface{})

func (*RabbitmqSourceStatus) MarkNotDeployed 

func (s *RabbitmqSourceStatus) MarkNotDeployed(reason, messageFormat string, messageA ...interface{})

func (*RabbitmqSourceStatus) MarkResourcesCorrect 

func (s *RabbitmqSourceStatus) MarkResourcesCorrect()

func (*RabbitmqSourceStatus) MarkResourcesIncorrect 

func (s *RabbitmqSourceStatus) MarkResourcesIncorrect(reason, messageFormat string, messageA ...interface{})

func (*RabbitmqSourceStatus) MarkSink 

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

type SecretValueFromSource 

type SecretValueFromSource struct {
	// The Secret key to select from.
	SecretKeyRef *corev1.SecretKeySelector `json:"secretKeyRef,omitempty"`
}

SecretValueFromSource represents the source of a secret value

func (*SecretValueFromSource) DeepCopy 

func (in *SecretValueFromSource) DeepCopy() *SecretValueFromSource

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

func (*SecretValueFromSource) DeepCopyInto 

func (in *SecretValueFromSource) DeepCopyInto(out *SecretValueFromSource)

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.