v1alpha1

package
v0.0.0-...-ea047a2 Latest Latest
Warning

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

 Go to latest Published: Jan 19, 2024 License: Apache-2.0 Imports: 16 Imported by: 7

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 (
	ErrorHubVersionMsg     = "hub version is not the expected v1alpha2 version"
	ErrorMultipleSourceMsg = "subscription contains more than 1 eventSource"
)
View Source 
const (
	ProtocolSettingsContentModeBinary     string = "BINARY"
	ProtocolSettingsContentModeStructured string = "STRUCTURED"
)

TODO: Remove it when depreciating code of v1alpha1

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
)
View Source 
var Finalizer = GroupVersion.Group

Functions

func ConditionEquals 

func ConditionEquals(existing, expected Condition) bool

ConditionEquals checks if two conditions are equal.

func ConditionsEquals 

func ConditionsEquals(existing, expected []Condition) bool

ConditionsEquals checks if two list of conditions are equal.

func ContainSameConditionTypes 

func ContainSameConditionTypes(conditions1, conditions2 []Condition) bool

func CreateMessageForConditionReasonSubscriptionCreated 

func CreateMessageForConditionReasonSubscriptionCreated(bebName string) string

func InitializeEventTypeCleaner 

func InitializeEventTypeCleaner(cleaner eventtype.Cleaner)

func V1ToV2 

func V1ToV2(src *Subscription, dst *v1alpha2.Subscription) error

V1ToV2 copies the v1alpha1-type field values into v1alpha2-type field values.

func V2ToV1 

func V2ToV1(dst *Subscription, src *v1alpha2.Subscription) error

V2ToV1 copies the v1alpha2-type field values into v1alpha1-type field values.

Types

type BEBFilters 

type BEBFilters struct {
	// Contains a `URI-reference` to the CloudEvent filter dialect. See
	// [here](https://github.com/cloudevents/spec/blob/main/subscriptions/spec.md#3241-filter-dialects) for more details.
	// +optional
	Dialect string `json:"dialect,omitempty"`

	Filters []*EventMeshFilter `json:"filters"`
}

BEBFilters defines the list of BEB filters.

func (*BEBFilters) Deduplicate 

func (bf *BEBFilters) Deduplicate() (*BEBFilters, error)

Deduplicate returns a deduplicated copy of BEBFilters.

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 BackendType 

type BackendType string
const (
	BEBBackendType  BackendType = "BEB"
	NatsBackendType BackendType = "NATS"
)

type Condition 

type Condition struct {
	// Short description of the condition.
	Type ConditionType `json:"type,omitempty"`
	// Status of the condition. The value is either `True`, `False`, or `Unknown`.
	Status corev1.ConditionStatus `json:"status"`
	// Defines the date of the last condition status change.
	LastTransitionTime metav1.Time `json:"lastTransitionTime,omitempty"`
	// Defines the reason for the condition status change.
	Reason ConditionReason `json:"reason,omitempty"`
	// Provides more details about the condition status change.
	Message string `json:"message,omitempty"`
}

func ConditionV2ToV1 

func ConditionV2ToV1(condition v1alpha2.Condition) Condition

ConditionV2ToV1 converts the v1alpha2 Condition to v1alpha1 version.

func MakeCondition 

func MakeCondition(conditionType ConditionType, reason ConditionReason, status corev1.ConditionStatus, message string) Condition

func MakeSubscriptionConditions 

func MakeSubscriptionConditions() []Condition

MakeSubscriptionConditions creates a map of all conditions which the Subscription should have.

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 (
	// BEB Conditions.
	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"
	ConditionReasonWebhookCallStatus          ConditionReason = "BEB Subscription webhook call no errors status"
	ConditionReasonOauth2ClientSyncFailed     ConditionReason = "Failed to sync OAuth2 Client Credentials"

	// NATS Conditions.
	ConditionReasonNATSSubscriptionActive    ConditionReason = "NATS Subscription active"
	ConditionReasonNATSSubscriptionNotActive ConditionReason = "NATS Subscription not active"

	// Common backend Conditions.
	ConditionReasonSubscriptionControllerReady    ConditionReason = "Subscription controller started"
	ConditionReasonSubscriptionControllerNotReady ConditionReason = "Subscription controller not ready"
	ConditionReasonPublisherDeploymentReady       ConditionReason = "Publisher proxy deployment ready"
	ConditionReasonPublisherDeploymentNotReady    ConditionReason = "Publisher proxy deployment not ready"
	ConditionReasonBackendCRSyncFailed            ConditionReason = "Backend CR sync failed"
	ConditionReasonPublisherProxySyncFailed       ConditionReason = "Publisher Proxy deployment sync failed"
	ConditionReasonControllerStartFailed          ConditionReason = "Starting the controller failed"
	ConditionReasonControllerStopFailed           ConditionReason = "Stopping the controller failed"
	ConditionReasonPublisherProxySecretError      ConditionReason = "Publisher proxy secret sync failed"
	ConditionDuplicateSecrets                     ConditionReason = "Multiple eventing backend labeled secrets exist"
)

type ConditionType 

type ConditionType string
const (
	ConditionSubscribed         ConditionType = "Subscribed"
	ConditionSubscriptionActive ConditionType = "Subscription active"
	ConditionAPIRuleStatus      ConditionType = "APIRule status"
	ConditionWebhookCallStatus  ConditionType = "Webhook call status"

	ConditionPublisherProxyReady ConditionType = "Publisher Proxy Ready"
	ConditionControllerReady     ConditionType = "Subscription Controller Ready"
)

type EmsSubscriptionStatus 

type EmsSubscriptionStatus struct {
	// Status of the Subscription as reported by EventMesh.
	// +optional
	SubscriptionStatus string `json:"subscriptionStatus,omitempty"`

	// Reason for the current status.
	// +optional
	SubscriptionStatusReason string `json:"subscriptionStatusReason,omitempty"`

	// Timestamp of the last successful delivery.
	// +optional
	LastSuccessfulDelivery string `json:"lastSuccessfulDelivery,omitempty"`

	// Timestamp of the last failed delivery.
	// +optional
	LastFailedDelivery string `json:"lastFailedDelivery,omitempty"`

	// Reason for the last failed delivery.
	// +optional
	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 EventMeshFilter 

type EventMeshFilter struct {
	// Defines the source of the CE filter.
	EventSource *Filter `json:"eventSource"`

	// Defines the type of the CE filter.
	EventType *Filter `json:"eventType"`
}

Defines the BEB filter element as a combination of two CE filter elements.

func (*EventMeshFilter) DeepCopy 

func (in *EventMeshFilter) DeepCopy() *EventMeshFilter

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

func (*EventMeshFilter) DeepCopyInto 

func (in *EventMeshFilter) DeepCopyInto(out *EventMeshFilter)

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

type EventingBackend 

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

	Spec   EventingBackendSpec   `json:"spec,omitempty"`
	Status EventingBackendStatus `json:"status,omitempty"`
}

EventingBackend is the Schema for the eventingbackends API.

func (*EventingBackend) DeepCopy 

func (in *EventingBackend) DeepCopy() *EventingBackend

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

func (*EventingBackend) DeepCopyInto 

func (in *EventingBackend) DeepCopyInto(out *EventingBackend)

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

func (*EventingBackend) DeepCopyObject 

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

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

type EventingBackendList 

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

EventingBackendList contains a list of EventingBackend.

func (*EventingBackendList) DeepCopy 

func (in *EventingBackendList) DeepCopy() *EventingBackendList

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

func (*EventingBackendList) DeepCopyInto 

func (in *EventingBackendList) DeepCopyInto(out *EventingBackendList)

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

func (*EventingBackendList) DeepCopyObject 

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

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

type EventingBackendSpec 

type EventingBackendSpec struct {
}

EventingBackendSpec defines the desired state of EventingBackend.

func (*EventingBackendSpec) DeepCopy 

func (in *EventingBackendSpec) DeepCopy() *EventingBackendSpec

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

func (*EventingBackendSpec) DeepCopyInto 

func (in *EventingBackendSpec) DeepCopyInto(out *EventingBackendSpec)

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

type EventingBackendStatus 

type EventingBackendStatus struct {
	// Specifies the backend type used. The value is either `BEB`, or `NATS`.
	// +optional
	Backend BackendType `json:"backendType"`

	// Defines the overall Backend status.
	// +optional
	EventingReady *bool `json:"eventingReady"`

	// Defines the status of the Controller and the EPP.
	// +optional
	Conditions []Condition `json:"conditions,omitempty"`

	// Name of the Secret containing BEB access tokens, required for BEB only.
	// +optional
	BEBSecretName string `json:"bebSecretName,omitempty"`

	// Namespace of the Secret containing BEB access tokens, required for BEB only.
	// +optional
	BEBSecretNamespace string `json:"bebSecretNamespace,omitempty"`
}

EventingBackendStatus defines the observed state of EventingBackend.

func (*EventingBackendStatus) DeepCopy 

func (in *EventingBackendStatus) DeepCopy() *EventingBackendStatus

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

func (*EventingBackendStatus) DeepCopyInto 

func (in *EventingBackendStatus) DeepCopyInto(out *EventingBackendStatus)

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

func (EventingBackendStatus) FindCondition 

func (b EventingBackendStatus) FindCondition(conditionType ConditionType) *Condition

func (*EventingBackendStatus) InitializeConditions 

func (b *EventingBackendStatus) InitializeConditions()

InitializeConditions sets all the Backend conditions to true.

func (*EventingBackendStatus) IsPublisherStatusReady 

func (b *EventingBackendStatus) IsPublisherStatusReady() bool

func (*EventingBackendStatus) IsSubscriptionControllerStatusReady 

func (b *EventingBackendStatus) IsSubscriptionControllerStatusReady() bool

func (*EventingBackendStatus) SetPublisherReadyCondition 

func (b *EventingBackendStatus) SetPublisherReadyCondition(ready bool, reason ConditionReason, message string)

func (*EventingBackendStatus) SetSubscriptionControllerReadyCondition 

func (b *EventingBackendStatus) SetSubscriptionControllerReadyCondition(ready bool, reason ConditionReason, message string)

type Filter 

type Filter struct {
	// Defines the type of the filter.
	// +optional
	Type string `json:"type,omitempty"`

	// Defines the property of the filter.
	Property string `json:"property"`

	// Defines the value of the filter.
	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 {
	// Defines the content mode for eventing based on BEB.
	//  The value is either `BINARY`, or `STRUCTURED`.
	// +optional
	ContentMode *string `json:"contentMode,omitempty"`

	// Defines if the exempt handshake for eventing is based on BEB.
	// +optional
	ExemptHandshake *bool `json:"exemptHandshake,omitempty"`

	// Defines the quality of service for eventing based on BEB.
	// +optional
	Qos *string `json:"qos,omitempty"`

	// Defines the Webhook called by an active subscription on BEB.
	// +optional
	WebhookAuth *WebhookAuth `json:"webhookAuth,omitempty"`
}

ProtocolSettings defines the CE protocol setting specification implementation. TODO: Remove it when depreciating code of v1alpha1

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. +kubebuilder:object:root=true +kubebuilder:subresource:status +kubebuilder:deprecatedversion:warning=The v1alpha1 API version is deprecated as of Kyma 2.14.X. +kubebuilder:printcolumn:name="Ready",type="string",JSONPath=".status.ready" +kubebuilder:printcolumn:name="Age",type="date",JSONPath=".metadata.creationTimestamp" +kubebuilder:printcolumn:name="Clean Event Types",type="string",JSONPath=".status.cleanEventTypes"

func (*Subscription) ConvertFrom 

func (dst *Subscription) ConvertFrom(srcRaw conversion.Hub) error

ConvertFrom converts this Subscription from the Hub version (v2) to v1.

func (*Subscription) ConvertTo 

func (src *Subscription) ConvertTo(dstRaw conversion.Hub) error

ConvertTo converts this Subscription in version v1 to the Hub version v2.

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.

func (Subscription) MarshalJSON 

func (s Subscription) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface. If the SubscriptionStatus.CleanEventTypes is nil, it will be initialized to an empty slice of stings. It is needed because the Kubernetes APIServer will reject requests containing null in the JSON payload.

func (*Subscription) SetupWebhookWithManager 

func (r *Subscription) SetupWebhookWithManager(mgr ctrl.Manager) error

type SubscriptionConfig 

type SubscriptionConfig struct {
	// Defines how many not-ACKed messages can be in flight simultaneously.
	// +optional
	// +kubebuilder:validation:Minimum=1
	MaxInFlightMessages int `json:"maxInFlightMessages,omitempty"`
}

func MergeSubsConfigs 

func MergeSubsConfigs(config *SubscriptionConfig, defaults *env.DefaultSubscriptionConfig) *SubscriptionConfig

MergeSubsConfigs returns a valid subscription config object based on the provided config, complemented with default values, if necessary.

func (*SubscriptionConfig) DeepCopy 

func (in *SubscriptionConfig) DeepCopy() *SubscriptionConfig

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

func (*SubscriptionConfig) DeepCopyInto 

func (in *SubscriptionConfig) DeepCopyInto(out *SubscriptionConfig)

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

type SubscriptionList 

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

SubscriptionList contains a list of Subscription. +kubebuilder:object:root=true

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 {
	// Unique identifier of the Subscription, read-only.
	// +optional
	ID string `json:"id,omitempty"`

	// Defines the CE protocol specification implementation.
	// +optional
	Protocol string `json:"protocol,omitempty"`

	// Defines the CE protocol settings specification implementation.
	// +optional
	ProtocolSettings *ProtocolSettings `json:"protocolsettings,omitempty"`

	// Kubernetes Service that should be used as a target for the events that match the Subscription.
	// Must exist in the same Namespace as the Subscription.
	Sink string `json:"sink"`

	// Defines which events will be sent to the sink.
	Filter *BEBFilters `json:"filter"`

	// Defines additional configuration for the active backend.
	// +optional
	Config *SubscriptionConfig `json:"config,omitempty"`
}

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 {
	// Current state of the Subscription.
	// +optional
	Conditions []Condition `json:"conditions,omitempty"`

	// Overall readiness of the Subscription.
	Ready bool `json:"ready"`

	// CleanEventTypes defines the filter's event types after cleanup to use it with the configured backend.
	CleanEventTypes []string `json:"cleanEventTypes"`

	// Defines the checksum for the Subscription custom resource.
	// +optional
	Ev2hash int64 `json:"ev2hash,omitempty"`

	// Defines the checksum for the Subscription in EventMesh.
	// +optional
	Emshash int64 `json:"emshash,omitempty"`

	// Defines the webhook URL which is used by EventMesh to trigger subscribers.
	// +optional
	ExternalSink string `json:"externalSink,omitempty"`

	// Defines the reason if a Subscription failed activation in EventMesh.
	// +optional
	FailedActivation string `json:"failedActivation,omitempty"`

	// Defines the name of the APIRule which is used by the Subscription.
	// +optional
	APIRuleName string `json:"apiRuleName,omitempty"`

	// Defines the status of the Subscription in EventMesh.
	// +optional
	EmsSubscriptionStatus *EmsSubscriptionStatus `json:"emsSubscriptionStatus,omitempty"`

	// Defines the configurations that have been applied to the eventing backend when creating this Subscription.
	// +optional
	Config *SubscriptionConfig `json:"config,omitempty"`
}

SubscriptionStatus defines the observed state of the 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) FindCondition 

func (s SubscriptionStatus) FindCondition(conditionType ConditionType) *Condition

func (*SubscriptionStatus) GetConditionAPIRuleStatus 

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

func (*SubscriptionStatus) InitializeCleanEventTypes 

func (s *SubscriptionStatus) InitializeCleanEventTypes()

InitializeCleanEventTypes initializes the SubscriptionStatus.CleanEventTypes with an empty slice of strings.

func (*SubscriptionStatus) InitializeConditions 

func (s *SubscriptionStatus) InitializeConditions()

InitializeConditions sets unset Subscription conditions to Unknown.

func (*SubscriptionStatus) IsConditionSubscribed 

func (s *SubscriptionStatus) IsConditionSubscribed() bool

func (*SubscriptionStatus) IsConditionWebhookCall 

func (s *SubscriptionStatus) IsConditionWebhookCall() bool

func (SubscriptionStatus) IsReady 

func (s SubscriptionStatus) IsReady() bool

func (*SubscriptionStatus) SetConditionAPIRuleStatus 

func (s *SubscriptionStatus) SetConditionAPIRuleStatus(err error)

func (SubscriptionStatus) ShouldUpdateReadyStatus 

func (s SubscriptionStatus) ShouldUpdateReadyStatus() bool

ShouldUpdateReadyStatus checks if there is a mismatch between the subscription Ready Status and the Ready status of all the conditions.

type WebhookAuth 

type WebhookAuth struct {
	// Defines the authentication type.
	// +optional
	Type string `json:"type,omitempty"`

	// Defines the grant type for OAuth2.
	GrantType string `json:"grantType"`

	// Defines the clientID for OAuth2.
	ClientID string `json:"clientId"`

	// Defines the Client Secret for OAuth2.
	ClientSecret string `json:"clientSecret"`

	// Defines the token URL for OAuth2.
	TokenURL string `json:"tokenUrl"`

	// Defines the scope for OAuth2.
	Scope []string `json:"scope,omitempty"`
}

WebhookAuth defines the Webhook called by an active subscription in BEB. TODO: Remove it when depreciating code of v1alpha1

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.