v1beta1

package
v0.13.4 Latest Latest
Warning

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

 Go to latest Published: Mar 19, 2020 License: Apache-2.0 Imports: 20 Imported by: 0

Documentation

Overview

Package v1beta1 is the v1beta1 version of the API. +k8s:deepcopy-gen=package +groupName=eventing.knative.dev

Index

Constants

View Source 
const (
	BrokerConditionReady                          = apis.ConditionReady
	BrokerConditionAddressable apis.ConditionType = "Addressable"
)
View Source 
const (
	// TriggerConditionReady has status True when all subconditions below have been set to True.
	TriggerConditionReady = apis.ConditionReady

	TriggerConditionBroker apis.ConditionType = "BrokerReady"

	TriggerConditionSubscribed apis.ConditionType = "Subscribed"

	TriggerConditionDependency apis.ConditionType = "DependencyReady"

	TriggerConditionSubscriberResolved apis.ConditionType = "SubscriberResolved"

	// TriggerAnyFilter Constant to represent that we should allow anything.
	TriggerAnyFilter = ""
)
View Source 
const (
	// DependencyAnnotation is the annotation key used to mark the sources that the Trigger depends on.
	// This will be used when the kn client creates a source and trigger pair for the user such that the trigger only receives events produced by the paired source.
	DependencyAnnotation = "knative.dev/dependency"
	// InjectionAnnotation is the annotation key used to enable knative eventing injection for a namespace and automatically create a default broker.
	// This will be used when the client creates a trigger paired with default broker and the default broker doesn't exist in the namespace
	InjectionAnnotation = "knative-eventing-injection"
)
View Source 
const (
	BrokerClassAnnotationKey = "eventing.knative.dev/broker.class"
)

Variables

View Source 
var (
	SchemeBuilder = runtime.NewSchemeBuilder(addKnownTypes)
	AddToScheme   = SchemeBuilder.AddToScheme
)
View Source 
var SchemeGroupVersion = schema.GroupVersion{Group: eventing.GroupName, Version: "v1beta1"}

SchemeGroupVersion is group version used to register these objects

View Source 
var TestHelper = testHelper{}

TestHelper contains helpers for unit tests.

Functions

func GetObjRefFromDependencyAnnotation 

func GetObjRefFromDependencyAnnotation(dependencyAnnotation string) (corev1.ObjectReference, error)

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 {
	metav1.TypeMeta `json:",inline"`
	// +optional
	metav1.ObjectMeta `json:"metadata,omitempty"`

	// Spec defines the desired state of the Broker.
	Spec BrokerSpec `json:"spec,omitempty"`

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

Broker 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. Receivers use Triggers to request delivery of events from a Broker's pool to a specific URL or Addressable endpoint.

func (*Broker) CheckImmutableFields 

func (b *Broker) CheckImmutableFields(ctx context.Context, original *Broker) *apis.FieldError

func (*Broker) ConvertFrom 

func (sink *Broker) ConvertFrom(ctx context.Context, source apis.Convertible) error

ConvertFrom implements apis.Convertible

func (*Broker) ConvertTo 

func (source *Broker) ConvertTo(ctx context.Context, sink apis.Convertible) error

ConvertTo implements apis.Convertible

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.

func (*Broker) DeepCopyObject 

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

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

func (*Broker) GetGroupVersionKind 

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

GetGroupVersionKind returns GroupVersionKind for Brokers

func (*Broker) GetUntypedSpec 

func (b *Broker) GetUntypedSpec() interface{}

GetUntypedSpec returns the spec of the Broker.

func (*Broker) SetDefaults 

func (b *Broker) SetDefaults(ctx context.Context)

func (*Broker) Validate 

func (b *Broker) Validate(ctx context.Context) *apis.FieldError

type BrokerList 

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

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

BrokerList is a collection of Brokers.

func (*BrokerList) DeepCopy 

func (in *BrokerList) DeepCopy() *BrokerList

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

func (*BrokerList) DeepCopyInto 

func (in *BrokerList) DeepCopyInto(out *BrokerList)

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

func (*BrokerList) DeepCopyObject 

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

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

type BrokerSpec 

type BrokerSpec struct {
	// Config is a KReference to the configuration that specifies
	// configuration options for this Broker. For example, this could be
	// a pointer to a ConfigMap.
	// +optional
	Config *duckv1.KReference `json:"config,omitempty"`

	// Delivery is the delivery specification for Events within the Broker mesh.
	// This includes things like retries, DLQ, etc.
	// +optional
	Delivery *eventingduckv1beta1.DeliverySpec `json:"delivery,omitempty"`
}

func (*BrokerSpec) DeepCopy 

func (in *BrokerSpec) DeepCopy() *BrokerSpec

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

func (*BrokerSpec) DeepCopyInto 

func (in *BrokerSpec) DeepCopyInto(out *BrokerSpec)

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

func (*BrokerSpec) SetDefaults 

func (bs *BrokerSpec) SetDefaults(ctx context.Context)

func (*BrokerSpec) Validate 

func (bs *BrokerSpec) Validate(ctx context.Context) *apis.FieldError

type BrokerStatus 

type BrokerStatus 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.Status `json:",inline"`

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

BrokerStatus represents the current state of a Broker.

func (*BrokerStatus) DeepCopy 

func (in *BrokerStatus) DeepCopy() *BrokerStatus

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

func (*BrokerStatus) DeepCopyInto 

func (in *BrokerStatus) DeepCopyInto(out *BrokerStatus)

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

func (*BrokerStatus) GetTopLevelCondition 

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

GetTopLevelCondition returns the top level Condition.

func (*BrokerStatus) SetAddress 

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

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

type EventType 

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

	// Spec defines the desired state of the EventType.
	Spec EventTypeSpec `json:"spec,omitempty"`

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

func (*EventType) CheckImmutableFields 

func (et *EventType) CheckImmutableFields(ctx context.Context, original *EventType) *apis.FieldError

func (*EventType) ConvertFrom 

func (sink *EventType) ConvertFrom(ctx context.Context, source apis.Convertible) error

ConvertFrom implements apis.Convertible

func (*EventType) ConvertTo 

func (source *EventType) ConvertTo(ctx context.Context, sink apis.Convertible) error

ConvertTo implements apis.Convertible

func (*EventType) DeepCopy 

func (in *EventType) DeepCopy() *EventType

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

func (*EventType) DeepCopyInto 

func (in *EventType) DeepCopyInto(out *EventType)

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

func (*EventType) DeepCopyObject 

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

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

func (*EventType) GetGroupVersionKind 

func (p *EventType) GetGroupVersionKind() schema.GroupVersionKind

GetGroupVersionKind returns GroupVersionKind for EventType

func (*EventType) GetUntypedSpec 

func (e *EventType) GetUntypedSpec() interface{}

GetUntypedSpec returns the spec of the EventType.

func (*EventType) SetDefaults 

func (et *EventType) SetDefaults(ctx context.Context)

func (*EventType) Validate 

func (et *EventType) Validate(ctx context.Context) *apis.FieldError

type EventTypeList 

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

EventTypeList is a collection of EventTypes.

func (*EventTypeList) DeepCopy 

func (in *EventTypeList) DeepCopy() *EventTypeList

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

func (*EventTypeList) DeepCopyInto 

func (in *EventTypeList) DeepCopyInto(out *EventTypeList)

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

func (*EventTypeList) DeepCopyObject 

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

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

type EventTypeSpec 

type EventTypeSpec struct {
	// Type represents the CloudEvents type. It is authoritative.
	Type string `json:"type"`
	// Source is a URI, it represents the CloudEvents source.
	Source apis.URL `json:"source"`
	// Schema is a URI, it represents the CloudEvents schemaurl extension attribute.
	// It may be a JSON schema, a protobuf schema, etc. It is optional.
	// +optional
	Schema *apis.URL `json:"schema,omitempty"`
	// Broker refers to the Broker that can provide the EventType.
	Broker string `json:"broker"`
	// Description is an optional field used to describe the EventType, in any meaningful way.
	// +optional
	Description string `json:"description,omitempty"`
}

func (*EventTypeSpec) DeepCopy 

func (in *EventTypeSpec) DeepCopy() *EventTypeSpec

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

func (*EventTypeSpec) DeepCopyInto 

func (in *EventTypeSpec) DeepCopyInto(out *EventTypeSpec)

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

func (*EventTypeSpec) SetDefaults 

func (ets *EventTypeSpec) SetDefaults(ctx context.Context)

func (*EventTypeSpec) Validate 

func (ets *EventTypeSpec) Validate(ctx context.Context) *apis.FieldError

type EventTypeStatus 

type EventTypeStatus 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.Status `json:",inline"`
}

EventTypeStatus represents the current state of a EventType.

func (*EventTypeStatus) DeepCopy 

func (in *EventTypeStatus) DeepCopy() *EventTypeStatus

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

func (*EventTypeStatus) DeepCopyInto 

func (in *EventTypeStatus) DeepCopyInto(out *EventTypeStatus)

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 TriggerSpec `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 consumer from a Broker's event pool.

func (*Trigger) CheckImmutableFields 

func (t *Trigger) CheckImmutableFields(ctx context.Context, original *Trigger) *apis.FieldError

CheckImmutableFields checks that any immutable fields were not changed.

func (*Trigger) ConvertFrom 

func (sink *Trigger) ConvertFrom(ctx context.Context, source apis.Convertible) error

ConvertFrom implements apis.Convertible

func (*Trigger) ConvertTo 

func (source *Trigger) ConvertTo(ctx context.Context, sink apis.Convertible) error

ConvertTo implements apis.Convertible

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

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

GetGroupVersionKind returns GroupVersionKind for Triggers

func (*Trigger) GetUntypedSpec 

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

GetUntypedSpec returns the spec of the Trigger.

func (*Trigger) SetDefaults 

func (t *Trigger) SetDefaults(ctx context.Context)

func (*Trigger) Validate 

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

Validate the Trigger.

type TriggerFilter 

type TriggerFilter struct {
	// Attributes filters events by exact match on event context attributes.
	// Each key in the map is compared with the equivalent key in the event
	// context. An event passes the filter if all values are equal to the
	// specified values.
	//
	// Nested context attributes are not supported as keys. Only string values are supported.
	//
	// +optional
	Attributes TriggerFilterAttributes `json:"attributes,omitempty"`
}

func (*TriggerFilter) DeepCopy 

func (in *TriggerFilter) DeepCopy() *TriggerFilter

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

func (*TriggerFilter) DeepCopyInto 

func (in *TriggerFilter) DeepCopyInto(out *TriggerFilter)

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

type TriggerFilterAttributes 

type TriggerFilterAttributes map[string]string

TriggerFilterAttributes is a map of context attribute names to values for filtering by equality. Only exact matches will pass the filter. You can use the value ” to indicate all strings match.

func (TriggerFilterAttributes) DeepCopy 

func (in TriggerFilterAttributes) DeepCopy() TriggerFilterAttributes

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

func (TriggerFilterAttributes) DeepCopyInto 

func (in TriggerFilterAttributes) DeepCopyInto(out *TriggerFilterAttributes)

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. If not specified, will default
	// to 'default'.
	Broker string `json:"broker,omitempty"`

	// Filter is the filter to apply against all events from the Broker. Only events that pass this
	// filter will be sent to the Subscriber. If not specified, will default to allowing all events.
	//
	// +optional
	Filter *TriggerFilter `json:"filter,omitempty"`

	// Subscriber is the addressable that receives events from the Broker that pass the Filter. It
	// is required.
	Subscriber duckv1.Destination `json:"subscriber"`
}

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

func (ts *TriggerSpec) SetDefaults(ctx context.Context)

func (*TriggerSpec) Validate 

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

Validate the TriggerSpec.

type TriggerStatus 

type TriggerStatus 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.Status `json:",inline"`

	// SubscriberURI is the resolved URI of the receiver for this Trigger.
	SubscriberURI *apis.URL `json:"subscriberUri,omitempty"`
}

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

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

func (*TriggerStatus) MarkDependencyNotConfigured 

func (ts *TriggerStatus) MarkDependencyNotConfigured()

func (*TriggerStatus) MarkDependencySucceeded 

func (ts *TriggerStatus) MarkDependencySucceeded()

func (*TriggerStatus) MarkDependencyUnknown 

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

func (*TriggerStatus) MarkNotSubscribed 

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

func (*TriggerStatus) MarkSubscribedUnknown 

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

func (*TriggerStatus) MarkSubscriberResolvedFailed 

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

func (*TriggerStatus) MarkSubscriberResolvedSucceeded 

func (ts *TriggerStatus) MarkSubscriberResolvedSucceeded()

func (*TriggerStatus) MarkSubscriberResolvedUnknown 

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

func (*TriggerStatus) MarkSubscriptionNotConfigured 

func (ts *TriggerStatus) MarkSubscriptionNotConfigured()

func (*TriggerStatus) PropagateBrokerStatus 

func (ts *TriggerStatus) PropagateBrokerStatus(bs *BrokerStatus)

func (*TriggerStatus) PropagateDependencyStatus 

func (ts *TriggerStatus) PropagateDependencyStatus(ks *duckv1.KResource)

func (*TriggerStatus) PropagateSubscriptionCondition 

func (ts *TriggerStatus) PropagateSubscriptionCondition(sc *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.