v1alpha1

package
v0.1.12 Latest Latest
Warning

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

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

Documentation

Overview

Package v1alpha1 contains API Schema definitions for the routing/v1alpha1 API group.

+k8s:deepcopy-gen=package +groupName=routing.typhoon.zeiss.com

Index

Constants

View Source 
const (
	FilterGenericEventType = "com.zeiss.routing.filter"
)

Supported event types

View Source 
const (
	SplitterGenericEventType = "com.zeiss.routing.splitter"
)

Supported event types

Variables

View Source 
var (
	// 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
)
View Source 
var AllTypes = []v1alpha1.GroupObject{
	{Single: &Filter{}, List: &FilterList{}},
	{Single: &Splitter{}, List: &SplitterList{}},
}

AllTypes is a list of all the types defined in this package.

View Source 
var SchemeGroupVersion = schema.GroupVersion{Group: routing.GroupName, Version: "v1alpha1"}

SchemeGroupVersion is group version used to register these objects

Functions

func Kind 

func Kind(kind string) schema.GroupKind

Kind takes an unqualified kind and returns back a Group qualified GroupKind

func Resource 

func Resource(resource string) schema.GroupResource

Resource takes an unqualified resource and returns a Group qualified GroupResource

Types

type CloudEventContext 

type CloudEventContext struct {
	Type       string            `json:"type"`
	Source     string            `json:"source"`
	Extensions map[string]string `json:"extensions"`
}

CloudEventContext declares context attributes that will be propagated to resulting events.

func (*CloudEventContext) DeepCopy 

func (in *CloudEventContext) DeepCopy() *CloudEventContext

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

func (*CloudEventContext) DeepCopyInto 

func (in *CloudEventContext) DeepCopyInto(out *CloudEventContext)

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

type Filter 

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

	Spec   FilterSpec      `json:"spec,omitempty"`
	Status v1alpha1.Status `json:"status,omitempty"`
}

Filter is an addressable object that filters incoming events according to provided Common Language Expression

func (*Filter) AsEventSource 

func (f *Filter) AsEventSource() string

AsEventSource implements EventSource.

func (*Filter) DeepCopy 

func (in *Filter) DeepCopy() *Filter

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

func (*Filter) DeepCopyInto 

func (in *Filter) DeepCopyInto(out *Filter)

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

func (*Filter) DeepCopyObject 

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

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

func (*Filter) GetAdapterOverrides 

func (f *Filter) GetAdapterOverrides() *v1alpha1.AdapterOverrides

GetAdapterOverrides implements AdapterConfigurable.

func (*Filter) GetConditionSet 

func (*Filter) GetConditionSet() apis.ConditionSet

GetConditionSet implements duckv1.KRShaped.

func (*Filter) GetEventTypes 

func (*Filter) GetEventTypes() []string

GetEventTypes implements EventSource.

func (*Filter) GetGroupVersionKind 

func (*Filter) GetGroupVersionKind() schema.GroupVersionKind

GetGroupVersionKind implements kmeta.OwnerRefable

func (*Filter) GetSink 

func (f *Filter) GetSink() *duckv1.Destination

GetSink implements EventSender.

func (*Filter) GetStatus 

func (f *Filter) GetStatus() *duckv1.Status

GetStatus implements duckv1.KRShaped.

func (*Filter) GetStatusManager 

func (f *Filter) GetStatusManager() *v1alpha1.StatusManager

GetStatusManager implements Reconcilable.

func (*Filter) IsMultiTenant 

func (*Filter) IsMultiTenant() bool

IsMultiTenant implements MultiTenant.

func (*Filter) SetDefaults 

func (f *Filter) SetDefaults(ctx context.Context)

SetDefaults implements apis.Defaultable

func (*Filter) Validate 

func (f *Filter) Validate(ctx context.Context) *apis.FieldError

Validate implements apis.Validatable

type FilterList 

type FilterList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata"`

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

FilterList is a list of component instances.

func (*FilterList) DeepCopy 

func (in *FilterList) DeepCopy() *FilterList

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

func (*FilterList) DeepCopyInto 

func (in *FilterList) DeepCopyInto(out *FilterList)

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

func (*FilterList) DeepCopyObject 

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

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

type FilterSpec 

type FilterSpec struct {
	Expression string `json:"expression"`

	// Sink is a reference to an object that will resolve to a domain name to use as the sink.
	Sink *duckv1.Destination `json:"sink"`

	// Adapter spec overrides parameters.
	// +optional
	AdapterOverrides *v1alpha1.AdapterOverrides `json:"adapterOverrides,omitempty"`
}

FilterSpec defines the desired state of the component.

func (*FilterSpec) DeepCopy 

func (in *FilterSpec) DeepCopy() *FilterSpec

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

func (*FilterSpec) DeepCopyInto 

func (in *FilterSpec) DeepCopyInto(out *FilterSpec)

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

func (*FilterSpec) Validate 

func (fs *FilterSpec) Validate(ctx context.Context) *apis.FieldError

Validate implements apis.Validatable

type Splitter 

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

	Spec   SplitterSpec    `json:"spec,omitempty"`
	Status v1alpha1.Status `json:"status,omitempty"`
}

Splitter is an addressable object that splits incoming events according to provided specification.

func (*Splitter) AsEventSource 

func (s *Splitter) AsEventSource() string

AsEventSource implements EventSource.

func (*Splitter) DeepCopy 

func (in *Splitter) DeepCopy() *Splitter

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

func (*Splitter) DeepCopyInto 

func (in *Splitter) DeepCopyInto(out *Splitter)

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

func (*Splitter) DeepCopyObject 

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

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

func (*Splitter) GetAdapterOverrides 

func (s *Splitter) GetAdapterOverrides() *v1alpha1.AdapterOverrides

GetAdapterOverrides implements AdapterConfigurable.

func (*Splitter) GetConditionSet 

func (*Splitter) GetConditionSet() apis.ConditionSet

GetConditionSet implements duckv1.KRShaped.

func (*Splitter) GetEventTypes 

func (*Splitter) GetEventTypes() []string

GetEventTypes implements EventSource.

func (*Splitter) GetGroupVersionKind 

func (*Splitter) GetGroupVersionKind() schema.GroupVersionKind

GetGroupVersionKind implements kmeta.OwnerRefable

func (*Splitter) GetSink 

func (s *Splitter) GetSink() *duckv1.Destination

GetSink implements EventSender.

func (*Splitter) GetStatus 

func (s *Splitter) GetStatus() *duckv1.Status

GetStatus implements duckv1.KRShaped.

func (*Splitter) GetStatusManager 

func (s *Splitter) GetStatusManager() *v1alpha1.StatusManager

GetStatusManager implements Reconcilable.

func (*Splitter) IsMultiTenant 

func (*Splitter) IsMultiTenant() bool

IsMultiTenant implements MultiTenant.

func (*Splitter) SetDefaults 

func (s *Splitter) SetDefaults(ctx context.Context)

SetDefaults implements apis.Defaultable

func (*Splitter) Validate 

func (s *Splitter) Validate(ctx context.Context) *apis.FieldError

Validate implements apis.Validatable

type SplitterList 

type SplitterList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata"`

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

SplitterList is a list of component instances.

func (*SplitterList) DeepCopy 

func (in *SplitterList) DeepCopy() *SplitterList

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

func (*SplitterList) DeepCopyInto 

func (in *SplitterList) DeepCopyInto(out *SplitterList)

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

func (*SplitterList) DeepCopyObject 

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

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

type SplitterSpec 

type SplitterSpec struct {
	Path      string              `json:"path"`
	CEContext CloudEventContext   `json:"ceContext"`
	Sink      *duckv1.Destination `json:"sink"`

	// Adapter spec overrides parameters.
	// +optional
	AdapterOverrides *v1alpha1.AdapterOverrides `json:"adapterOverrides,omitempty"`
}

SplitterSpec defines the desired state of the component.

func (*SplitterSpec) DeepCopy 

func (in *SplitterSpec) DeepCopy() *SplitterSpec

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

func (*SplitterSpec) DeepCopyInto 

func (in *SplitterSpec) DeepCopyInto(out *SplitterSpec)

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

func (*SplitterSpec) Validate 

func (ss *SplitterSpec) Validate(ctx context.Context) *apis.FieldError

Validate implements apis.Validatable

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.