v1alpha1

package
v0.1.63 Latest Latest
Warning

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

 Go to latest Published: Nov 28, 2024 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Overview

Package v1alpha1 contains API Schema definitions for the sources/v1alpha1 API group. +k8s:deepcopy-gen=package +groupName=sources.typhoon.zeiss.com

Index

Constants

View Source 
const (
	// AzureReasonNoClient is set on a status condition when an Azure API client cannot be obtained.
	AzureReasonNoClient = "NoClient"
	// AzureReasonAPIError is set on a status condition when an Azure API returns an error.
	AzureReasonAPIError = "APIError"
)

Reasons for status conditions

View Source 
const (
	// AzureServiceBusConditionSubscribed has status True when the source has subscribed to a topic or queue.
	AzureServiceBusConditionSubscribed apis.ConditionType = "Subscribed"
)

Status conditions

View Source 
const (
	AzureServiceBusGenericEventType = "message"
)

Supported event types

View Source 
const (
	// AzureServiceBusTopicConditionSubscribed has status True when the source has subscribed to a topic.
	AzureServiceBusTopicConditionSubscribed apis.ConditionType = "Subscribed"
)

Status conditions

View Source 
const (
	KafkaSourceEventType = "com.zeiss.kafka.event"
)

Managed event types

View Source 
const (
	OCIMetricsGenericEventType = "com.oracle.cloud.monitoring"
)

Supported event types

View Source 
const (
	// ReasonFailedSync is set on a status condition when some external resource can not be reconciled.
	ReasonFailedSync = "FailedSync"
)

Reasons for status conditions

Variables

View Source 
var (
	// SchemeGroupVersion contains the group and version used to register types for this custom API.
	SchemeGroupVersion = schema.GroupVersion{Group: sources.GroupName, Version: "v1alpha1"}
	// 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: &CloudEventsSource{}, List: &CloudEventsSourceList{}},
	{Single: &KafkaSource{}, List: &KafkaSourceList{}},
	{Single: &HTTPPollerSource{}, List: &HTTPPollerSourceList{}},
	{Single: &OCIMetricsSource{}, List: &OCIMetricsSourceList{}},
	{Single: &WebhookSource{}, List: &WebhookSourceList{}},
	{Single: &SalesforceSource{}, List: &SalesforceSourceList{}},
}

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

Functions

func AWSEventType 

func AWSEventType(awsService, eventType string) string

AWSEventType returns an event type in a format suitable for usage as a CloudEvent type attribute.

func AzureEventType added in v0.1.63 

func AzureEventType(service, eventType string) string

AzureEventType returns an event type in a format suitable for usage as a CloudEvent type attribute.

func EventType 

func EventType(service, eventType string) string

EventType returns an event type in a format suitable for usage as a CloudEvent type attribute.

func Kind 

func Kind(kind string) schema.GroupKind

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

func OCIGenerateEventSource 

func OCIGenerateEventSource(namespace, name string) string

OCIGenerateEventSource generate the event source name to be used in the adapter

func Resource 

func Resource(resource string) schema.GroupResource

Resource takes an unqualified resource and returns a Group qualified GroupResource.

Types

type AzureAuth added in v0.1.63 

type AzureAuth struct {
	// Service principals provide a way to create a non-interactive account
	// associated with your identity to which you grant only the privileges
	// your app needs to run.
	// See https://docs.microsoft.com/en-us/azure/active-directory/develop/app-objects-and-service-principals
	ServicePrincipal *AzureServicePrincipal `json:"servicePrincipal,omitempty"`

	// A shared access signature (SAS) provides secure delegated access to
	// resources in a storage account.
	// See https://docs.microsoft.com/en-us/azure/storage/common/storage-sas-overview
	SASToken *AzureSASToken `json:"sasToken,omitempty"`
}

AzureAuth contains multiple authentication methods for Azure services.

func (*AzureAuth) DeepCopy added in v0.1.63 

func (in *AzureAuth) DeepCopy() *AzureAuth

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

func (*AzureAuth) DeepCopyInto added in v0.1.63 

func (in *AzureAuth) DeepCopyInto(out *AzureAuth)

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

type AzureResourceID added in v0.1.63 

type AzureResourceID struct {
	SubscriptionID   string
	ResourceGroup    string
	ResourceProvider string
	Namespace        string
	ResourceType     string
	ResourceName     string
	SubResourceType  string
	SubResourceName  string
}

AzureResourceID represents a resource ID for an Azure resource.

func (*AzureResourceID) DeepCopy added in v0.1.63 

func (in *AzureResourceID) DeepCopy() *AzureResourceID

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

func (*AzureResourceID) DeepCopyInto added in v0.1.63 

func (in *AzureResourceID) DeepCopyInto(out *AzureResourceID)

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

func (*AzureResourceID) MarshalJSON added in v0.1.63 

func (rID *AzureResourceID) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler nolint:gocyclo

func (*AzureResourceID) String added in v0.1.63 

func (rID *AzureResourceID) String() string

String implements the fmt.Stringer interface.

func (*AzureResourceID) UnmarshalJSON added in v0.1.63 

func (rID *AzureResourceID) UnmarshalJSON(data []byte) error

UnmarshalJSON implements json.Unmarshaler nolint:gocyclo

type AzureSASToken added in v0.1.63 

type AzureSASToken struct {
	KeyName          v1alpha1.ValueFromField `json:"keyName"`
	KeyValue         v1alpha1.ValueFromField `json:"keyValue"`
	ConnectionString v1alpha1.ValueFromField `json:"connectionString"`
}

AzureSASToken represents an Azure SAS token.

func (*AzureSASToken) DeepCopy added in v0.1.63 

func (in *AzureSASToken) DeepCopy() *AzureSASToken

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

func (*AzureSASToken) DeepCopyInto added in v0.1.63 

func (in *AzureSASToken) DeepCopyInto(out *AzureSASToken)

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

type AzureServiceBusQueueSource added in v0.1.63 

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

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

AzureServiceBusQueueSource is the Schema for the event source.

func (*AzureServiceBusQueueSource) AsEventSource added in v0.1.63 

func (s *AzureServiceBusQueueSource) AsEventSource() string

AsEventSource implements EventSource.

func (*AzureServiceBusQueueSource) DeepCopy added in v0.1.63 

func (in *AzureServiceBusQueueSource) DeepCopy() *AzureServiceBusQueueSource

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

func (*AzureServiceBusQueueSource) DeepCopyInto added in v0.1.63 

func (in *AzureServiceBusQueueSource) DeepCopyInto(out *AzureServiceBusQueueSource)

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

func (*AzureServiceBusQueueSource) DeepCopyObject added in v0.1.63 

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

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

func (*AzureServiceBusQueueSource) GetAdapterOverrides added in v0.1.63 

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

GetAdapterOverrides implements AdapterConfigurable.

func (*AzureServiceBusQueueSource) GetConditionSet added in v0.1.63 

func (s *AzureServiceBusQueueSource) GetConditionSet() apis.ConditionSet

GetConditionSet implements duckv1.KRShaped.

func (*AzureServiceBusQueueSource) GetEventTypes added in v0.1.63 

func (s *AzureServiceBusQueueSource) GetEventTypes() []string

GetEventTypes returns the event types generated by the source.

func (*AzureServiceBusQueueSource) GetGroupVersionKind added in v0.1.63 

func (s *AzureServiceBusQueueSource) GetGroupVersionKind() schema.GroupVersionKind

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*AzureServiceBusQueueSource) GetSink added in v0.1.63 

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

GetSink implements EventSender.

func (*AzureServiceBusQueueSource) GetStatus added in v0.1.63 

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

GetStatus implements duckv1.KRShaped.

func (*AzureServiceBusQueueSource) GetStatusManager added in v0.1.63 

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

GetStatusManager implements Reconcilable.

func (*AzureServiceBusQueueSource) SetDefaults added in v0.1.63 

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

SetDefaults implements apis.Defaultable

func (*AzureServiceBusQueueSource) Validate added in v0.1.63 

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

Validate implements apis.Validatable

type AzureServiceBusQueueSourceList added in v0.1.63 

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

AzureServiceBusQueueSourceList contains a list of event sources.

func (*AzureServiceBusQueueSourceList) DeepCopy added in v0.1.63 

func (in *AzureServiceBusQueueSourceList) DeepCopy() *AzureServiceBusQueueSourceList

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

func (*AzureServiceBusQueueSourceList) DeepCopyInto added in v0.1.63 

func (in *AzureServiceBusQueueSourceList) DeepCopyInto(out *AzureServiceBusQueueSourceList)

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

func (*AzureServiceBusQueueSourceList) DeepCopyObject added in v0.1.63 

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

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

type AzureServiceBusQueueSourceSpec added in v0.1.63 

type AzureServiceBusQueueSourceSpec struct {
	duckv1.SourceSpec `json:",inline"`

	// The resource ID the Service Bus Queue to subscribe to.
	//
	// Expected format:
	// - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.ServiceBus/namespaces/{namespaceName}/queues/{queueName}
	QueueID AzureResourceID `json:"queueID"`

	// Authentication method to interact with Azure Service Bus.
	// If it not present, it will try to use Azure AKS Managed Identity
	Auth AzureAuth `json:"auth"`

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

AzureServiceBusQueueSourceSpec defines the desired state of the event source.

func (*AzureServiceBusQueueSourceSpec) DeepCopy added in v0.1.63 

func (in *AzureServiceBusQueueSourceSpec) DeepCopy() *AzureServiceBusQueueSourceSpec

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

func (*AzureServiceBusQueueSourceSpec) DeepCopyInto added in v0.1.63 

func (in *AzureServiceBusQueueSourceSpec) DeepCopyInto(out *AzureServiceBusQueueSourceSpec)

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

type AzureServiceBusSource added in v0.1.63 

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

	Spec   AzureServiceBusSourceSpec   `json:"spec,omitempty"`
	Status AzureServiceBusSourceStatus `json:"status,omitempty"`
}

AzureServiceBusSource is the Schema for the event source.

func (*AzureServiceBusSource) AsEventSource added in v0.1.63 

func (s *AzureServiceBusSource) AsEventSource() string

AsEventSource implements EventSource.

func (*AzureServiceBusSource) DeepCopy added in v0.1.63 

func (in *AzureServiceBusSource) DeepCopy() *AzureServiceBusSource

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

func (*AzureServiceBusSource) DeepCopyInto added in v0.1.63 

func (in *AzureServiceBusSource) DeepCopyInto(out *AzureServiceBusSource)

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

func (*AzureServiceBusSource) DeepCopyObject added in v0.1.63 

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

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

func (*AzureServiceBusSource) GetAdapterOverrides added in v0.1.63 

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

GetAdapterOverrides implements AdapterConfigurable.

func (*AzureServiceBusSource) GetConditionSet added in v0.1.63 

func (s *AzureServiceBusSource) GetConditionSet() apis.ConditionSet

GetConditionSet implements duckv1.KRShaped.

func (*AzureServiceBusSource) GetEventTypes added in v0.1.63 

func (*AzureServiceBusSource) GetEventTypes() []string

GetEventTypes returns the event types generated by the source.

func (*AzureServiceBusSource) GetGroupVersionKind added in v0.1.63 

func (s *AzureServiceBusSource) GetGroupVersionKind() schema.GroupVersionKind

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*AzureServiceBusSource) GetSink added in v0.1.63 

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

GetSink implements EventSender.

func (*AzureServiceBusSource) GetStatus added in v0.1.63 

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

GetStatus implements duckv1.KRShaped.

func (*AzureServiceBusSource) GetStatusManager added in v0.1.63 

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

GetStatusManager implements Reconcilable.

func (*AzureServiceBusSource) SetDefaults added in v0.1.63 

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

SetDefaults implements apis.Defaultable

func (*AzureServiceBusSource) Validate added in v0.1.63 

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

Validate implements apis.Validatable

type AzureServiceBusSourceList added in v0.1.63 

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

AzureServiceBusSourceList contains a list of event sources.

func (*AzureServiceBusSourceList) DeepCopy added in v0.1.63 

func (in *AzureServiceBusSourceList) DeepCopy() *AzureServiceBusSourceList

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

func (*AzureServiceBusSourceList) DeepCopyInto added in v0.1.63 

func (in *AzureServiceBusSourceList) DeepCopyInto(out *AzureServiceBusSourceList)

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

func (*AzureServiceBusSourceList) DeepCopyObject added in v0.1.63 

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

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

type AzureServiceBusSourceSpec added in v0.1.63 

type AzureServiceBusSourceSpec struct {
	duckv1.SourceSpec `json:",inline"`

	// The resource ID the Service Bus Topic to subscribe to.
	//
	// Expected format:
	// - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.ServiceBus/namespaces/{namespaceName}/topics/{topicName}
	// +optional
	TopicID *AzureResourceID `json:"topicID,omitempty"`

	// The resource ID the Service Bus Queue to subscribe to.
	//
	// Expected format:
	// - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.ServiceBus/namespaces/{namespaceName}/queues/{queueName}
	// +optional
	QueueID *AzureResourceID `json:"queueID,omitempty"`

	// Authentication method to interact with the Azure REST API.
	// This event source only supports the ServicePrincipal authentication.
	// If it not present, it will try to use Azure AKS Managed Identity
	Auth AzureAuth `json:"auth"`

	// WebSocketsEnable
	// +optional
	WebSocketsEnable *bool `json:"webSocketsEnable,omitempty"`

	// MaxConcurrent
	// +optional
	MaxConcurrent *int `json:"maxConcurrent,omitempty"`

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

AzureServiceBusSourceSpec defines the desired state of the event source.

func (*AzureServiceBusSourceSpec) DeepCopy added in v0.1.63 

func (in *AzureServiceBusSourceSpec) DeepCopy() *AzureServiceBusSourceSpec

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

func (*AzureServiceBusSourceSpec) DeepCopyInto added in v0.1.63 

func (in *AzureServiceBusSourceSpec) DeepCopyInto(out *AzureServiceBusSourceSpec)

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

type AzureServiceBusSourceStatus added in v0.1.63 

type AzureServiceBusSourceStatus struct {
	v1alpha1.Status `json:",inline"`

	// Resource ID of the Service Bus Subscription that is currently used
	// by the event source for consuming events from the configured Service
	// Bus.
	SubscriptionID *AzureResourceID `json:"subscriptionID,omitempty"`
}

AzureServiceBusSourceStatus defines the observed state of the event source.

func (*AzureServiceBusSourceStatus) DeepCopy added in v0.1.63 

func (in *AzureServiceBusSourceStatus) DeepCopy() *AzureServiceBusSourceStatus

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

func (*AzureServiceBusSourceStatus) DeepCopyInto added in v0.1.63 

func (in *AzureServiceBusSourceStatus) DeepCopyInto(out *AzureServiceBusSourceStatus)

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

func (*AzureServiceBusSourceStatus) MarkNotSubscribed added in v0.1.63 

func (s *AzureServiceBusSourceStatus) MarkNotSubscribed(reason, msg string)

MarkNotSubscribed sets the Subscribed condition to False with the given reason and message.

func (*AzureServiceBusSourceStatus) MarkSubscribed added in v0.1.63 

func (s *AzureServiceBusSourceStatus) MarkSubscribed()

MarkSubscribed sets the Subscribed condition to True.

func (*AzureServiceBusSourceStatus) MarkSubscribedWithReason added in v0.1.63 

func (s *AzureServiceBusSourceStatus) MarkSubscribedWithReason(reason, msg string)

MarkSubscribedWithReason sets the Subscribed condition to True with reason.

type AzureServiceBusTopicSource added in v0.1.63 

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

	Spec   AzureServiceBusTopicSourceSpec   `json:"spec,omitempty"`
	Status AzureServiceBusTopicSourceStatus `json:"status,omitempty"`
}

AzureServiceBusTopicSource is the Schema for the event source.

func (*AzureServiceBusTopicSource) AsEventSource added in v0.1.63 

func (s *AzureServiceBusTopicSource) AsEventSource() string

AsEventSource implements EventSource.

func (*AzureServiceBusTopicSource) DeepCopy added in v0.1.63 

func (in *AzureServiceBusTopicSource) DeepCopy() *AzureServiceBusTopicSource

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

func (*AzureServiceBusTopicSource) DeepCopyInto added in v0.1.63 

func (in *AzureServiceBusTopicSource) DeepCopyInto(out *AzureServiceBusTopicSource)

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

func (*AzureServiceBusTopicSource) DeepCopyObject added in v0.1.63 

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

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

func (*AzureServiceBusTopicSource) GetAdapterOverrides added in v0.1.63 

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

GetAdapterOverrides implements AdapterConfigurable.

func (*AzureServiceBusTopicSource) GetConditionSet added in v0.1.63 

func (s *AzureServiceBusTopicSource) GetConditionSet() apis.ConditionSet

GetConditionSet implements duckv1.KRShaped.

func (*AzureServiceBusTopicSource) GetEventTypes added in v0.1.63 

func (*AzureServiceBusTopicSource) GetEventTypes() []string

GetEventTypes returns the event types generated by the source.

func (*AzureServiceBusTopicSource) GetGroupVersionKind added in v0.1.63 

func (s *AzureServiceBusTopicSource) GetGroupVersionKind() schema.GroupVersionKind

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*AzureServiceBusTopicSource) GetSink added in v0.1.63 

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

GetSink implements EventSender.

func (*AzureServiceBusTopicSource) GetStatus added in v0.1.63 

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

GetStatus implements duckv1.KRShaped.

func (*AzureServiceBusTopicSource) GetStatusManager added in v0.1.63 

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

GetStatusManager implements Reconcilable.

func (*AzureServiceBusTopicSource) SetDefaults added in v0.1.63 

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

SetDefaults implements apis.Defaultable

func (*AzureServiceBusTopicSource) Validate added in v0.1.63 

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

Validate implements apis.Validatable

type AzureServiceBusTopicSourceList added in v0.1.63 

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

AzureServiceBusTopicSourceList contains a list of event sources.

func (*AzureServiceBusTopicSourceList) DeepCopy added in v0.1.63 

func (in *AzureServiceBusTopicSourceList) DeepCopy() *AzureServiceBusTopicSourceList

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

func (*AzureServiceBusTopicSourceList) DeepCopyInto added in v0.1.63 

func (in *AzureServiceBusTopicSourceList) DeepCopyInto(out *AzureServiceBusTopicSourceList)

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

func (*AzureServiceBusTopicSourceList) DeepCopyObject added in v0.1.63 

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

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

type AzureServiceBusTopicSourceSpec added in v0.1.63 

type AzureServiceBusTopicSourceSpec struct {
	duckv1.SourceSpec `json:",inline"`

	// The resource ID the Service Bus Topic to subscribe to.
	//
	// Expected format:
	// - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.ServiceBus/namespaces/{namespaceName}/topics/{topicName}
	TopicID AzureResourceID `json:"topicID"`

	// Authentication method to interact with the Azure REST API.
	// This event source only supports the ServicePrincipal authentication.
	// If it not present, it will try to use Azure AKS Managed Identity
	Auth AzureAuth `json:"auth"`

	// WebSocketsEnable
	// +optional
	WebSocketsEnable *bool `json:"webSocketsEnable,omitempty"`

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

AzureServiceBusTopicSourceSpec defines the desired state of the event source.

func (*AzureServiceBusTopicSourceSpec) DeepCopy added in v0.1.63 

func (in *AzureServiceBusTopicSourceSpec) DeepCopy() *AzureServiceBusTopicSourceSpec

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

func (*AzureServiceBusTopicSourceSpec) DeepCopyInto added in v0.1.63 

func (in *AzureServiceBusTopicSourceSpec) DeepCopyInto(out *AzureServiceBusTopicSourceSpec)

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

type AzureServiceBusTopicSourceStatus added in v0.1.63 

type AzureServiceBusTopicSourceStatus struct {
	v1alpha1.Status `json:",inline"`

	// Resource ID of the Service Bus Subscription that is currently used
	// by the event source for consuming events from the configured Service
	// Bus Topic.
	SubscriptionID *AzureResourceID `json:"subscriptionID,omitempty"`
}

AzureServiceBusTopicSourceStatus defines the observed state of the event source.

func (*AzureServiceBusTopicSourceStatus) DeepCopy added in v0.1.63 

func (in *AzureServiceBusTopicSourceStatus) DeepCopy() *AzureServiceBusTopicSourceStatus

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

func (*AzureServiceBusTopicSourceStatus) DeepCopyInto added in v0.1.63 

func (in *AzureServiceBusTopicSourceStatus) DeepCopyInto(out *AzureServiceBusTopicSourceStatus)

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

func (*AzureServiceBusTopicSourceStatus) MarkNotSubscribed added in v0.1.63 

func (s *AzureServiceBusTopicSourceStatus) MarkNotSubscribed(reason, msg string)

MarkNotSubscribed sets the Subscribed condition to False with the given reason and message.

func (*AzureServiceBusTopicSourceStatus) MarkSubscribed added in v0.1.63 

func (s *AzureServiceBusTopicSourceStatus) MarkSubscribed()

MarkSubscribed sets the Subscribed condition to True.

type AzureServicePrincipal added in v0.1.63 

type AzureServicePrincipal struct {
	TenantID     v1alpha1.ValueFromField `json:"tenantID"`
	ClientID     v1alpha1.ValueFromField `json:"clientID"`
	ClientSecret v1alpha1.ValueFromField `json:"clientSecret"`
}

AzureServicePrincipal represents an AAD Service Principal.

func (*AzureServicePrincipal) DeepCopy added in v0.1.63 

func (in *AzureServicePrincipal) DeepCopy() *AzureServicePrincipal

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

func (*AzureServicePrincipal) DeepCopyInto added in v0.1.63 

func (in *AzureServicePrincipal) DeepCopyInto(out *AzureServicePrincipal)

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

type CloudEventsSource 

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

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

CloudEventsSource is the Schema for the event source.

func (*CloudEventsSource) AsEventSource 

func (s *CloudEventsSource) AsEventSource() string

AsEventSource implements EventSource.

func (*CloudEventsSource) DeepCopy 

func (in *CloudEventsSource) DeepCopy() *CloudEventsSource

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

func (*CloudEventsSource) DeepCopyInto 

func (in *CloudEventsSource) DeepCopyInto(out *CloudEventsSource)

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

func (*CloudEventsSource) DeepCopyObject 

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

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

func (*CloudEventsSource) GetAdapterOverrides 

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

GetAdapterOverrides implements AdapterConfigurable.

func (*CloudEventsSource) GetConditionSet 

func (*CloudEventsSource) GetConditionSet() apis.ConditionSet

GetConditionSet implements duckv1.KRShaped.

func (*CloudEventsSource) GetEventTypes 

func (s *CloudEventsSource) GetEventTypes() []string

GetEventTypes implements EventSource.

func (*CloudEventsSource) GetGroupVersionKind 

func (*CloudEventsSource) GetGroupVersionKind() schema.GroupVersionKind

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*CloudEventsSource) GetSink 

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

GetSink implements EventSender.

func (*CloudEventsSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*CloudEventsSource) GetStatusManager 

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

GetStatusManager implements Reconcilable.

func (*CloudEventsSource) SetDefaults 

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

SetDefaults implements apis.Defaultable

func (*CloudEventsSource) Validate 

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

Validate implements apis.Validatable

type CloudEventsSourceList 

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

CloudEventsSourceList contains a list of event sources.

func (*CloudEventsSourceList) DeepCopy 

func (in *CloudEventsSourceList) DeepCopy() *CloudEventsSourceList

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

func (*CloudEventsSourceList) DeepCopyInto 

func (in *CloudEventsSourceList) DeepCopyInto(out *CloudEventsSourceList)

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

func (*CloudEventsSourceList) DeepCopyObject 

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

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

type CloudEventsSourceSpec 

type CloudEventsSourceSpec struct {
	duckv1.SourceSpec `json:",inline"`

	// Credentials to connect to this source.
	// +optional
	Credentials *HTTPCredentials `json:"credentials,omitempty"`

	// Path under which requests are accepted.
	// +optional
	Path *string `json:"path,omitempty"`

	// RateLimiter for incoming events per adapter instance.
	// A single CloudEventsSource object can create multiple adapter instances,
	// the rate limiting configuration being applied to each of them individually.
	// +optional
	RateLimiter *RateLimiter `json:"rateLimiter,omitempty"`

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

CloudEventsSourceSpec defines the desired state of the event source.

func (*CloudEventsSourceSpec) DeepCopy 

func (in *CloudEventsSourceSpec) DeepCopy() *CloudEventsSourceSpec

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

func (*CloudEventsSourceSpec) DeepCopyInto 

func (in *CloudEventsSourceSpec) DeepCopyInto(out *CloudEventsSourceSpec)

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

func (*CloudEventsSourceSpec) Validate 

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

Validate CloudEventsSource spec

type HTTPBasicAuth 

type HTTPBasicAuth struct {
	Username string                  `json:"username"`
	Password v1alpha1.ValueFromField `json:"password"`
}

HTTPBasicAuth credentials.

func (*HTTPBasicAuth) DeepCopy 

func (in *HTTPBasicAuth) DeepCopy() *HTTPBasicAuth

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

func (*HTTPBasicAuth) DeepCopyInto 

func (in *HTTPBasicAuth) DeepCopyInto(out *HTTPBasicAuth)

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

type HTTPCredentials 

type HTTPCredentials struct {
	BasicAuths []HTTPBasicAuth `json:"basicAuths,omitempty"`
}

HTTPCredentials to be used when receiving requests.

func (*HTTPCredentials) DeepCopy 

func (in *HTTPCredentials) DeepCopy() *HTTPCredentials

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

func (*HTTPCredentials) DeepCopyInto 

func (in *HTTPCredentials) DeepCopyInto(out *HTTPCredentials)

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

func (*HTTPCredentials) Validate 

func (c *HTTPCredentials) Validate(ctx context.Context) *apis.FieldError

type HTTPPollerSource 

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

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

HTTPPollerSource is the schema for the event source.

func (*HTTPPollerSource) AsEventSource 

func (s *HTTPPollerSource) AsEventSource() string

AsEventSource implements EventSource.

func (*HTTPPollerSource) DeepCopy 

func (in *HTTPPollerSource) DeepCopy() *HTTPPollerSource

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

func (*HTTPPollerSource) DeepCopyInto 

func (in *HTTPPollerSource) DeepCopyInto(out *HTTPPollerSource)

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

func (*HTTPPollerSource) DeepCopyObject 

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

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

func (*HTTPPollerSource) GetAdapterOverrides 

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

GetAdapterOverrides implements AdapterConfigurable.

func (*HTTPPollerSource) GetConditionSet 

func (s *HTTPPollerSource) GetConditionSet() apis.ConditionSet

GetConditionSet implements duckv1.KRShaped.

func (*HTTPPollerSource) GetEventTypes 

func (s *HTTPPollerSource) GetEventTypes() []string

GetEventTypes implements EventSource.

func (*HTTPPollerSource) GetGroupVersionKind 

func (*HTTPPollerSource) GetGroupVersionKind() schema.GroupVersionKind

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*HTTPPollerSource) GetSink 

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

GetSink implements EventSender.

func (*HTTPPollerSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*HTTPPollerSource) GetStatusManager 

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

GetStatusManager implements Reconcilable.

func (*HTTPPollerSource) SetDefaults 

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

SetDefaults implements apis.Defaultable

func (*HTTPPollerSource) Validate 

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

Validate implements apis.Validatable

type HTTPPollerSourceList 

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

HTTPPollerSourceList contains a list of event sources.

func (*HTTPPollerSourceList) DeepCopy 

func (in *HTTPPollerSourceList) DeepCopy() *HTTPPollerSourceList

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

func (*HTTPPollerSourceList) DeepCopyInto 

func (in *HTTPPollerSourceList) DeepCopyInto(out *HTTPPollerSourceList)

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

func (*HTTPPollerSourceList) DeepCopyObject 

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

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

type HTTPPollerSourceSpec 

type HTTPPollerSourceSpec struct {
	// inherits duck/v1 SourceSpec, which currently provides:
	// * Sink - a reference to an object that will resolve to a domain name or
	//   a URI directly to use as the sink.
	// * CloudEventOverrides - defines overrides to control the output format
	//   and modifications of the event sent to the sink.
	duckv1.SourceSpec `json:",inline"`

	// Value of the CloudEvents 'type' attribute to set on ingested events.
	// https://github.com/cloudevents/spec/blob/v1.0.1/spec.md#type
	EventType string `json:"eventType"`

	// Value of the CloudEvents 'source' attribute to set on ingested events.
	// https://github.com/cloudevents/spec/blob/v1.0.1/spec.md#source-1
	// +optional
	EventSource *string `json:"eventSource,omitempty"`

	// HTTP/S URL of the endpoint to poll data from.
	Endpoint pkgapis.URL `json:"endpoint"`

	// HTTP request method to use in requests to the specified 'endpoint'.
	// https://developer.mozilla.org/en-US/docs/Web/HTTP/Methods
	Method string `json:"method"`

	// Controls whether the HTTP client verifies the server's certificate
	// chain and host name when communicating over TLS.
	// +optional
	SkipVerify *bool `json:"skipVerify,omitempty"`

	// CA certificate in X.509 format the HTTP client should use to verify
	// the identity of remote servers when communicating over TLS.
	// +optional
	CACertificate *string `json:"caCertificate,omitempty"`

	// User name to set in HTTP requests that require HTTP Basic authentication.
	// +optional
	BasicAuthUsername *string `json:"basicAuthUsername,omitempty"`

	// Password to set in HTTP requests that require HTTP Basic authentication.
	// +optional
	BasicAuthPassword *v1alpha1.ValueFromField `json:"basicAuthPassword,omitempty"`

	// HTTP headers to include in HTTP requests.
	// +optional
	Headers map[string]string `json:"headers,omitempty"`

	// Duration which defines how often the HTTP/S endpoint should be polled.
	// Expressed as a duration string, which format is documented at https://pkg.go.dev/time#ParseDuration.
	Interval apis.Duration `json:"interval"`

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

HTTPPollerSourceSpec defines the desired state of the event source.

func (*HTTPPollerSourceSpec) DeepCopy 

func (in *HTTPPollerSourceSpec) DeepCopy() *HTTPPollerSourceSpec

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

func (*HTTPPollerSourceSpec) DeepCopyInto 

func (in *HTTPPollerSourceSpec) DeepCopyInto(out *HTTPPollerSourceSpec)

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

type KafkaSource 

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

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

KafkaSource is the Schema for the KafkaSource.

func (*KafkaSource) AsEventSource 

func (s *KafkaSource) AsEventSource() string

AsEventSource implements EventSource.

func (*KafkaSource) DeepCopy 

func (in *KafkaSource) DeepCopy() *KafkaSource

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

func (*KafkaSource) DeepCopyInto 

func (in *KafkaSource) DeepCopyInto(out *KafkaSource)

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

func (*KafkaSource) DeepCopyObject 

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

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

func (*KafkaSource) GetAdapterOverrides 

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

GetAdapterOverrides implements AdapterConfigurable.

func (*KafkaSource) GetConditionSet 

func (*KafkaSource) GetConditionSet() apis.ConditionSet

GetConditionSet implements duckv1.KRShaped.

func (*KafkaSource) GetEventTypes 

func (*KafkaSource) GetEventTypes() []string

GetEventTypes implements EventSource.

func (*KafkaSource) GetGroupVersionKind 

func (*KafkaSource) GetGroupVersionKind() schema.GroupVersionKind

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*KafkaSource) GetSink 

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

GetSink implements EventSender.

func (*KafkaSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*KafkaSource) GetStatusManager 

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

GetStatusManager implements Reconcilable.

func (*KafkaSource) SetDefaults 

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

SetDefaults implements apis.Defaultable

func (*KafkaSource) Validate 

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

Validate implements apis.Validatable

type KafkaSourceAuth 

type KafkaSourceAuth struct {
	Kerberos *KafkaSourceKerberos `json:"kerberos,omitempty"`
	TLS      *KafkaSourceTLSAuth  `json:"tls,omitempty"`

	// SASL Enable
	SASLEnable bool `json:"saslEnable"`

	// TLS Enable
	// +optional
	TLSEnable *bool `json:"tlsEnable,omitempty"`

	// SecurityMechanisms holds the assignment of the specific SASL mechanisms.
	// +optional
	SecurityMechanisms *string `json:"securityMechanism,omitempty"`

	// Username Kafka account User
	// +optional
	Username *string `json:"username,omitempty"`

	// Password Kafka account Password
	// +optional
	Password *v1alpha1.ValueFromField `json:"password,omitempty"`
}

KafkaSourceAuth contains Authentication method used to interact with Kafka.

func (*KafkaSourceAuth) DeepCopy 

func (in *KafkaSourceAuth) DeepCopy() *KafkaSourceAuth

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

func (*KafkaSourceAuth) DeepCopyInto 

func (in *KafkaSourceAuth) DeepCopyInto(out *KafkaSourceAuth)

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

type KafkaSourceKerberos 

type KafkaSourceKerberos struct {
	Username    *string                  `json:"username,omitempty"`
	Password    *v1alpha1.ValueFromField `json:"password,omitempty"`
	Realm       *string                  `json:"realm,omitempty"`
	ServiceName *string                  `json:"serviceName,omitempty"`
	ConfigPath  *string                  `json:"configPath,omitempty"`
	KeytabPath  *string                  `json:"keytabPath,omitempty"`
	Config      *v1alpha1.ValueFromField `json:"config,omitempty"`
	Keytab      *v1alpha1.ValueFromField `json:"keytab,omitempty"`
}

KafkaSourceKerberos contains kerberos credentials.

func (*KafkaSourceKerberos) DeepCopy 

func (in *KafkaSourceKerberos) DeepCopy() *KafkaSourceKerberos

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

func (*KafkaSourceKerberos) DeepCopyInto 

func (in *KafkaSourceKerberos) DeepCopyInto(out *KafkaSourceKerberos)

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

type KafkaSourceList 

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

KafkaSourceList contains a list of event sources.

func (*KafkaSourceList) DeepCopy 

func (in *KafkaSourceList) DeepCopy() *KafkaSourceList

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

func (*KafkaSourceList) DeepCopyInto 

func (in *KafkaSourceList) DeepCopyInto(out *KafkaSourceList)

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

func (*KafkaSourceList) DeepCopyObject 

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

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

type KafkaSourceSpec 

type KafkaSourceSpec struct {
	duckv1.SourceSpec `json:",inline"`

	// BootstrapServers holds the name of the Kafka Bootstrap server.
	BootstrapServers []string `json:"bootstrapServers"`

	// Topic holds the name of the Kafka Topic.
	Topic string `json:"topic"`

	// GroupID holds the name of the Kafka Group ID.
	GroupID string `json:"groupID"`

	// Auth contains Authentication method used to interact with Kafka.
	// +optional
	Auth KafkaSourceAuth `json:"auth"`

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

KafkaSourceSpec defines the desired state of the event source.

func (*KafkaSourceSpec) DeepCopy 

func (in *KafkaSourceSpec) DeepCopy() *KafkaSourceSpec

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

func (*KafkaSourceSpec) DeepCopyInto 

func (in *KafkaSourceSpec) DeepCopyInto(out *KafkaSourceSpec)

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

type KafkaSourceTLSAuth 

type KafkaSourceTLSAuth struct {
	CA         *v1alpha1.ValueFromField `json:"ca,omitempty"`
	ClientCert *v1alpha1.ValueFromField `json:"clientCert,omitempty"`
	ClientKey  *v1alpha1.ValueFromField `json:"clientKey,omitempty"`
	SkipVerify *bool                    `json:"skipVerify,omitempty"`
}

KafkaSourceTLSAuth contains kerberos credentials.

func (*KafkaSourceTLSAuth) DeepCopy 

func (in *KafkaSourceTLSAuth) DeepCopy() *KafkaSourceTLSAuth

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

func (*KafkaSourceTLSAuth) DeepCopyInto 

func (in *KafkaSourceTLSAuth) DeepCopyInto(out *KafkaSourceTLSAuth)

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

type OCIMetrics 

type OCIMetrics struct {
	// Human description for the metrics entry
	Name string `json:"name"`

	// Namespace for the query metric to use
	MetricsNamespace string `json:"metricsNamespace"`

	// OCI Metrics Query See https://docs.cloud.oracle.com/en-us/iaas/api/#/en/monitoring/20180401/MetricData
	MetricsQuery string `json:"metricsQuery"`

	// Oracle Compartment OCID
	Compartment *string `json:"oracleCompartment,omitempty"`
}

OCIMetrics represents OCI metrics structure.

func (*OCIMetrics) DeepCopy 

func (in *OCIMetrics) DeepCopy() *OCIMetrics

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

func (*OCIMetrics) DeepCopyInto 

func (in *OCIMetrics) DeepCopyInto(out *OCIMetrics)

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

type OCIMetricsDecodedList 

type OCIMetricsDecodedList []OCIMetrics

OCIMetricsDecodedList is a list of OCI metrics.

func (OCIMetricsDecodedList) Decode 

func (o OCIMetricsDecodedList) Decode(value string) error

Decode deserializes a list of OCI metrics.

func (OCIMetricsDecodedList) DeepCopy 

func (in OCIMetricsDecodedList) DeepCopy() OCIMetricsDecodedList

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

func (OCIMetricsDecodedList) DeepCopyInto 

func (in OCIMetricsDecodedList) DeepCopyInto(out *OCIMetricsDecodedList)

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

type OCIMetricsSource 

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

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

OCIMetricsSource is the schema for the event source.

func (*OCIMetricsSource) AsEventSource 

func (s *OCIMetricsSource) AsEventSource() string

AsEventSource implements EventSource.

func (*OCIMetricsSource) DeepCopy 

func (in *OCIMetricsSource) DeepCopy() *OCIMetricsSource

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

func (*OCIMetricsSource) DeepCopyInto 

func (in *OCIMetricsSource) DeepCopyInto(out *OCIMetricsSource)

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

func (*OCIMetricsSource) DeepCopyObject 

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

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

func (*OCIMetricsSource) GetAdapterOverrides 

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

GetAdapterOverrides implements AdapterConfigurable.

func (*OCIMetricsSource) GetConditionSet 

func (*OCIMetricsSource) GetConditionSet() apis.ConditionSet

GetConditionSet implements duckv1.KRShaped.

func (*OCIMetricsSource) GetEventTypes 

func (*OCIMetricsSource) GetEventTypes() []string

GetEventTypes implements EventSource.

func (*OCIMetricsSource) GetGroupVersionKind 

func (*OCIMetricsSource) GetGroupVersionKind() schema.GroupVersionKind

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*OCIMetricsSource) GetSink 

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

GetSink implements EventSender.

func (*OCIMetricsSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*OCIMetricsSource) GetStatusManager 

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

GetStatusManager implements Reconcilable.

func (*OCIMetricsSource) SetDefaults 

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

SetDefaults implements apis.Defaultable

func (*OCIMetricsSource) Validate 

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

Validate implements apis.Validatable

type OCIMetricsSourceList 

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

OCIMetricsSourceList contains a list of event sources.

func (*OCIMetricsSourceList) DeepCopy 

func (in *OCIMetricsSourceList) DeepCopy() *OCIMetricsSourceList

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

func (*OCIMetricsSourceList) DeepCopyInto 

func (in *OCIMetricsSourceList) DeepCopyInto(out *OCIMetricsSourceList)

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

func (*OCIMetricsSourceList) DeepCopyObject 

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

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

type OCIMetricsSourceSpec 

type OCIMetricsSourceSpec struct {
	// inherits duck/v1 SourceSpec, which currently provides:
	// * Sink - a reference to an object that will resolve to a domain name or
	//   a URI directly to use as the sink.
	// * CloudEventOverrides - defines overrides to control the output format
	//   and modifications of the event sent to the sink.
	duckv1.SourceSpec `json:",inline"`

	// Oracle User API private key
	OracleAPIPrivateKey v1alpha1.ValueFromField `json:"oracleApiPrivateKey"`

	// Oracle User API private key passphrase
	OracleAPIPrivateKeyPassphrase v1alpha1.ValueFromField `json:"oracleApiPrivateKeyPassphrase"`

	// Oracle User API cert fingerprint
	OracleAPIPrivateKeyFingerprint v1alpha1.ValueFromField `json:"oracleApiPrivateKeyFingerprint"`

	// Oracle Tenancy OCID
	Tenancy string `json:"oracleTenancy"`

	// Oracle User OCID associated with the API key
	User string `json:"oracleUser"`

	// Oracle Cloud Region
	Region string `json:"oracleRegion"`

	// OCI Metrics Polling Frequency
	// +optional
	PollingFrequency *string `json:"metricsPollingFrequency,omitempty"`

	// Array of metrics
	Metrics []OCIMetrics `json:"metrics"`

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

OCIMetricsSourceSpec defines the desired state of the event source.

func (*OCIMetricsSourceSpec) DeepCopy 

func (in *OCIMetricsSourceSpec) DeepCopy() *OCIMetricsSourceSpec

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

func (*OCIMetricsSourceSpec) DeepCopyInto 

func (in *OCIMetricsSourceSpec) DeepCopyInto(out *OCIMetricsSourceSpec)

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

type RateLimiter 

type RateLimiter struct {
	// RequestsPerSecond is used to limit the number of requests that a
	// single instance of the CloudEventsSource adapter can accept.
	RequestsPerSecond int `json:"requestsPerSecond"`
}

RateLimiter parameters.

func (*RateLimiter) DeepCopy 

func (in *RateLimiter) DeepCopy() *RateLimiter

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

func (*RateLimiter) DeepCopyInto 

func (in *RateLimiter) DeepCopyInto(out *RateLimiter)

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

type SalesforceAuth added in v0.1.14 

type SalesforceAuth struct {
	ClientID     string `json:"clientID"`
	ClientSecret string `json:"clientSecret"`
	TokenURL     string `json:"tokenURL"`
}

SalesforceAuth contains Salesforce credentials.

func (*SalesforceAuth) DeepCopy added in v0.1.14 

func (in *SalesforceAuth) DeepCopy() *SalesforceAuth

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

func (*SalesforceAuth) DeepCopyInto added in v0.1.14 

func (in *SalesforceAuth) DeepCopyInto(out *SalesforceAuth)

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

type SalesforceSource added in v0.1.14 

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

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

SalesforceSource is the Schema for the event source.

func (*SalesforceSource) AsEventSource added in v0.1.14 

func (s *SalesforceSource) AsEventSource() string

AsEventSource implements EventSource.

func (*SalesforceSource) DeepCopy added in v0.1.14 

func (in *SalesforceSource) DeepCopy() *SalesforceSource

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

func (*SalesforceSource) DeepCopyInto added in v0.1.14 

func (in *SalesforceSource) DeepCopyInto(out *SalesforceSource)

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

func (*SalesforceSource) DeepCopyObject added in v0.1.14 

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

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

func (*SalesforceSource) GetAdapterOverrides added in v0.1.14 

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

GetAdapterOverrides implements AdapterConfigurable.

func (*SalesforceSource) GetConditionSet added in v0.1.14 

func (s *SalesforceSource) GetConditionSet() apis.ConditionSet

GetConditionSet implements duckv1.KRShaped.

func (*SalesforceSource) GetEventTypes added in v0.1.14 

func (s *SalesforceSource) GetEventTypes() []string

GetEventTypes returns the event types generated by the source.

func (*SalesforceSource) GetGroupVersionKind added in v0.1.14 

func (s *SalesforceSource) GetGroupVersionKind() schema.GroupVersionKind

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*SalesforceSource) GetSink added in v0.1.14 

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

GetSink implements EventSender.

func (*SalesforceSource) GetStatus added in v0.1.14 

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

GetStatus implements duckv1.KRShaped.

func (*SalesforceSource) GetStatusManager added in v0.1.14 

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

GetStatusManager implements Reconcilable.

func (*SalesforceSource) SetDefaults added in v0.1.14 

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

SetDefaults implements apis.Defaultable

func (*SalesforceSource) Validate added in v0.1.14 

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

Validate implements apis.Validatable

type SalesforceSourceList added in v0.1.14 

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

SalesforceSourceList contains a list of event sources.

func (*SalesforceSourceList) DeepCopy added in v0.1.14 

func (in *SalesforceSourceList) DeepCopy() *SalesforceSourceList

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

func (*SalesforceSourceList) DeepCopyInto added in v0.1.14 

func (in *SalesforceSourceList) DeepCopyInto(out *SalesforceSourceList)

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

func (*SalesforceSourceList) DeepCopyObject added in v0.1.14 

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

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

type SalesforceSourceSpec added in v0.1.14 

type SalesforceSourceSpec struct {
	duckv1.SourceSpec `json:",inline"`

	// Authentication method to interact with the Salesforce API.
	Auth SalesforceAuth `json:"auth"`

	// InstanceURL of the Salesforce instance.
	InstanceURL string `json:"instanceURL"`

	// APIVersion at Salesforce.
	// +optional
	APIVersion *string `json:"apiVersion"`

	// Subscription to a Salesforce channel
	Subscription SalesforceSubscription `json:"subscription"`

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

SalesforceSourceSpec defines the desired state of the event source.

func (*SalesforceSourceSpec) DeepCopy added in v0.1.14 

func (in *SalesforceSourceSpec) DeepCopy() *SalesforceSourceSpec

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

func (*SalesforceSourceSpec) DeepCopyInto added in v0.1.14 

func (in *SalesforceSourceSpec) DeepCopyInto(out *SalesforceSourceSpec)

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

type SalesforceSubscription added in v0.1.14 

type SalesforceSubscription struct {
	Channel  string `json:"channel"`
	ReplayID *int   `json:"replayID,omitempty"`
}

SalesforceSubscription to connect to.

func (*SalesforceSubscription) DeepCopy added in v0.1.14 

func (in *SalesforceSubscription) DeepCopy() *SalesforceSubscription

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

func (*SalesforceSubscription) DeepCopyInto added in v0.1.14 

func (in *SalesforceSubscription) DeepCopyInto(out *SalesforceSubscription)

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

type WebhookEventExtensionAttributes 

type WebhookEventExtensionAttributes struct {
	// From informs HTTP elements that will be converted into CloudEvents attributes
	// +optional
	From []string `json:"from,omitempty"`
}

WebhookEventExtensionAttributes sets the policy for converting HTTP data into.

func (*WebhookEventExtensionAttributes) DeepCopy 

func (in *WebhookEventExtensionAttributes) DeepCopy() *WebhookEventExtensionAttributes

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

func (*WebhookEventExtensionAttributes) DeepCopyInto 

func (in *WebhookEventExtensionAttributes) DeepCopyInto(out *WebhookEventExtensionAttributes)

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

type WebhookSource 

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

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

WebhookSource is the schema for the event source.

func (*WebhookSource) AsEventSource 

func (s *WebhookSource) AsEventSource() string

AsEventSource implements EventSource.

func (*WebhookSource) DeepCopy 

func (in *WebhookSource) DeepCopy() *WebhookSource

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

func (*WebhookSource) DeepCopyInto 

func (in *WebhookSource) DeepCopyInto(out *WebhookSource)

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

func (*WebhookSource) DeepCopyObject 

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

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

func (*WebhookSource) GetAdapterOverrides 

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

GetAdapterOverrides implements AdapterConfigurable.

func (*WebhookSource) GetConditionSet 

func (s *WebhookSource) GetConditionSet() apis.ConditionSet

GetConditionSet implements duckv1.KRShaped.

func (*WebhookSource) GetEventTypes 

func (s *WebhookSource) GetEventTypes() []string

GetEventTypes implements EventSource.

func (*WebhookSource) GetGroupVersionKind 

func (*WebhookSource) GetGroupVersionKind() schema.GroupVersionKind

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*WebhookSource) GetSink 

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

GetSink implements EventSender.

func (*WebhookSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*WebhookSource) GetStatusManager 

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

GetStatusManager implements Reconcilable.

func (*WebhookSource) SetDefaults 

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

SetDefaults implements apis.Defaultable

func (*WebhookSource) Validate 

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

Validate implements apis.Validatable

type WebhookSourceList 

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

WebhookSourceList contains a list of event sources.

func (*WebhookSourceList) DeepCopy 

func (in *WebhookSourceList) DeepCopy() *WebhookSourceList

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

func (*WebhookSourceList) DeepCopyInto 

func (in *WebhookSourceList) DeepCopyInto(out *WebhookSourceList)

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

func (*WebhookSourceList) DeepCopyObject 

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

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

type WebhookSourceSpec 

type WebhookSourceSpec struct {
	// inherits duck/v1 SourceSpec, which currently provides:
	// * Sink - a reference to an object that will resolve to a domain name or
	//   a URI directly to use as the sink.
	// * CloudEventOverrides - defines overrides to control the output format
	//   and modifications of the event sent to the sink.
	duckv1.SourceSpec `json:",inline"`

	// Value of the CloudEvents 'type' attribute to set on ingested events.
	// https://github.com/cloudevents/spec/blob/v1.0.1/spec.md#type
	EventType string `json:"eventType"`

	// Value of the CloudEvents 'source' attribute to set on ingested events.
	// https://github.com/cloudevents/spec/blob/v1.0.1/spec.md#source-1
	// +optional
	EventSource *string `json:"eventSource,omitempty"`

	// Options to transform HTTP request data into CloudEvent extensions.
	// https://github.com/cloudevents/spec/blob/main/cloudevents/spec.md#extension-context-attributes
	// +optional
	EventExtensionAttributes *WebhookEventExtensionAttributes `json:"eventExtensionAttributes,omitempty"`

	// User name HTTP clients must set to authenticate with the webhook using HTTP Basic authentication.
	// +optional
	BasicAuthUsername *string `json:"basicAuthUsername,omitempty"`

	// Password HTTP clients must set to authenticate with the webhook using HTTP Basic authentication.
	// +optional
	BasicAuthPassword *v1alpha1.ValueFromField `json:"basicAuthPassword,omitempty"`

	// Specifies the CORS Origin to use in pre-flight headers.
	// +optional
	CORSAllowOrigin *string `json:"corsAllowOrigin,omitempty"`

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

WebhookSourceSpec defines the desired state of the event source.

func (*WebhookSourceSpec) DeepCopy 

func (in *WebhookSourceSpec) DeepCopy() *WebhookSourceSpec

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

func (*WebhookSourceSpec) DeepCopyInto 

func (in *WebhookSourceSpec) DeepCopyInto(out *WebhookSourceSpec)

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.