v1alpha1

package
v0.1.8 Latest Latest
Warning

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

 Go to latest Published: Mar 1, 2024 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Overview

Package v1alpha1 is the v1alpha1 version of the API. +k8s:deepcopy-gen=package +groupName=eventing.typhoon.zeiss.com

Index

Constants

View Source 
const (
	RedisBrokerConditionReady                                          = apis.ConditionReady
	RedisBrokerRedisDeployment                      apis.ConditionType = "RedisDeploymentReady"
	RedisBrokerRedisService                         apis.ConditionType = "RedisServiceReady"
	RedisBrokerRedisServiceEndpointsConditionReady  apis.ConditionType = "RedisEndpointsReady"
	RedisBrokerBrokerDeployment                     apis.ConditionType = "BrokerDeploymentReady"
	RedisBrokerBrokerServiceAccount                 apis.ConditionType = "BrokerServiceAccountReady"
	RedisBrokerBrokerRoleBinding                    apis.ConditionType = "RedisBrokerBrokerRoleBinding"
	RedisBrokerBrokerService                        apis.ConditionType = "BrokerServiceReady"
	RedisBrokerBrokerServiceEndpointsConditionReady apis.ConditionType = "BrokerEndpointsReady"
	RedisBrokerConfigSecret                         apis.ConditionType = "BrokerConfigSecretReady"
	RedisBrokerConditionAddressable                 apis.ConditionType = "Addressable"
	RedisBrokerStatusConfig                         apis.ConditionType = "BrokerStatusConfigReady"

	RedisBrokerReasonUserProvided string = "ReasonUserProvidedRedis"
)
View Source 
const (
	// TriggerConditionReady has status True when all subconditions below have been set to True.
	TriggerConditionReady = apis.ConditionReady

	TriggerConditionBroker apis.ConditionType = "BrokerReady"

	TriggerConditionStatusConfigMap apis.ConditionType = "StatusConfigMapReady"

	TriggerConditionTargetResolved apis.ConditionType = "TargetResolved"

	TriggerConditionDeadLetterSinkResolved apis.ConditionType = "DeadLetterSinkResolved"

	// TriggerAnyFilter Constant to represent that we should allow anything.
	TriggerAnyFilter = ""
)

Variables

View Source 
var (
	// SchemeGroupVersion is group version used to register these objects
	SchemeGroupVersion = schema.GroupVersion{Group: eventing.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 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 Broker 

type Broker struct {
	Port *int `json:"port,omitempty"`

	Observability *Observability `json:"observability,omitempty"`
}

func (*Broker) DeepCopy 

func (in *Broker) DeepCopy() *Broker

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

func (*Broker) DeepCopyInto 

func (in *Broker) DeepCopyInto(out *Broker)

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

type Observability 

type Observability struct {
	ValueFromConfigMap string `json:"valueFromConfigMap"`
}

func (*Observability) DeepCopy 

func (in *Observability) DeepCopy() *Observability

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

func (*Observability) DeepCopyInto 

func (in *Observability) DeepCopyInto(out *Observability)

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

type ReconcilableBroker 

type ReconcilableBroker interface {
	kmeta.OwnerRefable

	GetReconcilableBrokerStatus() ReconcilableBrokerStatus
	GetOwnedObjectsSuffix() string
	GetReconcilableBrokerSpec() *Broker
}

type ReconcilableBrokerStatus 

type ReconcilableBrokerStatus interface {
	// Secret as config status management.
	MarkConfigSecretFailed(reason, messageFormat string, messageA ...interface{})
	MarkConfigSecretReady()

	// Status Config management.
	MarkStatusConfigFailed(reason, messageFormat string, messageA ...interface{})
	MarkStatusConfigReady()

	// ServiceAccount status management.
	MarkBrokerServiceAccountFailed(reason, messageFormat string, messageA ...interface{})
	MarkBrokerServiceAccountReady()

	// RoleBinding status management.
	MarkBrokerRoleBindingFailed(reason, messageFormat string, messageA ...interface{})
	MarkBrokerRoleBindingReady()

	// Broker Deployment status management.
	MarkBrokerDeploymentFailed(reason, messageFormat string, messageA ...interface{})
	PropagateBrokerDeploymentAvailability(ctx context.Context, ds *appsv1.DeploymentStatus)

	// Broker Service status management
	MarkBrokerServiceFailed(reason, messageFormat string, messageA ...interface{})
	MarkBrokerServiceReady()

	// Broker Endpoints status management.
	MarkBrokerEndpointsTrue()
	MarkBrokerEndpointsUnknown(reason, messageFormat string, messageA ...interface{})
	MarkBrokerEndpointsFailed(reason, messageFormat string, messageA ...interface{})
}

type Redis 

type Redis struct {
	// Redis connection data.
	Connection *RedisConnection `json:"connection,omitempty"`

	// Stream name used by the broker.
	Stream *string `json:"stream,omitempty"`

	// Maximum number of items the stream can host.
	StreamMaxLen *int `json:"streamMaxLen,omitempty"`

	// Whether the Redis ID for the event is added as a CloudEvents attribute.
	EnableTrackingID *bool `json:"enableTrackingID,omitempty"`
}

func (*Redis) DeepCopy 

func (in *Redis) DeepCopy() *Redis

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

func (*Redis) DeepCopyInto 

func (in *Redis) DeepCopyInto(out *Redis)

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

type RedisBroker 

type RedisBroker struct {
	metav1.TypeMeta `json:",inline"`
	// +optional
	metav1.ObjectMeta `json:"metadata,omitempty"`

	// Spec defines the desired state of the broker.
	Spec RedisBrokerSpec `json:"spec,omitempty"`

	// Status represents the current state of the broker. This data may be out of
	// date.
	// +optional
	Status RedisBrokerStatus `json:"status,omitempty"`
}

RedisBroker is a Redis based broker implementation that collects a pool of events that are consumable using Triggers. Brokers provide a well-known endpoint for event delivery that senders can use with minimal knowledge of the event routing strategy. Subscribers use Triggers to request delivery of events from a broker's pool to a specific URL or Addressable endpoint.

func (*RedisBroker) DeepCopy 

func (in *RedisBroker) DeepCopy() *RedisBroker

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

func (*RedisBroker) DeepCopyInto 

func (in *RedisBroker) DeepCopyInto(out *RedisBroker)

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

func (*RedisBroker) DeepCopyObject 

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

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

func (*RedisBroker) GetConditionSet 

func (b *RedisBroker) GetConditionSet() apis.ConditionSet

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

func (*RedisBroker) GetGroupVersionKind 

func (t *RedisBroker) GetGroupVersionKind() schema.GroupVersionKind

GetGroupVersionKind returns GroupVersionKind for Brokers

func (*RedisBroker) GetOwnedObjectsSuffix 

func (t *RedisBroker) GetOwnedObjectsSuffix() string

GetOwnedObjectsSuffix returns a string to be appended for created/owned objects.

func (*RedisBroker) GetReconcilableBrokerSpec 

func (t *RedisBroker) GetReconcilableBrokerSpec() *Broker

GetReconcilableBrokerSpec returns the all brokers common Broker spec.

func (*RedisBroker) GetReconcilableBrokerStatus 

func (t *RedisBroker) GetReconcilableBrokerStatus() ReconcilableBrokerStatus

GetReconcilableBrokerStatus returns a status interface that allows generic reconciler to manage it.

func (*RedisBroker) GetStatus 

func (t *RedisBroker) GetStatus() *duckv1.Status

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

func (*RedisBroker) IsReady 

func (b *RedisBroker) IsReady() bool

IsReady returns true if the resource is ready overall and the latest spec has been observed.

func (*RedisBroker) IsUserProvidedRedis 

func (b *RedisBroker) IsUserProvidedRedis() bool

IsExternalRedis returns if the Redis instance is user provided.

type RedisBrokerList 

type RedisBrokerList struct {
	metav1.TypeMeta `json:",inline"`
	// +optional
	metav1.ListMeta `json:"metadata,omitempty"`

	Items []RedisBroker `json:"items"`
}

RedisBrokerList is a collection of Brokers.

func (*RedisBrokerList) DeepCopy 

func (in *RedisBrokerList) DeepCopy() *RedisBrokerList

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

func (*RedisBrokerList) DeepCopyInto 

func (in *RedisBrokerList) DeepCopyInto(out *RedisBrokerList)

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

func (*RedisBrokerList) DeepCopyObject 

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

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

type RedisBrokerSpec 

type RedisBrokerSpec struct {
	Redis *Redis `json:"redis,omitempty"`

	Broker Broker `json:"broker,omitempty"`
}

func (*RedisBrokerSpec) DeepCopy 

func (in *RedisBrokerSpec) DeepCopy() *RedisBrokerSpec

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

func (*RedisBrokerSpec) DeepCopyInto 

func (in *RedisBrokerSpec) DeepCopyInto(out *RedisBrokerSpec)

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

type RedisBrokerStatus 

type RedisBrokerStatus struct {
	// inherits duck/v1 Status, which currently provides:
	// * ObservedGeneration - the 'Generation' of the Broker that was last processed by the controller.
	// * Conditions - the latest available observations of a resource's current state.
	duckv1.Status `json:",inline"`

	// Broker is Addressable. It exposes the endpoint as an URI to get events
	// delivered into the Broker mesh.
	// +optional
	Address duckv1.Addressable `json:"address,omitempty"`
}

RedisBrokerStatus represents the current state of a Redis broker.

func (*RedisBrokerStatus) DeepCopy 

func (in *RedisBrokerStatus) DeepCopy() *RedisBrokerStatus

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

func (*RedisBrokerStatus) DeepCopyInto 

func (in *RedisBrokerStatus) DeepCopyInto(out *RedisBrokerStatus)

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

func (*RedisBrokerStatus) GetCondition 

func (bs *RedisBrokerStatus) GetCondition(t apis.ConditionType) *apis.Condition

GetCondition returns the condition currently associated with the given type, or nil.

func (*RedisBrokerStatus) GetConditionSet 

func (bs *RedisBrokerStatus) GetConditionSet() apis.ConditionSet

GetConditionSet retrieves the condition set for this resource.

func (*RedisBrokerStatus) GetTopLevelCondition 

func (bs *RedisBrokerStatus) GetTopLevelCondition() *apis.Condition

GetTopLevelCondition returns the top level Condition.

func (*RedisBrokerStatus) InitializeConditions 

func (bs *RedisBrokerStatus) InitializeConditions()

InitializeConditions sets relevant unset conditions to Unknown state.

func (*RedisBrokerStatus) MarkBrokerDeploymentFailed 

func (bs *RedisBrokerStatus) MarkBrokerDeploymentFailed(reason, messageFormat string, messageA ...interface{})

Manage Redis broker state for Deployment, Service and Endpoint

func (*RedisBrokerStatus) MarkBrokerDeploymentUnknown 

func (bs *RedisBrokerStatus) MarkBrokerDeploymentUnknown(reason, messageFormat string, messageA ...interface{})

func (*RedisBrokerStatus) MarkBrokerEndpointsFailed 

func (bs *RedisBrokerStatus) MarkBrokerEndpointsFailed(reason, messageFormat string, messageA ...interface{})

func (*RedisBrokerStatus) MarkBrokerEndpointsTrue 

func (bs *RedisBrokerStatus) MarkBrokerEndpointsTrue()

func (*RedisBrokerStatus) MarkBrokerEndpointsUnknown 

func (bs *RedisBrokerStatus) MarkBrokerEndpointsUnknown(reason, messageFormat string, messageA ...interface{})

func (*RedisBrokerStatus) MarkBrokerRoleBindingFailed 

func (bs *RedisBrokerStatus) MarkBrokerRoleBindingFailed(reason, messageFormat string, messageA ...interface{})

func (*RedisBrokerStatus) MarkBrokerRoleBindingReady 

func (bs *RedisBrokerStatus) MarkBrokerRoleBindingReady()

func (*RedisBrokerStatus) MarkBrokerRoleBindingUnknown 

func (bs *RedisBrokerStatus) MarkBrokerRoleBindingUnknown(reason, messageFormat string, messageA ...interface{})

func (*RedisBrokerStatus) MarkBrokerServiceAccountFailed 

func (bs *RedisBrokerStatus) MarkBrokerServiceAccountFailed(reason, messageFormat string, messageA ...interface{})

func (*RedisBrokerStatus) MarkBrokerServiceAccountReady 

func (bs *RedisBrokerStatus) MarkBrokerServiceAccountReady()

func (*RedisBrokerStatus) MarkBrokerServiceAccountUnknown 

func (bs *RedisBrokerStatus) MarkBrokerServiceAccountUnknown(reason, messageFormat string, messageA ...interface{})

func (*RedisBrokerStatus) MarkBrokerServiceFailed 

func (bs *RedisBrokerStatus) MarkBrokerServiceFailed(reason, messageFormat string, messageA ...interface{})

func (*RedisBrokerStatus) MarkBrokerServiceReady 

func (bs *RedisBrokerStatus) MarkBrokerServiceReady()

func (*RedisBrokerStatus) MarkBrokerServiceUnknown 

func (bs *RedisBrokerStatus) MarkBrokerServiceUnknown(reason, messageFormat string, messageA ...interface{})

func (*RedisBrokerStatus) MarkConfigSecretFailed 

func (bs *RedisBrokerStatus) MarkConfigSecretFailed(reason, messageFormat string, messageA ...interface{})

func (*RedisBrokerStatus) MarkConfigSecretReady 

func (bs *RedisBrokerStatus) MarkConfigSecretReady()

func (*RedisBrokerStatus) MarkConfigSecretUnknown 

func (bs *RedisBrokerStatus) MarkConfigSecretUnknown(reason, messageFormat string, messageA ...interface{})

func (*RedisBrokerStatus) MarkRedisDeploymentFailed 

func (bs *RedisBrokerStatus) MarkRedisDeploymentFailed(reason, messageFormat string, messageA ...interface{})

func (*RedisBrokerStatus) MarkRedisDeploymentUnknown 

func (bs *RedisBrokerStatus) MarkRedisDeploymentUnknown(reason, messageFormat string, messageA ...interface{})

func (*RedisBrokerStatus) MarkRedisEndpointsFailed 

func (bs *RedisBrokerStatus) MarkRedisEndpointsFailed(reason, messageFormat string, messageA ...interface{})

func (*RedisBrokerStatus) MarkRedisEndpointsTrue 

func (bs *RedisBrokerStatus) MarkRedisEndpointsTrue()

func (*RedisBrokerStatus) MarkRedisEndpointsUnknown 

func (bs *RedisBrokerStatus) MarkRedisEndpointsUnknown(reason, messageFormat string, messageA ...interface{})

func (*RedisBrokerStatus) MarkRedisServiceFailed 

func (bs *RedisBrokerStatus) MarkRedisServiceFailed(reason, messageFormat string, messageA ...interface{})

func (*RedisBrokerStatus) MarkRedisServiceReady 

func (bs *RedisBrokerStatus) MarkRedisServiceReady()

func (*RedisBrokerStatus) MarkRedisServiceUnknown 

func (bs *RedisBrokerStatus) MarkRedisServiceUnknown(reason, messageFormat string, messageA ...interface{})

func (*RedisBrokerStatus) MarkRedisUserProvided 

func (bs *RedisBrokerStatus) MarkRedisUserProvided()

func (*RedisBrokerStatus) MarkStatusConfigFailed 

func (bs *RedisBrokerStatus) MarkStatusConfigFailed(reason, messageFormat string, messageA ...interface{})

func (*RedisBrokerStatus) MarkStatusConfigReady 

func (bs *RedisBrokerStatus) MarkStatusConfigReady()

func (*RedisBrokerStatus) MarkStatusConfigUnknown 

func (bs *RedisBrokerStatus) MarkStatusConfigUnknown(reason, messageFormat string, messageA ...interface{})

func (*RedisBrokerStatus) PropagateBrokerDeploymentAvailability 

func (bs *RedisBrokerStatus) PropagateBrokerDeploymentAvailability(ctx context.Context, ds *appsv1.DeploymentStatus)

func (*RedisBrokerStatus) PropagateRedisDeploymentAvailability 

func (bs *RedisBrokerStatus) PropagateRedisDeploymentAvailability(ctx context.Context, ds *appsv1.DeploymentStatus)

func (*RedisBrokerStatus) SetAddress 

func (bs *RedisBrokerStatus) SetAddress(url *apis.URL)

SetAddress makes this Broker addressable by setting the URI. It also sets the BrokerConditionAddressable to true.

type RedisConnection 

type RedisConnection struct {
	// Redis URL for standalone instances
	URL *string `json:"url,omitempty"`

	// Redis URLs for cluster instances
	ClusterURLs []string `json:"clusterURLs,omitempty"`

	// Redis username.
	Username *SecretValueFromSource `json:"username,omitempty"`

	// Redis password.
	Password *SecretValueFromSource `json:"password,omitempty"`

	// CA Certificate used to connect to Redis.
	TLSCACertificate *SecretValueFromSource `json:"tlsCACertificate,omitempty"`

	// Certificate used to connect to authenticate to Redis.
	TLSCertificate *SecretValueFromSource `json:"tlsCertificate,omitempty"`

	// Certificate Key used to connect to authenticate to Redis.
	TLSKey *SecretValueFromSource `json:"tlsKey,omitempty"`

	// Use TLS enctrypted connection.
	TLSEnabled *bool `json:"tlsEnabled,omitempty"`

	// Skip TLS certificate verification.
	TLSSkipVerify *bool `json:"tlsSkipVerify,omitempty"`
}

func (*RedisConnection) DeepCopy 

func (in *RedisConnection) DeepCopy() *RedisConnection

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

func (*RedisConnection) DeepCopyInto 

func (in *RedisConnection) DeepCopyInto(out *RedisConnection)

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

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.

type Trigger 

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

	// Spec defines the desired state of the Trigger.
	Spec TriggerSpecBounded `json:"spec,omitempty"`

	// Status represents the current state of the Trigger. This data may be out of
	// date.
	// +optional
	Status TriggerStatus `json:"status,omitempty"`
}

Trigger represents a request to have events delivered to a target from a Broker's event pool.

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

func (*Trigger) GetConditionSet() apis.ConditionSet

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

func (*Trigger) GetGroupVersionKind 

func (t *Trigger) GetGroupVersionKind() schema.GroupVersionKind

GetGroupVersionKind returns GroupVersionKind for Triggers

func (*Trigger) GetStatus 

func (t *Trigger) GetStatus() *duckv1.Status

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

func (*Trigger) GetUntypedSpec 

func (t *Trigger) GetUntypedSpec() interface{}

GetUntypedSpec returns the spec of the Trigger.

func (*Trigger) OwnerRefableMatchesBroker 

func (t *Trigger) OwnerRefableMatchesBroker(broker kmeta.OwnerRefable) bool

func (*Trigger) OwnerReferenceMatchesBroker 

func (t *Trigger) OwnerReferenceMatchesBroker(broker metav1.OwnerReference) bool

func (*Trigger) Validate 

func (t *Trigger) Validate(ctx context.Context) *apis.FieldError

Validate the Trigger.

type TriggerBounds 

type TriggerBounds struct {
	// TriggerBoundsByID set offsets policy by backing broker ID.
	ById *TriggerBoundsByID `json:"byId,omitempty"`
	// TriggerBoundsByID set offsets policy by date.
	ByDate *TriggerBoundsByDate `json:"byDate,omitempty"`
}

TriggerBounds set the policy for the event offsets we are interested in receiving.

func (*TriggerBounds) DeepCopy 

func (in *TriggerBounds) DeepCopy() *TriggerBounds

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

func (*TriggerBounds) DeepCopyInto 

func (in *TriggerBounds) DeepCopyInto(out *TriggerBounds)

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

type TriggerBoundsByDate 

type TriggerBoundsByDate struct {
	// Starting date.
	Start *string `json:"start,omitempty"`
	// Ending date.
	End *string `json:"end,omitempty"`
}

func (*TriggerBoundsByDate) DeepCopy 

func (in *TriggerBoundsByDate) DeepCopy() *TriggerBoundsByDate

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

func (*TriggerBoundsByDate) DeepCopyInto 

func (in *TriggerBoundsByDate) DeepCopyInto(out *TriggerBoundsByDate)

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

type TriggerBoundsByID 

type TriggerBoundsByID struct {
	// Starting offset.
	Start *string `json:"start,omitempty"`
	// Ending offset.
	End *string `json:"end,omitempty"`
}

func (*TriggerBoundsByID) DeepCopy 

func (in *TriggerBoundsByID) DeepCopy() *TriggerBoundsByID

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

func (*TriggerBoundsByID) DeepCopyInto 

func (in *TriggerBoundsByID) DeepCopyInto(out *TriggerBoundsByID)

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

type TriggerList 

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

TriggerList is a collection of Triggers.

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 {
	// Broker is the broker that this trigger receives events from.
	Broker duckv1.KReference `json:"broker,omitempty"`

	// Filters is an experimental field that conforms to the CNCF CloudEvents Subscriptions
	// API. It's an array of filter expressions that evaluate to true or false.
	// If any filter expression in the array evaluates to false, the event MUST
	// NOT be sent to the target. If all the filter expressions in the array
	// evaluate to true, the event MUST be attempted to be delivered. Absence of
	// a filter or empty array implies a value of true. In the event of users
	// specifying both Filter and Filters, then the latter will override the former.
	// This will allow users to try out the effect of the new Filters field
	// without compromising the existing attribute-based Filter and try it out on existing
	// Trigger objects.
	//
	// +optional
	Filters []broker.Filter `json:"filters,omitempty"`

	// Target is the addressable that receives events from the Broker that pass
	// the Filter. It is required.
	Target duckv1.Destination `json:"target,omitempty"`

	// Delivery contains the delivery spec for this specific trigger.
	// +optional
	Delivery *eventingduckv1.DeliverySpec `json:"delivery,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.

func (*TriggerSpec) Validate 

func (ts *TriggerSpec) Validate(ctx context.Context) (errs *apis.FieldError)

Validate the TriggerSpec.

type TriggerSpecBounded 

type TriggerSpecBounded struct {
	TriggerSpec `json:",inline"`

	// Bounds for the receiving events
	Bounds *TriggerBounds `json:"bounds,omitempty"`
}

func (*TriggerSpecBounded) DeepCopy 

func (in *TriggerSpecBounded) DeepCopy() *TriggerSpecBounded

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

func (*TriggerSpecBounded) DeepCopyInto 

func (in *TriggerSpecBounded) DeepCopyInto(out *TriggerSpecBounded)

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

type TriggerStatus 

type TriggerStatus struct {
	// inherits duck/v1 Status, which currently provides:
	// * ObservedGeneration - the 'Generation' of the Trigger that was last processed by the controller.
	// * Conditions - the latest available observations of a resource's current state.
	duckv1.Status `json:",inline"`

	// TargetURI is the resolved URI of the receiver for this Trigger.
	// +optional
	TargetURI *apis.URL `json:"targetUri,omitempty"`

	// DeliveryStatus contains a resolved URL to the dead letter sink address, and any other
	// resolved delivery options.
	eventingduckv1.DeliveryStatus `json:",inline"`
}

TriggerStatus represents the current state of a 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.

func (*TriggerStatus) GetCondition 

func (ts *TriggerStatus) GetCondition(t apis.ConditionType) *apis.Condition

GetCondition returns the condition currently associated with the given type, or nil.

func (*TriggerStatus) GetTopLevelCondition 

func (ts *TriggerStatus) GetTopLevelCondition() *apis.Condition

GetTopLevelCondition returns the top level Condition.

func (*TriggerStatus) InitializeConditions 

func (ts *TriggerStatus) InitializeConditions()

InitializeConditions sets relevant unset conditions to Unknown state.

func (*TriggerStatus) IsReady 

func (ts *TriggerStatus) IsReady() bool

IsReady returns true if the resource is ready overall.

func (*TriggerStatus) MarkBrokerFailed 

func (ts *TriggerStatus) MarkBrokerFailed(reason, messageFormat string, messageA ...interface{})

func (*TriggerStatus) MarkBrokerNotConfigured 

func (ts *TriggerStatus) MarkBrokerNotConfigured()

func (*TriggerStatus) MarkBrokerUnknown 

func (ts *TriggerStatus) MarkBrokerUnknown(reason, messageFormat string, messageA ...interface{})

func (*TriggerStatus) MarkDeadLetterSinkNotConfigured 

func (ts *TriggerStatus) MarkDeadLetterSinkNotConfigured()

func (*TriggerStatus) MarkDeadLetterSinkResolvedFailed 

func (ts *TriggerStatus) MarkDeadLetterSinkResolvedFailed(reason, messageFormat string, messageA ...interface{})

func (*TriggerStatus) MarkDeadLetterSinkResolvedSucceeded 

func (ts *TriggerStatus) MarkDeadLetterSinkResolvedSucceeded()

func (*TriggerStatus) MarkStatusConfigMapFailed 

func (ts *TriggerStatus) MarkStatusConfigMapFailed(reason, messageFormat string, messageA ...interface{})

func (*TriggerStatus) MarkStatusConfigMapSucceeded 

func (ts *TriggerStatus) MarkStatusConfigMapSucceeded(reason, message string)

func (*TriggerStatus) MarkTargetResolvedFailed 

func (ts *TriggerStatus) MarkTargetResolvedFailed(reason, messageFormat string, messageA ...interface{})

func (*TriggerStatus) MarkTargetResolvedSucceeded 

func (ts *TriggerStatus) MarkTargetResolvedSucceeded()

func (*TriggerStatus) MarkTargetResolvedUnknown 

func (ts *TriggerStatus) MarkTargetResolvedUnknown(reason, messageFormat string, messageA ...interface{})

func (*TriggerStatus) PropagateBrokerCondition 

func (ts *TriggerStatus) PropagateBrokerCondition(bc *apis.Condition)

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.