v1alpha1

package
v1.0.0 Latest Latest
Warning

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

 Go to latest Published: Nov 11, 2020 License: Apache-2.0 Imports: 22 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 (
	// AzureActivityLogsConditionReady has status True when the source is ready to send events.
	AzureActivityLogsConditionReady = apis.ConditionReady
	// AzureActivityLogsConditionDiagnosticSettings has status True when diagnostic settings exist for the source.
	AzureActivityLogsConditionDiagnosticSettings apis.ConditionType = "DiagnosticSettings"
)

Status conditions

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"

	// ReasonUnavailable is set on a Deployed condition when an adapter in unavailable.
	ReasonUnavailable = "AdapterUnavailable"
)

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 (
	// AzureActivityLogsReasonFailedSync is set on a condition when some external resource can not be reconciled.
	AzureActivityLogsReasonFailedSync = "FailedSync"
)

Reasons for status conditions

View Source 
const (
	AzureBlobStorageEventType = "event"
)

Supported event types

View Source 
const (
	AzureEventHubGenericEventType = "message"
)

Supported event types

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

Supported event types

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 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 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 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 an SAS policy with Manage permissions on an Event Hubs namespace.
	// Besides the SAS policy name itself, the resource ID contains the subscription ID, resource group name
	// and Event Hubs namespace to uniquely identify the rule.
	// Format: /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.EventHub/namespaces/{namespaceName}/authorizationRules/{authorizationRuleName}
	// 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
	EventHubsSASPolicyID EventHubsSASPolicyResourceID `json:"eventHubsSASPolicyID"`

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

	// Name of an Event Hub to send data to.
	// When this attribute is set, an Event Hub with the given name MUST already exist within the namespace.
	// When this attribute is not set, Azure creates an Event Hub with the name 'insights-activity-logs'.
	// +optional
	EventHubName *string `json:"eventHubName,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) MarkDiagnosticSettings 

func (s *AzureActivityLogsSourceStatus) MarkDiagnosticSettings()

MarkDiagnosticSettings sets the DiagnosticSettings condition to True.

func (*AzureActivityLogsSourceStatus) MarkNoDiagnosticSettings 

func (s *AzureActivityLogsSourceStatus) MarkNoDiagnosticSettings(hasDiagSettings bool, msg string)

MarkNoDiagnosticSettings sets the DiagnosticSettings condition to False or Unknown with the given message, depending on the existence of diagnostic settings.

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

	// ContainerName is the name of the Blob Storage Container we plan to interface with
	ContainerName string `json:"containerName"`

	// AccountName is the account name
	AccountName string `json:"accountName"`

	// AccountKey is the account key
	AccountKey SecretValueFromSource `json:"accountKey"`
}

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 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 EventHubsSASPolicyResourceID 

type EventHubsSASPolicyResourceID struct {
	SubscriptionID    string
	ResourceGroup     string
	Namespace         string
	AuthorizationRule string
}

EventHubsSASPolicyResourceID represents a resource ID for an Event Hubs SAS policy.

func (*EventHubsSASPolicyResourceID) DeepCopy 

func (in *EventHubsSASPolicyResourceID) DeepCopy() *EventHubsSASPolicyResourceID

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

func (*EventHubsSASPolicyResourceID) DeepCopyInto 

func (in *EventHubsSASPolicyResourceID) DeepCopyInto(out *EventHubsSASPolicyResourceID)

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

func (EventHubsSASPolicyResourceID) MarshalText 

func (rID EventHubsSASPolicyResourceID) MarshalText() ([]byte, error)

MarshalText implements encoding.TextMarshaler

func (*EventHubsSASPolicyResourceID) String 

func (rID *EventHubsSASPolicyResourceID) String() string

String implements the fmt.Stringer interface.

func (*EventHubsSASPolicyResourceID) UnmarshalText 

func (rID *EventHubsSASPolicyResourceID) UnmarshalText(data []byte) error

UnmarshalText implements encoding.TextUnmarshaler

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

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

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

	// Oracle User API cert fingerprint
	OracleApiPrivateKeyFingerprint SecretValueFromSource `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
	PollingFrequency *string `json:"metricsPollingFrequency,omitempty"`

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

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

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

type SecretValueFromSource struct {
	// The Secret key to select from.
	SecretKeyRef *corev1.SecretKeySelector `json:"secretKeyRef,omitempty"`
}

SecretValueFromSource represents the source of a secret value

func (*SecretValueFromSource) DeepCopy added in v0.6.0 

func (in *SecretValueFromSource) DeepCopy() *SecretValueFromSource

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

func (*SecretValueFromSource) DeepCopyInto added in v0.6.0 

func (in *SecretValueFromSource) DeepCopyInto(out *SecretValueFromSource)

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.