v1alpha1

package
v1.5.0 Latest Latest
Warning

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

 Go to latest Published: Apr 26, 2021 License: Apache-2.0 Imports: 24 Imported by: 0

Documentation

Overview

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

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 (
	AzureBlobStorageBlobCreatedEventType      = "Microsoft.Storage.BlobCreated"
	AzureBlobStorageBlobDeletedEventType      = "Microsoft.Storage.BlobDeleted"
	AzureBlobStorageBlobRenamedEventType      = "Microsoft.Storage.BlobRenamed"
	AzureBlobStorageDirectoryCreatedEventType = "Microsoft.Storage.DirectoryCreated"
	AzureBlobStorageDirectoryDeletedEventType = "Microsoft.Storage.DirectoryDeleted"
	AzureBlobStorageDirectoryRenamedEventType = "Microsoft.Storage.DirectoryRenamed"
)

Supported event types (see AzureBlobStorageSourceSpec)

View Source 
const (
	// ConditionReady has status True when the source is ready to send events.
	ConditionReady = apis.ConditionReady
	// ConditionSinkProvided has status True when the source has been configured with a sink target.
	ConditionSinkProvided apis.ConditionType = "SinkProvided"
	// ConditionDeployed has status True when the source's adapter is up and running.
	ConditionDeployed apis.ConditionType = "Deployed"
)

Status conditions

View Source 
const (
	// ReasonSinkNotFound is set on a SinkProvided condition when a sink does not exist.
	ReasonSinkNotFound = "SinkNotFound"
	// ReasonSinkEmpty is set on a SinkProvided condition when a sink URI is empty.
	ReasonSinkEmpty = "EmptySinkURI"

	// ReasonRBACNotBound is set on a Deployed condition when an adapter's
	// ServiceAccount cannot be bound.
	ReasonRBACNotBound = "RBACNotBound"
	// ReasonUnavailable is set on a Deployed condition when an adapter in unavailable.
	ReasonUnavailable = "AdapterUnavailable"

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

Reasons for status conditions

View Source 
const (
	// GCloudReasonNoClient is set on a status condition when a Google Cloud API client cannot be obtained.
	GCloudReasonNoClient = "NoClient"
	// GCloudReasonAPIError is set on a status condition when a Google Cloud API returns an error.
	GCloudReasonAPIError = "APIError"
)

Reasons for status conditions

View Source 
const (
	// https://docs.microsoft.com/en-us/azure/azure-monitor/platform/activity-log-schema
	AzureActivityLogsActivityLogEventType = "activity-log"
)

Supported event types

View Source 
const (
	// AzureActivityLogsConditionSubscribed has status True when Diagnostic Settings are successfully registered for
	// the Azure subscription.
	AzureActivityLogsConditionSubscribed apis.ConditionType = "Subscribed"
)

Status conditions

View Source 
const (
	// AzureBlobStorageConditionSubscribed has status True when an event subscription exists for the source.
	AzureBlobStorageConditionSubscribed apis.ConditionType = "Subscribed"
)

Status conditions

View Source 
const (
	AzureEventHubGenericEventType = "message"
)

Supported event types

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

Status conditions

View Source 
const (
	GoogleCloudPubSubGenericEventType = "com.google.cloud.pubsub.message"
)

Supported event types

View Source 
const (
	GoogleCloudStorageSourceGenericEventType = "com.triggermesh.googlecloudstorage.event"
)
View Source 
const (
	OCIMetricsGenericEventType = "com.oracle.cloud.monitoring"
)

Supported event types

View Source 
const (
	TwilioSourceGenericEventType = "com.triggermesh.twilio.sms"
)

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
)

Functions

func AzureEventHubSourceName added in v1.4.1 

func AzureEventHubSourceName(hubNamespace, hubName string) string

func AzureEventType 

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 GoogleCloudStorageSourceName added in v1.4.1 

func GoogleCloudStorageSourceName(namespace, name string) string

GoogleCloudStorageSourceName returns a unique reference to the source suitable for use as as a CloudEvent source.

func IsMultiTenant added in v1.4.0 

func IsMultiTenant(src EventSource) bool

IsMultiTenant returns whether the given source type is multi-tenant.

func Kind 

func Kind(kind string) schema.GroupKind

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

func NewEventSourceConditionSet added in v0.6.0 

func NewEventSourceConditionSet(cts ...apis.ConditionType) apis.ConditionSet

NewEventSourceConditionSet returns a set of status conditions for an event source. Default conditions can be augmented by passing condition types as function arguments.

func OCIGenerateEventSource added in v0.7.0 

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.

func TwilioSourceName added in v1.2.0 

func TwilioSourceName(namespace, name string) string

TwilioSourceName returns a unique reference to the source suitable for use as as a CloudEvent source.

func WithSource 

func WithSource(ctx context.Context, s EventSource) context.Context

WithSource returns a copy of the parent context in which the value associated with the source key is the given event source.

Types

type AzureActivityLogsSource 

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

	Spec   AzureActivityLogsSourceSpec   `json:"spec,omitempty"`
	Status AzureActivityLogsSourceStatus `json:"status,omitempty"`
}

AzureActivityLogsSource is the Schema for the event source.

func (*AzureActivityLogsSource) AsEventSource added in v0.4.1 

func (s *AzureActivityLogsSource) AsEventSource() string

AsEventSource implements EventSource.

func (*AzureActivityLogsSource) DeepCopy 

func (in *AzureActivityLogsSource) DeepCopy() *AzureActivityLogsSource

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

func (*AzureActivityLogsSource) DeepCopyInto 

func (in *AzureActivityLogsSource) DeepCopyInto(out *AzureActivityLogsSource)

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

func (*AzureActivityLogsSource) DeepCopyObject 

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

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

func (*AzureActivityLogsSource) GetConditionSet 

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

GetConditionSet implements duckv1.KRShaped.

func (*AzureActivityLogsSource) GetEventTypes 

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

GetEventTypes returns the event types generated by the source.

func (*AzureActivityLogsSource) GetGroupVersionKind 

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

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*AzureActivityLogsSource) GetSink 

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

GetSink implements EventSource.

func (*AzureActivityLogsSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*AzureActivityLogsSource) GetStatusManager added in v0.6.0 

func (s *AzureActivityLogsSource) GetStatusManager() *EventSourceStatusManager

GetStatusManager implements EventSource.

type AzureActivityLogsSourceList 

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

AzureActivityLogsSourceList contains a list of event sources.

func (*AzureActivityLogsSourceList) DeepCopy 

func (in *AzureActivityLogsSourceList) DeepCopy() *AzureActivityLogsSourceList

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

func (*AzureActivityLogsSourceList) DeepCopyInto 

func (in *AzureActivityLogsSourceList) DeepCopyInto(out *AzureActivityLogsSourceList)

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

func (*AzureActivityLogsSourceList) DeepCopyObject 

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

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

type AzureActivityLogsSourceSpec 

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

	// Resource ID of either the Event Hubs instance or Event Hubs namespace to send activity logs to.
	// This resource ID also conveniently contains the ID of the subscription which activity logs are to be
	// subscribed to.
	//
	// If the resource ID represents an Event Hubs namespace, Azure automatically creates an Event Hub with the name
	// 'insights-activity-logs' inside that namespace. Otherwise, the user-provided Event Hub is used.
	//
	// Accepted formats:
	// * /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.EventHub/namespaces/{namespaceName}/eventHubs/{eventHubName}
	// * /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.EventHub/namespaces/{namespaceName}
	EventHubID EventHubResourceID `json:"eventHubID"`

	// Name of a SAS policy with Manage permissions inside the Event Hubs namespace referenced in the EventHubID
	// field.
	//
	// Defaults to "RootManageSharedAccessKey".
	//
	// References:
	//  * https://docs.microsoft.com/en-us/rest/api/eventhub/2017-04-01/authorization%20rules%20-%20namespaces/getauthorizationrule
	//  * https://docs.microsoft.com/en-us/azure/event-hubs/authorize-access-shared-access-signature
	//
	// +optional
	EventHubsSASPolicy *string `json:"eventHubsSASPolicy,omitempty"`

	// Categories of Activity Logs to collect.
	//
	// All available categories are selected when this attribute is empty.
	// https://docs.microsoft.com/en-us/azure/azure-monitor/platform/activity-log-schema#categories
	//
	// +optional
	Categories []string `json:"categories,omitempty"`

	// Authentication method to interact with the Azure Monitor REST API.
	// This event source only supports the ServicePrincipal authentication.
	Auth AzureAuth `json:"auth"`
}

AzureActivityLogsSourceSpec defines the desired state of the event source.

func (*AzureActivityLogsSourceSpec) DeepCopy 

func (in *AzureActivityLogsSourceSpec) DeepCopy() *AzureActivityLogsSourceSpec

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

func (*AzureActivityLogsSourceSpec) DeepCopyInto 

func (in *AzureActivityLogsSourceSpec) DeepCopyInto(out *AzureActivityLogsSourceSpec)

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

type AzureActivityLogsSourceStatus 

type AzureActivityLogsSourceStatus struct {
	EventSourceStatus `json:",inline"`
}

AzureActivityLogsSourceStatus defines the observed state of the event source.

func (*AzureActivityLogsSourceStatus) DeepCopy 

func (in *AzureActivityLogsSourceStatus) DeepCopy() *AzureActivityLogsSourceStatus

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

func (*AzureActivityLogsSourceStatus) DeepCopyInto 

func (in *AzureActivityLogsSourceStatus) DeepCopyInto(out *AzureActivityLogsSourceStatus)

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

func (*AzureActivityLogsSourceStatus) MarkNotSubscribed added in v1.4.1 

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

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

func (*AzureActivityLogsSourceStatus) MarkSubscribed added in v1.4.1 

func (s *AzureActivityLogsSourceStatus) MarkSubscribed()

MarkSubscribed sets the Subscribed condition to True.

type AzureAuth 

type AzureAuth struct {
	// SASToken contains either Azure Connection string
	// or a key-value pair required to produce an access token.
	// See https://docs.microsoft.com/en-us/azure/storage/common/storage-sas-overview
	SASToken *AzureSASToken `json:"sasToken,omitempty"`

	// 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"`
}

AzureAuth contains multiple authentication methods for Azure services.

func (*AzureAuth) DeepCopy 

func (in *AzureAuth) DeepCopy() *AzureAuth

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

func (*AzureAuth) DeepCopyInto 

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

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

type AzureBlobStorageSource added in v0.6.0 

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

	Spec   AzureBlobStorageSourceSpec   `json:"spec,omitempty"`
	Status AzureBlobStorageSourceStatus `json:"status,omitempty"`
}

AzureBlobStorageSource is the Schema for the event source.

func (*AzureBlobStorageSource) AsEventSource added in v0.6.0 

func (s *AzureBlobStorageSource) AsEventSource() string

AsEventSource implements EventSource.

func (*AzureBlobStorageSource) DeepCopy added in v0.6.0 

func (in *AzureBlobStorageSource) DeepCopy() *AzureBlobStorageSource

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

func (*AzureBlobStorageSource) DeepCopyInto added in v0.6.0 

func (in *AzureBlobStorageSource) DeepCopyInto(out *AzureBlobStorageSource)

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

func (*AzureBlobStorageSource) DeepCopyObject added in v0.6.0 

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

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

func (*AzureBlobStorageSource) GetConditionSet added in v0.6.0 

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

GetConditionSet implements duckv1.KRShaped.

func (*AzureBlobStorageSource) GetEventTypes added in v0.6.0 

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

GetEventTypes returns the event types generated by the source.

func (*AzureBlobStorageSource) GetGroupVersionKind added in v0.6.0 

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

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*AzureBlobStorageSource) GetSink added in v0.6.0 

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

GetSink implements EventSource.

func (*AzureBlobStorageSource) GetStatus added in v0.6.0 

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

GetStatus implements duckv1.KRShaped.

func (*AzureBlobStorageSource) GetStatusManager added in v0.6.0 

func (s *AzureBlobStorageSource) GetStatusManager() *EventSourceStatusManager

GetStatusManager implements EventSource.

type AzureBlobStorageSourceList added in v0.6.0 

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

AzureBlobStorageSourceList contains a list of event sources.

func (*AzureBlobStorageSourceList) DeepCopy added in v0.6.0 

func (in *AzureBlobStorageSourceList) DeepCopy() *AzureBlobStorageSourceList

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

func (*AzureBlobStorageSourceList) DeepCopyInto added in v0.6.0 

func (in *AzureBlobStorageSourceList) DeepCopyInto(out *AzureBlobStorageSourceList)

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

func (*AzureBlobStorageSourceList) DeepCopyObject added in v0.6.0 

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

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

type AzureBlobStorageSourceSpec added in v0.6.0 

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

	// Resource ID of the Storage Account to receive events for.
	//
	// Format: /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.Storage/storageAccounts/{storageAccountName}
	//
	// Besides the Storage Account name itself, the resource ID contains
	// the subscription ID and resource group name which all together
	// uniquely identify the Storage Account within Azure.
	StorageAccountID StorageAccountResourceID `json:"storageAccountID"`

	// Resource ID of either the Event Hubs instance or Event Hubs
	// namespace to send events to.
	//
	// Accepted formats:
	// * /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.EventHub/namespaces/{namespaceName}/eventHubs/{eventHubName}
	// * /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.EventHub/namespaces/{namespaceName}
	//
	// If the resource ID represents an Event Hubs namespace, an Event Hubs
	// instance is created on behalf of the user inside that namespace.
	// Otherwise, the user-provided Event Hub is used.
	EventHubID EventHubResourceID `json:"eventHubID"`

	// Types of events to subscribe to.
	//
	// The list of available event types can be found at
	// https://docs.microsoft.com/en-us/azure/event-grid/event-schema-blob-storage
	//
	// All types are selected when this attribute is not set.
	//
	// +optional
	EventTypes []string `json:"eventTypes,omitempty"`

	// Authentication method to interact with the Azure REST API.
	// This event source only supports the ServicePrincipal authentication.
	Auth AzureAuth `json:"auth"`
}

AzureBlobStorageSourceSpec defines the desired state of the event source.

func (*AzureBlobStorageSourceSpec) DeepCopy added in v0.6.0 

func (in *AzureBlobStorageSourceSpec) DeepCopy() *AzureBlobStorageSourceSpec

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

func (*AzureBlobStorageSourceSpec) DeepCopyInto added in v0.6.0 

func (in *AzureBlobStorageSourceSpec) DeepCopyInto(out *AzureBlobStorageSourceSpec)

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

type AzureBlobStorageSourceStatus added in v1.4.1 

type AzureBlobStorageSourceStatus struct {
	EventSourceStatus `json:",inline"`
	EventHubID        *EventHubResourceID `json:"eventHubID,omitempty"`
}

AzureBlobStorageSourceStatus defines the observed state of the event source.

func (*AzureBlobStorageSourceStatus) DeepCopy added in v1.4.1 

func (in *AzureBlobStorageSourceStatus) DeepCopy() *AzureBlobStorageSourceStatus

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

func (*AzureBlobStorageSourceStatus) DeepCopyInto added in v1.4.1 

func (in *AzureBlobStorageSourceStatus) DeepCopyInto(out *AzureBlobStorageSourceStatus)

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

func (*AzureBlobStorageSourceStatus) MarkNotSubscribed added in v1.4.1 

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

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

func (*AzureBlobStorageSourceStatus) MarkSubscribed added in v1.4.1 

func (s *AzureBlobStorageSourceStatus) MarkSubscribed()

MarkSubscribed sets the Subscribed condition to True.

type AzureEventHubSource 

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

	Spec   AzureEventHubSourceSpec `json:"spec,omitempty"`
	Status EventSourceStatus       `json:"status,omitempty"`
}

AzureEventHubSource is the Schema for the event source.

func (*AzureEventHubSource) AsEventSource added in v0.4.1 

func (s *AzureEventHubSource) AsEventSource() string

AsEventSource implements EventSource.

func (*AzureEventHubSource) DeepCopy 

func (in *AzureEventHubSource) DeepCopy() *AzureEventHubSource

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

func (*AzureEventHubSource) DeepCopyInto 

func (in *AzureEventHubSource) DeepCopyInto(out *AzureEventHubSource)

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

func (*AzureEventHubSource) DeepCopyObject 

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

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

func (*AzureEventHubSource) GetConditionSet 

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

GetConditionSet implements duckv1.KRShaped.

func (*AzureEventHubSource) GetEventTypes added in v0.4.1 

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

GetEventTypes returns the event types generated by the source.

func (*AzureEventHubSource) GetGroupVersionKind 

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

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*AzureEventHubSource) GetSink 

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

GetSink implements EventSource.

func (*AzureEventHubSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*AzureEventHubSource) GetStatusManager added in v0.6.0 

func (s *AzureEventHubSource) GetStatusManager() *EventSourceStatusManager

GetStatusManager implements EventSource.

func (*AzureEventHubSource) SetDefaults 

func (s *AzureEventHubSource) SetDefaults(_ context.Context)

SetDefaults implements apis.Defaultable.

func (*AzureEventHubSource) Validate 

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

Validate implements apis.Validatable.

type AzureEventHubSourceList 

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

AzureEventHubSourceList contains a list of event sources.

func (*AzureEventHubSourceList) DeepCopy 

func (in *AzureEventHubSourceList) DeepCopy() *AzureEventHubSourceList

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

func (*AzureEventHubSourceList) DeepCopyInto 

func (in *AzureEventHubSourceList) DeepCopyInto(out *AzureEventHubSourceList)

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

func (*AzureEventHubSourceList) DeepCopyObject 

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

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

type AzureEventHubSourceSpec 

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

	// Authentication method to interact with the Azure Event Hubs API.
	Auth AzureAuth `json:"auth"`

	// If we use SP account or SAS token key, we must specify which
	// Event Hub to use
	HubNamespace string `json:"hubNamespace"`
	HubName      string `json:"hubName"`
}

AzureEventHubSourceSpec defines the desired state of the event source.

func (*AzureEventHubSourceSpec) DeepCopy 

func (in *AzureEventHubSourceSpec) DeepCopy() *AzureEventHubSourceSpec

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

func (*AzureEventHubSourceSpec) DeepCopyInto 

func (in *AzureEventHubSourceSpec) DeepCopyInto(out *AzureEventHubSourceSpec)

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

func (*AzureEventHubSourceSpec) ValidateSpec 

func (s *AzureEventHubSourceSpec) ValidateSpec(_ context.Context) *apis.FieldError

ValidateSpec validates Azure Event Hub spec parameters

type AzureSASToken 

type AzureSASToken struct {
	KeyName          *string `json:"keyName"`
	KeyValue         *string `json:"keyValue"`
	ConnectionString *string `json:"connectionString"`
}

AzureSASToken represents Azure shared access signatures auth.

func (*AzureSASToken) DeepCopy 

func (in *AzureSASToken) DeepCopy() *AzureSASToken

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

func (*AzureSASToken) DeepCopyInto 

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

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

type AzureServicePrincipal 

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

AzureServicePrincipal represents an AAD Service Principal.

func (*AzureServicePrincipal) DeepCopy 

func (in *AzureServicePrincipal) DeepCopy() *AzureServicePrincipal

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

func (*AzureServicePrincipal) DeepCopyInto 

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

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

type EventHubResourceID added in v1.4.1 

type EventHubResourceID struct {
	SubscriptionID string
	ResourceGroup  string
	Namespace      string
	EventHub       string
}

EventHubResourceID represents a resource ID for an Event Hubs instance or namespace.

func (*EventHubResourceID) DeepCopy added in v1.4.1 

func (in *EventHubResourceID) DeepCopy() *EventHubResourceID

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

func (*EventHubResourceID) DeepCopyInto added in v1.4.1 

func (in *EventHubResourceID) DeepCopyInto(out *EventHubResourceID)

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

func (EventHubResourceID) MarshalJSON added in v1.4.1 

func (rID EventHubResourceID) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*EventHubResourceID) String added in v1.4.1 

func (rID *EventHubResourceID) String() string

String implements the fmt.Stringer interface.

func (*EventHubResourceID) UnmarshalJSON added in v1.4.1 

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

UnmarshalJSON implements json.Unmarshaler

type EventSource 

type EventSource interface {
	metav1.Object
	runtime.Object
	// OwnerRefable is used to construct a generic reconciler for each
	// source type, and convert source objects to owner references.
	kmeta.OwnerRefable
	// KRShaped is used by generated reconcilers to perform pre and
	// post-reconcile status updates.
	duckv1.KRShaped
	// GetSink returns the source's event sink.
	GetSink() *duckv1.Destination
	// GetStatusManager returns a manager for the source's status.
	GetStatusManager() *EventSourceStatusManager
	// GetEventTypes returns the event types generated by the source.
	GetEventTypes() []string
	// AsEventSource returns a unique reference to the source suitable for
	// use as a CloudEvent source attribute.
	AsEventSource() string
}

EventSource is implemented by all event source types.

func SourceFromContext 

func SourceFromContext(ctx context.Context) EventSource

SourceFromContext returns the source stored in the context.

type EventSourceStatus 

type EventSourceStatus struct {
	duckv1.SourceStatus  `json:",inline"`
	duckv1.AddressStatus `json:",inline"`
}

EventSourceStatus defines the observed state of an event source.

func (*EventSourceStatus) DeepCopy 

func (in *EventSourceStatus) DeepCopy() *EventSourceStatus

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

func (*EventSourceStatus) DeepCopyInto 

func (in *EventSourceStatus) DeepCopyInto(out *EventSourceStatus)

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

type EventSourceStatusManager added in v0.6.0 

type EventSourceStatusManager struct {
	apis.ConditionSet
	*EventSourceStatus
}

EventSourceStatusManager manages the status of event sources.

+k8s:deepcopy-gen=false

func (*EventSourceStatusManager) MarkNoSink added in v0.6.0 

func (m *EventSourceStatusManager) MarkNoSink()

MarkNoSink sets the SinkProvided condition to False.

func (*EventSourceStatusManager) MarkRBACNotBound added in v1.3.0 

func (m *EventSourceStatusManager) MarkRBACNotBound()

MarkRBACNotBound sets the Deployed condition to False, indicating that the adapter's ServiceAccount couldn't be bound.

func (*EventSourceStatusManager) MarkSink added in v0.6.0 

func (m *EventSourceStatusManager) MarkSink(uri *apis.URL)

MarkSink sets the SinkProvided condition to True using the given URI.

func (*EventSourceStatusManager) PropagateDeploymentAvailability added in v0.6.0 

func (m *EventSourceStatusManager) PropagateDeploymentAvailability(ctx context.Context,
	d *appsv1.Deployment, pi coreclientv1.PodInterface)

PropagateDeploymentAvailability uses the readiness of the provided Deployment to determine whether the Deployed condition should be marked as True or False. Given an optional PodInterface, the status of dependant Pods is inspected to generate a more meaningful failure reason in case of non-ready status of the Deployment.

func (*EventSourceStatusManager) PropagateServiceAvailability added in v0.6.0 

func (m *EventSourceStatusManager) PropagateServiceAvailability(ksvc *servingv1.Service)

PropagateServiceAvailability uses the readiness of the provided Service to determine whether the Deployed condition should be marked as True or False.

func (*EventSourceStatusManager) SetRoute added in v1.4.0 

func (m *EventSourceStatusManager) SetRoute(urlPath string)

SetRoute appends the given URL path to the current source's URL.

type GCloudPubSubResourceName added in v1.5.0 

type GCloudPubSubResourceName struct {
	Project    string
	Collection string
	Resource   string
}

GCloudPubSubResourceName represents a fully qualified Pub/Sub resource name, as described at 

https://cloud.google.com/pubsub/docs/admin#resource_names

Examples of such resource names include:

  • projects/{project_name}/topics/{topic_name}
  • projects/{project_name}/subscriptions/{subscription_name}

func (*GCloudPubSubResourceName) DeepCopy added in v1.5.0 

func (in *GCloudPubSubResourceName) DeepCopy() *GCloudPubSubResourceName

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

func (*GCloudPubSubResourceName) DeepCopyInto added in v1.5.0 

func (in *GCloudPubSubResourceName) DeepCopyInto(out *GCloudPubSubResourceName)

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

func (GCloudPubSubResourceName) MarshalJSON added in v1.5.0 

func (n GCloudPubSubResourceName) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*GCloudPubSubResourceName) String added in v1.5.0 

func (n *GCloudPubSubResourceName) String() string

String implements the fmt.Stringer interface.

func (*GCloudPubSubResourceName) UnmarshalJSON added in v1.5.0 

func (n *GCloudPubSubResourceName) UnmarshalJSON(data []byte) error

UnmarshalJSON implements json.Unmarshaler

type GoogleCloudPubSubSource added in v1.5.0 

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

	Spec   GoogleCloudPubSubSourceSpec   `json:"spec,omitempty"`
	Status GoogleCloudPubSubSourceStatus `json:"status,omitempty"`
}

GoogleCloudPubSubSource is the Schema for the event source.

func (*GoogleCloudPubSubSource) AsEventSource added in v1.5.0 

func (s *GoogleCloudPubSubSource) AsEventSource() string

AsEventSource implements EventSource.

func (*GoogleCloudPubSubSource) DeepCopy added in v1.5.0 

func (in *GoogleCloudPubSubSource) DeepCopy() *GoogleCloudPubSubSource

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

func (*GoogleCloudPubSubSource) DeepCopyInto added in v1.5.0 

func (in *GoogleCloudPubSubSource) DeepCopyInto(out *GoogleCloudPubSubSource)

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

func (*GoogleCloudPubSubSource) DeepCopyObject added in v1.5.0 

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

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

func (*GoogleCloudPubSubSource) GetConditionSet added in v1.5.0 

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

GetConditionSet implements duckv1.KRShaped.

func (*GoogleCloudPubSubSource) GetEventTypes added in v1.5.0 

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

GetEventTypes returns the event types generated by the source.

func (*GoogleCloudPubSubSource) GetGroupVersionKind added in v1.5.0 

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

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*GoogleCloudPubSubSource) GetSink added in v1.5.0 

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

GetSink implements EventSource.

func (*GoogleCloudPubSubSource) GetStatus added in v1.5.0 

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

GetStatus implements duckv1.KRShaped.

func (*GoogleCloudPubSubSource) GetStatusManager added in v1.5.0 

func (s *GoogleCloudPubSubSource) GetStatusManager() *EventSourceStatusManager

GetStatusManager implements EventSource.

type GoogleCloudPubSubSourceList added in v1.5.0 

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

GoogleCloudPubSubSourceList contains a list of event sources.

func (*GoogleCloudPubSubSourceList) DeepCopy added in v1.5.0 

func (in *GoogleCloudPubSubSourceList) DeepCopy() *GoogleCloudPubSubSourceList

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

func (*GoogleCloudPubSubSourceList) DeepCopyInto added in v1.5.0 

func (in *GoogleCloudPubSubSourceList) DeepCopyInto(out *GoogleCloudPubSubSourceList)

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

func (*GoogleCloudPubSubSourceList) DeepCopyObject added in v1.5.0 

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

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

type GoogleCloudPubSubSourceSpec added in v1.5.0 

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

	// Full resource name of the Pub/Sub topic to subscribe to, in the
	// format "projects/{project_name}/topics/{topic_name}".
	Topic GCloudPubSubResourceName `json:"topic"`

	// ID of the subscription to use to pull messages from the topic.
	//
	// If supplied, this subscription must 1) exist and 2) belong to the
	// provided topic. Otherwise, a pull subscription to that topic is
	// created on behalf of the user.
	//
	// +optional
	SubscriptionID *string `json:"subscriptionID,omitempty"`

	// Service account key in JSON format.
	// https://cloud.google.com/iam/docs/creating-managing-service-account-keys
	ServiceAccountKey ValueFromField `json:"serviceAccountKey"`
}

GoogleCloudPubSubSourceSpec defines the desired state of the event source.

func (*GoogleCloudPubSubSourceSpec) DeepCopy added in v1.5.0 

func (in *GoogleCloudPubSubSourceSpec) DeepCopy() *GoogleCloudPubSubSourceSpec

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

func (*GoogleCloudPubSubSourceSpec) DeepCopyInto added in v1.5.0 

func (in *GoogleCloudPubSubSourceSpec) DeepCopyInto(out *GoogleCloudPubSubSourceSpec)

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

type GoogleCloudPubSubSourceStatus added in v1.5.0 

type GoogleCloudPubSubSourceStatus struct {
	EventSourceStatus `json:",inline"`
	Subscription      *GCloudPubSubResourceName `json:"subscription,omitempty"`
}

GoogleCloudPubSubSourceStatus defines the observed state of the event source.

func (*GoogleCloudPubSubSourceStatus) DeepCopy added in v1.5.0 

func (in *GoogleCloudPubSubSourceStatus) DeepCopy() *GoogleCloudPubSubSourceStatus

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

func (*GoogleCloudPubSubSourceStatus) DeepCopyInto added in v1.5.0 

func (in *GoogleCloudPubSubSourceStatus) DeepCopyInto(out *GoogleCloudPubSubSourceStatus)

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

func (*GoogleCloudPubSubSourceStatus) MarkNotSubscribed added in v1.5.0 

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

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

func (*GoogleCloudPubSubSourceStatus) MarkSubscribed added in v1.5.0 

func (s *GoogleCloudPubSubSourceStatus) MarkSubscribed()

MarkSubscribed sets the Subscribed condition to True.

type GoogleCloudStorageSource added in v1.4.1 

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

	Spec   GoogleCloudStorageSourceSpec `json:"spec,omitempty"`
	Status EventSourceStatus            `json:"status,omitempty"`
}

GoogleCloudStorageSource is the schema for the event source.

func (*GoogleCloudStorageSource) AsEventSource added in v1.4.1 

func (s *GoogleCloudStorageSource) AsEventSource() string

AsEventSource implements EventSource.

func (*GoogleCloudStorageSource) DeepCopy added in v1.4.1 

func (in *GoogleCloudStorageSource) DeepCopy() *GoogleCloudStorageSource

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

func (*GoogleCloudStorageSource) DeepCopyInto added in v1.4.1 

func (in *GoogleCloudStorageSource) DeepCopyInto(out *GoogleCloudStorageSource)

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

func (*GoogleCloudStorageSource) DeepCopyObject added in v1.4.1 

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

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

func (*GoogleCloudStorageSource) GetConditionSet added in v1.4.1 

func (s *GoogleCloudStorageSource) GetConditionSet() pkgapis.ConditionSet

GetConditionSet implements duckv1.KRShaped.

func (*GoogleCloudStorageSource) GetEventTypes added in v1.4.1 

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

GetEventTypes implements EventSource.

func (*GoogleCloudStorageSource) GetGroupVersionKind added in v1.4.1 

func (*GoogleCloudStorageSource) GetGroupVersionKind() schema.GroupVersionKind

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*GoogleCloudStorageSource) GetSink added in v1.4.1 

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

GetSink implements EventSource.

func (*GoogleCloudStorageSource) GetStatus added in v1.4.1 

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

GetStatus implements duckv1.KRShaped.

func (*GoogleCloudStorageSource) GetStatusManager added in v1.4.1 

func (s *GoogleCloudStorageSource) GetStatusManager() *EventSourceStatusManager

GetStatusManager implements EventSource.

type GoogleCloudStorageSourceList added in v1.4.1 

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

GoogleCloudStorageSourceList contains a list of event sources.

func (*GoogleCloudStorageSourceList) DeepCopy added in v1.4.1 

func (in *GoogleCloudStorageSourceList) DeepCopy() *GoogleCloudStorageSourceList

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

func (*GoogleCloudStorageSourceList) DeepCopyInto added in v1.4.1 

func (in *GoogleCloudStorageSourceList) DeepCopyInto(out *GoogleCloudStorageSourceList)

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

func (*GoogleCloudStorageSourceList) DeepCopyObject added in v1.4.1 

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

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

type GoogleCloudStorageSourceSpec added in v1.4.1 

type GoogleCloudStorageSourceSpec struct {
	duckv1.SourceSpec `json:",inline"`
	// ID of the Google Cloud Project that the Google Cloud Storage resources live under
	Project string `json:"project"`
	// Service account's JSON credentials
	Credentials ValueFromField `json:"credentials"`
	// PubSub Subscription
	Subscription string `json:"subscription"`
}

GoogleCloudStorageSourceSpec defines the desired state of the event source.

func (*GoogleCloudStorageSourceSpec) DeepCopy added in v1.4.1 

func (in *GoogleCloudStorageSourceSpec) DeepCopy() *GoogleCloudStorageSourceSpec

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

func (*GoogleCloudStorageSourceSpec) DeepCopyInto added in v1.4.1 

func (in *GoogleCloudStorageSourceSpec) DeepCopyInto(out *GoogleCloudStorageSourceSpec)

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

type OCIMetrics added in v1.3.0 

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"`
}

func (*OCIMetrics) DeepCopy added in v1.3.0 

func (in *OCIMetrics) DeepCopy() *OCIMetrics

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

func (*OCIMetrics) DeepCopyInto added in v1.3.0 

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 added in v1.3.0 

type OCIMetricsDecodedList []OCIMetrics

func (*OCIMetricsDecodedList) Decode added in v1.3.0 

func (o *OCIMetricsDecodedList) Decode(value string) error

func (OCIMetricsDecodedList) DeepCopy added in v1.3.0 

func (in OCIMetricsDecodedList) DeepCopy() OCIMetricsDecodedList

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

func (OCIMetricsDecodedList) DeepCopyInto added in v1.3.0 

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 added in v0.7.0 

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

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

OCIMetricsSource is the schema for the event source.

func (*OCIMetricsSource) AsEventSource added in v0.7.0 

func (s *OCIMetricsSource) AsEventSource() string

AsEventSource implements EventSource.

func (*OCIMetricsSource) DeepCopy added in v0.7.0 

func (in *OCIMetricsSource) DeepCopy() *OCIMetricsSource

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

func (*OCIMetricsSource) DeepCopyInto added in v0.7.0 

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 added in v0.7.0 

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

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

func (*OCIMetricsSource) GetConditionSet added in v0.7.0 

func (*OCIMetricsSource) GetConditionSet() pkgapis.ConditionSet

GetConditionSet implements duckv1.KRShaped.

func (*OCIMetricsSource) GetEventTypes added in v0.7.0 

func (*OCIMetricsSource) GetEventTypes() []string

GetEventTypes implements EventSource.

func (*OCIMetricsSource) GetGroupVersionKind added in v0.7.0 

func (*OCIMetricsSource) GetGroupVersionKind() schema.GroupVersionKind

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*OCIMetricsSource) GetSink added in v0.7.0 

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

GetSink implements EventSource.

func (*OCIMetricsSource) GetStatus added in v0.7.0 

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

GetStatus implements duckv1.KRShaped.

func (*OCIMetricsSource) GetStatusManager added in v0.7.0 

func (s *OCIMetricsSource) GetStatusManager() *EventSourceStatusManager

GetStatusManager implements EventSource.

type OCIMetricsSourceList added in v0.7.0 

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 added in v0.7.0 

func (in *OCIMetricsSourceList) DeepCopy() *OCIMetricsSourceList

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

func (*OCIMetricsSourceList) DeepCopyInto added in v0.7.0 

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 added in v0.7.0 

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

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

type OCIMetricsSourceSpec added in v0.7.0 

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 ValueFromField `json:"oracleApiPrivateKey"`

	// Oracle User API private key passphrase
	OracleApiPrivateKeyPassphrase ValueFromField `json:"oracleApiPrivateKeyPassphrase"`

	// Oracle User API cert fingerprint
	OracleApiPrivateKeyFingerprint 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"`
}

OCIMetricsSourceSpec defines the desired state of the event source.

func (*OCIMetricsSourceSpec) DeepCopy added in v0.7.0 

func (in *OCIMetricsSourceSpec) DeepCopy() *OCIMetricsSourceSpec

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

func (*OCIMetricsSourceSpec) DeepCopyInto added in v0.7.0 

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

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

type SalesforceAuth added in v0.6.0 

type SalesforceAuth struct {
	ClientID string         `json:"clientID"`
	Server   string         `json:"server"`
	User     string         `json:"user"`
	CertKey  ValueFromField `json:"certKey"`
}

SalesforceAuth contains Salesforce credentials.

func (*SalesforceAuth) DeepCopy added in v0.6.0 

func (in *SalesforceAuth) DeepCopy() *SalesforceAuth

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

func (*SalesforceAuth) DeepCopyInto added in v0.6.0 

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.6.0 

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

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

SalesforceSource is the Schema for the event source.

func (*SalesforceSource) AsEventSource added in v0.6.0 

func (s *SalesforceSource) AsEventSource() string

AsEventSource implements EventSource.

func (*SalesforceSource) DeepCopy added in v0.6.0 

func (in *SalesforceSource) DeepCopy() *SalesforceSource

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

func (*SalesforceSource) DeepCopyInto added in v0.6.0 

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.6.0 

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

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

func (*SalesforceSource) GetConditionSet added in v0.6.0 

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

GetConditionSet implements duckv1.KRShaped.

func (*SalesforceSource) GetEventTypes added in v0.6.0 

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

GetEventTypes returns the event types generated by the source.

func (*SalesforceSource) GetGroupVersionKind added in v0.6.0 

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

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*SalesforceSource) GetSink added in v0.6.0 

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

GetSink implements EventSource.

func (*SalesforceSource) GetStatus added in v0.6.0 

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

GetStatus implements duckv1.KRShaped.

func (*SalesforceSource) GetStatusManager added in v0.6.0 

func (s *SalesforceSource) GetStatusManager() *EventSourceStatusManager

GetStatusManager implements EventSource.

type SalesforceSourceList added in v0.6.0 

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.6.0 

func (in *SalesforceSourceList) DeepCopy() *SalesforceSourceList

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

func (*SalesforceSourceList) DeepCopyInto added in v0.6.0 

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.6.0 

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.6.0 

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

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

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

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

	// EventStore connection
	// +optional
	EventStore *esv1alpha1.EventStoreConnection `json:"eventStore"`
}

SalesforceSourceSpec defines the desired state of the event source.

func (*SalesforceSourceSpec) DeepCopy added in v0.6.0 

func (in *SalesforceSourceSpec) DeepCopy() *SalesforceSourceSpec

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

func (*SalesforceSourceSpec) DeepCopyInto added in v0.6.0 

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.6.0 

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

SalesforceSubscription to connect to.

func (*SalesforceSubscription) DeepCopy added in v0.6.0 

func (in *SalesforceSubscription) DeepCopy() *SalesforceSubscription

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

func (*SalesforceSubscription) DeepCopyInto added in v0.6.0 

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

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

type StorageAccountResourceID added in v1.4.1 

type StorageAccountResourceID struct {
	SubscriptionID string
	ResourceGroup  string
	StorageAccount string
}

StorageAccountResourceID represents a resource ID for a Storage Account.

func (*StorageAccountResourceID) DeepCopy added in v1.4.1 

func (in *StorageAccountResourceID) DeepCopy() *StorageAccountResourceID

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

func (*StorageAccountResourceID) DeepCopyInto added in v1.4.1 

func (in *StorageAccountResourceID) DeepCopyInto(out *StorageAccountResourceID)

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

func (StorageAccountResourceID) MarshalJSON added in v1.4.1 

func (rID StorageAccountResourceID) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*StorageAccountResourceID) String added in v1.4.1 

func (rID *StorageAccountResourceID) String() string

String implements the fmt.Stringer interface.

func (*StorageAccountResourceID) UnmarshalJSON added in v1.4.1 

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

UnmarshalJSON implements json.Unmarshaler

type TwilioSource added in v1.2.0 

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

	Spec   TwilioSourceSpec  `json:"spec,omitempty"`
	Status EventSourceStatus `json:"status,omitempty"`
}

TwilioSource is the schema for the event source.

func (*TwilioSource) AsEventSource added in v1.2.0 

func (s *TwilioSource) AsEventSource() string

AsEventSource implements EventSource.

func (*TwilioSource) DeepCopy added in v1.2.0 

func (in *TwilioSource) DeepCopy() *TwilioSource

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

func (*TwilioSource) DeepCopyInto added in v1.2.0 

func (in *TwilioSource) DeepCopyInto(out *TwilioSource)

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

func (*TwilioSource) DeepCopyObject added in v1.2.0 

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

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

func (*TwilioSource) GetConditionSet added in v1.2.0 

func (s *TwilioSource) GetConditionSet() pkgapis.ConditionSet

GetConditionSet implements duckv1.KRShaped.

func (*TwilioSource) GetEventTypes added in v1.2.0 

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

GetEventTypes implements EventSource.

func (*TwilioSource) GetGroupVersionKind added in v1.2.0 

func (*TwilioSource) GetGroupVersionKind() schema.GroupVersionKind

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*TwilioSource) GetSink added in v1.2.0 

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

GetSink implements EventSource.

func (*TwilioSource) GetStatus added in v1.2.0 

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

GetStatus implements duckv1.KRShaped.

func (*TwilioSource) GetStatusManager added in v1.2.0 

func (s *TwilioSource) GetStatusManager() *EventSourceStatusManager

GetStatusManager implements EventSource.

type TwilioSourceList added in v1.2.0 

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

TwilioSourceList contains a list of event sources.

func (*TwilioSourceList) DeepCopy added in v1.2.0 

func (in *TwilioSourceList) DeepCopy() *TwilioSourceList

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

func (*TwilioSourceList) DeepCopyInto added in v1.2.0 

func (in *TwilioSourceList) DeepCopyInto(out *TwilioSourceList)

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

func (*TwilioSourceList) DeepCopyObject added in v1.2.0 

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

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

type TwilioSourceSpec added in v1.2.0 

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

TwilioSourceSpec defines the desired state of the event source.

func (*TwilioSourceSpec) DeepCopy added in v1.2.0 

func (in *TwilioSourceSpec) DeepCopy() *TwilioSourceSpec

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

func (*TwilioSourceSpec) DeepCopyInto added in v1.2.0 

func (in *TwilioSourceSpec) DeepCopyInto(out *TwilioSourceSpec)

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

type ValueFromField 

type ValueFromField struct {

	// Field value.
	// +optional
	Value string `json:"value,omitempty"`
	// Field value from a Kubernetes Secret.
	// +optional
	ValueFromSecret *corev1.SecretKeySelector `json:"valueFromSecret,omitempty"`
}

ValueFromField is a struct field that can have its value either defined explicitly or sourced from another entity.

func (*ValueFromField) DeepCopy 

func (in *ValueFromField) DeepCopy() *ValueFromField

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

func (*ValueFromField) DeepCopyInto 

func (in *ValueFromField) DeepCopyInto(out *ValueFromField)

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.