Documentation ¶
Overview ¶
Package v1alpha1 is the v1alpha1 version of the API. +groupName=argoproj.io +k8s:deepcopy-gen=package,register +k8s:openapi-gen=true
Copyright 2018 BlackRock, Inc.
Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.
Copyright 2018 BlackRock, Inc.
Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.
Copyright 2018 BlackRock, Inc.
Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.
Index ¶
- Variables
- func GetOpenAPIDefinitions(ref common.ReferenceCallback) map[string]common.OpenAPIDefinition
- func Kind(kind string) schema.GroupKind
- func Resource(resource string) schema.GroupResource
- func ValidateEventSource(eventSource *EventSource) error
- func ValidateTLSConfig(tlsConfig *TLSConfig) error
- type AMQPEventSource
- type AzureEventsHubEventSource
- type CalendarEventSource
- type EmitterEventSource
- type EventSource
- type EventSourceList
- type EventSourceSpec
- type EventSourceStatus
- type FileEventSource
- type GenericEventSource
- type GithubEventSource
- type GitlabEventSource
- type HDFSEventSource
- type KafkaEventSource
- type MQTTEventSource
- type NATSEventsSource
- type NSQEventSource
- type PubSubEventSource
- type RedisEventSource
- type ResourceEventSource
- type ResourceEventType
- type ResourceFilter
- type SNSEventSource
- type SQSEventSource
- type Selector
- type SlackEventSource
- type StorageGridEventSource
- type StorageGridFilter
- type StripeEventSource
- type TLSConfig
Constants ¶
This section is empty.
Variables ¶
var ( // SchemeBuilder is the builder for this scheme SchemeBuilder = runtime.NewSchemeBuilder(addKnownTypes) // AddToScheme adds this AddToScheme = SchemeBuilder.AddToScheme )
var SchemaGroupVersionKind = schema.GroupVersionKind{Group: event_sources.Group, Version: "v1alpha1", Kind: event_sources.Kind}
SchemaGroupVersionKind is a group version kind used to attach owner references to gateway-controller
var SchemeGroupVersion = schema.GroupVersion{Group: event_sources.Group, Version: "v1alpha1"}
SchemeGroupVersion is a group version used to register these objects
Functions ¶
func GetOpenAPIDefinitions ¶
func GetOpenAPIDefinitions(ref common.ReferenceCallback) map[string]common.OpenAPIDefinition
func Resource ¶
func Resource(resource string) schema.GroupResource
Resource takes unqualified resource and returns Group qualified GroupResource
func ValidateEventSource ¶
func ValidateEventSource(eventSource *EventSource) error
ValidateEventSource validates a generic event source
func ValidateTLSConfig ¶ added in v0.14.0
ValidateTLSConfig validates a TLS configuration.
Types ¶
type AMQPEventSource ¶
type AMQPEventSource struct { // URL for rabbitmq service URL string `json:"url" protobuf:"bytes,1,name=url"` // ExchangeName is the exchange name // For more information, visit https://www.rabbitmq.com/tutorials/amqp-concepts.html ExchangeName string `json:"exchangeName" protobuf:"bytes,2,name=exchangeName"` // ExchangeType is rabbitmq exchange type ExchangeType string `json:"exchangeType" protobuf:"bytes,3,name=exchangeType"` // Routing key for bindings RoutingKey string `json:"routingKey" protobuf:"bytes,4,name=routingKey"` // Backoff holds parameters applied to connection. // +optional ConnectionBackoff *common.Backoff `json:"connectionBackoff,omitempty" protobuf:"bytes,5,opt,name=connectionBackoff"` // JSONBody specifies that all event body payload coming from this // source will be JSON // +optional JSONBody bool `json:"jsonBody,omitempty" protobuf:"bytes,6,opt,name=jsonBody"` // TLS configuration for the amqp client. // +optional TLS *TLSConfig `json:"tls,omitempty" protobuf:"bytes,7,opt,name=tls"` }
AMQPEventSource refers to an event-source for AMQP stream events
func (*AMQPEventSource) DeepCopy ¶
func (in *AMQPEventSource) DeepCopy() *AMQPEventSource
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AMQPEventSource.
func (*AMQPEventSource) DeepCopyInto ¶
func (in *AMQPEventSource) DeepCopyInto(out *AMQPEventSource)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type AzureEventsHubEventSource ¶
type AzureEventsHubEventSource struct { // FQDN of the EventHubs namespace you created // More info at https://docs.microsoft.com/en-us/azure/event-hubs/event-hubs-get-connection-string FQDN string `json:"fqdn" protobuf:"bytes,1,name=fqdn"` SharedAccessKeyName *corev1.SecretKeySelector `json:"sharedAccessKeyName" protobuf:"bytes,2,name=sharedAccessKeyName"` SharedAccessKey *corev1.SecretKeySelector `json:"sharedAccessKey" protobuf:"bytes,3,name=sharedAccessKey"` // Event Hub path/name HubName string `json:"hubName" protobuf:"bytes,4,name=hubName"` // Namespace refers to Kubernetes namespace which is used to retrieve the shared access key and name from. // +optional Namespace string `json:"namespace,omitempty" protobuf:"bytes,5,opt,name=namespace"` }
AzureEventsHubEventSource describes the event source for azure events hub More info at https://docs.microsoft.com/en-us/azure/event-hubs/
func (*AzureEventsHubEventSource) DeepCopy ¶
func (in *AzureEventsHubEventSource) DeepCopy() *AzureEventsHubEventSource
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AzureEventsHubEventSource.
func (*AzureEventsHubEventSource) DeepCopyInto ¶
func (in *AzureEventsHubEventSource) DeepCopyInto(out *AzureEventsHubEventSource)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type CalendarEventSource ¶
type CalendarEventSource struct { // Schedule is a cron-like expression. For reference, see: https://en.wikipedia.org/wiki/Cron Schedule string `json:"schedule" protobuf:"bytes,1,name=schedule"` // Interval is a string that describes an interval duration, e.g. 1s, 30m, 2h... Interval string `json:"interval" protobuf:"bytes,2,name=interval"` // ExclusionDates defines the list of DATE-TIME exceptions for recurring events. // +listType=string ExclusionDates []string `json:"exclusionDates,omitempty" protobuf:"bytes,3,opt,name=exclusionDates"` // Timezone in which to run the schedule // +optional Timezone string `json:"timezone,omitempty" protobuf:"bytes,4,opt,name=timezone"` // UserPayload will be sent to sensor as extra data once the event is triggered // +optional UserPayload *json.RawMessage `json:"userPayload,omitempty" protobuf:"bytes,5,opt,name=userPayload"` }
CalendarEventSource describes a time based dependency. One of the fields (schedule, interval, or recurrence) must be passed. Schedule takes precedence over interval; interval takes precedence over recurrence
func (*CalendarEventSource) DeepCopy ¶
func (in *CalendarEventSource) DeepCopy() *CalendarEventSource
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CalendarEventSource.
func (*CalendarEventSource) DeepCopyInto ¶
func (in *CalendarEventSource) DeepCopyInto(out *CalendarEventSource)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type EmitterEventSource ¶
type EmitterEventSource struct { // Broker URI to connect to. Broker string `json:"broker" protobuf:"bytes,1,name=broker"` // ChannelKey refers to the channel key ChannelKey string `json:"channelKey" protobuf:"bytes,2,name=channelKey"` // ChannelName refers to the channel name ChannelName string `json:"channelName" protobuf:"bytes,3,name=channelName"` // Namespace to use to retrieve the channel key and optional username/password // +optional Namespace string `json:"namespace,omitempty" protobuf:"bytes,4,opt,name=namespace"` // Username to use to connect to broker // +optional Username *corev1.SecretKeySelector `json:"username,omitempty" protobuf:"bytes,5,opt,name=username"` // Password to use to connect to broker // +optional Password *corev1.SecretKeySelector `json:"password,omitempty" protobuf:"bytes,6,opt,name=password"` // Backoff holds parameters applied to connection. // +optional ConnectionBackoff *common.Backoff `json:"connectionBackoff,omitempty" protobuf:"bytes,7,opt,name=connectionBackoff"` // JSONBody specifies that all event body payload coming from this // source will be JSON // +optional JSONBody bool `json:"jsonBody,omitempty" protobuf:"bytes,8,opt,name=jsonBody"` // TLS configuration for the emitter client. // +optional TLS *TLSConfig `json:"tls,omitempty" protobuf:"bytes,9,opt,name=tls"` }
EmitterEventSource describes the event source for emitter More info at https://emitter.io/develop/getting-started/
func (*EmitterEventSource) DeepCopy ¶
func (in *EmitterEventSource) DeepCopy() *EmitterEventSource
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EmitterEventSource.
func (*EmitterEventSource) DeepCopyInto ¶
func (in *EmitterEventSource) DeepCopyInto(out *EmitterEventSource)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type EventSource ¶
type EventSource struct { metav1.TypeMeta `json:",inline"` metav1.ObjectMeta `json:"metadata" protobuf:"bytes,1,opt,name=metadata"` Status EventSourceStatus `json:"status" protobuf:"bytes,2,opt,name=status"` Spec *EventSourceSpec `json:"spec" protobuf:"bytes,3,opt,name=spec"` }
EventSource is the definition of a eventsource resource +genclient +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object +k8s:openapi-gen=true
func (*EventSource) DeepCopy ¶
func (in *EventSource) DeepCopy() *EventSource
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EventSource.
func (*EventSource) DeepCopyInto ¶
func (in *EventSource) DeepCopyInto(out *EventSource)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*EventSource) DeepCopyObject ¶
func (in *EventSource) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type EventSourceList ¶
type EventSourceList struct { metav1.TypeMeta `json:",inline"` metav1.ListMeta `json:"metadata" protobuf:"bytes,1,opt,name=metadata"` // +listType=eventsource Items []EventSource `json:"items" protobuf:"bytes,2,opt,name=items"` }
EventSourceList is the list of eventsource resources +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object
func (*EventSourceList) DeepCopy ¶
func (in *EventSourceList) DeepCopy() *EventSourceList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EventSourceList.
func (*EventSourceList) DeepCopyInto ¶
func (in *EventSourceList) DeepCopyInto(out *EventSourceList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*EventSourceList) DeepCopyObject ¶
func (in *EventSourceList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type EventSourceSpec ¶
type EventSourceSpec struct { // Minio event sources Minio map[string]apicommon.S3Artifact `json:"minio,omitempty" protobuf:"bytes,1,opt,name=minio"` // Calendar event sources Calendar map[string]CalendarEventSource `json:"calendar,omitempty" protobuf:"bytes,2,opt,name=calendar"` // File event sources File map[string]FileEventSource `json:"file,omitempty" protobuf:"bytes,3,opt,name=file"` // Resource event sources Resource map[string]ResourceEventSource `json:"resource,omitempty" protobuf:"bytes,4,opt,name=resource"` // Webhook event sources Webhook map[string]webhook.Context `json:"webhook,omitempty" protobuf:"bytes,5,opt,name=webhook"` // AMQP event sources AMQP map[string]AMQPEventSource `json:"amqp,omitempty" protobuf:"bytes,6,opt,name=amqp"` // Kafka event sources Kafka map[string]KafkaEventSource `json:"kafka,omitempty" protobuf:"bytes,7,opt,name=kafka"` // MQTT event sources MQTT map[string]MQTTEventSource `json:"mqtt,omitempty" protobuf:"bytes,8,opt,name=mqtt"` // NATS event sources NATS map[string]NATSEventsSource `json:"nats,omitempty" protobuf:"bytes,9,opt,name=nats"` // SNS event sources SNS map[string]SNSEventSource `json:"sns,omitempty" protobuf:"bytes,10,opt,name=sns"` // SQS event sources SQS map[string]SQSEventSource `json:"sqs,omitempty" protobuf:"bytes,11,opt,name=sqs"` // PubSub eevnt sources PubSub map[string]PubSubEventSource `json:"pubSub,omitempty" protobuf:"bytes,12,opt,name=pubSub"` // Github event sources Github map[string]GithubEventSource `json:"github,omitempty" protobuf:"bytes,13,opt,name=github"` // Gitlab event sources Gitlab map[string]GitlabEventSource `json:"gitlab,omitempty" protobuf:"bytes,14,opt,name=gitlab"` // HDFS event sources HDFS map[string]HDFSEventSource `json:"hdfs,omitempty" protobuf:"bytes,15,opt,name=hdfs"` // Slack event sources Slack map[string]SlackEventSource `json:"slack,omitempty" protobuf:"bytes,16,opt,name=slack"` // StorageGrid event sources StorageGrid map[string]StorageGridEventSource `json:"storageGrid,omitempty" protobuf:"bytes,17,opt,name=storageGrid"` // AzureEventsHub event sources AzureEventsHub map[string]AzureEventsHubEventSource `json:"azureEventsHub,omitempty" protobuf:"bytes,18,opt,name=azureEventsHub"` // Stripe event sources Stripe map[string]StripeEventSource `json:"stripe,omitempty" protobuf:"bytes,19,opt,name=stripe"` // Emitter event source Emitter map[string]EmitterEventSource `json:"emitter,omitempty" protobuf:"bytes,20,opt,name=emitter"` // Redis event source Redis map[string]RedisEventSource `json:"redis,omitempty" protobuf:"bytes,21,opt,name=redis"` // NSQ event source NSQ map[string]NSQEventSource `json:"nsq,omitempty" protobuf:"bytes,22,opt,name=nsq"` // Generic event source Generic map[string]GenericEventSource `json:"generic,omitempty" protobuf:"bytes,23,opt,name=generic"` // Type of the event source Type apicommon.EventSourceType `json:"type" protobuf:"bytes,24,name=type"` }
EventSourceSpec refers to specification of event-source resource
func (*EventSourceSpec) DeepCopy ¶
func (in *EventSourceSpec) DeepCopy() *EventSourceSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EventSourceSpec.
func (*EventSourceSpec) DeepCopyInto ¶
func (in *EventSourceSpec) DeepCopyInto(out *EventSourceSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type EventSourceStatus ¶
type EventSourceStatus struct {
CreatedAt metav1.Time `json:"createdAt,omitempty" protobuf:"bytes,1,opt,name=createdAt"`
}
EventSourceStatus holds the status of the event-source resource
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 FileEventSource ¶
type FileEventSource struct { // Type of file operations to watch // Refer https://github.com/fsnotify/fsnotify/blob/master/fsnotify.go for more information EventType string `json:"eventType" protobuf:"bytes,1,name=eventType"` // WatchPathConfig contains configuration about the file path to watch WatchPathConfig fsevent.WatchPathConfig `json:"watchPathConfig" protobuf:"bytes,2,name=watchPathConfig"` }
FileEventSource describes an event-source for file related events.
func (*FileEventSource) DeepCopy ¶
func (in *FileEventSource) DeepCopy() *FileEventSource
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new FileEventSource.
func (*FileEventSource) DeepCopyInto ¶
func (in *FileEventSource) DeepCopyInto(out *FileEventSource)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type GenericEventSource ¶
type GenericEventSource struct { // Value of the event source Value string `json:"value" protobuf:"bytes,1,name=value"` }
GenericEventSource refers to a generic event source. It can be used to implement a custom event source.
func (*GenericEventSource) DeepCopy ¶
func (in *GenericEventSource) DeepCopy() *GenericEventSource
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GenericEventSource.
func (*GenericEventSource) DeepCopyInto ¶
func (in *GenericEventSource) DeepCopyInto(out *GenericEventSource)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type GithubEventSource ¶
type GithubEventSource struct { // Id is the webhook's id Id int64 `json:"id" protobuf:"bytes,1,name=id"` // Webhook refers to the configuration required to run a http server Webhook *webhook.Context `json:"webhook" protobuf:"bytes,2,name=webhook"` // Owner refers to GitHub owner name i.e. argoproj Owner string `json:"owner" protobuf:"bytes,3,name=owner"` // Repository refers to GitHub repo name i.e. argo-events Repository string `json:"repository" protobuf:"bytes,4,name=repository"` // Events refer to Github events to subscribe to which the gateway will subscribe // +listType=string Events []string `json:"events" protobuf:"bytes,5,rep,name=events"` // APIToken refers to a K8s secret containing github api token APIToken *corev1.SecretKeySelector `json:"apiToken"` // WebhookSecret refers to K8s secret containing GitHub webhook secret // https://developer.github.com/webhooks/securing/ // +optional WebhookSecret *corev1.SecretKeySelector `json:"webhookSecret,omitempty" protobuf:"bytes,7,opt,name=webhookSecret"` // Insecure tls verification Insecure bool `json:"insecure,omitempty" protobuf:"bytes,8,opt,name=insecure"` // Active refers to status of the webhook for event deliveries. // https://developer.github.com/webhooks/creating/#active // +optional Active bool `json:"active,omitempty" protobuf:"bytes,9,opt,name=active"` // ContentType of the event delivery ContentType string `json:"contentType,omitempty" protobuf:"bytes,10,opt,name=contentType"` // GitHub base URL (for GitHub Enterprise) // +optional GithubBaseURL string `json:"githubBaseURL,omitempty" protobuf:"bytes,11,opt,name=githubBaseURL"` // GitHub upload URL (for GitHub Enterprise) // +optional GithubUploadURL string `json:"githubUploadURL,omitempty" protobuf:"bytes,12,opt,name=githubUploadURL"` // Namespace refers to Kubernetes namespace which is used to retrieve webhook secret and api token from. // +optional Namespace string `json:"namespace,omitempty" protobuf:"bytes,13.opt,name=namespace"` // DeleteHookOnFinish determines whether to delete the GitHub hook for the repository once the event source is stopped. // +optional DeleteHookOnFinish bool `json:"deleteHookOnFinish,omitempty" protobuf:"bytes,14,opt,name=deleteHookOnFinish"` }
GithubEventSource refers to event-source for github related events
func (*GithubEventSource) DeepCopy ¶
func (in *GithubEventSource) DeepCopy() *GithubEventSource
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GithubEventSource.
func (*GithubEventSource) DeepCopyInto ¶
func (in *GithubEventSource) DeepCopyInto(out *GithubEventSource)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type GitlabEventSource ¶
type GitlabEventSource struct { // Webhook holds configuration to run a http server Webhook *webhook.Context `json:"webhook" protobuf:"bytes,1,name=webhook"` // ProjectId is the id of project for which integration needs to setup ProjectId string `json:"projectId" protobuf:"bytes,2,name=projectId"` // Event is a gitlab event to listen to. // Refer https://github.com/xanzy/go-gitlab/blob/bf34eca5d13a9f4c3f501d8a97b8ac226d55e4d9/projects.go#L794. Event string `json:"event" protobuf:"bytes,3,name=event"` // AccessToken is reference to k8 secret which holds the gitlab api access information AccessToken *corev1.SecretKeySelector `json:"accessToken" protobuf:"bytes,4,name=accessToken"` // EnableSSLVerification to enable ssl verification // +optional EnableSSLVerification bool `json:"enableSSLVerification,omitempty" protobuf:"bytes,5,opt,name=enableSSLVerification"` // GitlabBaseURL is the base URL for API requests to a custom endpoint GitlabBaseURL string `json:"gitlabBaseURL" protobuf:"bytes,6,name=gitlabBaseURL"` // Namespace refers to Kubernetes namespace which is used to retrieve access token from. // +optional Namespace string `json:"namespace,omitempty" protobuf:"bytes,7,opt,name=namespace"` // DeleteHookOnFinish determines whether to delete the GitLab hook for the project once the event source is stopped. // +optional DeleteHookOnFinish bool `json:"deleteHookOnFinish,omitempty" protobuf:"bytes,8,opt,name=deleteHookOnFinish"` // AllowDuplicate allows the gateway to register the same webhook integrations for multiple event source configurations. // Defaults to false. // +optional. AllowDuplicate bool `json:"allowDuplicate,omitempty" protobuf:"bytes,9,opt,name=allowDuplicate"` }
GitlabEventSource refers to event-source related to Gitlab events
func (*GitlabEventSource) DeepCopy ¶
func (in *GitlabEventSource) DeepCopy() *GitlabEventSource
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GitlabEventSource.
func (*GitlabEventSource) DeepCopyInto ¶
func (in *GitlabEventSource) DeepCopyInto(out *GitlabEventSource)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type HDFSEventSource ¶
type HDFSEventSource struct { fsevent.WatchPathConfig `json:",inline"` // Type of file operations to watch Type string `json:"type"` // CheckInterval is a string that describes an interval duration to check the directory state, e.g. 1s, 30m, 2h... (defaults to 1m) CheckInterval string `json:"checkInterval,omitempty"` // Addresses is accessible addresses of HDFS name nodes // +listType=string Addresses []string `json:"addresses"` // HDFSUser is the user to access HDFS file system. // It is ignored if either ccache or keytab is used. HDFSUser string `json:"hdfsUser,omitempty"` // KrbCCacheSecret is the secret selector for Kerberos ccache // Either ccache or keytab can be set to use Kerberos. KrbCCacheSecret *corev1.SecretKeySelector `json:"krbCCacheSecret,omitempty"` // KrbKeytabSecret is the secret selector for Kerberos keytab // Either ccache or keytab can be set to use Kerberos. KrbKeytabSecret *corev1.SecretKeySelector `json:"krbKeytabSecret,omitempty"` // KrbUsername is the Kerberos username used with Kerberos keytab // It must be set if keytab is used. KrbUsername string `json:"krbUsername,omitempty"` // KrbRealm is the Kerberos realm used with Kerberos keytab // It must be set if keytab is used. KrbRealm string `json:"krbRealm,omitempty"` // KrbConfig is the configmap selector for Kerberos config as string // It must be set if either ccache or keytab is used. KrbConfigConfigMap *corev1.ConfigMapKeySelector `json:"krbConfigConfigMap,omitempty"` // KrbServicePrincipalName is the principal name of Kerberos service // It must be set if either ccache or keytab is used. KrbServicePrincipalName string `json:"krbServicePrincipalName,omitempty"` // Namespace refers to Kubernetes namespace which is used to retrieve cache secret and ket tab secret from. // +optional Namespace string `json:"namespace,omitempty" protobuf:"bytes,1,opt,name=namespace"` }
HDFSEventSource refers to event-source for HDFS related events
func (*HDFSEventSource) DeepCopy ¶
func (in *HDFSEventSource) DeepCopy() *HDFSEventSource
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new HDFSEventSource.
func (*HDFSEventSource) DeepCopyInto ¶
func (in *HDFSEventSource) DeepCopyInto(out *HDFSEventSource)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type KafkaEventSource ¶
type KafkaEventSource struct { // URL to kafka cluster URL string `json:"url" protobuf:"bytes,1,name=url"` // Partition name Partition string `json:"partition" protobuf:"bytes,2,name=partition"` // Topic name Topic string `json:"topic" protobuf:"bytes,3,name=topic"` // Backoff holds parameters applied to connection. ConnectionBackoff *common.Backoff `json:"connectionBackoff,omitempty" protobuf:"bytes,4,opt,name=connectionBackoff"` // TLS configuration for the kafka client. // +optional TLS *TLSConfig `json:"tls,omitempty" protobuf:"bytes,5,opt,name=tls"` }
KafkaEventSource refers to event-source for Kafka related events
func (*KafkaEventSource) DeepCopy ¶
func (in *KafkaEventSource) DeepCopy() *KafkaEventSource
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KafkaEventSource.
func (*KafkaEventSource) DeepCopyInto ¶
func (in *KafkaEventSource) DeepCopyInto(out *KafkaEventSource)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type MQTTEventSource ¶
type MQTTEventSource struct { // URL to connect to broker URL string `json:"url" protobuf:"bytes,1,name=url"` // Topic name Topic string `json:"topic" protobuf:"bytes,2,name=topic"` // ClientID is the id of the client ClientId string `json:"clientId" protobuf:"bytes,3,name=clientId"` // ConnectionBackoff holds backoff applied to connection. ConnectionBackoff *common.Backoff `json:"connectionBackoff,omitempty" protobuf:"bytes,4,opt,name=connectionBackoff"` // JSONBody specifies that all event body payload coming from this // source will be JSON // +optional JSONBody bool `json:"jsonBody,omitempty" protobuf:"bytes,5,opt,name=jsonBody"` // TLS configuration for the mqtt client. // +optional TLS *TLSConfig `json:"tls,omitempty" protobuf:"bytes,6,opt,name=tls"` }
MQTTEventSource refers to event-source for MQTT related events
func (*MQTTEventSource) DeepCopy ¶
func (in *MQTTEventSource) DeepCopy() *MQTTEventSource
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new MQTTEventSource.
func (*MQTTEventSource) DeepCopyInto ¶
func (in *MQTTEventSource) DeepCopyInto(out *MQTTEventSource)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type NATSEventsSource ¶
type NATSEventsSource struct { // URL to connect to NATS cluster URL string `json:"url" protobuf:"bytes,1,name=url"` // Subject holds the name of the subject onto which messages are published Subject string `json:"subject" protobuf:"bytes,2,name=2"` // ConnectionBackoff holds backoff applied to connection. ConnectionBackoff *common.Backoff `json:"connectionBackoff,omitempty" protobuf:"bytes,3,opt,name=connectionBackoff"` // JSONBody specifies that all event body payload coming from this // source will be JSON // +optional JSONBody bool `json:"jsonBody,omitempty" protobuf:"bytes,4,opt,name=jsonBody"` // TLS configuration for the nats client. // +optional TLS *TLSConfig `json:"tls,omitempty" protobuf:"bytes,5,opt,name=tls"` }
NATSEventSource refers to event-source for NATS related events
func (*NATSEventsSource) DeepCopy ¶
func (in *NATSEventsSource) DeepCopy() *NATSEventsSource
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NATSEventsSource.
func (*NATSEventsSource) DeepCopyInto ¶
func (in *NATSEventsSource) DeepCopyInto(out *NATSEventsSource)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type NSQEventSource ¶
type NSQEventSource struct { // HostAddress is the address of the host for NSQ lookup HostAddress string `json:"hostAddress" protobuf:"bytes,1,name=hostAddress"` // Topic to subscribe to. Topic string `json:"topic" protobuf:"bytes,2,name=topic"` // Channel used for subscription Channel string `json:"channel" protobuf:"bytes,3,name=channel"` // Backoff holds parameters applied to connection. // +optional ConnectionBackoff *common.Backoff `json:"connectionBackoff,omitempty" protobuf:"bytes,4,opt,name=connectionBackoff"` // JSONBody specifies that all event body payload coming from this // source will be JSON // +optional JSONBody bool `json:"jsonBody,omitempty" protobuf:"bytes,5,opt,name=jsonBody"` // TLS configuration for the nsq client. // +optional TLS *TLSConfig `json:"tls,omitempty" protobuf:"bytes,6,opt,name=tls"` }
NSQEventSource describes the event source for NSQ PubSub More info at https://godoc.org/github.com/nsqio/go-nsq
func (*NSQEventSource) DeepCopy ¶
func (in *NSQEventSource) DeepCopy() *NSQEventSource
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NSQEventSource.
func (*NSQEventSource) DeepCopyInto ¶
func (in *NSQEventSource) DeepCopyInto(out *NSQEventSource)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type PubSubEventSource ¶
type PubSubEventSource struct { // ProjectID is the unique identifier for your project on GCP ProjectID string `json:"projectID" protobuf:"bytes,1,name=projectID"` // TopicProjectID identifies the project where the topic should exist or be created // (assumed to be the same as ProjectID by default) TopicProjectID string `json:"topicProjectID" protobuf:"bytes,2,name=topicProjectID"` // Topic on which a subscription will be created Topic string `json:"topic" protobuf:"bytes,3,name=topic"` // CredentialsFile is the file that contains credentials to authenticate for GCP CredentialsFile string `json:"credentialsFile" protobuf:"bytes,4,name=credentialsFile"` // EnableWorkflowIdentity determines if your project authenticates to GCP with WorkflowIdentity or CredentialsFile. // If true, authentication is done with WorkflowIdentity. If false or omited, authentication is done with CredentialsFile. // +optional EnableWorkflowIdentity bool `json:"enableWorkflowIdentity,omitempty" protobuf:"bytes,5,opt,name=enableWorkflowIdentity"` // DeleteSubscriptionOnFinish determines whether to delete the GCP PubSub subscription once the event source is stopped. // +optional DeleteSubscriptionOnFinish bool `json:"deleteSubscriptionOnFinish,omitempty" protobuf:"bytes,6,opt,name=deleteSubscriptionOnFinish"` // JSONBody specifies that all event body payload coming from this // source will be JSON // +optional JSONBody bool `json:"jsonBody,omitempty" protobuf:"bytes,8,opt,name=jsonBody"` }
PubSubEventSource refers to event-source for GCP PubSub related events.
func (*PubSubEventSource) DeepCopy ¶
func (in *PubSubEventSource) DeepCopy() *PubSubEventSource
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PubSubEventSource.
func (*PubSubEventSource) DeepCopyInto ¶
func (in *PubSubEventSource) DeepCopyInto(out *PubSubEventSource)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type RedisEventSource ¶
type RedisEventSource struct { // HostAddress refers to the address of the Redis host/server HostAddress string `json:"hostAddress" protobuf:"bytes,1,name=hostAddress"` // Password required for authentication if any. // +optional Password *corev1.SecretKeySelector `json:"password,omitempty" protobuf:"bytes,2,opt,name=password"` // Namespace to use to retrieve the password from. It should only be specified if password is declared // +optional Namespace string `json:"namespace,omitempty" protobuf:"bytes,3,opt,name=namespace"` // DB to use. If not specified, default DB 0 will be used. // +optional DB int `json:"db,omitempty" protobuf:"bytes,4,opt,name=db"` // Channels to subscribe to listen events. // +listType=string Channels []string `json:"channels" protobuf:"bytes,5,name=channels"` // TLS configuration for the redis client. // +optional TLS *TLSConfig `json:"tls,omitempty" protobuf:"bytes,6,opt,name=tls"` }
RedisEventSource describes an event source for the Redis PubSub. More info at https://godoc.org/github.com/go-redis/redis#example-PubSub
func (*RedisEventSource) DeepCopy ¶
func (in *RedisEventSource) DeepCopy() *RedisEventSource
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RedisEventSource.
func (*RedisEventSource) DeepCopyInto ¶
func (in *RedisEventSource) DeepCopyInto(out *RedisEventSource)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ResourceEventSource ¶
type ResourceEventSource struct { // Namespace where resource is deployed Namespace string `json:"namespace" protobuf:"bytes,1,name=namespace"` // Filter is applied on the metadata of the resource // If you apply filter, then the internal event informer will only monitor objects that pass the filter. // +optional Filter *ResourceFilter `json:"filter,omitempty" protobuf:"bytes,2,opt,name=filter"` // Group of the resource metav1.GroupVersionResource `json:",inline"` // EventTypes is the list of event type to watch. // Possible values are - ADD, UPDATE and DELETE. EventTypes []ResourceEventType `json:"eventTypes" protobuf:"bytes,3,name=eventTypes"` }
ResourceEventSource refers to a event-source for K8s resource related events.
func (*ResourceEventSource) DeepCopy ¶
func (in *ResourceEventSource) DeepCopy() *ResourceEventSource
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ResourceEventSource.
func (*ResourceEventSource) DeepCopyInto ¶
func (in *ResourceEventSource) DeepCopyInto(out *ResourceEventSource)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ResourceEventType ¶
type ResourceEventType string
ResourceEventType is the type of event for the K8s resource mutation
const ( ADD ResourceEventType = "ADD" UPDATE ResourceEventType = "UPDATE" DELETE ResourceEventType = "DELETE" )
possible values of ResourceEventType
type ResourceFilter ¶
type ResourceFilter struct { // Prefix filter is applied on the resource name. // +optional Prefix string `json:"prefix,omitempty" protobuf:"bytes,1,opt,name=prefix"` // Labels provide listing options to K8s API to watch resource/s. // Refer https://kubernetes.io/docs/concepts/overview/working-with-objects/label-selectors/ for more info. // +optional Labels []Selector `json:"labels,omitempty" protobuf:"bytes,2,opt,name=labels"` // Fields provide listing options to K8s API to watch resource/s. // Refer https://kubernetes.io/docs/concepts/overview/working-with-objects/field-selectors/ for more info. // +optional Fields []Selector `json:"fields,omitempty" protobuf:"bytes,3,opt,name=fields"` // If resource is created before the specified time then the event is treated as valid. // +optional CreatedBy metav1.Time `json:"createdBy,omitempty" protobuf:"bytes,4,opt,name=createdBy"` }
ResourceFilter contains K8 ObjectMeta information to further filter resource event objects
func (*ResourceFilter) DeepCopy ¶
func (in *ResourceFilter) DeepCopy() *ResourceFilter
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ResourceFilter.
func (*ResourceFilter) DeepCopyInto ¶
func (in *ResourceFilter) DeepCopyInto(out *ResourceFilter)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type SNSEventSource ¶
type SNSEventSource struct { // Webhook configuration for http server Webhook *webhook.Context `json:"webhook" protobuf:"bytes,1,name=webhook"` // TopicArn TopicArn string `json:"topicArn" protobuf:"bytes,2,name=topicArn"` // AccessKey refers K8 secret containing aws access key AccessKey *corev1.SecretKeySelector `json:"accessKey,omitempty" protobuf:"bytes,3,opt,name=accessKey"` // SecretKey refers K8 secret containing aws secret key SecretKey *corev1.SecretKeySelector `json:"secretKey,omitempty" protobuf:"bytes,4,opt,name=secretKey"` // Namespace refers to Kubernetes namespace to read access related secret from. // +optional Namespace string `json:"namespace,omitempty" protobuf:"bytes,5,opt,name=namespace"` // Region is AWS region Region string `json:"region" protobuf:"bytes,6,name=region"` // RoleARN is the Amazon Resource Name (ARN) of the role to assume. // +optional RoleARN string `json:"roleARN,omitempty" protobuf:"bytes,6,opt,name=roleARN"` }
SNSEventSource refers to event-source for AWS SNS related events
func (*SNSEventSource) DeepCopy ¶
func (in *SNSEventSource) DeepCopy() *SNSEventSource
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SNSEventSource.
func (*SNSEventSource) DeepCopyInto ¶
func (in *SNSEventSource) DeepCopyInto(out *SNSEventSource)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type SQSEventSource ¶
type SQSEventSource struct { // AccessKey refers K8 secret containing aws access key AccessKey *corev1.SecretKeySelector `json:"accessKey,omitempty" protobuf:"bytes,1,opt,name=accessKey"` // SecretKey refers K8 secret containing aws secret key SecretKey *corev1.SecretKeySelector `json:"secretKey,omitempty" protobuf:"bytes,2,opt,name=accessKey"` // Region is AWS region Region string `json:"region" protobuf:"bytes,3,name=region"` // Queue is AWS SQS queue to listen to for messages Queue string `json:"queue" protobuf:"bytes,4,name=queue"` // WaitTimeSeconds is The duration (in seconds) for which the call waits for a message to arrive // in the queue before returning. WaitTimeSeconds int64 `json:"waitTimeSeconds" protobuf:"bytes,5,name=waitTimeSeconds"` // Namespace refers to Kubernetes namespace to read access related secret from. // +optional Namespace string `json:"namespace,omitempty" protobuf:"bytes,6,opt,name=namespace"` // RoleARN is the Amazon Resource Name (ARN) of the role to assume. // +optional RoleARN string `json:"roleARN,omitempty" protobuf:"bytes,7,opt,name=roleARN"` // JSONBody specifies that all event body payload coming from this // source will be JSON // +optional JSONBody bool `json:"jsonBody,omitempty" protobuf:"bytes,8,opt,name=jsonBody"` // QueueAccountId is the ID of the account that created the queue to monitor // +optional QueueAccountId string `json:"queueAccountId,omitempty" protobuf:"bytes,9,opt,name=queueAccountId"` }
SQSEventSource refers to event-source for AWS SQS related events
func (*SQSEventSource) DeepCopy ¶
func (in *SQSEventSource) DeepCopy() *SQSEventSource
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SQSEventSource.
func (*SQSEventSource) DeepCopyInto ¶
func (in *SQSEventSource) DeepCopyInto(out *SQSEventSource)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type Selector ¶ added in v0.14.0
type Selector struct { // Key name Key string `json:"key" protobuf:"bytes,1,name=key"` // Supported operations like ==, !=, <=, >= etc. // Defaults to ==. // Refer https://kubernetes.io/docs/concepts/overview/working-with-objects/labels/#label-selectors for more info. // +optional Operation string `json:"operation,omitempty" protobuf:"bytes,2,opt,name=operation"` // Value Value string `json:"value" protobuf:"bytes,3,name=value"` }
Selector represents conditional operation to select K8s objects.
func (*Selector) DeepCopy ¶ added in v0.14.0
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Selector.
func (*Selector) DeepCopyInto ¶ added in v0.14.0
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type SlackEventSource ¶
type SlackEventSource struct { // Slack App signing secret SigningSecret *corev1.SecretKeySelector `json:"signingSecret,omitempty" protobuf:"bytes,1,opt,name=signingSecret"` // Token for URL verification handshake Token *corev1.SecretKeySelector `json:"token,omitempty" protobuf:"bytes,2,name=token"` // Webhook holds configuration for a REST endpoint Webhook *webhook.Context `json:"webhook" protobuf:"bytes,3,name=webhook"` // Namespace refers to Kubernetes namespace which is used to retrieve token and signing secret from. // +optional Namespace string `json:"namespace,omitempty" protobuf:"bytes,4.opt,name=namespace"` }
SlackEventSource refers to event-source for Slack related events
func (*SlackEventSource) DeepCopy ¶
func (in *SlackEventSource) DeepCopy() *SlackEventSource
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SlackEventSource.
func (*SlackEventSource) DeepCopyInto ¶
func (in *SlackEventSource) DeepCopyInto(out *SlackEventSource)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type StorageGridEventSource ¶
type StorageGridEventSource struct { // Webhook holds configuration for a REST endpoint Webhook *webhook.Context `json:"webhook" protobuf:"bytes,1,name=webhook"` // Events are s3 bucket notification events. // For more information on s3 notifications, follow https://docs.aws.amazon.com/AmazonS3/latest/dev/NotificationHowTo.html#notification-how-to-event-types-and-destinations // Note that storage grid notifications do not contain `s3:` // +listType=string Events []string `json:"events,omitempty" protobuf:"bytes,2,opt,name=events"` // Filter on object key which caused the notification. Filter *StorageGridFilter `json:"filter,omitempty" protobuf:"bytes,3,opt,name=filter"` }
StorageGridEventSource refers to event-source for StorageGrid related events
func (*StorageGridEventSource) DeepCopy ¶
func (in *StorageGridEventSource) DeepCopy() *StorageGridEventSource
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StorageGridEventSource.
func (*StorageGridEventSource) DeepCopyInto ¶
func (in *StorageGridEventSource) DeepCopyInto(out *StorageGridEventSource)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type StorageGridFilter ¶
Filter represents filters to apply to bucket notifications for specifying constraints on objects +k8s:openapi-gen=true
func (*StorageGridFilter) DeepCopy ¶
func (in *StorageGridFilter) DeepCopy() *StorageGridFilter
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StorageGridFilter.
func (*StorageGridFilter) DeepCopyInto ¶
func (in *StorageGridFilter) DeepCopyInto(out *StorageGridFilter)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type StripeEventSource ¶
type StripeEventSource struct { // Webhook holds configuration for a REST endpoint Webhook *webhook.Context `json:"webhook" protobuf:"bytes,1,name=webhook"` // CreateWebhook if specified creates a new webhook programmatically. // +optional CreateWebhook bool `json:"createWebhook,omitempty" protobuf:"bytes,2,opt,name=createWebhook"` // APIKey refers to K8s secret that holds Stripe API key. Used only if CreateWebhook is enabled. // +optional APIKey *corev1.SecretKeySelector `json:"apiKey,omitempty" protobuf:"bytes,3,opt,name=apiKey"` // Namespace to retrieve the APIKey secret from. Must be specified in order to read API key from APIKey K8s secret. // +optional Namespace string `json:"namespace,omitempty" protobuf:"bytes,4,opt,name=namespace"` // EventFilter describes the type of events to listen to. If not specified, all types of events will be processed. // More info at https://stripe.com/docs/api/events/list // +optional // +listType=string EventFilter []string `json:"eventFilter,omitempty" protobuf:"bytes,5,rep,name=eventFilter"` }
StripeEventSource describes the event source for stripe webhook notifications More info at https://stripe.com/docs/webhooks
func (*StripeEventSource) DeepCopy ¶
func (in *StripeEventSource) DeepCopy() *StripeEventSource
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StripeEventSource.
func (*StripeEventSource) DeepCopyInto ¶
func (in *StripeEventSource) DeepCopyInto(out *StripeEventSource)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type TLSConfig ¶ added in v0.14.0
type TLSConfig struct { // CACertPath refers the file path that contains the CA cert. CACertPath string `json:"caCertPath" protobuf:"bytes,1,name=caCertPath"` // ClientCertPath refers the file path that contains client cert. ClientCertPath string `json:"clientCertPath" protobuf:"bytes,2,name=clientCertPath"` // ClientKeyPath refers the file path that contains client key. ClientKeyPath string `json:"clientKeyPath" protobuf:"bytes,3,name=clientKeyPath"` }
TLSConfig refers to TLS configuration for a client.
func (*TLSConfig) DeepCopy ¶ added in v0.14.0
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TLSConfig.
func (*TLSConfig) DeepCopyInto ¶ added in v0.14.0
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.