v1alpha1

package
v0.1.5 Latest Latest
Warning

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

 Go to latest Published: Feb 29, 2024 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Overview

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

Index

Constants

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

Managed event types

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

Supported event types

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

Reasons for status conditions

Variables

View Source 
var (
	// SchemeGroupVersion contains the group and version used to register types for this custom API.
	SchemeGroupVersion = schema.GroupVersion{Group: sources.GroupName, Version: "v1alpha1"}
	// SchemeBuilder creates a Scheme builder that is used to register types for this custom API.
	SchemeBuilder = runtime.NewSchemeBuilder(addKnownTypes)
	// AddToScheme registers the types stored in SchemeBuilder.
	AddToScheme = SchemeBuilder.AddToScheme
)
View Source 
var AllTypes = []v1alpha1.GroupObject{
	{Single: &CloudEventsSource{}, List: &CloudEventsSourceList{}},
	{Single: &KafkaSource{}, List: &KafkaSourceList{}},
	{Single: &HTTPPollerSource{}, List: &HTTPPollerSourceList{}},
	{Single: &OCIMetricsSource{}, List: &OCIMetricsSourceList{}},
	{Single: &WebhookSource{}, List: &WebhookSourceList{}},
}

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

Functions

func AWSEventType 

func AWSEventType(awsService, eventType string) string

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

func EventType 

func EventType(service, eventType string) string

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

func Kind 

func Kind(kind string) schema.GroupKind

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

func OCIGenerateEventSource 

func OCIGenerateEventSource(namespace, name string) string

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

func Resource 

func Resource(resource string) schema.GroupResource

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

Types

type CloudEventsSource 

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

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

CloudEventsSource is the Schema for the event source.

func (*CloudEventsSource) AsEventSource 

func (s *CloudEventsSource) AsEventSource() string

AsEventSource implements EventSource.

func (*CloudEventsSource) DeepCopy 

func (in *CloudEventsSource) DeepCopy() *CloudEventsSource

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

func (*CloudEventsSource) DeepCopyInto 

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

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

func (*CloudEventsSource) DeepCopyObject 

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

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

func (*CloudEventsSource) GetAdapterOverrides 

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

GetAdapterOverrides implements AdapterConfigurable.

func (*CloudEventsSource) GetConditionSet 

func (*CloudEventsSource) GetConditionSet() apis.ConditionSet

GetConditionSet implements duckv1.KRShaped.

func (*CloudEventsSource) GetEventTypes 

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

GetEventTypes implements EventSource.

func (*CloudEventsSource) GetGroupVersionKind 

func (*CloudEventsSource) GetGroupVersionKind() schema.GroupVersionKind

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*CloudEventsSource) GetSink 

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

GetSink implements EventSender.

func (*CloudEventsSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*CloudEventsSource) GetStatusManager 

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

GetStatusManager implements Reconcilable.

func (*CloudEventsSource) SetDefaults 

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

SetDefaults implements apis.Defaultable

func (*CloudEventsSource) Validate 

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

Validate implements apis.Validatable

type CloudEventsSourceList 

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

CloudEventsSourceList contains a list of event sources.

func (*CloudEventsSourceList) DeepCopy 

func (in *CloudEventsSourceList) DeepCopy() *CloudEventsSourceList

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

func (*CloudEventsSourceList) DeepCopyInto 

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

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

func (*CloudEventsSourceList) DeepCopyObject 

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

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

type CloudEventsSourceSpec 

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

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

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

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

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

CloudEventsSourceSpec defines the desired state of the event source.

func (*CloudEventsSourceSpec) DeepCopy 

func (in *CloudEventsSourceSpec) DeepCopy() *CloudEventsSourceSpec

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

func (*CloudEventsSourceSpec) DeepCopyInto 

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

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

func (*CloudEventsSourceSpec) Validate 

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

Validate CloudEventsSource spec

type HTTPBasicAuth 

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

HTTPBasicAuth credentials.

func (*HTTPBasicAuth) DeepCopy 

func (in *HTTPBasicAuth) DeepCopy() *HTTPBasicAuth

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

func (*HTTPBasicAuth) DeepCopyInto 

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

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

type HTTPCredentials 

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

HTTPCredentials to be used when receiving requests.

func (*HTTPCredentials) DeepCopy 

func (in *HTTPCredentials) DeepCopy() *HTTPCredentials

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

func (*HTTPCredentials) DeepCopyInto 

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

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

func (*HTTPCredentials) Validate 

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

type HTTPPollerSource 

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

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

HTTPPollerSource is the schema for the event source.

func (*HTTPPollerSource) AsEventSource 

func (s *HTTPPollerSource) AsEventSource() string

AsEventSource implements EventSource.

func (*HTTPPollerSource) DeepCopy 

func (in *HTTPPollerSource) DeepCopy() *HTTPPollerSource

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

func (*HTTPPollerSource) DeepCopyInto 

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

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

func (*HTTPPollerSource) DeepCopyObject 

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

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

func (*HTTPPollerSource) GetAdapterOverrides 

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

GetAdapterOverrides implements AdapterConfigurable.

func (*HTTPPollerSource) GetConditionSet 

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

GetConditionSet implements duckv1.KRShaped.

func (*HTTPPollerSource) GetEventTypes 

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

GetEventTypes implements EventSource.

func (*HTTPPollerSource) GetGroupVersionKind 

func (*HTTPPollerSource) GetGroupVersionKind() schema.GroupVersionKind

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*HTTPPollerSource) GetSink 

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

GetSink implements EventSender.

func (*HTTPPollerSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*HTTPPollerSource) GetStatusManager 

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

GetStatusManager implements Reconcilable.

func (*HTTPPollerSource) SetDefaults 

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

SetDefaults implements apis.Defaultable

func (*HTTPPollerSource) Validate 

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

Validate implements apis.Validatable

type HTTPPollerSourceList 

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

HTTPPollerSourceList contains a list of event sources.

func (*HTTPPollerSourceList) DeepCopy 

func (in *HTTPPollerSourceList) DeepCopy() *HTTPPollerSourceList

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

func (*HTTPPollerSourceList) DeepCopyInto 

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

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

func (*HTTPPollerSourceList) DeepCopyObject 

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

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

type HTTPPollerSourceSpec 

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

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

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

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

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

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

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

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

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

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

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

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

HTTPPollerSourceSpec defines the desired state of the event source.

func (*HTTPPollerSourceSpec) DeepCopy 

func (in *HTTPPollerSourceSpec) DeepCopy() *HTTPPollerSourceSpec

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

func (*HTTPPollerSourceSpec) DeepCopyInto 

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

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

type KafkaSource 

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

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

KafkaSource is the Schema for the KafkaSource.

func (*KafkaSource) AsEventSource 

func (s *KafkaSource) AsEventSource() string

AsEventSource implements EventSource.

func (*KafkaSource) DeepCopy 

func (in *KafkaSource) DeepCopy() *KafkaSource

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

func (*KafkaSource) DeepCopyInto 

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

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

func (*KafkaSource) DeepCopyObject 

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

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

func (*KafkaSource) GetAdapterOverrides 

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

GetAdapterOverrides implements AdapterConfigurable.

func (*KafkaSource) GetConditionSet 

func (*KafkaSource) GetConditionSet() apis.ConditionSet

GetConditionSet implements duckv1.KRShaped.

func (*KafkaSource) GetEventTypes 

func (*KafkaSource) GetEventTypes() []string

GetEventTypes implements EventSource.

func (*KafkaSource) GetGroupVersionKind 

func (*KafkaSource) GetGroupVersionKind() schema.GroupVersionKind

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*KafkaSource) GetSink 

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

GetSink implements EventSender.

func (*KafkaSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*KafkaSource) GetStatusManager 

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

GetStatusManager implements Reconcilable.

func (*KafkaSource) SetDefaults 

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

SetDefaults implements apis.Defaultable

func (*KafkaSource) Validate 

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

Validate implements apis.Validatable

type KafkaSourceAuth 

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

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

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

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

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

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

KafkaSourceAuth contains Authentication method used to interact with Kafka.

func (*KafkaSourceAuth) DeepCopy 

func (in *KafkaSourceAuth) DeepCopy() *KafkaSourceAuth

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

func (*KafkaSourceAuth) DeepCopyInto 

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

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

type KafkaSourceKerberos 

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

KafkaSourceKerberos contains kerberos credentials.

func (*KafkaSourceKerberos) DeepCopy 

func (in *KafkaSourceKerberos) DeepCopy() *KafkaSourceKerberos

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

func (*KafkaSourceKerberos) DeepCopyInto 

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

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

type KafkaSourceList 

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

KafkaSourceList contains a list of event sources.

func (*KafkaSourceList) DeepCopy 

func (in *KafkaSourceList) DeepCopy() *KafkaSourceList

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

func (*KafkaSourceList) DeepCopyInto 

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

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

func (*KafkaSourceList) DeepCopyObject 

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

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

type KafkaSourceSpec 

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

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

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

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

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

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

KafkaSourceSpec defines the desired state of the event source.

func (*KafkaSourceSpec) DeepCopy 

func (in *KafkaSourceSpec) DeepCopy() *KafkaSourceSpec

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

func (*KafkaSourceSpec) DeepCopyInto 

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

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

type KafkaSourceTLSAuth 

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

KafkaSourceTLSAuth contains kerberos credentials.

func (*KafkaSourceTLSAuth) DeepCopy 

func (in *KafkaSourceTLSAuth) DeepCopy() *KafkaSourceTLSAuth

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

func (*KafkaSourceTLSAuth) DeepCopyInto 

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

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

type OCIMetrics 

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

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

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

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

OCIMetrics represents OCI metrics structure.

func (*OCIMetrics) DeepCopy 

func (in *OCIMetrics) DeepCopy() *OCIMetrics

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

func (*OCIMetrics) DeepCopyInto 

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

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

type OCIMetricsDecodedList 

type OCIMetricsDecodedList []OCIMetrics

OCIMetricsDecodedList is a list of OCI metrics.

func (*OCIMetricsDecodedList) Decode 

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

Decode deserializes a list of OCI metrics.

func (OCIMetricsDecodedList) DeepCopy 

func (in OCIMetricsDecodedList) DeepCopy() OCIMetricsDecodedList

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

func (OCIMetricsDecodedList) DeepCopyInto 

func (in OCIMetricsDecodedList) DeepCopyInto(out *OCIMetricsDecodedList)

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

type OCIMetricsSource 

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

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

OCIMetricsSource is the schema for the event source.

func (*OCIMetricsSource) AsEventSource 

func (s *OCIMetricsSource) AsEventSource() string

AsEventSource implements EventSource.

func (*OCIMetricsSource) DeepCopy 

func (in *OCIMetricsSource) DeepCopy() *OCIMetricsSource

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

func (*OCIMetricsSource) DeepCopyInto 

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

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

func (*OCIMetricsSource) DeepCopyObject 

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

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

func (*OCIMetricsSource) GetAdapterOverrides 

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

GetAdapterOverrides implements AdapterConfigurable.

func (*OCIMetricsSource) GetConditionSet 

func (*OCIMetricsSource) GetConditionSet() apis.ConditionSet

GetConditionSet implements duckv1.KRShaped.

func (*OCIMetricsSource) GetEventTypes 

func (*OCIMetricsSource) GetEventTypes() []string

GetEventTypes implements EventSource.

func (*OCIMetricsSource) GetGroupVersionKind 

func (*OCIMetricsSource) GetGroupVersionKind() schema.GroupVersionKind

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*OCIMetricsSource) GetSink 

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

GetSink implements EventSender.

func (*OCIMetricsSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*OCIMetricsSource) GetStatusManager 

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

GetStatusManager implements Reconcilable.

func (*OCIMetricsSource) SetDefaults 

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

SetDefaults implements apis.Defaultable

func (*OCIMetricsSource) Validate 

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

Validate implements apis.Validatable

type OCIMetricsSourceList 

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

OCIMetricsSourceList contains a list of event sources.

func (*OCIMetricsSourceList) DeepCopy 

func (in *OCIMetricsSourceList) DeepCopy() *OCIMetricsSourceList

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

func (*OCIMetricsSourceList) DeepCopyInto 

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

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

func (*OCIMetricsSourceList) DeepCopyObject 

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

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

type OCIMetricsSourceSpec 

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

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

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

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

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

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

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

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

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

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

OCIMetricsSourceSpec defines the desired state of the event source.

func (*OCIMetricsSourceSpec) DeepCopy 

func (in *OCIMetricsSourceSpec) DeepCopy() *OCIMetricsSourceSpec

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

func (*OCIMetricsSourceSpec) DeepCopyInto 

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

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

type RateLimiter 

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

RateLimiter parameters.

func (*RateLimiter) DeepCopy 

func (in *RateLimiter) DeepCopy() *RateLimiter

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

func (*RateLimiter) DeepCopyInto 

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

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

type WebhookEventExtensionAttributes 

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

WebhookEventExtensionAttributes sets the policy for converting HTTP data into.

func (*WebhookEventExtensionAttributes) DeepCopy 

func (in *WebhookEventExtensionAttributes) DeepCopy() *WebhookEventExtensionAttributes

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

func (*WebhookEventExtensionAttributes) DeepCopyInto 

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

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

type WebhookSource 

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

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

WebhookSource is the schema for the event source.

func (*WebhookSource) AsEventSource 

func (s *WebhookSource) AsEventSource() string

AsEventSource implements EventSource.

func (*WebhookSource) DeepCopy 

func (in *WebhookSource) DeepCopy() *WebhookSource

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

func (*WebhookSource) DeepCopyInto 

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

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

func (*WebhookSource) DeepCopyObject 

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

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

func (*WebhookSource) GetAdapterOverrides 

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

GetAdapterOverrides implements AdapterConfigurable.

func (*WebhookSource) GetConditionSet 

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

GetConditionSet implements duckv1.KRShaped.

func (*WebhookSource) GetEventTypes 

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

GetEventTypes implements EventSource.

func (*WebhookSource) GetGroupVersionKind 

func (*WebhookSource) GetGroupVersionKind() schema.GroupVersionKind

GetGroupVersionKind implements kmeta.OwnerRefable.

func (*WebhookSource) GetSink 

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

GetSink implements EventSender.

func (*WebhookSource) GetStatus 

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

GetStatus implements duckv1.KRShaped.

func (*WebhookSource) GetStatusManager 

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

GetStatusManager implements Reconcilable.

func (*WebhookSource) SetDefaults 

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

SetDefaults implements apis.Defaultable

func (*WebhookSource) Validate 

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

Validate implements apis.Validatable

type WebhookSourceList 

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

WebhookSourceList contains a list of event sources.

func (*WebhookSourceList) DeepCopy 

func (in *WebhookSourceList) DeepCopy() *WebhookSourceList

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

func (*WebhookSourceList) DeepCopyInto 

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

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

func (*WebhookSourceList) DeepCopyObject 

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

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

type WebhookSourceSpec 

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

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

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

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

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

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

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

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

WebhookSourceSpec defines the desired state of the event source.

func (*WebhookSourceSpec) DeepCopy 

func (in *WebhookSourceSpec) DeepCopy() *WebhookSourceSpec

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

func (*WebhookSourceSpec) DeepCopyInto 

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

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.