v1alpha1

package
v0.0.0-...-932eec2 Latest Latest
Warning

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

 Go to latest Published: Jul 18, 2023 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Overview

+k8s:deepcopy-gen=package +groupName=events.openfunction.io

Package v1alpha1 contains API Schema definitions for the event v1alpha1 API group +kubebuilder:object:generate=true +groupName=events.openfunction.io

Index

Constants

This section is empty.

Variables

View Source 
var (
	// GroupVersion is group version used to register these objects
	GroupVersion = schema.GroupVersion{Group: "events.openfunction.io", Version: "v1alpha1"}

	// SchemeGroupVersion is group version used to register these objects
	// added for generated clientset
	SchemeGroupVersion = GroupVersion

	// SchemeBuilder is used to add go types to the GroupVersionKind scheme
	SchemeBuilder = &scheme.Builder{GroupVersion: GroupVersion}

	// AddToScheme adds the types in this group-version to the given scheme.
	AddToScheme = SchemeBuilder.AddToScheme
)

Functions

This section is empty.

Types

type ClusterEventBus 

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

	Spec EventBusSpec `json:"spec,omitempty"`
}

ClusterEventBus is the Schema for the clustereventbus API

func (*ClusterEventBus) DeepCopy 

func (in *ClusterEventBus) DeepCopy() *ClusterEventBus

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

func (*ClusterEventBus) DeepCopyInto 

func (in *ClusterEventBus) DeepCopyInto(out *ClusterEventBus)

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

func (*ClusterEventBus) DeepCopyObject 

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

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

type ClusterEventBusList 

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

ClusterEventBusList contains a list of ClusterEventBus

func (*ClusterEventBusList) DeepCopy 

func (in *ClusterEventBusList) DeepCopy() *ClusterEventBusList

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

func (*ClusterEventBusList) DeepCopyInto 

func (in *ClusterEventBusList) DeepCopyInto(out *ClusterEventBusList)

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

func (*ClusterEventBusList) DeepCopyObject 

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

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

type Condition 

type Condition struct {
	// Timestamp of the condition
	// +optional
	Timestamp string `json:"timestamp" description:"Timestamp of this condition"`
	// Type of condition
	// +required
	Type CreationStatus `json:"type" description:"type of status condition"`
	// Status of the condition, one of True, False, Unknown.
	// +required
	Status metav1.ConditionStatus `json:"status" description:"status of the condition, one of True, False, Unknown"`
	// The reason for the condition's last transition.
	// +optional
	Reason ConditionReason `json:"reason,omitempty" description:"one-word CamelCase reason for the condition's last transition"`
	// A human readable message indicating details about the transition.
	// +optional
	Message string `json:"message,omitempty" description:"human-readable message indicating details about last transition"`
}

func CreateCondition 

func CreateCondition(
	condType CreationStatus,
	status metav1.ConditionStatus,
	reason ConditionReason,
) *Condition

func (*Condition) DeepCopy 

func (in *Condition) DeepCopy() *Condition

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

func (*Condition) DeepCopyInto 

func (in *Condition) DeepCopyInto(out *Condition)

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

func (*Condition) SetMessage 

func (c *Condition) SetMessage(message string) *Condition

SetMessage sets the optional reason for the condition

type ConditionReason 

type ConditionReason string

ConditionReason describes the reason why the condition transitioned +kubebuilder:validation:Enum=EventSourceFunctionCreated;ErrorCreatingEventSource;ErrorCreatingEventSourceFunction;EventSourceIsReady;ErrorConfiguration;ErrorToFindExistEventBus;ErrorGenerateComponent;ErrorGenerateScaledObject;PendingCreation;ErrorToFindTriggerSubscribers;ErrorCreatingTrigger;TriggerIsReady;ErrorCreatingTriggerFunction;TriggerFunctionCreated 

const (
	ErrorConfiguration               ConditionReason = "ErrorConfiguration"
	ErrorToFindTriggerSubscribers    ConditionReason = "ErrorToFindTriggerSubscribers"
	ErrorToFindExistEventBus         ConditionReason = "ErrorToFindExistEventBus"
	ErrorGenerateComponent           ConditionReason = "ErrorGenerateComponent"
	ErrorGenerateScaledObject        ConditionReason = "ErrorGenerateScaledObject"
	ErrorCreatingEventSourceFunction ConditionReason = "ErrorCreatingEventSourceFunction"
	ErrorCreatingTriggerFunction     ConditionReason = "ErrorCreatingTriggerFunction"
	ErrorCreatingEventSource         ConditionReason = "ErrorCreatingEventSource"
	ErrorCreatingTrigger             ConditionReason = "ErrorCreatingTrigger"
	EventSourceFunctionCreated       ConditionReason = "EventSourceFunctionCreated"
	TriggerFunctionCreated           ConditionReason = "TriggerFunctionCreated"
	PendingCreation                  ConditionReason = "PendingCreation"
	EventSourceIsReady               ConditionReason = "EventSourceIsReady"
	TriggerIsReady                   ConditionReason = "TriggerIsReady"
)

type CreationStatus 

type CreationStatus string

CreationStatus describes the creation status of the scaler's additional resources such as Services, Ingresses and Deployments +kubebuilder:validation:Enum=Created;Error;Pending;Unknown;Terminating;Terminated;Ready 

const (
	// Created indicates the resource has been created
	Created CreationStatus = "Created"
	// Terminated indicates the resource has been terminated
	Terminated CreationStatus = "Terminated"
	// Error indicates the resource had an error
	Error CreationStatus = "Error"
	// Pending indicates the resource hasn't been created
	Pending CreationStatus = "Pending"
	// Terminating indicates that the resource is marked for deletion but hasn't
	// been deleted yet
	Terminating CreationStatus = "Terminating"
	// Unknown indicates the status is unavailable
	Unknown CreationStatus = "Unknown"
	// Ready indicates the object is fully created
	Ready CreationStatus = "Ready"
)

type CronSpec 

type CronSpec struct {
	Schedule string `json:"schedule"`
}

func (*CronSpec) DeepCopy 

func (in *CronSpec) DeepCopy() *CronSpec

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

func (*CronSpec) DeepCopyInto 

func (in *CronSpec) DeepCopyInto(out *CronSpec)

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

type EventBus 

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

	Spec EventBusSpec `json:"spec,omitempty"`
}

EventBus is the Schema for the eventbus API

func (*EventBus) DeepCopy 

func (in *EventBus) DeepCopy() *EventBus

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

func (*EventBus) DeepCopyInto 

func (in *EventBus) DeepCopyInto(out *EventBus)

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

func (*EventBus) DeepCopyObject 

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

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

type EventBusList 

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

EventBusList contains a list of EventBus

func (*EventBusList) DeepCopy 

func (in *EventBusList) DeepCopy() *EventBusList

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

func (*EventBusList) DeepCopyInto 

func (in *EventBusList) DeepCopyInto(out *EventBusList)

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

func (*EventBusList) DeepCopyObject 

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

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

type EventBusSpec 

type EventBusSpec struct {

	// Topic indicates the name of the message channel of eventbus
	// If not specified, "default" will be used as the name of the message channel
	// +optional
	Topic string `json:"topic,omitempty"`
	// Use Nats streaming as the default backend for event bus
	NatsStreaming *NatsStreamingSpec `json:"natsStreaming,omitempty"`
}

EventBusSpec defines the desired state of EventBus and ClusterEventBus

func (*EventBusSpec) DeepCopy 

func (in *EventBusSpec) DeepCopy() *EventBusSpec

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

func (*EventBusSpec) DeepCopyInto 

func (in *EventBusSpec) DeepCopyInto(out *EventBusSpec)

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

type EventSource 

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

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

EventSource is the Schema for the eventsources API

func (*EventSource) AddCondition 

func (es *EventSource) AddCondition(condition Condition) *EventSource

AddCondition adds a new condition to the resource

func (*EventSource) DeepCopy 

func (in *EventSource) DeepCopy() *EventSource

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

func (*EventSource) DeepCopyInto 

func (in *EventSource) DeepCopyInto(out *EventSource)

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

func (*EventSource) DeepCopyObject 

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

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

func (*EventSource) SaveStatus 

func (es *EventSource) SaveStatus(ctx context.Context, logger logr.Logger, cl client.Client)

SaveStatus will trigger an object update to save the current status conditions

type EventSourceList 

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

EventSourceList contains a list of EventSource

func (*EventSourceList) DeepCopy 

func (in *EventSourceList) DeepCopy() *EventSourceList

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

func (*EventSourceList) DeepCopyInto 

func (in *EventSourceList) DeepCopyInto(out *EventSourceList)

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

func (*EventSourceList) DeepCopyObject 

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

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

type EventSourceSpec 

type EventSourceSpec struct {

	// EventBus allows you to specify a specific EventBus to be used instead of the "default" one
	// +optional
	EventBus string `json:"eventBus,omitempty"`
	// Redis event source, the Key is used to refer to the name of the event
	// +optional
	Redis map[string]*RedisSpec `json:"redis,omitempty"`
	// Kafka event source, the Key is used to refer to the name of the event
	// +optional
	Kafka map[string]*KafkaSpec `json:"kafka,omitempty"`
	// Cron event source, the Key is used to refer to the name of the event
	// +optional
	Cron map[string]*CronSpec `json:"cron,omitempty"`
	// Mqtt event source, the Key is used to refer to the name of the event
	// +optional
	Mqtt map[string]*MQTTSpec `json:"mqtt,omitempty"`
	// Sink is a callable address, such as Knative Service
	// +optional
	Sink *SinkSpec `json:"sink,omitempty"`
	// Information needed to build a function. The build step will be skipped if Build is nil.
	Build *openfunction.BuildImpl `json:"build,omitempty"`
	// The logging level of the event source handler, e.g. "1", "2", "3".
	// The level increases as the value increases, default is "1".
	// +optional
	LogLevel *string `json:"logLevel,omitempty"`
}

EventSourceSpec defines the desired state of EventSource

func (*EventSourceSpec) DeepCopy 

func (in *EventSourceSpec) DeepCopy() *EventSourceSpec

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

func (*EventSourceSpec) DeepCopyInto 

func (in *EventSourceSpec) DeepCopyInto(out *EventSourceSpec)

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

type EventSourceStatus 

type EventSourceStatus struct {
	// INSERT ADDITIONAL STATUS FIELD - define observed state of cluster
	// Important: Run "make" to regenerate code after modifying this file
	Conditions []Condition `json:"conditions,omitempty" description:"List of auditable conditions of EventSource"`
}

EventSourceStatus defines the observed state of EventSource

func (*EventSourceStatus) DeepCopy 

func (in *EventSourceStatus) DeepCopy() *EventSourceStatus

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

func (*EventSourceStatus) DeepCopyInto 

func (in *EventSourceStatus) DeepCopyInto(out *EventSourceStatus)

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

type GenericScaleOption 

type GenericScaleOption struct {
	PollingInterval *int32                            `json:"pollingInterval,omitempty"`
	CooldownPeriod  *int32                            `json:"cooldownPeriod,omitempty"`
	MinReplicaCount *int32                            `json:"minReplicaCount,omitempty"`
	MaxReplicaCount *int32                            `json:"maxReplicaCount,omitempty"`
	Advanced        *kedav1alpha1.AdvancedConfig      `json:"advanced,omitempty"`
	Metadata        map[string]string                 `json:"metadata,omitempty"`
	AuthRef         *kedav1alpha1.ScaledObjectAuthRef `json:"authRef,omitempty"`
}

func (*GenericScaleOption) DeepCopy 

func (in *GenericScaleOption) DeepCopy() *GenericScaleOption

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

func (*GenericScaleOption) DeepCopyInto 

func (in *GenericScaleOption) DeepCopyInto(out *GenericScaleOption)

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

type Input 

type Input struct {
	// Namespace, namespace of EventSource, default to namespace of Trigger
	Namespace string `json:"namespace,omitempty"`
	// EventSource, name of EventSource
	EventSource string `json:"eventSource"`
	// Event, name of event
	Event string `json:"event"`
}

func (*Input) DeepCopy 

func (in *Input) DeepCopy() *Input

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

func (*Input) DeepCopyInto 

func (in *Input) DeepCopyInto(out *Input)

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

type KafkaScaleOption 

type KafkaScaleOption struct {
	*GenericScaleOption `json:",inline"`
	ConsumerGroup       string `json:"consumerGroup,omitempty"`
	Topic               string `json:"topic,omitempty"`
	LagThreshold        string `json:"lagThreshold"`
}

func (*KafkaScaleOption) DeepCopy 

func (in *KafkaScaleOption) DeepCopy() *KafkaScaleOption

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

func (*KafkaScaleOption) DeepCopyInto 

func (in *KafkaScaleOption) DeepCopyInto(out *KafkaScaleOption)

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

type KafkaSpec 

type KafkaSpec struct {
	Brokers         string            `json:"brokers"`
	AuthRequired    bool              `json:"authRequired"`
	Topic           string            `json:"topic,omitempty"`
	SaslUsername    *string           `json:"saslUsername,omitempty"`
	SaslPassword    *string           `json:"saslPassword,omitempty"`
	MaxMessageBytes *int64            `json:"maxMessageBytes,omitempty"`
	ScaleOption     *KafkaScaleOption `json:"scaleOption,omitempty"`
}

func (*KafkaSpec) DeepCopy 

func (in *KafkaSpec) DeepCopy() *KafkaSpec

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

func (*KafkaSpec) DeepCopyInto 

func (in *KafkaSpec) DeepCopyInto(out *KafkaSpec)

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

type MQTTSpec 

type MQTTSpec struct {
	Url          string  `json:"url"`
	Topic        string  `json:"topic"`
	ConsumerID   *string `json:"consumerID,omitempty"`
	Qos          *int64  `json:"qos,omitempty"`
	Retain       *bool   `json:"retain,omitempty"`
	CleanSession *bool   `json:"cleanSession,omitempty"`
	CaCert       *string `json:"caCert,omitempty"`
	ClientCert   *string `json:"clientCert,omitempty"`
	ClientKey    *string `json:"clientKey,omitempty"`
}

func (*MQTTSpec) DeepCopy 

func (in *MQTTSpec) DeepCopy() *MQTTSpec

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

func (*MQTTSpec) DeepCopyInto 

func (in *MQTTSpec) DeepCopyInto(out *MQTTSpec)

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

type NatsStreamingScaleOption 

type NatsStreamingScaleOption struct {
	*GenericScaleOption          `json:",inline"`
	NatsServerMonitoringEndpoint string `json:"natsServerMonitoringEndpoint"`
	QueueGroup                   string `json:"queueGroup,omitempty"`
	DurableName                  string `json:"durableName,omitempty"`
	Subject                      string `json:"subject,omitempty"`
	LagThreshold                 string `json:"lagThreshold"`
}

func (*NatsStreamingScaleOption) DeepCopy 

func (in *NatsStreamingScaleOption) DeepCopy() *NatsStreamingScaleOption

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

func (*NatsStreamingScaleOption) DeepCopyInto 

func (in *NatsStreamingScaleOption) DeepCopyInto(out *NatsStreamingScaleOption)

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

type NatsStreamingSpec 

type NatsStreamingSpec struct {
	NatsURL                 string                    `json:"natsURL"`
	NatsStreamingClusterID  string                    `json:"natsStreamingClusterID"`
	SubscriptionType        string                    `json:"subscriptionType"`
	AckWaitTime             *string                   `json:"ackWaitTime,omitempty"`
	MaxInFlight             *int64                    `json:"maxInFlight,omitempty"`
	DurableSubscriptionName string                    `json:"durableSubscriptionName"`
	DeliverNew              *bool                     `json:"deliverNew,omitempty"`
	StartAtSequence         *int64                    `json:"startAtSequence,omitempty"`
	StartWithLastReceived   *bool                     `json:"startWithLastReceived,omitempty"`
	DeliverAll              *bool                     `json:"deliverAll,omitempty"`
	StartAtTimeDelta        *string                   `json:"startAtTimeDelta,omitempty"`
	StartAtTime             *string                   `json:"startAtTime,omitempty"`
	StartAtTimeFormat       *string                   `json:"startAtTimeFormat,omitempty"`
	ConsumerID              *string                   `json:"consumerID,omitempty"`
	ScaleOption             *NatsStreamingScaleOption `json:"scaleOption,omitempty"`
}

func (*NatsStreamingSpec) DeepCopy 

func (in *NatsStreamingSpec) DeepCopy() *NatsStreamingSpec

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

func (*NatsStreamingSpec) DeepCopyInto 

func (in *NatsStreamingSpec) DeepCopyInto(out *NatsStreamingSpec)

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

type RedisSpec 

type RedisSpec struct {
	RedisHost             string  `json:"redisHost"`
	RedisPassword         string  `json:"redisPassword"`
	EnableTLS             *bool   `json:"enableTLS,omitempty"`
	Failover              *bool   `json:"failover,omitempty"`
	SentinelMasterName    *string `json:"sentinelMasterName,omitempty"`
	RedeliverInterval     *string `json:"redeliverInterval,omitempty"`
	ProcessingTimeout     *string `json:"processingTimeout,omitempty"`
	RedisType             *string `json:"redisType,omitempty"`
	RedisDB               *int64  `json:"redisDB,omitempty"`
	RedisMaxRetries       *int64  `json:"redisMaxRetries,omitempty"`
	RedisMinRetryInterval *string `json:"redisMinRetryInterval,omitempty"`
	RedisMaxRetryInterval *string `json:"redisMaxRetryInterval,omitempty"`
	DialTimeout           *string `json:"dialTimeout,omitempty"`
	ReadTimeout           *string `json:"readTimeout,omitempty"`
	WriteTimeout          *string `json:"writeTimeout,omitempty"`
	PoolSize              *int64  `json:"poolSize,omitempty"`
	PoolTimeout           *string `json:"poolTimeout,omitempty"`
	MaxConnAge            *string `json:"maxConnAge,omitempty"`
	MinIdleConns          *int64  `json:"minIdleConns,omitempty"`
	IdleCheckFrequency    *string `json:"idleCheckFrequency,omitempty"`
	IdleTimeout           *string `json:"idleTimeout,omitempty"`
}

func (*RedisSpec) DeepCopy 

func (in *RedisSpec) DeepCopy() *RedisSpec

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

func (*RedisSpec) DeepCopyInto 

func (in *RedisSpec) DeepCopyInto(out *RedisSpec)

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

type Reference 

type Reference struct {
	// Kind of the referent.
	Kind string `json:"kind"`
	// Namespace of the referent.
	// +optional
	Namespace string `json:"namespace,omitempty"`
	// Name of the referent.
	Name string `json:"name"`
	// API version of the referent.
	APIVersion string `json:"apiVersion"`
}

func (*Reference) DeepCopy 

func (in *Reference) DeepCopy() *Reference

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

func (*Reference) DeepCopyInto 

func (in *Reference) DeepCopyInto(out *Reference)

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

func (Reference) GroupVersionKind 

func (ref Reference) GroupVersionKind() schema.GroupVersionKind

type SinkSpec 

type SinkSpec struct {
	Ref *Reference `json:"ref,omitempty"`
	Uri *string    `json:"uri,omitempty"`
}

SinkSpec specifies the receiver of the events an EventSource received, sinks in the Uri format have higher priority than sinks in Reference format.

func (*SinkSpec) DeepCopy 

func (in *SinkSpec) DeepCopy() *SinkSpec

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

func (*SinkSpec) DeepCopyInto 

func (in *SinkSpec) DeepCopyInto(out *SinkSpec)

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

type Subscriber 

type Subscriber struct {
	// Condition for judging events
	Condition string `json:"condition"`
	// Sink and DeadLetterSink are used to handle subscribers who use the synchronous call method
	Sink           *SinkSpec `json:"sink,omitempty"`
	DeadLetterSink *SinkSpec `json:"deadLetterSink,omitempty"`
	// Topic and DeadLetterTopic are used to handle subscribers who use the asynchronous call method
	Topic           string `json:"topic,omitempty"`
	DeadLetterTopic string `json:"deadLetterTopic,omitempty"`
}

func (*Subscriber) DeepCopy 

func (in *Subscriber) DeepCopy() *Subscriber

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

func (*Subscriber) DeepCopyInto 

func (in *Subscriber) DeepCopyInto(out *Subscriber)

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

type Trigger 

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

	Spec   TriggerSpec   `json:"spec,omitempty"`
	Status TriggerStatus `json:"status,omitempty"`
}

Trigger is the Schema for the triggers API

func (*Trigger) AddCondition 

func (t *Trigger) AddCondition(condition Condition) *Trigger

func (*Trigger) DeepCopy 

func (in *Trigger) DeepCopy() *Trigger

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

func (*Trigger) DeepCopyInto 

func (in *Trigger) DeepCopyInto(out *Trigger)

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

func (*Trigger) DeepCopyObject 

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

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

func (*Trigger) SaveStatus 

func (t *Trigger) SaveStatus(ctx context.Context, logger logr.Logger, cl client.Client)

SaveStatus will trigger an object update to save the current status conditions

type TriggerList 

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

TriggerList contains a list of Trigger

func (*TriggerList) DeepCopy 

func (in *TriggerList) DeepCopy() *TriggerList

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

func (*TriggerList) DeepCopyInto 

func (in *TriggerList) DeepCopyInto(out *TriggerList)

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

func (*TriggerList) DeepCopyObject 

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

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

type TriggerSpec 

type TriggerSpec struct {

	// EventBus allows you to specify a specific EventBus to be used instead of the "default" one
	EventBus string `json:"eventBus"`
	// Inputs defines the event sources associated with the Trigger
	Inputs map[string]*Input `json:"inputs"`
	// Subscribers defines the subscribers associated with the Trigger
	Subscribers []*Subscriber `json:"subscribers"`
	// The logging level of the event source handler, e.g. "1", "2", "3".
	// The level increases as the value increases, default is "1".
	// +optional
	LogLevel *string `json:"logLevel,omitempty"`
}

TriggerSpec defines the desired state of Trigger

func (*TriggerSpec) DeepCopy 

func (in *TriggerSpec) DeepCopy() *TriggerSpec

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

func (*TriggerSpec) DeepCopyInto 

func (in *TriggerSpec) DeepCopyInto(out *TriggerSpec)

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

type TriggerStatus 

type TriggerStatus struct {
	Conditions []Condition `json:"conditions,omitempty" description:"List of auditable conditions of Trigger"`
}

TriggerStatus defines the observed state of Trigger

func (*TriggerStatus) DeepCopy 

func (in *TriggerStatus) DeepCopy() *TriggerStatus

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

func (*TriggerStatus) DeepCopyInto 

func (in *TriggerStatus) DeepCopyInto(out *TriggerStatus)

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.