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
- Variables
- type BebFilter
- type BebFilters
- type Condition
- type ConditionReason
- type ConditionType
- type EmsSubscriptionStatus
- type Filter
- type ProtocolSettings
- type Subscription
- type SubscriptionList
- type SubscriptionSpec
- type SubscriptionStatus
- func (in *SubscriptionStatus) DeepCopy() *SubscriptionStatus
- func (in *SubscriptionStatus) DeepCopyInto(out *SubscriptionStatus)
- func (s *SubscriptionStatus) GetConditionAPIRuleStatus() corev1.ConditionStatus
- func (s *SubscriptionStatus) InitializeConditions()
- func (s *SubscriptionStatus) IsConditionSubscribed() bool
- func (s SubscriptionStatus) IsReady() bool
- func (s *SubscriptionStatus) SetConditionAPIRuleStatus(ready bool)
- type WebhookAuth
Constants ¶
const ( ProtocolSettingsContentModeBinary string = "BINARY" ProtocolSettingsContentModeStructured string = "STRUCTURED" )
Variables ¶
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 ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BebFilter.
func (*BebFilter) DeepCopyInto ¶
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 ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Condition.
func (*Condition) DeepCopyInto ¶
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 ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Filter.
func (*Filter) DeepCopyInto ¶
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.