v1alpha1

package
v0.5.1-0...-cc7cbc4 Latest Latest
Warning

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

 Go to latest Published: Dec 21, 2021 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Overview

Package v1alpha1 contains API Schema definitions for the eventing v1alpha1 API group +kubebuilder:object:generate=true +groupName=eventing.kyma-project.io

Index

Constants

View Source 
const (
	ProtocolSettingsContentModeBinary     string = "BINARY"
	ProtocolSettingsContentModeStructured string = "STRUCTURED"
)

Variables

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

	// 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 BebFilter 

type BebFilter struct {
	EventSource *Filter `json:"eventSource"`
	EventType   *Filter `json:"eventType"`
}

BebFilter defines the BEB filter element as a combination of two CE filter elements

func (*BebFilter) DeepCopy 

func (in *BebFilter) DeepCopy() *BebFilter

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

func (*BebFilter) DeepCopyInto 

func (in *BebFilter) DeepCopyInto(out *BebFilter)

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

type BebFilters 

type BebFilters struct {
	Dialect string       `json:"dialect,omitempty"`
	Filters []*BebFilter `json:"filters"`
}

BebFilters defines the list of BEB filters

func (*BebFilters) DeepCopy 

func (in *BebFilters) DeepCopy() *BebFilters

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

func (*BebFilters) DeepCopyInto 

func (in *BebFilters) DeepCopyInto(out *BebFilters)

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

type Condition 

type Condition struct {
	Type               ConditionType          `json:"type,omitempty"`
	Status             corev1.ConditionStatus `json:"status" description:"status of the condition, one of True, False, Unknown"`
	LastTransitionTime metav1.Time            `json:"lastTransitionTime,omitempty"`
	Reason             ConditionReason        `json:"reason,omitempty"`
	Message            string                 `json:"message,omitempty"`
}

func MakeCondition 

func MakeCondition(conditionType ConditionType, reason ConditionReason, status corev1.ConditionStatus, message string) 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.

type ConditionReason 

type ConditionReason string
const (
	ConditionReasonSubscriptionCreated        ConditionReason = "BEB Subscription created"
	ConditionReasonSubscriptionCreationFailed ConditionReason = "BEB Subscription creation failed"
	ConditionReasonSubscriptionActive         ConditionReason = "BEB Subscription active"
	ConditionReasonSubscriptionNotActive      ConditionReason = "BEB Subscription not active"
	ConditionReasonSubscriptionDeleted        ConditionReason = "BEB Subscription deleted"
	ConditionReasonAPIRuleStatusReady         ConditionReason = "APIRule status ready"
	ConditionReasonAPIRuleStatusNotReady      ConditionReason = "APIRule status not ready"
	ConditionReasonNATSSubscriptionActive     ConditionReason = "NATS Subscription active"
)

type ConditionType 

type ConditionType string
const (
	ConditionSubscribed         ConditionType = "Subscribed"
	ConditionSubscriptionActive ConditionType = "Subscription active"
	ConditionAPIRuleStatus      ConditionType = "APIRule status"
)

type EmsSubscriptionStatus 

type EmsSubscriptionStatus struct {
	SubscriptionStatus       string `json:"subscriptionStatus,omitempty"`
	SubscriptionStatusReason string `json:"subscriptionStatusReason,omitempty"`
	LastSuccessfulDelivery   string `json:"lastSuccessfulDelivery,omitempty"`
	LastFailedDelivery       string `json:"lastFailedDelivery,omitempty"`
	LastFailedDeliveryReason string `json:"lastFailedDeliveryReason,omitempty"`
}

func (*EmsSubscriptionStatus) DeepCopy 

func (in *EmsSubscriptionStatus) DeepCopy() *EmsSubscriptionStatus

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

func (*EmsSubscriptionStatus) DeepCopyInto 

func (in *EmsSubscriptionStatus) DeepCopyInto(out *EmsSubscriptionStatus)

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

type Filter 

type Filter struct {
	Type     string `json:"type,omitempty"`
	Property string `json:"property"`
	Value    string `json:"value"`
}

Filter defines the CE filter element

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.

type ProtocolSettings 

type ProtocolSettings struct {
	ContentMode     string       `json:"contentMode,omitempty"`
	ExemptHandshake bool         `json:"exemptHandshake,omitempty"`
	Qos             string       `json:"qos,omitempty"`
	WebhookAuth     *WebhookAuth `json:"webhookAuth,omitempty"`
}

ProtocolSettings defines the CE protocol setting specification implementation

func (*ProtocolSettings) DeepCopy 

func (in *ProtocolSettings) DeepCopy() *ProtocolSettings

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

func (*ProtocolSettings) DeepCopyInto 

func (in *ProtocolSettings) DeepCopyInto(out *ProtocolSettings)

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

type Subscription 

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

	Spec   SubscriptionSpec   `json:"spec,omitempty"`
	Status SubscriptionStatus `json:"status,omitempty"`
}

Subscription is the Schema for the subscriptions API

func (*Subscription) DeepCopy 

func (in *Subscription) DeepCopy() *Subscription

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

func (*Subscription) DeepCopyInto 

func (in *Subscription) DeepCopyInto(out *Subscription)

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

func (*Subscription) DeepCopyObject 

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

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

type SubscriptionList 

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

SubscriptionList contains a list of Subscription

func (*SubscriptionList) DeepCopy 

func (in *SubscriptionList) DeepCopy() *SubscriptionList

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

func (*SubscriptionList) DeepCopyInto 

func (in *SubscriptionList) DeepCopyInto(out *SubscriptionList)

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

func (*SubscriptionList) DeepCopyObject 

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

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

type SubscriptionSpec 

type SubscriptionSpec struct {
	// ID is the unique identifier of Subscription, read-only.
	ID               string            `json:"id,omitempty"`
	Protocol         string            `json:"protocol"`
	ProtocolSettings *ProtocolSettings `json:"protocolsettings"`
	Sink             string            `json:"sink"`
	Filter           *BebFilters       `json:"filter"`
}

SubscriptionSpec defines the desired state of Subscription

func (*SubscriptionSpec) DeepCopy 

func (in *SubscriptionSpec) DeepCopy() *SubscriptionSpec

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

func (*SubscriptionSpec) DeepCopyInto 

func (in *SubscriptionSpec) DeepCopyInto(out *SubscriptionSpec)

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

type SubscriptionStatus 

type SubscriptionStatus struct {
	Conditions            []Condition           `json:"conditions,omitempty"`
	Ready                 bool                  `json:"ready"`
	Ev2hash               int64                 `json:"ev2hash,omitempty"`
	Emshash               int64                 `json:"emshash,omitempty"`
	ExternalSink          string                `json:"externalSink,omitempty"`
	FailedActivation      string                `json:"failedActivation,omitempty"`
	APIRuleName           string                `json:"apiRuleName,omitempty"`
	EmsSubscriptionStatus EmsSubscriptionStatus `json:"emsSubscriptionStatus,omitempty"`
}

SubscriptionStatus defines the observed state of Subscription

func (*SubscriptionStatus) DeepCopy 

func (in *SubscriptionStatus) DeepCopy() *SubscriptionStatus

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

func (*SubscriptionStatus) DeepCopyInto 

func (in *SubscriptionStatus) DeepCopyInto(out *SubscriptionStatus)

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

func (*SubscriptionStatus) GetConditionAPIRuleStatus 

func (s *SubscriptionStatus) GetConditionAPIRuleStatus() corev1.ConditionStatus

func (*SubscriptionStatus) InitializeConditions 

func (s *SubscriptionStatus) InitializeConditions()

InitializeConditions sets unset conditions to Unknown

func (*SubscriptionStatus) IsConditionSubscribed 

func (s *SubscriptionStatus) IsConditionSubscribed() bool

func (SubscriptionStatus) IsReady 

func (s SubscriptionStatus) IsReady() bool

func (*SubscriptionStatus) SetConditionAPIRuleStatus 

func (s *SubscriptionStatus) SetConditionAPIRuleStatus(ready bool)

type WebhookAuth 

type WebhookAuth struct {
	Type         string   `json:"type,omitempty"`
	GrantType    string   `json:"grantType"`
	ClientId     string   `json:"clientId"`
	ClientSecret string   `json:"clientSecret"`
	TokenUrl     string   `json:"tokenUrl"`
	Scope        []string `json:"scope,omitempty"`
}

Webhook defines the Webhook called by an active subscription in BEB

func (*WebhookAuth) DeepCopy 

func (in *WebhookAuth) DeepCopy() *WebhookAuth

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

func (*WebhookAuth) DeepCopyInto 

func (in *WebhookAuth) DeepCopyInto(out *WebhookAuth)

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.