v1alpha1

package
v1.3.0-rc3 Latest Latest
Warning

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

 Go to latest Published: Apr 5, 2021 License: Apache-2.0 Imports: 21 Imported by: 12

Documentation

Overview

Package v1alpha1 is the v1alpha1 version of the API. +groupName=argoproj.io +k8s:deepcopy-gen=package,register +k8s:openapi-gen=true

Package v1alpha1 contains API Schema definitions for the sources v1alpha1 API group +k8s:openapi-gen=true +k8s:deepcopy-gen=package,register +k8s:defaulter-gen=TypeMeta +groupName=argoproj.io

Index

Constants

View Source 
const (
	// EventSourceConditionSourcesProvided has the status True when the EventSource
	// has its event source provided.
	EventSourceConditionSourcesProvided apicommon.ConditionType = "SourcesProvided"
	// EventSourceConditionDeployed has the status True when the EventSource
	// has its Deployment created.
	EventSourceConditionDeployed apicommon.ConditionType = "Deployed"
)

Variables

View Source 
var (
	ErrInvalidLengthGenerated        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowGenerated          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupGenerated = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	// SchemeGroupVersion is a group version used to register these objects
	SchemeGroupVersion = schema.GroupVersion{Group: eventsource.Group, Version: "v1alpha1"}

	// SchemaGroupVersionKind is a group version kind used to attach owner references to gateway-controller
	SchemaGroupVersionKind = schema.GroupVersionKind{Group: eventsource.Group, Version: "v1alpha1", Kind: eventsource.Kind}

	// SchemeBuilder is used to add go types to the GroupVersionKind scheme
	SchemeBuilder = runtime.NewSchemeBuilder(addKnownTypes)

	// AddToScheme is required by pkg/client/...
	AddToScheme = SchemeBuilder.AddToScheme
)

Functions

func GetOpenAPIDefinitions 

func GetOpenAPIDefinitions(ref common.ReferenceCallback) map[string]common.OpenAPIDefinition

func Kind 

func Kind(kind string) schema.GroupKind

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

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

Types

type AMQPConsumeConfig added in v1.3.0 

type AMQPConsumeConfig struct {
	// ConsumerTag is the identity of the consumer included in every delivery
	// +optional
	ConsumerTag string `json:"consumerTag,omitempty" protobuf:"bytes,1,opt,name=consumerTag"`
	// AutoAck when true, the server will acknowledge deliveries to this consumer prior to writing
	// the delivery to the network
	// +optional
	AutoAck bool `json:"autoAck,omitempty" protobuf:"varint,2,opt,name=autoAck"`
	// Exclusive when true, the server will ensure that this is the sole consumer from this queue
	// +optional
	Exclusive bool `json:"exclusive,omitempty" protobuf:"varint,3,opt,name=exclusive"`
	// NoLocal flag is not supported by RabbitMQ
	// +optional
	NoLocal bool `json:"noLocal,omitempty" protobuf:"varint,4,opt,name=noLocal"`
	// NowWait when true, do not wait for the server to confirm the request and immediately begin deliveries
	// +optional
	NoWait bool `json:"noWait,omitempty" protobuf:"varint,5,opt,name=noWait"`
}

AMQPConsumeConfig holds the configuration to immediately starts delivering queued messages +k8s:openapi-gen=true

func (*AMQPConsumeConfig) DeepCopy added in v1.3.0 

func (in *AMQPConsumeConfig) DeepCopy() *AMQPConsumeConfig

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

func (*AMQPConsumeConfig) DeepCopyInto added in v1.3.0 

func (in *AMQPConsumeConfig) DeepCopyInto(out *AMQPConsumeConfig)

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

func (*AMQPConsumeConfig) Descriptor added in v1.3.0 

func (*AMQPConsumeConfig) Descriptor() ([]byte, []int)

func (*AMQPConsumeConfig) Marshal added in v1.3.0 

func (m *AMQPConsumeConfig) Marshal() (dAtA []byte, err error)

func (*AMQPConsumeConfig) MarshalTo added in v1.3.0 

func (m *AMQPConsumeConfig) MarshalTo(dAtA []byte) (int, error)

func (*AMQPConsumeConfig) MarshalToSizedBuffer added in v1.3.0 

func (m *AMQPConsumeConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AMQPConsumeConfig) ProtoMessage added in v1.3.0 

func (*AMQPConsumeConfig) ProtoMessage()

func (*AMQPConsumeConfig) Reset added in v1.3.0 

func (m *AMQPConsumeConfig) Reset()

func (*AMQPConsumeConfig) Size added in v1.3.0 

func (m *AMQPConsumeConfig) Size() (n int)

func (*AMQPConsumeConfig) String added in v1.3.0 

func (this *AMQPConsumeConfig) String() string

func (*AMQPConsumeConfig) Unmarshal added in v1.3.0 

func (m *AMQPConsumeConfig) Unmarshal(dAtA []byte) error

func (*AMQPConsumeConfig) XXX_DiscardUnknown added in v1.3.0 

func (m *AMQPConsumeConfig) XXX_DiscardUnknown()

func (*AMQPConsumeConfig) XXX_Marshal added in v1.3.0 

func (m *AMQPConsumeConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AMQPConsumeConfig) XXX_Merge added in v1.3.0 

func (m *AMQPConsumeConfig) XXX_Merge(src proto.Message)

func (*AMQPConsumeConfig) XXX_Size added in v1.3.0 

func (m *AMQPConsumeConfig) XXX_Size() int

func (*AMQPConsumeConfig) XXX_Unmarshal added in v1.3.0 

func (m *AMQPConsumeConfig) XXX_Unmarshal(b []byte) error

type AMQPEventSource 

type AMQPEventSource struct {
	// URL for rabbitmq service
	URL string `json:"url" protobuf:"bytes,1,opt,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,opt,name=exchangeName"`
	// ExchangeType is rabbitmq exchange type
	ExchangeType string `json:"exchangeType" protobuf:"bytes,3,opt,name=exchangeType"`
	// Routing key for bindings
	RoutingKey string `json:"routingKey" protobuf:"bytes,4,opt,name=routingKey"`
	// Backoff holds parameters applied to connection.
	// +optional
	ConnectionBackoff *apicommon.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:"varint,6,opt,name=jsonBody"`
	// TLS configuration for the amqp client.
	// +optional
	TLS *apicommon.TLSConfig `json:"tls,omitempty" protobuf:"bytes,7,opt,name=tls"`
	// Metadata holds the user defined metadata which will passed along the event payload.
	// +optional
	Metadata map[string]string `json:"metadata,omitempty" protobuf:"bytes,8,rep,name=metadata"`
	// ExchangeDeclare holds the configuration for the exchange on the server
	// For more information, visit https://godoc.org/github.com/streadway/amqp#Channel.ExchangeDeclare
	// +optional
	ExchangeDeclare *AMQPExchangeDeclareConfig `json:"exchangeDeclare,omitempty" protobuf:"bytes,9,opt,name=exchangeDeclare"`
	// QueueDeclare holds the configuration of a queue to hold messages and deliver to consumers.
	// Declaring creates a queue if it doesn't already exist, or ensures that an existing queue matches
	// the same parameters
	// For more information, visit https://godoc.org/github.com/streadway/amqp#Channel.QueueDeclare
	// +optional
	QueueDeclare *AMQPQueueDeclareConfig `json:"queueDeclare,omitempty" protobuf:"bytes,10,opt,name=queueDeclare"`
	// QueueBind holds the configuration that binds an exchange to a queue so that publishings to the
	// exchange will be routed to the queue when the publishing routing key matches the binding routing key
	// For more information, visit https://godoc.org/github.com/streadway/amqp#Channel.QueueBind
	// +optional
	QueueBind *AMQPQueueBindConfig `json:"queueBind,omitempty" protobuf:"bytes,11,opt,name=queueBind"`
	// Consume holds the configuration to immediately starts delivering queued messages
	// For more information, visit https://godoc.org/github.com/streadway/amqp#Channel.Consume
	// +optional
	Consume *AMQPConsumeConfig `json:"consume,omitempty" protobuf:"bytes,12,opt,name=consume"`
}

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.

func (*AMQPEventSource) Descriptor added in v0.17.0 

func (*AMQPEventSource) Descriptor() ([]byte, []int)

func (*AMQPEventSource) Marshal added in v0.17.0 

func (m *AMQPEventSource) Marshal() (dAtA []byte, err error)

func (*AMQPEventSource) MarshalTo added in v0.17.0 

func (m *AMQPEventSource) MarshalTo(dAtA []byte) (int, error)

func (*AMQPEventSource) MarshalToSizedBuffer added in v0.17.0 

func (m *AMQPEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AMQPEventSource) ProtoMessage added in v0.17.0 

func (*AMQPEventSource) ProtoMessage()

func (*AMQPEventSource) Reset added in v0.17.0 

func (m *AMQPEventSource) Reset()

func (*AMQPEventSource) Size added in v0.17.0 

func (m *AMQPEventSource) Size() (n int)

func (*AMQPEventSource) String added in v0.17.0 

func (this *AMQPEventSource) String() string

func (*AMQPEventSource) Unmarshal added in v0.17.0 

func (m *AMQPEventSource) Unmarshal(dAtA []byte) error

func (*AMQPEventSource) XXX_DiscardUnknown added in v0.17.0 

func (m *AMQPEventSource) XXX_DiscardUnknown()

func (*AMQPEventSource) XXX_Marshal added in v0.17.0 

func (m *AMQPEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AMQPEventSource) XXX_Merge added in v0.17.0 

func (m *AMQPEventSource) XXX_Merge(src proto.Message)

func (*AMQPEventSource) XXX_Size added in v0.17.0 

func (m *AMQPEventSource) XXX_Size() int

func (*AMQPEventSource) XXX_Unmarshal added in v0.17.0 

func (m *AMQPEventSource) XXX_Unmarshal(b []byte) error

type AMQPExchangeDeclareConfig added in v1.3.0 

type AMQPExchangeDeclareConfig struct {
	// Durable keeps the exchange also after the server restarts
	// +optional
	Durable bool `json:"durable,omitempty" protobuf:"varint,1,opt,name=durable"`
	// AutoDelete removes the exchange when no bindings are active
	// +optional
	AutoDelete bool `json:"autoDelete,omitempty" protobuf:"varint,2,opt,name=autoDelete"`
	// Internal when true does not accept publishings
	// +optional
	Internal bool `json:"internal,omitempty" protobuf:"varint,3,opt,name=internal"`
	// NowWait when true does not wait for a confirmation from the server
	// +optional
	NoWait bool `json:"noWait,omitempty" protobuf:"varint,4,opt,name=noWait"`
}

AMQPExchangeDeclareConfig holds the configuration for the exchange on the server +k8s:openapi-gen=true

func (*AMQPExchangeDeclareConfig) DeepCopy added in v1.3.0 

func (in *AMQPExchangeDeclareConfig) DeepCopy() *AMQPExchangeDeclareConfig

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

func (*AMQPExchangeDeclareConfig) DeepCopyInto added in v1.3.0 

func (in *AMQPExchangeDeclareConfig) DeepCopyInto(out *AMQPExchangeDeclareConfig)

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

func (*AMQPExchangeDeclareConfig) Descriptor added in v1.3.0 

func (*AMQPExchangeDeclareConfig) Descriptor() ([]byte, []int)

func (*AMQPExchangeDeclareConfig) Marshal added in v1.3.0 

func (m *AMQPExchangeDeclareConfig) Marshal() (dAtA []byte, err error)

func (*AMQPExchangeDeclareConfig) MarshalTo added in v1.3.0 

func (m *AMQPExchangeDeclareConfig) MarshalTo(dAtA []byte) (int, error)

func (*AMQPExchangeDeclareConfig) MarshalToSizedBuffer added in v1.3.0 

func (m *AMQPExchangeDeclareConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AMQPExchangeDeclareConfig) ProtoMessage added in v1.3.0 

func (*AMQPExchangeDeclareConfig) ProtoMessage()

func (*AMQPExchangeDeclareConfig) Reset added in v1.3.0 

func (m *AMQPExchangeDeclareConfig) Reset()

func (*AMQPExchangeDeclareConfig) Size added in v1.3.0 

func (m *AMQPExchangeDeclareConfig) Size() (n int)

func (*AMQPExchangeDeclareConfig) String added in v1.3.0 

func (this *AMQPExchangeDeclareConfig) String() string

func (*AMQPExchangeDeclareConfig) Unmarshal added in v1.3.0 

func (m *AMQPExchangeDeclareConfig) Unmarshal(dAtA []byte) error

func (*AMQPExchangeDeclareConfig) XXX_DiscardUnknown added in v1.3.0 

func (m *AMQPExchangeDeclareConfig) XXX_DiscardUnknown()

func (*AMQPExchangeDeclareConfig) XXX_Marshal added in v1.3.0 

func (m *AMQPExchangeDeclareConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AMQPExchangeDeclareConfig) XXX_Merge added in v1.3.0 

func (m *AMQPExchangeDeclareConfig) XXX_Merge(src proto.Message)

func (*AMQPExchangeDeclareConfig) XXX_Size added in v1.3.0 

func (m *AMQPExchangeDeclareConfig) XXX_Size() int

func (*AMQPExchangeDeclareConfig) XXX_Unmarshal added in v1.3.0 

func (m *AMQPExchangeDeclareConfig) XXX_Unmarshal(b []byte) error

type AMQPQueueBindConfig added in v1.3.0 

type AMQPQueueBindConfig struct {
	// NowWait false and the queue could not be bound, the channel will be closed with an error
	// +optional
	NoWait bool `json:"noWait,omitempty" protobuf:"varint,1,opt,name=noWait"`
}

AMQPQueueBindConfig holds the configuration that binds an exchange to a queue so that publishings to the exchange will be routed to the queue when the publishing routing key matches the binding routing key +k8s:openapi-gen=true

func (*AMQPQueueBindConfig) DeepCopy added in v1.3.0 

func (in *AMQPQueueBindConfig) DeepCopy() *AMQPQueueBindConfig

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

func (*AMQPQueueBindConfig) DeepCopyInto added in v1.3.0 

func (in *AMQPQueueBindConfig) DeepCopyInto(out *AMQPQueueBindConfig)

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

func (*AMQPQueueBindConfig) Descriptor added in v1.3.0 

func (*AMQPQueueBindConfig) Descriptor() ([]byte, []int)

func (*AMQPQueueBindConfig) Marshal added in v1.3.0 

func (m *AMQPQueueBindConfig) Marshal() (dAtA []byte, err error)

func (*AMQPQueueBindConfig) MarshalTo added in v1.3.0 

func (m *AMQPQueueBindConfig) MarshalTo(dAtA []byte) (int, error)

func (*AMQPQueueBindConfig) MarshalToSizedBuffer added in v1.3.0 

func (m *AMQPQueueBindConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AMQPQueueBindConfig) ProtoMessage added in v1.3.0 

func (*AMQPQueueBindConfig) ProtoMessage()

func (*AMQPQueueBindConfig) Reset added in v1.3.0 

func (m *AMQPQueueBindConfig) Reset()

func (*AMQPQueueBindConfig) Size added in v1.3.0 

func (m *AMQPQueueBindConfig) Size() (n int)

func (*AMQPQueueBindConfig) String added in v1.3.0 

func (this *AMQPQueueBindConfig) String() string

func (*AMQPQueueBindConfig) Unmarshal added in v1.3.0 

func (m *AMQPQueueBindConfig) Unmarshal(dAtA []byte) error

func (*AMQPQueueBindConfig) XXX_DiscardUnknown added in v1.3.0 

func (m *AMQPQueueBindConfig) XXX_DiscardUnknown()

func (*AMQPQueueBindConfig) XXX_Marshal added in v1.3.0 

func (m *AMQPQueueBindConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AMQPQueueBindConfig) XXX_Merge added in v1.3.0 

func (m *AMQPQueueBindConfig) XXX_Merge(src proto.Message)

func (*AMQPQueueBindConfig) XXX_Size added in v1.3.0 

func (m *AMQPQueueBindConfig) XXX_Size() int

func (*AMQPQueueBindConfig) XXX_Unmarshal added in v1.3.0 

func (m *AMQPQueueBindConfig) XXX_Unmarshal(b []byte) error

type AMQPQueueDeclareConfig added in v1.3.0 

type AMQPQueueDeclareConfig struct {
	// Name of the queue. If empty the server auto-generates a unique name for this queue
	// +optional
	Name string `json:"name,omitempty" protobuf:"bytes,1,opt,name=name"`
	// Durable keeps the queue also after the server restarts
	// +optional
	Durable bool `json:"durable,omitempty" protobuf:"varint,2,opt,name=durable"`
	// AutoDelete removes the queue when no consumers are active
	// +optional
	AutoDelete bool `json:"autoDelete,omitempty" protobuf:"varint,3,opt,name=autoDelete"`
	// Exclusive sets the queues to be accessible only by the connection that declares them and will be
	// deleted wgen the connection closes
	// +optional
	Exclusive bool `json:"exclusive,omitempty" protobuf:"varint,4,opt,name=exclusive"`
	// NowWait when true, the queue assumes to be declared on the server
	// +optional
	NoWait bool `json:"noWait,omitempty" protobuf:"varint,5,opt,name=noWait"`
}

AMQPQueueDeclareConfig holds the configuration of a queue to hold messages and deliver to consumers. Declaring creates a queue if it doesn't already exist, or ensures that an existing queue matches the same parameters +k8s:openapi-gen=true

func (*AMQPQueueDeclareConfig) DeepCopy added in v1.3.0 

func (in *AMQPQueueDeclareConfig) DeepCopy() *AMQPQueueDeclareConfig

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

func (*AMQPQueueDeclareConfig) DeepCopyInto added in v1.3.0 

func (in *AMQPQueueDeclareConfig) DeepCopyInto(out *AMQPQueueDeclareConfig)

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

func (*AMQPQueueDeclareConfig) Descriptor added in v1.3.0 

func (*AMQPQueueDeclareConfig) Descriptor() ([]byte, []int)

func (*AMQPQueueDeclareConfig) Marshal added in v1.3.0 

func (m *AMQPQueueDeclareConfig) Marshal() (dAtA []byte, err error)

func (*AMQPQueueDeclareConfig) MarshalTo added in v1.3.0 

func (m *AMQPQueueDeclareConfig) MarshalTo(dAtA []byte) (int, error)

func (*AMQPQueueDeclareConfig) MarshalToSizedBuffer added in v1.3.0 

func (m *AMQPQueueDeclareConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AMQPQueueDeclareConfig) ProtoMessage added in v1.3.0 

func (*AMQPQueueDeclareConfig) ProtoMessage()

func (*AMQPQueueDeclareConfig) Reset added in v1.3.0 

func (m *AMQPQueueDeclareConfig) Reset()

func (*AMQPQueueDeclareConfig) Size added in v1.3.0 

func (m *AMQPQueueDeclareConfig) Size() (n int)

func (*AMQPQueueDeclareConfig) String added in v1.3.0 

func (this *AMQPQueueDeclareConfig) String() string

func (*AMQPQueueDeclareConfig) Unmarshal added in v1.3.0 

func (m *AMQPQueueDeclareConfig) Unmarshal(dAtA []byte) error

func (*AMQPQueueDeclareConfig) XXX_DiscardUnknown added in v1.3.0 

func (m *AMQPQueueDeclareConfig) XXX_DiscardUnknown()

func (*AMQPQueueDeclareConfig) XXX_Marshal added in v1.3.0 

func (m *AMQPQueueDeclareConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AMQPQueueDeclareConfig) XXX_Merge added in v1.3.0 

func (m *AMQPQueueDeclareConfig) XXX_Merge(src proto.Message)

func (*AMQPQueueDeclareConfig) XXX_Size added in v1.3.0 

func (m *AMQPQueueDeclareConfig) XXX_Size() int

func (*AMQPQueueDeclareConfig) XXX_Unmarshal added in v1.3.0 

func (m *AMQPQueueDeclareConfig) XXX_Unmarshal(b []byte) error

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,opt,name=fqdn"`
	// SharedAccessKeyName is the name you chose for your application's SAS keys
	SharedAccessKeyName *corev1.SecretKeySelector `json:"sharedAccessKeyName,omitempty" protobuf:"bytes,2,opt,name=sharedAccessKeyName"`
	// SharedAccessKey is the generated value of the key
	SharedAccessKey *corev1.SecretKeySelector `json:"sharedAccessKey,omitempty" protobuf:"bytes,3,opt,name=sharedAccessKey"`
	// Event Hub path/name
	HubName string `json:"hubName" protobuf:"bytes,4,opt,name=hubName"`
	// Metadata holds the user defined metadata which will passed along the event payload.
	// +optional
	Metadata map[string]string `json:"metadata,omitempty" protobuf:"bytes,5,rep,name=metadata"`
}

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.

func (*AzureEventsHubEventSource) Descriptor added in v0.17.0 

func (*AzureEventsHubEventSource) Descriptor() ([]byte, []int)

func (*AzureEventsHubEventSource) Marshal added in v0.17.0 

func (m *AzureEventsHubEventSource) Marshal() (dAtA []byte, err error)

func (*AzureEventsHubEventSource) MarshalTo added in v0.17.0 

func (m *AzureEventsHubEventSource) MarshalTo(dAtA []byte) (int, error)

func (*AzureEventsHubEventSource) MarshalToSizedBuffer added in v0.17.0 

func (m *AzureEventsHubEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AzureEventsHubEventSource) ProtoMessage added in v0.17.0 

func (*AzureEventsHubEventSource) ProtoMessage()

func (*AzureEventsHubEventSource) Reset added in v0.17.0 

func (m *AzureEventsHubEventSource) Reset()

func (*AzureEventsHubEventSource) Size added in v0.17.0 

func (m *AzureEventsHubEventSource) Size() (n int)

func (*AzureEventsHubEventSource) String added in v0.17.0 

func (this *AzureEventsHubEventSource) String() string

func (*AzureEventsHubEventSource) Unmarshal added in v0.17.0 

func (m *AzureEventsHubEventSource) Unmarshal(dAtA []byte) error

func (*AzureEventsHubEventSource) XXX_DiscardUnknown added in v0.17.0 

func (m *AzureEventsHubEventSource) XXX_DiscardUnknown()

func (*AzureEventsHubEventSource) XXX_Marshal added in v0.17.0 

func (m *AzureEventsHubEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AzureEventsHubEventSource) XXX_Merge added in v0.17.0 

func (m *AzureEventsHubEventSource) XXX_Merge(src proto.Message)

func (*AzureEventsHubEventSource) XXX_Size added in v0.17.0 

func (m *AzureEventsHubEventSource) XXX_Size() int

func (*AzureEventsHubEventSource) XXX_Unmarshal added in v0.17.0 

func (m *AzureEventsHubEventSource) XXX_Unmarshal(b []byte) error

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,opt,name=schedule"`
	// Interval is a string that describes an interval duration, e.g. 1s, 30m, 2h...
	Interval string `json:"interval" protobuf:"bytes,2,opt,name=interval"`

	ExclusionDates []string `json:"exclusionDates,omitempty" protobuf:"bytes,3,rep,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
	// Deprecated: will be removed in v1.5. Please use Metadata instead.
	UserPayload json.RawMessage `json:"userPayload,omitempty" protobuf:"bytes,5,opt,name=userPayload,casttype=encoding/json.RawMessage"`
	// Metadata holds the user defined metadata which will passed along the event payload.
	// +optional
	Metadata map[string]string `json:"metadata,omitempty" protobuf:"bytes,6,rep,name=metadata"`
	// Persistence hold the configuration for event persistence
	Persistence *EventPersistence `json:"persistence,omitempty" protobuf:"bytes,7,opt,name=persistence"`
}

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.

func (*CalendarEventSource) Descriptor added in v0.17.0 

func (*CalendarEventSource) Descriptor() ([]byte, []int)

func (*CalendarEventSource) Marshal added in v0.17.0 

func (m *CalendarEventSource) Marshal() (dAtA []byte, err error)

func (*CalendarEventSource) MarshalTo added in v0.17.0 

func (m *CalendarEventSource) MarshalTo(dAtA []byte) (int, error)

func (*CalendarEventSource) MarshalToSizedBuffer added in v0.17.0 

func (m *CalendarEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CalendarEventSource) ProtoMessage added in v0.17.0 

func (*CalendarEventSource) ProtoMessage()

func (*CalendarEventSource) Reset added in v0.17.0 

func (m *CalendarEventSource) Reset()

func (*CalendarEventSource) Size added in v0.17.0 

func (m *CalendarEventSource) Size() (n int)

func (*CalendarEventSource) String added in v0.17.0 

func (this *CalendarEventSource) String() string

func (*CalendarEventSource) Unmarshal added in v0.17.0 

func (m *CalendarEventSource) Unmarshal(dAtA []byte) error

func (*CalendarEventSource) XXX_DiscardUnknown added in v0.17.0 

func (m *CalendarEventSource) XXX_DiscardUnknown()

func (*CalendarEventSource) XXX_Marshal added in v0.17.0 

func (m *CalendarEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CalendarEventSource) XXX_Merge added in v0.17.0 

func (m *CalendarEventSource) XXX_Merge(src proto.Message)

func (*CalendarEventSource) XXX_Size added in v0.17.0 

func (m *CalendarEventSource) XXX_Size() int

func (*CalendarEventSource) XXX_Unmarshal added in v0.17.0 

func (m *CalendarEventSource) XXX_Unmarshal(b []byte) error

type CatchupConfiguration added in v1.1.0 

type CatchupConfiguration struct {
	// Enabled enables to triggered the missed schedule when eventsource restarts
	Enabled bool `json:"enabled,omitempty" protobuf:"varint,1,opt,name=enabled"`
	// MaxDuration holds max catchup duration
	MaxDuration string `json:"maxDuration,omitempty" protobuf:"bytes,2,opt,name=maxDuration"`
}

func (*CatchupConfiguration) DeepCopy added in v1.1.0 

func (in *CatchupConfiguration) DeepCopy() *CatchupConfiguration

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

func (*CatchupConfiguration) DeepCopyInto added in v1.1.0 

func (in *CatchupConfiguration) DeepCopyInto(out *CatchupConfiguration)

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

func (*CatchupConfiguration) Descriptor added in v1.1.0 

func (*CatchupConfiguration) Descriptor() ([]byte, []int)

func (*CatchupConfiguration) Marshal added in v1.1.0 

func (m *CatchupConfiguration) Marshal() (dAtA []byte, err error)

func (*CatchupConfiguration) MarshalTo added in v1.1.0 

func (m *CatchupConfiguration) MarshalTo(dAtA []byte) (int, error)

func (*CatchupConfiguration) MarshalToSizedBuffer added in v1.1.0 

func (m *CatchupConfiguration) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CatchupConfiguration) ProtoMessage added in v1.1.0 

func (*CatchupConfiguration) ProtoMessage()

func (*CatchupConfiguration) Reset added in v1.1.0 

func (m *CatchupConfiguration) Reset()

func (*CatchupConfiguration) Size added in v1.1.0 

func (m *CatchupConfiguration) Size() (n int)

func (*CatchupConfiguration) String added in v1.1.0 

func (this *CatchupConfiguration) String() string

func (*CatchupConfiguration) Unmarshal added in v1.1.0 

func (m *CatchupConfiguration) Unmarshal(dAtA []byte) error

func (*CatchupConfiguration) XXX_DiscardUnknown added in v1.1.0 

func (m *CatchupConfiguration) XXX_DiscardUnknown()

func (*CatchupConfiguration) XXX_Marshal added in v1.1.0 

func (m *CatchupConfiguration) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CatchupConfiguration) XXX_Merge added in v1.1.0 

func (m *CatchupConfiguration) XXX_Merge(src proto.Message)

func (*CatchupConfiguration) XXX_Size added in v1.1.0 

func (m *CatchupConfiguration) XXX_Size() int

func (*CatchupConfiguration) XXX_Unmarshal added in v1.1.0 

func (m *CatchupConfiguration) XXX_Unmarshal(b []byte) error

type ConfigMapPersistence added in v1.1.0 

type ConfigMapPersistence struct {
	// Name of the configmap
	Name string `json:"name,omitempty" protobuf:"bytes,1,opt,name=name"`
	// CreateIfNotExist will create configmap if it doesn't exists
	CreateIfNotExist bool `json:"createIfNotExist,omitempty" protobuf:"varint,2,opt,name=createIfNotExist"`
}

func (*ConfigMapPersistence) DeepCopy added in v1.1.0 

func (in *ConfigMapPersistence) DeepCopy() *ConfigMapPersistence

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

func (*ConfigMapPersistence) DeepCopyInto added in v1.1.0 

func (in *ConfigMapPersistence) DeepCopyInto(out *ConfigMapPersistence)

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

func (*ConfigMapPersistence) Descriptor added in v1.1.0 

func (*ConfigMapPersistence) Descriptor() ([]byte, []int)

func (*ConfigMapPersistence) Marshal added in v1.1.0 

func (m *ConfigMapPersistence) Marshal() (dAtA []byte, err error)

func (*ConfigMapPersistence) MarshalTo added in v1.1.0 

func (m *ConfigMapPersistence) MarshalTo(dAtA []byte) (int, error)

func (*ConfigMapPersistence) MarshalToSizedBuffer added in v1.1.0 

func (m *ConfigMapPersistence) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ConfigMapPersistence) ProtoMessage added in v1.1.0 

func (*ConfigMapPersistence) ProtoMessage()

func (*ConfigMapPersistence) Reset added in v1.1.0 

func (m *ConfigMapPersistence) Reset()

func (*ConfigMapPersistence) Size added in v1.1.0 

func (m *ConfigMapPersistence) Size() (n int)

func (*ConfigMapPersistence) String added in v1.1.0 

func (this *ConfigMapPersistence) String() string

func (*ConfigMapPersistence) Unmarshal added in v1.1.0 

func (m *ConfigMapPersistence) Unmarshal(dAtA []byte) error

func (*ConfigMapPersistence) XXX_DiscardUnknown added in v1.1.0 

func (m *ConfigMapPersistence) XXX_DiscardUnknown()

func (*ConfigMapPersistence) XXX_Marshal added in v1.1.0 

func (m *ConfigMapPersistence) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ConfigMapPersistence) XXX_Merge added in v1.1.0 

func (m *ConfigMapPersistence) XXX_Merge(src proto.Message)

func (*ConfigMapPersistence) XXX_Size added in v1.1.0 

func (m *ConfigMapPersistence) XXX_Size() int

func (*ConfigMapPersistence) XXX_Unmarshal added in v1.1.0 

func (m *ConfigMapPersistence) XXX_Unmarshal(b []byte) error

type EmitterEventSource 

type EmitterEventSource struct {
	// Broker URI to connect to.
	Broker string `json:"broker" protobuf:"bytes,1,opt,name=broker"`
	// ChannelKey refers to the channel key
	ChannelKey string `json:"channelKey" protobuf:"bytes,2,opt,name=channelKey"`
	// ChannelName refers to the channel name
	ChannelName string `json:"channelName" protobuf:"bytes,3,opt,name=channelName"`
	// Username to use to connect to broker
	// +optional
	Username *corev1.SecretKeySelector `json:"username,omitempty" protobuf:"bytes,4,opt,name=username"`
	// Password to use to connect to broker
	// +optional
	Password *corev1.SecretKeySelector `json:"password,omitempty" protobuf:"bytes,5,opt,name=password"`
	// Backoff holds parameters applied to connection.
	// +optional
	ConnectionBackoff *apicommon.Backoff `json:"connectionBackoff,omitempty" protobuf:"bytes,6,opt,name=connectionBackoff"`
	// JSONBody specifies that all event body payload coming from this
	// source will be JSON
	// +optional
	JSONBody bool `json:"jsonBody,omitempty" protobuf:"varint,7,opt,name=jsonBody"`
	// TLS configuration for the emitter client.
	// +optional
	TLS *apicommon.TLSConfig `json:"tls,omitempty" protobuf:"bytes,8,opt,name=tls"`
	// Metadata holds the user defined metadata which will passed along the event payload.
	// +optional
	Metadata map[string]string `json:"metadata,omitempty" protobuf:"bytes,9,rep,name=metadata"`
}

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.

func (*EmitterEventSource) Descriptor added in v0.17.0 

func (*EmitterEventSource) Descriptor() ([]byte, []int)

func (*EmitterEventSource) Marshal added in v0.17.0 

func (m *EmitterEventSource) Marshal() (dAtA []byte, err error)

func (*EmitterEventSource) MarshalTo added in v0.17.0 

func (m *EmitterEventSource) MarshalTo(dAtA []byte) (int, error)

func (*EmitterEventSource) MarshalToSizedBuffer added in v0.17.0 

func (m *EmitterEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*EmitterEventSource) ProtoMessage added in v0.17.0 

func (*EmitterEventSource) ProtoMessage()

func (*EmitterEventSource) Reset added in v0.17.0 

func (m *EmitterEventSource) Reset()

func (*EmitterEventSource) Size added in v0.17.0 

func (m *EmitterEventSource) Size() (n int)

func (*EmitterEventSource) String added in v0.17.0 

func (this *EmitterEventSource) String() string

func (*EmitterEventSource) Unmarshal added in v0.17.0 

func (m *EmitterEventSource) Unmarshal(dAtA []byte) error

func (*EmitterEventSource) XXX_DiscardUnknown added in v0.17.0 

func (m *EmitterEventSource) XXX_DiscardUnknown()

func (*EmitterEventSource) XXX_Marshal added in v0.17.0 

func (m *EmitterEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EmitterEventSource) XXX_Merge added in v0.17.0 

func (m *EmitterEventSource) XXX_Merge(src proto.Message)

func (*EmitterEventSource) XXX_Size added in v0.17.0 

func (m *EmitterEventSource) XXX_Size() int

func (*EmitterEventSource) XXX_Unmarshal added in v0.17.0 

func (m *EmitterEventSource) XXX_Unmarshal(b []byte) error

type EventPersistence added in v1.1.0 

type EventPersistence struct {
	// Catchup enables to triggered the missed schedule when eventsource restarts
	Catchup *CatchupConfiguration `json:"catchup,omitempty" protobuf:"bytes,1,opt,name=catchup"`
	// ConfigMap holds configmap details for persistence
	ConfigMap *ConfigMapPersistence `json:"configMap,omitempty" protobuf:"bytes,2,opt,name=configMap"`
}

func (*EventPersistence) DeepCopy added in v1.1.0 

func (in *EventPersistence) DeepCopy() *EventPersistence

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

func (*EventPersistence) DeepCopyInto added in v1.1.0 

func (in *EventPersistence) DeepCopyInto(out *EventPersistence)

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

func (*EventPersistence) Descriptor added in v1.1.0 

func (*EventPersistence) Descriptor() ([]byte, []int)

func (*EventPersistence) IsCatchUpEnabled added in v1.1.0 

func (ep *EventPersistence) IsCatchUpEnabled() bool

func (*EventPersistence) Marshal added in v1.1.0 

func (m *EventPersistence) Marshal() (dAtA []byte, err error)

func (*EventPersistence) MarshalTo added in v1.1.0 

func (m *EventPersistence) MarshalTo(dAtA []byte) (int, error)

func (*EventPersistence) MarshalToSizedBuffer added in v1.1.0 

func (m *EventPersistence) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*EventPersistence) ProtoMessage added in v1.1.0 

func (*EventPersistence) ProtoMessage()

func (*EventPersistence) Reset added in v1.1.0 

func (m *EventPersistence) Reset()

func (*EventPersistence) Size added in v1.1.0 

func (m *EventPersistence) Size() (n int)

func (*EventPersistence) String added in v1.1.0 

func (this *EventPersistence) String() string

func (*EventPersistence) Unmarshal added in v1.1.0 

func (m *EventPersistence) Unmarshal(dAtA []byte) error

func (*EventPersistence) XXX_DiscardUnknown added in v1.1.0 

func (m *EventPersistence) XXX_DiscardUnknown()

func (*EventPersistence) XXX_Marshal added in v1.1.0 

func (m *EventPersistence) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EventPersistence) XXX_Merge added in v1.1.0 

func (m *EventPersistence) XXX_Merge(src proto.Message)

func (*EventPersistence) XXX_Size added in v1.1.0 

func (m *EventPersistence) XXX_Size() int

func (*EventPersistence) XXX_Unmarshal added in v1.1.0 

func (m *EventPersistence) XXX_Unmarshal(b []byte) error

type EventSource 

type EventSource struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata" protobuf:"bytes,1,opt,name=metadata"`
	Spec              EventSourceSpec `json:"spec" protobuf:"bytes,2,opt,name=spec"`
	// +optional
	Status EventSourceStatus `json:"status,omitempty" protobuf:"bytes,3,opt,name=status"`
}

EventSource is the definition of a eventsource resource +genclient +kubebuilder:resource:shortName=es +kubebuilder:subresource:status +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.

func (*EventSource) Descriptor added in v0.17.0 

func (*EventSource) Descriptor() ([]byte, []int)

func (*EventSource) Marshal added in v0.17.0 

func (m *EventSource) Marshal() (dAtA []byte, err error)

func (*EventSource) MarshalTo added in v0.17.0 

func (m *EventSource) MarshalTo(dAtA []byte) (int, error)

func (*EventSource) MarshalToSizedBuffer added in v0.17.0 

func (m *EventSource) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*EventSource) ProtoMessage added in v0.17.0 

func (*EventSource) ProtoMessage()

func (*EventSource) Reset added in v0.17.0 

func (m *EventSource) Reset()

func (*EventSource) Size added in v0.17.0 

func (m *EventSource) Size() (n int)

func (*EventSource) String added in v0.17.0 

func (this *EventSource) String() string

func (*EventSource) Unmarshal added in v0.17.0 

func (m *EventSource) Unmarshal(dAtA []byte) error

func (*EventSource) XXX_DiscardUnknown added in v0.17.0 

func (m *EventSource) XXX_DiscardUnknown()

func (*EventSource) XXX_Marshal added in v0.17.0 

func (m *EventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EventSource) XXX_Merge added in v0.17.0 

func (m *EventSource) XXX_Merge(src proto.Message)

func (*EventSource) XXX_Size added in v0.17.0 

func (m *EventSource) XXX_Size() int

func (*EventSource) XXX_Unmarshal added in v0.17.0 

func (m *EventSource) XXX_Unmarshal(b []byte) error

type EventSourceList 

type EventSourceList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata" protobuf:"bytes,1,opt,name=metadata"`

	Items []EventSource `json:"items" protobuf:"bytes,2,rep,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.

func (*EventSourceList) Descriptor added in v0.17.0 

func (*EventSourceList) Descriptor() ([]byte, []int)

func (*EventSourceList) Marshal added in v0.17.0 

func (m *EventSourceList) Marshal() (dAtA []byte, err error)

func (*EventSourceList) MarshalTo added in v0.17.0 

func (m *EventSourceList) MarshalTo(dAtA []byte) (int, error)

func (*EventSourceList) MarshalToSizedBuffer added in v0.17.0 

func (m *EventSourceList) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*EventSourceList) ProtoMessage added in v0.17.0 

func (*EventSourceList) ProtoMessage()

func (*EventSourceList) Reset added in v0.17.0 

func (m *EventSourceList) Reset()

func (*EventSourceList) Size added in v0.17.0 

func (m *EventSourceList) Size() (n int)

func (*EventSourceList) String added in v0.17.0 

func (this *EventSourceList) String() string

func (*EventSourceList) Unmarshal added in v0.17.0 

func (m *EventSourceList) Unmarshal(dAtA []byte) error

func (*EventSourceList) XXX_DiscardUnknown added in v0.17.0 

func (m *EventSourceList) XXX_DiscardUnknown()

func (*EventSourceList) XXX_Marshal added in v0.17.0 

func (m *EventSourceList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EventSourceList) XXX_Merge added in v0.17.0 

func (m *EventSourceList) XXX_Merge(src proto.Message)

func (*EventSourceList) XXX_Size added in v0.17.0 

func (m *EventSourceList) XXX_Size() int

func (*EventSourceList) XXX_Unmarshal added in v0.17.0 

func (m *EventSourceList) XXX_Unmarshal(b []byte) error

type EventSourceSpec 

type EventSourceSpec struct {
	// EventBusName references to a EventBus name. By default the value is "default"
	EventBusName string `json:"eventBusName,omitempty" protobuf:"bytes,1,opt,name=eventBusName"`
	// Template is the pod specification for the event source
	// +optional
	Template *Template `json:"template,omitempty" protobuf:"bytes,2,opt,name=template"`
	// Service is the specifications of the service to expose the event source
	// +optional
	Service *Service `json:"service,omitempty" protobuf:"bytes,3,opt,name=service"`
	// DeprecatedReplica is the event source deployment replicas
	// Deprecated: use replicas instead, will be removed in v1.5
	DeprecatedReplica *int32 `json:"replica,omitempty" protobuf:"varint,4,opt,name=replica"`

	// Minio event sources
	Minio map[string]apicommon.S3Artifact `json:"minio,omitempty" protobuf:"bytes,5,rep,name=minio"`
	// Calendar event sources
	Calendar map[string]CalendarEventSource `json:"calendar,omitempty" protobuf:"bytes,6,rep,name=calendar"`
	// File event sources
	File map[string]FileEventSource `json:"file,omitempty" protobuf:"bytes,7,rep,name=file"`
	// Resource event sources
	Resource map[string]ResourceEventSource `json:"resource,omitempty" protobuf:"bytes,8,rep,name=resource"`
	// Webhook event sources
	Webhook map[string]WebhookContext `json:"webhook,omitempty" protobuf:"bytes,9,rep,name=webhook"`
	// AMQP event sources
	AMQP map[string]AMQPEventSource `json:"amqp,omitempty" protobuf:"bytes,10,rep,name=amqp"`
	// Kafka event sources
	Kafka map[string]KafkaEventSource `json:"kafka,omitempty" protobuf:"bytes,11,rep,name=kafka"`
	// MQTT event sources
	MQTT map[string]MQTTEventSource `json:"mqtt,omitempty" protobuf:"bytes,12,rep,name=mqtt"`
	// NATS event sources
	NATS map[string]NATSEventsSource `json:"nats,omitempty" protobuf:"bytes,13,rep,name=nats"`
	// SNS event sources
	SNS map[string]SNSEventSource `json:"sns,omitempty" protobuf:"bytes,14,rep,name=sns"`
	// SQS event sources
	SQS map[string]SQSEventSource `json:"sqs,omitempty" protobuf:"bytes,15,rep,name=sqs"`
	// PubSub event sources
	PubSub map[string]PubSubEventSource `json:"pubSub,omitempty" protobuf:"bytes,16,rep,name=pubSub"`
	// Github event sources
	Github map[string]GithubEventSource `json:"github,omitempty" protobuf:"bytes,17,rep,name=github"`
	// Gitlab event sources
	Gitlab map[string]GitlabEventSource `json:"gitlab,omitempty" protobuf:"bytes,18,rep,name=gitlab"`
	// HDFS event sources
	HDFS map[string]HDFSEventSource `json:"hdfs,omitempty" protobuf:"bytes,19,rep,name=hdfs"`
	// Slack event sources
	Slack map[string]SlackEventSource `json:"slack,omitempty" protobuf:"bytes,20,rep,name=slack"`
	// StorageGrid event sources
	StorageGrid map[string]StorageGridEventSource `json:"storageGrid,omitempty" protobuf:"bytes,21,rep,name=storageGrid"`
	// AzureEventsHub event sources
	AzureEventsHub map[string]AzureEventsHubEventSource `json:"azureEventsHub,omitempty" protobuf:"bytes,22,rep,name=azureEventsHub"`
	// Stripe event sources
	Stripe map[string]StripeEventSource `json:"stripe,omitempty" protobuf:"bytes,23,rep,name=stripe"`
	// Emitter event source
	Emitter map[string]EmitterEventSource `json:"emitter,omitempty" protobuf:"bytes,24,rep,name=emitter"`
	// Redis event source
	Redis map[string]RedisEventSource `json:"redis,omitempty" protobuf:"bytes,25,rep,name=redis"`
	// NSQ event source
	NSQ map[string]NSQEventSource `json:"nsq,omitempty" protobuf:"bytes,26,rep,name=nsq"`
	// Pulsar event source
	Pulsar map[string]PulsarEventSource `json:"pulsar,omitempty" protobuf:"bytes,27,opt,name=pulsar"`
	// Generic event source
	Generic map[string]GenericEventSource `json:"generic,omitempty" protobuf:"bytes,28,rep,name=generic"`
	// Replicas is the event source deployment replicas
	Replicas *int32 `json:"replicas,omitempty" protobuf:"varint,29,opt,name=replicas"`
}

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.

func (*EventSourceSpec) Descriptor added in v0.17.0 

func (*EventSourceSpec) Descriptor() ([]byte, []int)

func (EventSourceSpec) GetReplicas added in v1.3.0 

func (e EventSourceSpec) GetReplicas() int32

func (*EventSourceSpec) Marshal added in v0.17.0 

func (m *EventSourceSpec) Marshal() (dAtA []byte, err error)

func (*EventSourceSpec) MarshalTo added in v0.17.0 

func (m *EventSourceSpec) MarshalTo(dAtA []byte) (int, error)

func (*EventSourceSpec) MarshalToSizedBuffer added in v0.17.0 

func (m *EventSourceSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*EventSourceSpec) ProtoMessage added in v0.17.0 

func (*EventSourceSpec) ProtoMessage()

func (*EventSourceSpec) Reset added in v0.17.0 

func (m *EventSourceSpec) Reset()

func (*EventSourceSpec) Size added in v0.17.0 

func (m *EventSourceSpec) Size() (n int)

func (*EventSourceSpec) String added in v0.17.0 

func (this *EventSourceSpec) String() string

func (*EventSourceSpec) Unmarshal added in v0.17.0 

func (m *EventSourceSpec) Unmarshal(dAtA []byte) error

func (*EventSourceSpec) XXX_DiscardUnknown added in v0.17.0 

func (m *EventSourceSpec) XXX_DiscardUnknown()

func (*EventSourceSpec) XXX_Marshal added in v0.17.0 

func (m *EventSourceSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EventSourceSpec) XXX_Merge added in v0.17.0 

func (m *EventSourceSpec) XXX_Merge(src proto.Message)

func (*EventSourceSpec) XXX_Size added in v0.17.0 

func (m *EventSourceSpec) XXX_Size() int

func (*EventSourceSpec) XXX_Unmarshal added in v0.17.0 

func (m *EventSourceSpec) XXX_Unmarshal(b []byte) error

type EventSourceStatus 

type EventSourceStatus struct {
	apicommon.Status `json:",inline" protobuf:"bytes,1,opt,name=status"`
}

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.

func (*EventSourceStatus) Descriptor added in v0.17.0 

func (*EventSourceStatus) Descriptor() ([]byte, []int)

func (*EventSourceStatus) InitConditions added in v0.17.0 

func (es *EventSourceStatus) InitConditions()

InitConditions sets conditions to Unknown state.

func (*EventSourceStatus) MarkDeployFailed added in v0.17.0 

func (es *EventSourceStatus) MarkDeployFailed(reason, message string)

MarkDeployFailed set the eventsource deploy failed

func (*EventSourceStatus) MarkDeployed added in v0.17.0 

func (es *EventSourceStatus) MarkDeployed()

MarkDeployed set the eventsource has been deployed.

func (*EventSourceStatus) MarkSourcesNotProvided added in v0.17.0 

func (es *EventSourceStatus) MarkSourcesNotProvided(reason, message string)

MarkSourcesNotProvided the eventsource has invalid sources spec provided.

func (*EventSourceStatus) MarkSourcesProvided added in v0.17.0 

func (es *EventSourceStatus) MarkSourcesProvided()

MarkSourcesProvided set the eventsource has valid sources spec provided.

func (*EventSourceStatus) Marshal added in v0.17.0 

func (m *EventSourceStatus) Marshal() (dAtA []byte, err error)

func (*EventSourceStatus) MarshalTo added in v0.17.0 

func (m *EventSourceStatus) MarshalTo(dAtA []byte) (int, error)

func (*EventSourceStatus) MarshalToSizedBuffer added in v0.17.0 

func (m *EventSourceStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*EventSourceStatus) ProtoMessage added in v0.17.0 

func (*EventSourceStatus) ProtoMessage()

func (*EventSourceStatus) Reset added in v0.17.0 

func (m *EventSourceStatus) Reset()

func (*EventSourceStatus) Size added in v0.17.0 

func (m *EventSourceStatus) Size() (n int)

func (*EventSourceStatus) String added in v0.17.0 

func (this *EventSourceStatus) String() string

func (*EventSourceStatus) Unmarshal added in v0.17.0 

func (m *EventSourceStatus) Unmarshal(dAtA []byte) error

func (*EventSourceStatus) XXX_DiscardUnknown added in v0.17.0 

func (m *EventSourceStatus) XXX_DiscardUnknown()

func (*EventSourceStatus) XXX_Marshal added in v0.17.0 

func (m *EventSourceStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EventSourceStatus) XXX_Merge added in v0.17.0 

func (m *EventSourceStatus) XXX_Merge(src proto.Message)

func (*EventSourceStatus) XXX_Size added in v0.17.0 

func (m *EventSourceStatus) XXX_Size() int

func (*EventSourceStatus) XXX_Unmarshal added in v0.17.0 

func (m *EventSourceStatus) XXX_Unmarshal(b []byte) error

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,opt,name=eventType"`
	// WatchPathConfig contains configuration about the file path to watch
	WatchPathConfig WatchPathConfig `json:"watchPathConfig" protobuf:"bytes,2,opt,name=watchPathConfig"`
	// Use polling instead of inotify
	Polling bool `json:"polling,omitempty" protobuf:"varint,3,opt,name=polling"`
	// Metadata holds the user defined metadata which will passed along the event payload.
	// +optional
	Metadata map[string]string `json:"metadata,omitempty" protobuf:"bytes,4,rep,name=metadata"`
}

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.

func (*FileEventSource) Descriptor added in v0.17.0 

func (*FileEventSource) Descriptor() ([]byte, []int)

func (*FileEventSource) Marshal added in v0.17.0 

func (m *FileEventSource) Marshal() (dAtA []byte, err error)

func (*FileEventSource) MarshalTo added in v0.17.0 

func (m *FileEventSource) MarshalTo(dAtA []byte) (int, error)

func (*FileEventSource) MarshalToSizedBuffer added in v0.17.0 

func (m *FileEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*FileEventSource) ProtoMessage added in v0.17.0 

func (*FileEventSource) ProtoMessage()

func (*FileEventSource) Reset added in v0.17.0 

func (m *FileEventSource) Reset()

func (*FileEventSource) Size added in v0.17.0 

func (m *FileEventSource) Size() (n int)

func (*FileEventSource) String added in v0.17.0 

func (this *FileEventSource) String() string

func (*FileEventSource) Unmarshal added in v0.17.0 

func (m *FileEventSource) Unmarshal(dAtA []byte) error

func (*FileEventSource) XXX_DiscardUnknown added in v0.17.0 

func (m *FileEventSource) XXX_DiscardUnknown()

func (*FileEventSource) XXX_Marshal added in v0.17.0 

func (m *FileEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FileEventSource) XXX_Merge added in v0.17.0 

func (m *FileEventSource) XXX_Merge(src proto.Message)

func (*FileEventSource) XXX_Size added in v0.17.0 

func (m *FileEventSource) XXX_Size() int

func (*FileEventSource) XXX_Unmarshal added in v0.17.0 

func (m *FileEventSource) XXX_Unmarshal(b []byte) error

type GenericEventSource 

type GenericEventSource struct {
	// URL of the gRPC server that implements the event source.
	URL string `json:"url" protobuf:"bytes,1,name=url"`
	// Config is the event source configuration
	Config string `json:"config" protobuf:"bytes,2,name=config"`
	// Insecure determines the type of connection.
	Insecure bool `json:"insecure,omitempty" protobuf:"varint,3,opt,name=insecure"`
	// JSONBody specifies that all event body payload coming from this
	// source will be JSON
	// +optional
	JSONBody bool `json:"jsonBody,omitempty" protobuf:"varint,4,opt,name=jsonBody"`
	// Metadata holds the user defined metadata which will passed along the event payload.
	// +optional
	Metadata map[string]string `json:"metadata,omitempty" protobuf:"bytes,5,rep,name=metadata"`
	// AuthSecret holds a secret selector that contains a bearer token for authentication
	// +optional
	AuthSecret *corev1.SecretKeySelector `json:"authSecret,omitempty" protobuf:"bytes,6,opt,name=authSecret"`
}

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.

func (*GenericEventSource) Descriptor added in v0.17.0 

func (*GenericEventSource) Descriptor() ([]byte, []int)

func (*GenericEventSource) Marshal added in v0.17.0 

func (m *GenericEventSource) Marshal() (dAtA []byte, err error)

func (*GenericEventSource) MarshalTo added in v0.17.0 

func (m *GenericEventSource) MarshalTo(dAtA []byte) (int, error)

func (*GenericEventSource) MarshalToSizedBuffer added in v0.17.0 

func (m *GenericEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GenericEventSource) ProtoMessage added in v0.17.0 

func (*GenericEventSource) ProtoMessage()

func (*GenericEventSource) Reset added in v0.17.0 

func (m *GenericEventSource) Reset()

func (*GenericEventSource) Size added in v0.17.0 

func (m *GenericEventSource) Size() (n int)

func (*GenericEventSource) String added in v0.17.0 

func (this *GenericEventSource) String() string

func (*GenericEventSource) Unmarshal added in v0.17.0 

func (m *GenericEventSource) Unmarshal(dAtA []byte) error

func (*GenericEventSource) XXX_DiscardUnknown added in v0.17.0 

func (m *GenericEventSource) XXX_DiscardUnknown()

func (*GenericEventSource) XXX_Marshal added in v0.17.0 

func (m *GenericEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GenericEventSource) XXX_Merge added in v0.17.0 

func (m *GenericEventSource) XXX_Merge(src proto.Message)

func (*GenericEventSource) XXX_Size added in v0.17.0 

func (m *GenericEventSource) XXX_Size() int

func (*GenericEventSource) XXX_Unmarshal added in v0.17.0 

func (m *GenericEventSource) XXX_Unmarshal(b []byte) error

type GithubEventSource 

type GithubEventSource struct {
	// Id is the webhook's id
	ID int64 `json:"id" protobuf:"varint,1,opt,name=id"`
	// Webhook refers to the configuration required to run a http server
	Webhook *WebhookContext `json:"webhook,omitempty" protobuf:"bytes,2,opt,name=webhook"`
	// Owner refers to GitHub owner name i.e. argoproj
	Owner string `json:"owner" protobuf:"bytes,3,opt,name=owner"`
	// Repository refers to GitHub repo name i.e. argo-events
	Repository string `json:"repository" protobuf:"bytes,4,opt,name=repository"`

	Events []string `json:"events" protobuf:"bytes,5,rep,name=events"`
	// APIToken refers to a K8s secret containing github api token
	// +optional
	APIToken *corev1.SecretKeySelector `json:"apiToken,omitempty" protobuf:"bytes,6,opt,name=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:"varint,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:"varint,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"`
	// DeleteHookOnFinish determines whether to delete the GitHub hook for the repository once the event source is stopped.
	// +optional
	DeleteHookOnFinish bool `json:"deleteHookOnFinish,omitempty" protobuf:"varint,13,opt,name=deleteHookOnFinish"`
	// Metadata holds the user defined metadata which will passed along the event payload.
	// +optional
	Metadata map[string]string `json:"metadata,omitempty" protobuf:"bytes,14,rep,name=metadata"`
}

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.

func (*GithubEventSource) Descriptor added in v0.17.0 

func (*GithubEventSource) Descriptor() ([]byte, []int)

func (*GithubEventSource) Marshal added in v0.17.0 

func (m *GithubEventSource) Marshal() (dAtA []byte, err error)

func (*GithubEventSource) MarshalTo added in v0.17.0 

func (m *GithubEventSource) MarshalTo(dAtA []byte) (int, error)

func (*GithubEventSource) MarshalToSizedBuffer added in v0.17.0 

func (m *GithubEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GithubEventSource) ProtoMessage added in v0.17.0 

func (*GithubEventSource) ProtoMessage()

func (*GithubEventSource) Reset added in v0.17.0 

func (m *GithubEventSource) Reset()

func (*GithubEventSource) Size added in v0.17.0 

func (m *GithubEventSource) Size() (n int)

func (*GithubEventSource) String added in v0.17.0 

func (this *GithubEventSource) String() string

func (*GithubEventSource) Unmarshal added in v0.17.0 

func (m *GithubEventSource) Unmarshal(dAtA []byte) error

func (*GithubEventSource) XXX_DiscardUnknown added in v0.17.0 

func (m *GithubEventSource) XXX_DiscardUnknown()

func (*GithubEventSource) XXX_Marshal added in v0.17.0 

func (m *GithubEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GithubEventSource) XXX_Merge added in v0.17.0 

func (m *GithubEventSource) XXX_Merge(src proto.Message)

func (*GithubEventSource) XXX_Size added in v0.17.0 

func (m *GithubEventSource) XXX_Size() int

func (*GithubEventSource) XXX_Unmarshal added in v0.17.0 

func (m *GithubEventSource) XXX_Unmarshal(b []byte) error

type GitlabEventSource 

type GitlabEventSource struct {
	// Webhook holds configuration to run a http server
	Webhook *WebhookContext `json:"webhook,omitempty" protobuf:"bytes,1,opt,name=webhook"`
	// ProjectID is the id of project for which integration needs to setup
	ProjectID string `json:"projectID" protobuf:"bytes,2,opt,name=projectID"`
	// Events are gitlab event to listen to.
	// Refer https://github.com/xanzy/go-gitlab/blob/bf34eca5d13a9f4c3f501d8a97b8ac226d55e4d9/projects.go#L794.
	Events []string `json:"events" protobuf:"bytes,3,opt,name=events"`
	// AccessToken is reference to k8 secret which holds the gitlab api access information
	AccessToken *corev1.SecretKeySelector `json:"accessToken,omitempty" protobuf:"bytes,4,opt,name=accessToken"`
	// EnableSSLVerification to enable ssl verification
	// +optional
	EnableSSLVerification bool `json:"enableSSLVerification,omitempty" protobuf:"varint,5,opt,name=enableSSLVerification"`
	// GitlabBaseURL is the base URL for API requests to a custom endpoint
	GitlabBaseURL string `json:"gitlabBaseURL" protobuf:"bytes,6,opt,name=gitlabBaseURL"`
	// DeleteHookOnFinish determines whether to delete the GitLab hook for the project once the event source is stopped.
	// +optional
	DeleteHookOnFinish bool `json:"deleteHookOnFinish,omitempty" protobuf:"varint,8,opt,name=deleteHookOnFinish"`
	// Metadata holds the user defined metadata which will passed along the event payload.
	// +optional
	Metadata map[string]string `json:"metadata,omitempty" protobuf:"bytes,9,rep,name=metadata"`
}

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.

func (*GitlabEventSource) Descriptor added in v0.17.0 

func (*GitlabEventSource) Descriptor() ([]byte, []int)

func (*GitlabEventSource) Marshal added in v0.17.0 

func (m *GitlabEventSource) Marshal() (dAtA []byte, err error)

func (*GitlabEventSource) MarshalTo added in v0.17.0 

func (m *GitlabEventSource) MarshalTo(dAtA []byte) (int, error)

func (*GitlabEventSource) MarshalToSizedBuffer added in v0.17.0 

func (m *GitlabEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GitlabEventSource) ProtoMessage added in v0.17.0 

func (*GitlabEventSource) ProtoMessage()

func (*GitlabEventSource) Reset added in v0.17.0 

func (m *GitlabEventSource) Reset()

func (*GitlabEventSource) Size added in v0.17.0 

func (m *GitlabEventSource) Size() (n int)

func (*GitlabEventSource) String added in v0.17.0 

func (this *GitlabEventSource) String() string

func (*GitlabEventSource) Unmarshal added in v0.17.0 

func (m *GitlabEventSource) Unmarshal(dAtA []byte) error

func (*GitlabEventSource) XXX_DiscardUnknown added in v0.17.0 

func (m *GitlabEventSource) XXX_DiscardUnknown()

func (*GitlabEventSource) XXX_Marshal added in v0.17.0 

func (m *GitlabEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GitlabEventSource) XXX_Merge added in v0.17.0 

func (m *GitlabEventSource) XXX_Merge(src proto.Message)

func (*GitlabEventSource) XXX_Size added in v0.17.0 

func (m *GitlabEventSource) XXX_Size() int

func (*GitlabEventSource) XXX_Unmarshal added in v0.17.0 

func (m *GitlabEventSource) XXX_Unmarshal(b []byte) error

type HDFSEventSource 

type HDFSEventSource struct {
	WatchPathConfig `json:",inline" protobuf:"bytes,1,opt,name=watchPathConfig"`
	// Type of file operations to watch
	Type string `json:"type" protobuf:"bytes,2,opt,name=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" protobuf:"bytes,3,opt,name=checkInterval"`

	Addresses []string `json:"addresses" protobuf:"bytes,4,rep,name=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" protobuf:"bytes,5,opt,name=hdfsUser"`
	// KrbCCacheSecret is the secret selector for Kerberos ccache
	// Either ccache or keytab can be set to use Kerberos.
	KrbCCacheSecret *corev1.SecretKeySelector `json:"krbCCacheSecret,omitempty" protobuf:"bytes,6,opt,name=krbCCacheSecret"`
	// KrbKeytabSecret is the secret selector for Kerberos keytab
	// Either ccache or keytab can be set to use Kerberos.
	KrbKeytabSecret *corev1.SecretKeySelector `json:"krbKeytabSecret,omitempty" protobuf:"bytes,7,opt,name=krbKeytabSecret"`
	// KrbUsername is the Kerberos username used with Kerberos keytab
	// It must be set if keytab is used.
	KrbUsername string `json:"krbUsername,omitempty" protobuf:"bytes,8,opt,name=krbUsername"`
	// KrbRealm is the Kerberos realm used with Kerberos keytab
	// It must be set if keytab is used.
	KrbRealm string `json:"krbRealm,omitempty" protobuf:"bytes,9,opt,name=krbRealm"`
	// 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" protobuf:"bytes,10,opt,name=krbConfigConfigMap"`
	// KrbServicePrincipalName is the principal name of Kerberos service
	// It must be set if either ccache or keytab is used.
	KrbServicePrincipalName string `json:"krbServicePrincipalName,omitempty" protobuf:"bytes,11,opt,name=krbServicePrincipalName"`
	// Metadata holds the user defined metadata which will passed along the event payload.
	// +optional
	Metadata map[string]string `json:"metadata,omitempty" protobuf:"bytes,12,rep,name=metadata"`
}

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.

func (*HDFSEventSource) Descriptor added in v0.17.0 

func (*HDFSEventSource) Descriptor() ([]byte, []int)

func (*HDFSEventSource) Marshal added in v0.17.0 

func (m *HDFSEventSource) Marshal() (dAtA []byte, err error)

func (*HDFSEventSource) MarshalTo added in v0.17.0 

func (m *HDFSEventSource) MarshalTo(dAtA []byte) (int, error)

func (*HDFSEventSource) MarshalToSizedBuffer added in v0.17.0 

func (m *HDFSEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*HDFSEventSource) ProtoMessage added in v0.17.0 

func (*HDFSEventSource) ProtoMessage()

func (*HDFSEventSource) Reset added in v0.17.0 

func (m *HDFSEventSource) Reset()

func (*HDFSEventSource) Size added in v0.17.0 

func (m *HDFSEventSource) Size() (n int)

func (*HDFSEventSource) String added in v0.17.0 

func (this *HDFSEventSource) String() string

func (*HDFSEventSource) Unmarshal added in v0.17.0 

func (m *HDFSEventSource) Unmarshal(dAtA []byte) error

func (*HDFSEventSource) XXX_DiscardUnknown added in v0.17.0 

func (m *HDFSEventSource) XXX_DiscardUnknown()

func (*HDFSEventSource) XXX_Marshal added in v0.17.0 

func (m *HDFSEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HDFSEventSource) XXX_Merge added in v0.17.0 

func (m *HDFSEventSource) XXX_Merge(src proto.Message)

func (*HDFSEventSource) XXX_Size added in v0.17.0 

func (m *HDFSEventSource) XXX_Size() int

func (*HDFSEventSource) XXX_Unmarshal added in v0.17.0 

func (m *HDFSEventSource) XXX_Unmarshal(b []byte) error

type KafkaConsumerGroup added in v1.0.0 

type KafkaConsumerGroup struct {
	// The name for the consumer group to use
	GroupName string `json:"groupName" protobuf:"bytes,1,opt,name=groupName"`
	// When starting up a new group do we want to start from the oldest event (true) or the newest event (false), defaults to false
	// +optional
	Oldest bool `json:"oldest,omitempty" protobuf:"varint,2,opt,name=oldest"`
	// Rebalance strategy can be one of: sticky, roundrobin, range. Range is the default.
	// +optional
	RebalanceStrategy string `json:"rebalanceStrategy" protobuf:"bytes,3,opt,name=rebalanceStrategy"`
}

func (*KafkaConsumerGroup) DeepCopy added in v1.0.0 

func (in *KafkaConsumerGroup) DeepCopy() *KafkaConsumerGroup

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

func (*KafkaConsumerGroup) DeepCopyInto added in v1.0.0 

func (in *KafkaConsumerGroup) DeepCopyInto(out *KafkaConsumerGroup)

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

func (*KafkaConsumerGroup) Descriptor added in v1.0.0 

func (*KafkaConsumerGroup) Descriptor() ([]byte, []int)

func (*KafkaConsumerGroup) Marshal added in v1.0.0 

func (m *KafkaConsumerGroup) Marshal() (dAtA []byte, err error)

func (*KafkaConsumerGroup) MarshalTo added in v1.0.0 

func (m *KafkaConsumerGroup) MarshalTo(dAtA []byte) (int, error)

func (*KafkaConsumerGroup) MarshalToSizedBuffer added in v1.0.0 

func (m *KafkaConsumerGroup) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*KafkaConsumerGroup) ProtoMessage added in v1.0.0 

func (*KafkaConsumerGroup) ProtoMessage()

func (*KafkaConsumerGroup) Reset added in v1.0.0 

func (m *KafkaConsumerGroup) Reset()

func (*KafkaConsumerGroup) Size added in v1.0.0 

func (m *KafkaConsumerGroup) Size() (n int)

func (*KafkaConsumerGroup) String added in v1.0.0 

func (this *KafkaConsumerGroup) String() string

func (*KafkaConsumerGroup) Unmarshal added in v1.0.0 

func (m *KafkaConsumerGroup) Unmarshal(dAtA []byte) error

func (*KafkaConsumerGroup) XXX_DiscardUnknown added in v1.0.0 

func (m *KafkaConsumerGroup) XXX_DiscardUnknown()

func (*KafkaConsumerGroup) XXX_Marshal added in v1.0.0 

func (m *KafkaConsumerGroup) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*KafkaConsumerGroup) XXX_Merge added in v1.0.0 

func (m *KafkaConsumerGroup) XXX_Merge(src proto.Message)

func (*KafkaConsumerGroup) XXX_Size added in v1.0.0 

func (m *KafkaConsumerGroup) XXX_Size() int

func (*KafkaConsumerGroup) XXX_Unmarshal added in v1.0.0 

func (m *KafkaConsumerGroup) XXX_Unmarshal(b []byte) error

type KafkaEventSource 

type KafkaEventSource struct {
	// URL to kafka cluster, multiple URLs separated by comma
	URL string `json:"url" protobuf:"bytes,1,opt,name=url"`
	// Partition name
	Partition string `json:"partition" protobuf:"bytes,2,opt,name=partition"`
	// Topic name
	Topic string `json:"topic" protobuf:"bytes,3,opt,name=topic"`
	// Backoff holds parameters applied to connection.
	ConnectionBackoff *apicommon.Backoff `json:"connectionBackoff,omitempty" protobuf:"bytes,4,opt,name=connectionBackoff"`
	// TLS configuration for the kafka client.
	// +optional
	TLS *apicommon.TLSConfig `json:"tls,omitempty" protobuf:"bytes,5,opt,name=tls"`
	// JSONBody specifies that all event body payload coming from this
	// source will be JSON
	// +optional
	JSONBody bool `json:"jsonBody,omitempty" protobuf:"varint,6,opt,name=jsonBody"`
	// Metadata holds the user defined metadata which will passed along the event payload.
	// +optional
	Metadata map[string]string `json:"metadata,omitempty" protobuf:"bytes,7,rep,name=metadata"`

	// Consumer group for kafka client
	// +optional
	ConsumerGroup *KafkaConsumerGroup `json:"consumerGroup,omitempty" protobuf:"bytes,8,opt,name=consumerGroup"`

	// Sets a limit on how many events get read from kafka per second.
	// +optional
	LimitEventsPerSecond int64 `json:"limitEventsPerSecond,omitempty" protobuf:"varint,9,opt,name=limitEventsPerSecond"`

	// Specify what kafka version is being connected to enables certain features in sarama, defaults to 1.0.0
	// +optional
	Version string `json:"version" protobuf:"bytes,10,opt,name=version"`
}

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.

func (*KafkaEventSource) Descriptor added in v0.17.0 

func (*KafkaEventSource) Descriptor() ([]byte, []int)

func (*KafkaEventSource) Marshal added in v0.17.0 

func (m *KafkaEventSource) Marshal() (dAtA []byte, err error)

func (*KafkaEventSource) MarshalTo added in v0.17.0 

func (m *KafkaEventSource) MarshalTo(dAtA []byte) (int, error)

func (*KafkaEventSource) MarshalToSizedBuffer added in v0.17.0 

func (m *KafkaEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*KafkaEventSource) ProtoMessage added in v0.17.0 

func (*KafkaEventSource) ProtoMessage()

func (*KafkaEventSource) Reset added in v0.17.0 

func (m *KafkaEventSource) Reset()

func (*KafkaEventSource) Size added in v0.17.0 

func (m *KafkaEventSource) Size() (n int)

func (*KafkaEventSource) String added in v0.17.0 

func (this *KafkaEventSource) String() string

func (*KafkaEventSource) Unmarshal added in v0.17.0 

func (m *KafkaEventSource) Unmarshal(dAtA []byte) error

func (*KafkaEventSource) XXX_DiscardUnknown added in v0.17.0 

func (m *KafkaEventSource) XXX_DiscardUnknown()

func (*KafkaEventSource) XXX_Marshal added in v0.17.0 

func (m *KafkaEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*KafkaEventSource) XXX_Merge added in v0.17.0 

func (m *KafkaEventSource) XXX_Merge(src proto.Message)

func (*KafkaEventSource) XXX_Size added in v0.17.0 

func (m *KafkaEventSource) XXX_Size() int

func (*KafkaEventSource) XXX_Unmarshal added in v0.17.0 

func (m *KafkaEventSource) XXX_Unmarshal(b []byte) error

type MQTTEventSource 

type MQTTEventSource struct {
	// URL to connect to broker
	URL string `json:"url" protobuf:"bytes,1,opt,name=url"`
	// Topic name
	Topic string `json:"topic" protobuf:"bytes,2,opt,name=topic"`
	// ClientID is the id of the client
	ClientID string `json:"clientId" protobuf:"bytes,3,opt,name=clientId"`
	// ConnectionBackoff holds backoff applied to connection.
	ConnectionBackoff *apicommon.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:"varint,5,opt,name=jsonBody"`
	// TLS configuration for the mqtt client.
	// +optional
	TLS *apicommon.TLSConfig `json:"tls,omitempty" protobuf:"bytes,6,opt,name=tls"`
	// Metadata holds the user defined metadata which will passed along the event payload.
	// +optional
	Metadata map[string]string `json:"metadata,omitempty" protobuf:"bytes,7,rep,name=metadata"`
}

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.

func (*MQTTEventSource) Descriptor added in v0.17.0 

func (*MQTTEventSource) Descriptor() ([]byte, []int)

func (*MQTTEventSource) Marshal added in v0.17.0 

func (m *MQTTEventSource) Marshal() (dAtA []byte, err error)

func (*MQTTEventSource) MarshalTo added in v0.17.0 

func (m *MQTTEventSource) MarshalTo(dAtA []byte) (int, error)

func (*MQTTEventSource) MarshalToSizedBuffer added in v0.17.0 

func (m *MQTTEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MQTTEventSource) ProtoMessage added in v0.17.0 

func (*MQTTEventSource) ProtoMessage()

func (*MQTTEventSource) Reset added in v0.17.0 

func (m *MQTTEventSource) Reset()

func (*MQTTEventSource) Size added in v0.17.0 

func (m *MQTTEventSource) Size() (n int)

func (*MQTTEventSource) String added in v0.17.0 

func (this *MQTTEventSource) String() string

func (*MQTTEventSource) Unmarshal added in v0.17.0 

func (m *MQTTEventSource) Unmarshal(dAtA []byte) error

func (*MQTTEventSource) XXX_DiscardUnknown added in v0.17.0 

func (m *MQTTEventSource) XXX_DiscardUnknown()

func (*MQTTEventSource) XXX_Marshal added in v0.17.0 

func (m *MQTTEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MQTTEventSource) XXX_Merge added in v0.17.0 

func (m *MQTTEventSource) XXX_Merge(src proto.Message)

func (*MQTTEventSource) XXX_Size added in v0.17.0 

func (m *MQTTEventSource) XXX_Size() int

func (*MQTTEventSource) XXX_Unmarshal added in v0.17.0 

func (m *MQTTEventSource) XXX_Unmarshal(b []byte) error

type NATSAuth added in v1.3.0 

type NATSAuth struct {
	// Baisc auth with username and password
	// +optional
	Basic *apicommon.BasicAuth `json:"basic,omitempty" protobuf:"bytes,1,opt,name=basic"`
	// Token used to connect
	// +optional
	Token *corev1.SecretKeySelector `json:"token,omitempty" protobuf:"bytes,2,opt,name=token"`
	// NKey used to connect
	// +optional
	NKey *corev1.SecretKeySelector `json:"nkey,omitempty" protobuf:"bytes,3,opt,name=nkey"`
	// credential used to connect
	// +optional
	Credential *corev1.SecretKeySelector `json:"credential,omitempty" protobuf:"bytes,4,opt,name=credential"`
}

NATSAuth refers to the auth info for NATS EventSource

func (*NATSAuth) DeepCopy added in v1.3.0 

func (in *NATSAuth) DeepCopy() *NATSAuth

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

func (*NATSAuth) DeepCopyInto added in v1.3.0 

func (in *NATSAuth) DeepCopyInto(out *NATSAuth)

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

func (*NATSAuth) Descriptor added in v1.3.0 

func (*NATSAuth) Descriptor() ([]byte, []int)

func (*NATSAuth) Marshal added in v1.3.0 

func (m *NATSAuth) Marshal() (dAtA []byte, err error)

func (*NATSAuth) MarshalTo added in v1.3.0 

func (m *NATSAuth) MarshalTo(dAtA []byte) (int, error)

func (*NATSAuth) MarshalToSizedBuffer added in v1.3.0 

func (m *NATSAuth) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*NATSAuth) ProtoMessage added in v1.3.0 

func (*NATSAuth) ProtoMessage()

func (*NATSAuth) Reset added in v1.3.0 

func (m *NATSAuth) Reset()

func (*NATSAuth) Size added in v1.3.0 

func (m *NATSAuth) Size() (n int)

func (*NATSAuth) String added in v1.3.0 

func (this *NATSAuth) String() string

func (*NATSAuth) Unmarshal added in v1.3.0 

func (m *NATSAuth) Unmarshal(dAtA []byte) error

func (*NATSAuth) XXX_DiscardUnknown added in v1.3.0 

func (m *NATSAuth) XXX_DiscardUnknown()

func (*NATSAuth) XXX_Marshal added in v1.3.0 

func (m *NATSAuth) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NATSAuth) XXX_Merge added in v1.3.0 

func (m *NATSAuth) XXX_Merge(src proto.Message)

func (*NATSAuth) XXX_Size added in v1.3.0 

func (m *NATSAuth) XXX_Size() int

func (*NATSAuth) XXX_Unmarshal added in v1.3.0 

func (m *NATSAuth) XXX_Unmarshal(b []byte) error

type NATSEventsSource 

type NATSEventsSource struct {
	// URL to connect to NATS cluster
	URL string `json:"url" protobuf:"bytes,1,opt,name=url"`
	// Subject holds the name of the subject onto which messages are published
	Subject string `json:"subject" protobuf:"bytes,2,opt,name=subject"`
	// ConnectionBackoff holds backoff applied to connection.
	ConnectionBackoff *apicommon.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:"varint,4,opt,name=jsonBody"`
	// TLS configuration for the nats client.
	// +optional
	TLS *apicommon.TLSConfig `json:"tls,omitempty" protobuf:"bytes,5,opt,name=tls"`
	// Metadata holds the user defined metadata which will passed along the event payload.
	// +optional
	Metadata map[string]string `json:"metadata,omitempty" protobuf:"bytes,6,rep,name=metadata"`
	// Auth information
	// +optional
	Auth *NATSAuth `json:"auth,omitempty" protobuf:"bytes,7,opt,name=auth"`
}

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

func (*NATSEventsSource) Descriptor added in v0.17.0 

func (*NATSEventsSource) Descriptor() ([]byte, []int)

func (*NATSEventsSource) Marshal added in v0.17.0 

func (m *NATSEventsSource) Marshal() (dAtA []byte, err error)

func (*NATSEventsSource) MarshalTo added in v0.17.0 

func (m *NATSEventsSource) MarshalTo(dAtA []byte) (int, error)

func (*NATSEventsSource) MarshalToSizedBuffer added in v0.17.0 

func (m *NATSEventsSource) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*NATSEventsSource) ProtoMessage added in v0.17.0 

func (*NATSEventsSource) ProtoMessage()

func (*NATSEventsSource) Reset added in v0.17.0 

func (m *NATSEventsSource) Reset()

func (*NATSEventsSource) Size added in v0.17.0 

func (m *NATSEventsSource) Size() (n int)

func (*NATSEventsSource) String added in v0.17.0 

func (this *NATSEventsSource) String() string

func (*NATSEventsSource) Unmarshal added in v0.17.0 

func (m *NATSEventsSource) Unmarshal(dAtA []byte) error

func (*NATSEventsSource) XXX_DiscardUnknown added in v0.17.0 

func (m *NATSEventsSource) XXX_DiscardUnknown()

func (*NATSEventsSource) XXX_Marshal added in v0.17.0 

func (m *NATSEventsSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NATSEventsSource) XXX_Merge added in v0.17.0 

func (m *NATSEventsSource) XXX_Merge(src proto.Message)

func (*NATSEventsSource) XXX_Size added in v0.17.0 

func (m *NATSEventsSource) XXX_Size() int

func (*NATSEventsSource) XXX_Unmarshal added in v0.17.0 

func (m *NATSEventsSource) XXX_Unmarshal(b []byte) error

type NSQEventSource 

type NSQEventSource struct {
	// HostAddress is the address of the host for NSQ lookup
	HostAddress string `json:"hostAddress" protobuf:"bytes,1,opt,name=hostAddress"`
	// Topic to subscribe to.
	Topic string `json:"topic" protobuf:"bytes,2,opt,name=topic"`
	// Channel used for subscription
	Channel string `json:"channel" protobuf:"bytes,3,opt,name=channel"`
	// Backoff holds parameters applied to connection.
	// +optional
	ConnectionBackoff *apicommon.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:"varint,5,opt,name=jsonBody"`
	// TLS configuration for the nsq client.
	// +optional
	TLS *apicommon.TLSConfig `json:"tls,omitempty" protobuf:"bytes,6,opt,name=tls"`
	// Metadata holds the user defined metadata which will passed along the event payload.
	// +optional
	Metadata map[string]string `json:"metadata,omitempty" protobuf:"bytes,7,rep,name=metadata"`
}

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.

func (*NSQEventSource) Descriptor added in v0.17.0 

func (*NSQEventSource) Descriptor() ([]byte, []int)

func (*NSQEventSource) Marshal added in v0.17.0 

func (m *NSQEventSource) Marshal() (dAtA []byte, err error)

func (*NSQEventSource) MarshalTo added in v0.17.0 

func (m *NSQEventSource) MarshalTo(dAtA []byte) (int, error)

func (*NSQEventSource) MarshalToSizedBuffer added in v0.17.0 

func (m *NSQEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*NSQEventSource) ProtoMessage added in v0.17.0 

func (*NSQEventSource) ProtoMessage()

func (*NSQEventSource) Reset added in v0.17.0 

func (m *NSQEventSource) Reset()

func (*NSQEventSource) Size added in v0.17.0 

func (m *NSQEventSource) Size() (n int)

func (*NSQEventSource) String added in v0.17.0 

func (this *NSQEventSource) String() string

func (*NSQEventSource) Unmarshal added in v0.17.0 

func (m *NSQEventSource) Unmarshal(dAtA []byte) error

func (*NSQEventSource) XXX_DiscardUnknown added in v0.17.0 

func (m *NSQEventSource) XXX_DiscardUnknown()

func (*NSQEventSource) XXX_Marshal added in v0.17.0 

func (m *NSQEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NSQEventSource) XXX_Merge added in v0.17.0 

func (m *NSQEventSource) XXX_Merge(src proto.Message)

func (*NSQEventSource) XXX_Size added in v0.17.0 

func (m *NSQEventSource) XXX_Size() int

func (*NSQEventSource) XXX_Unmarshal added in v0.17.0 

func (m *NSQEventSource) XXX_Unmarshal(b []byte) error

type PubSubEventSource 

type PubSubEventSource struct {
	// ProjectID is GCP project ID for the subscription.
	// Required if you run Argo Events outside of GKE/GCE.
	// (otherwise, the default value is its project)
	// +optional
	ProjectID string `json:"projectID" protobuf:"bytes,1,opt,name=projectID"`
	// TopicProjectID is GCP project ID for the topic.
	// By default, it is same as ProjectID.
	// +optional
	TopicProjectID string `json:"topicProjectID" protobuf:"bytes,2,opt,name=topicProjectID"`
	// Topic to which the subscription should belongs.
	// Required if you want the eventsource to create a new subscription.
	// If you specify this field along with an existing subscription,
	// it will be verified whether it actually belongs to the specified topic.
	// +optional
	Topic string `json:"topic" protobuf:"bytes,3,opt,name=topic"`
	// SubscriptionID is ID of subscription.
	// Required if you use existing subscription.
	// The default value will be auto generated hash based on this eventsource setting, so the subscription
	// might be recreated every time you update the setting, which has a possibility of event loss.
	// +optional
	SubscriptionID string `json:"subscriptionID" protobuf:"bytes,4,opt,name=subscriptionID"`
	// CredentialSecret references to the secret that contains JSON credentials to access GCP.
	// If it is missing, it implicitly uses Workload Identity to access.
	// https://cloud.google.com/kubernetes-engine/docs/how-to/workload-identity
	// +optional
	CredentialSecret *corev1.SecretKeySelector `json:"credentialSecret,omitempty" protobuf:"bytes,5,opt,name=credentialSecret"`
	// DeleteSubscriptionOnFinish determines whether to delete the GCP PubSub subscription once the event source is stopped.
	// +optional
	DeleteSubscriptionOnFinish bool `json:"deleteSubscriptionOnFinish,omitempty" protobuf:"varint,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:"varint,7,opt,name=jsonBody"`
	// CredentialsFile is the file that contains credentials to authenticate for GCP
	// Deprecated: will be removed in v1.5, use CredentialSecret instead
	DeprecatedCredentialsFile string `json:"credentialsFile" protobuf:"bytes,8,opt,name=credentialsFile"`
	// Metadata holds the user defined metadata which will passed along the event payload.
	// +optional
	Metadata map[string]string `json:"metadata,omitempty" protobuf:"bytes,9,rep,name=metadata"`
}

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.

func (*PubSubEventSource) Descriptor added in v0.17.0 

func (*PubSubEventSource) Descriptor() ([]byte, []int)

func (*PubSubEventSource) Marshal added in v0.17.0 

func (m *PubSubEventSource) Marshal() (dAtA []byte, err error)

func (*PubSubEventSource) MarshalTo added in v0.17.0 

func (m *PubSubEventSource) MarshalTo(dAtA []byte) (int, error)

func (*PubSubEventSource) MarshalToSizedBuffer added in v0.17.0 

func (m *PubSubEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PubSubEventSource) ProtoMessage added in v0.17.0 

func (*PubSubEventSource) ProtoMessage()

func (*PubSubEventSource) Reset added in v0.17.0 

func (m *PubSubEventSource) Reset()

func (*PubSubEventSource) Size added in v0.17.0 

func (m *PubSubEventSource) Size() (n int)

func (*PubSubEventSource) String added in v0.17.0 

func (this *PubSubEventSource) String() string

func (*PubSubEventSource) Unmarshal added in v0.17.0 

func (m *PubSubEventSource) Unmarshal(dAtA []byte) error

func (*PubSubEventSource) XXX_DiscardUnknown added in v0.17.0 

func (m *PubSubEventSource) XXX_DiscardUnknown()

func (*PubSubEventSource) XXX_Marshal added in v0.17.0 

func (m *PubSubEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PubSubEventSource) XXX_Merge added in v0.17.0 

func (m *PubSubEventSource) XXX_Merge(src proto.Message)

func (*PubSubEventSource) XXX_Size added in v0.17.0 

func (m *PubSubEventSource) XXX_Size() int

func (*PubSubEventSource) XXX_Unmarshal added in v0.17.0 

func (m *PubSubEventSource) XXX_Unmarshal(b []byte) error

type PulsarEventSource added in v1.0.0 

type PulsarEventSource struct {
	// Name of the topics to subscribe to.
	// +required
	Topics []string `json:"topics" protobuf:"bytes,1,rep,name=topics"`
	// Type of the subscription.
	// Only "exclusive" and "shared" is supported.
	// Defaults to exclusive.
	// +optional
	Type string `json:"type,omitempty" protobuf:"bytes,2,opt,name=type"`
	// Configure the service URL for the Pulsar service.
	// +required
	URL string `json:"url" protobuf:"bytes,3,name=url"`
	// Trusted TLS certificate secret.
	// +optional
	TLSTrustCertsSecret *corev1.SecretKeySelector `json:"tlsTrustCertsSecret,omitempty" protobuf:"bytes,4,opt,name=tlsTrustCertsSecret"`
	// Whether the Pulsar client accept untrusted TLS certificate from broker.
	// +optional
	TLSAllowInsecureConnection bool `json:"tlsAllowInsecureConnection,omitempty" protobuf:"bytes,5,opt,name=tlsAllowInsecureConnection"`
	// Whether the Pulsar client verify the validity of the host name from broker.
	// +optional
	TLSValidateHostname bool `json:"tlsValidateHostname,omitempty" protobuf:"bytes,6,opt,name=tlsValidateHostname"`
	// TLS configuration for the pulsar client.
	// +optional
	TLS *apicommon.TLSConfig `json:"tls,omitempty" protobuf:"bytes,7,opt,name=tls"`
	// Backoff holds parameters applied to connection.
	// +optional
	ConnectionBackoff *apicommon.Backoff `json:"connectionBackoff,omitempty" protobuf:"bytes,8,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,9,opt,name=jsonBody"`
	// Metadata holds the user defined metadata which will passed along the event payload.
	// +optional
	Metadata map[string]string `json:"metadata,omitempty" protobuf:"bytes,10,rep,name=metadata"`
}

PulsarEventSource describes the event source for Apache Pulsar

func (*PulsarEventSource) DeepCopy added in v1.0.0 

func (in *PulsarEventSource) DeepCopy() *PulsarEventSource

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

func (*PulsarEventSource) DeepCopyInto added in v1.0.0 

func (in *PulsarEventSource) DeepCopyInto(out *PulsarEventSource)

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

func (*PulsarEventSource) Descriptor added in v1.0.0 

func (*PulsarEventSource) Descriptor() ([]byte, []int)

func (*PulsarEventSource) Marshal added in v1.0.0 

func (m *PulsarEventSource) Marshal() (dAtA []byte, err error)

func (*PulsarEventSource) MarshalTo added in v1.0.0 

func (m *PulsarEventSource) MarshalTo(dAtA []byte) (int, error)

func (*PulsarEventSource) MarshalToSizedBuffer added in v1.0.0 

func (m *PulsarEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PulsarEventSource) ProtoMessage added in v1.0.0 

func (*PulsarEventSource) ProtoMessage()

func (*PulsarEventSource) Reset added in v1.0.0 

func (m *PulsarEventSource) Reset()

func (*PulsarEventSource) Size added in v1.0.0 

func (m *PulsarEventSource) Size() (n int)

func (*PulsarEventSource) String added in v1.0.0 

func (this *PulsarEventSource) String() string

func (*PulsarEventSource) Unmarshal added in v1.0.0 

func (m *PulsarEventSource) Unmarshal(dAtA []byte) error

func (*PulsarEventSource) XXX_DiscardUnknown added in v1.0.0 

func (m *PulsarEventSource) XXX_DiscardUnknown()

func (*PulsarEventSource) XXX_Marshal added in v1.0.0 

func (m *PulsarEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PulsarEventSource) XXX_Merge added in v1.0.0 

func (m *PulsarEventSource) XXX_Merge(src proto.Message)

func (*PulsarEventSource) XXX_Size added in v1.0.0 

func (m *PulsarEventSource) XXX_Size() int

func (*PulsarEventSource) XXX_Unmarshal added in v1.0.0 

func (m *PulsarEventSource) XXX_Unmarshal(b []byte) error

type RedisEventSource 

type RedisEventSource struct {
	// HostAddress refers to the address of the Redis host/server
	HostAddress string `json:"hostAddress" protobuf:"bytes,1,opt,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 int32 `json:"db,omitempty" protobuf:"varint,4,opt,name=db"`

	Channels []string `json:"channels" protobuf:"bytes,5,rep,name=channels"`
	// TLS configuration for the redis client.
	// +optional
	TLS *apicommon.TLSConfig `json:"tls,omitempty" protobuf:"bytes,6,opt,name=tls"`
	// Metadata holds the user defined metadata which will passed along the event payload.
	// +optional
	Metadata map[string]string `json:"metadata,omitempty" protobuf:"bytes,7,rep,name=metadata"`
}

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.

func (*RedisEventSource) Descriptor added in v0.17.0 

func (*RedisEventSource) Descriptor() ([]byte, []int)

func (*RedisEventSource) Marshal added in v0.17.0 

func (m *RedisEventSource) Marshal() (dAtA []byte, err error)

func (*RedisEventSource) MarshalTo added in v0.17.0 

func (m *RedisEventSource) MarshalTo(dAtA []byte) (int, error)

func (*RedisEventSource) MarshalToSizedBuffer added in v0.17.0 

func (m *RedisEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RedisEventSource) ProtoMessage added in v0.17.0 

func (*RedisEventSource) ProtoMessage()

func (*RedisEventSource) Reset added in v0.17.0 

func (m *RedisEventSource) Reset()

func (*RedisEventSource) Size added in v0.17.0 

func (m *RedisEventSource) Size() (n int)

func (*RedisEventSource) String added in v0.17.0 

func (this *RedisEventSource) String() string

func (*RedisEventSource) Unmarshal added in v0.17.0 

func (m *RedisEventSource) Unmarshal(dAtA []byte) error

func (*RedisEventSource) XXX_DiscardUnknown added in v0.17.0 

func (m *RedisEventSource) XXX_DiscardUnknown()

func (*RedisEventSource) XXX_Marshal added in v0.17.0 

func (m *RedisEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RedisEventSource) XXX_Merge added in v0.17.0 

func (m *RedisEventSource) XXX_Merge(src proto.Message)

func (*RedisEventSource) XXX_Size added in v0.17.0 

func (m *RedisEventSource) XXX_Size() int

func (*RedisEventSource) XXX_Unmarshal added in v0.17.0 

func (m *RedisEventSource) XXX_Unmarshal(b []byte) error

type ResourceEventSource 

type ResourceEventSource struct {
	// Namespace where resource is deployed
	Namespace string `json:"namespace" protobuf:"bytes,1,opt,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" protobuf:"bytes,3,opt,name=groupVersionResource"`
	// EventTypes is the list of event type to watch.
	// Possible values are - ADD, UPDATE and DELETE.
	EventTypes []ResourceEventType `json:"eventTypes" protobuf:"bytes,4,rep,name=eventTypes,casttype=ResourceEventType"`
	// Metadata holds the user defined metadata which will passed along the event payload.
	// +optional
	Metadata map[string]string `json:"metadata,omitempty" protobuf:"bytes,5,rep,name=metadata"`
}

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.

func (*ResourceEventSource) Descriptor added in v0.17.0 

func (*ResourceEventSource) Descriptor() ([]byte, []int)

func (*ResourceEventSource) Marshal added in v0.17.0 

func (m *ResourceEventSource) Marshal() (dAtA []byte, err error)

func (*ResourceEventSource) MarshalTo added in v0.17.0 

func (m *ResourceEventSource) MarshalTo(dAtA []byte) (int, error)

func (*ResourceEventSource) MarshalToSizedBuffer added in v0.17.0 

func (m *ResourceEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ResourceEventSource) ProtoMessage added in v0.17.0 

func (*ResourceEventSource) ProtoMessage()

func (*ResourceEventSource) Reset added in v0.17.0 

func (m *ResourceEventSource) Reset()

func (*ResourceEventSource) Size added in v0.17.0 

func (m *ResourceEventSource) Size() (n int)

func (*ResourceEventSource) String added in v0.17.0 

func (this *ResourceEventSource) String() string

func (*ResourceEventSource) Unmarshal added in v0.17.0 

func (m *ResourceEventSource) Unmarshal(dAtA []byte) error

func (*ResourceEventSource) XXX_DiscardUnknown added in v0.17.0 

func (m *ResourceEventSource) XXX_DiscardUnknown()

func (*ResourceEventSource) XXX_Marshal added in v0.17.0 

func (m *ResourceEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ResourceEventSource) XXX_Merge added in v0.17.0 

func (m *ResourceEventSource) XXX_Merge(src proto.Message)

func (*ResourceEventSource) XXX_Size added in v0.17.0 

func (m *ResourceEventSource) XXX_Size() int

func (*ResourceEventSource) XXX_Unmarshal added in v0.17.0 

func (m *ResourceEventSource) XXX_Unmarshal(b []byte) error

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,rep,name=labels"`
	// Fields provide field filters similar to K8s field selector
	// (see https://kubernetes.io/docs/concepts/overview/working-with-objects/field-selectors/).
	// Unlike K8s field selector, it supports arbitrary fileds like "spec.serviceAccountName",
	// and the value could be a string or a regex.
	// Same as K8s field selector, operator "=", "==" and "!=" are supported.
	// +optional
	Fields []Selector `json:"fields,omitempty" protobuf:"bytes,3,rep,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"`
	// If the resource is created after the start time then the event is treated as valid.
	// +optional
	AfterStart bool `json:"afterStart,omitempty" protobuf:"varint,5,opt,name=afterStart"`
}

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.

func (*ResourceFilter) Descriptor added in v0.17.0 

func (*ResourceFilter) Descriptor() ([]byte, []int)

func (*ResourceFilter) Marshal added in v0.17.0 

func (m *ResourceFilter) Marshal() (dAtA []byte, err error)

func (*ResourceFilter) MarshalTo added in v0.17.0 

func (m *ResourceFilter) MarshalTo(dAtA []byte) (int, error)

func (*ResourceFilter) MarshalToSizedBuffer added in v0.17.0 

func (m *ResourceFilter) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ResourceFilter) ProtoMessage added in v0.17.0 

func (*ResourceFilter) ProtoMessage()

func (*ResourceFilter) Reset added in v0.17.0 

func (m *ResourceFilter) Reset()

func (*ResourceFilter) Size added in v0.17.0 

func (m *ResourceFilter) Size() (n int)

func (*ResourceFilter) String added in v0.17.0 

func (this *ResourceFilter) String() string

func (*ResourceFilter) Unmarshal added in v0.17.0 

func (m *ResourceFilter) Unmarshal(dAtA []byte) error

func (*ResourceFilter) XXX_DiscardUnknown added in v0.17.0 

func (m *ResourceFilter) XXX_DiscardUnknown()

func (*ResourceFilter) XXX_Marshal added in v0.17.0 

func (m *ResourceFilter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ResourceFilter) XXX_Merge added in v0.17.0 

func (m *ResourceFilter) XXX_Merge(src proto.Message)

func (*ResourceFilter) XXX_Size added in v0.17.0 

func (m *ResourceFilter) XXX_Size() int

func (*ResourceFilter) XXX_Unmarshal added in v0.17.0 

func (m *ResourceFilter) XXX_Unmarshal(b []byte) error

type SNSEventSource 

type SNSEventSource struct {
	// Webhook configuration for http server
	Webhook *WebhookContext `json:"webhook,omitempty" protobuf:"bytes,1,opt,name=webhook"`
	// TopicArn
	TopicArn string `json:"topicArn" protobuf:"bytes,2,opt,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"`
	// Region is AWS region
	Region string `json:"region" protobuf:"bytes,5,opt,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"`
	// Metadata holds the user defined metadata which will passed along the event payload.
	// +optional
	Metadata map[string]string `json:"metadata,omitempty" protobuf:"bytes,7,rep,name=metadata"`
	// ValidateSignature is boolean that can be set to true for SNS signature verification
	// +optional
	ValidateSignature bool `json:"validateSignature,omitempty" protobuf:"varint,8,opt,name=validateSignature"`
}

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.

func (*SNSEventSource) Descriptor added in v0.17.0 

func (*SNSEventSource) Descriptor() ([]byte, []int)

func (*SNSEventSource) Marshal added in v0.17.0 

func (m *SNSEventSource) Marshal() (dAtA []byte, err error)

func (*SNSEventSource) MarshalTo added in v0.17.0 

func (m *SNSEventSource) MarshalTo(dAtA []byte) (int, error)

func (*SNSEventSource) MarshalToSizedBuffer added in v0.17.0 

func (m *SNSEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SNSEventSource) ProtoMessage added in v0.17.0 

func (*SNSEventSource) ProtoMessage()

func (*SNSEventSource) Reset added in v0.17.0 

func (m *SNSEventSource) Reset()

func (*SNSEventSource) Size added in v0.17.0 

func (m *SNSEventSource) Size() (n int)

func (*SNSEventSource) String added in v0.17.0 

func (this *SNSEventSource) String() string

func (*SNSEventSource) Unmarshal added in v0.17.0 

func (m *SNSEventSource) Unmarshal(dAtA []byte) error

func (*SNSEventSource) XXX_DiscardUnknown added in v0.17.0 

func (m *SNSEventSource) XXX_DiscardUnknown()

func (*SNSEventSource) XXX_Marshal added in v0.17.0 

func (m *SNSEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SNSEventSource) XXX_Merge added in v0.17.0 

func (m *SNSEventSource) XXX_Merge(src proto.Message)

func (*SNSEventSource) XXX_Size added in v0.17.0 

func (m *SNSEventSource) XXX_Size() int

func (*SNSEventSource) XXX_Unmarshal added in v0.17.0 

func (m *SNSEventSource) XXX_Unmarshal(b []byte) error

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=secretKey"`
	// Region is AWS region
	Region string `json:"region" protobuf:"bytes,3,opt,name=region"`
	// Queue is AWS SQS queue to listen to for messages
	Queue string `json:"queue" protobuf:"bytes,4,opt,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:"varint,5,opt,name=waitTimeSeconds"`
	// RoleARN is the Amazon Resource Name (ARN) of the role to assume.
	// +optional
	RoleARN string `json:"roleARN,omitempty" protobuf:"bytes,6,opt,name=roleARN"`
	// JSONBody specifies that all event body payload coming from this
	// source will be JSON
	// +optional
	JSONBody bool `json:"jsonBody,omitempty" protobuf:"varint,7,opt,name=jsonBody"`
	// QueueAccountID is the ID of the account that created the queue to monitor
	// +optional
	QueueAccountID string `json:"queueAccountId,omitempty" protobuf:"bytes,8,opt,name=queueAccountId"`
	// Metadata holds the user defined metadata which will passed along the event payload.
	// +optional
	Metadata map[string]string `json:"metadata,omitempty" protobuf:"bytes,9,rep,name=metadata"`
}

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.

func (*SQSEventSource) Descriptor added in v0.17.0 

func (*SQSEventSource) Descriptor() ([]byte, []int)

func (*SQSEventSource) Marshal added in v0.17.0 

func (m *SQSEventSource) Marshal() (dAtA []byte, err error)

func (*SQSEventSource) MarshalTo added in v0.17.0 

func (m *SQSEventSource) MarshalTo(dAtA []byte) (int, error)

func (*SQSEventSource) MarshalToSizedBuffer added in v0.17.0 

func (m *SQSEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SQSEventSource) ProtoMessage added in v0.17.0 

func (*SQSEventSource) ProtoMessage()

func (*SQSEventSource) Reset added in v0.17.0 

func (m *SQSEventSource) Reset()

func (*SQSEventSource) Size added in v0.17.0 

func (m *SQSEventSource) Size() (n int)

func (*SQSEventSource) String added in v0.17.0 

func (this *SQSEventSource) String() string

func (*SQSEventSource) Unmarshal added in v0.17.0 

func (m *SQSEventSource) Unmarshal(dAtA []byte) error

func (*SQSEventSource) XXX_DiscardUnknown added in v0.17.0 

func (m *SQSEventSource) XXX_DiscardUnknown()

func (*SQSEventSource) XXX_Marshal added in v0.17.0 

func (m *SQSEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SQSEventSource) XXX_Merge added in v0.17.0 

func (m *SQSEventSource) XXX_Merge(src proto.Message)

func (*SQSEventSource) XXX_Size added in v0.17.0 

func (m *SQSEventSource) XXX_Size() int

func (*SQSEventSource) XXX_Unmarshal added in v0.17.0 

func (m *SQSEventSource) XXX_Unmarshal(b []byte) error

type Selector 

type Selector struct {
	// Key name
	Key string `json:"key" protobuf:"bytes,1,opt,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,opt,name=value"`
}

Selector represents conditional operation to select K8s objects.

func (*Selector) DeepCopy 

func (in *Selector) DeepCopy() *Selector

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

func (*Selector) DeepCopyInto 

func (in *Selector) DeepCopyInto(out *Selector)

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

func (*Selector) Descriptor added in v0.17.0 

func (*Selector) Descriptor() ([]byte, []int)

func (*Selector) Marshal added in v0.17.0 

func (m *Selector) Marshal() (dAtA []byte, err error)

func (*Selector) MarshalTo added in v0.17.0 

func (m *Selector) MarshalTo(dAtA []byte) (int, error)

func (*Selector) MarshalToSizedBuffer added in v0.17.0 

func (m *Selector) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Selector) ProtoMessage added in v0.17.0 

func (*Selector) ProtoMessage()

func (*Selector) Reset added in v0.17.0 

func (m *Selector) Reset()

func (*Selector) Size added in v0.17.0 

func (m *Selector) Size() (n int)

func (*Selector) String added in v0.17.0 

func (this *Selector) String() string

func (*Selector) Unmarshal added in v0.17.0 

func (m *Selector) Unmarshal(dAtA []byte) error

func (*Selector) XXX_DiscardUnknown added in v0.17.0 

func (m *Selector) XXX_DiscardUnknown()

func (*Selector) XXX_Marshal added in v0.17.0 

func (m *Selector) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Selector) XXX_Merge added in v0.17.0 

func (m *Selector) XXX_Merge(src proto.Message)

func (*Selector) XXX_Size added in v0.17.0 

func (m *Selector) XXX_Size() int

func (*Selector) XXX_Unmarshal added in v0.17.0 

func (m *Selector) XXX_Unmarshal(b []byte) error

type Service added in v0.17.0 

type Service struct {
	// The list of ports that are exposed by this ClusterIP service.
	// +patchMergeKey=port
	// +patchStrategy=merge
	// +listType=map
	// +listMapKey=port
	// +listMapKey=protocol
	Ports []corev1.ServicePort `json:"ports,omitempty" patchStrategy:"merge" patchMergeKey:"port" protobuf:"bytes,1,rep,name=ports"`
	// clusterIP is the IP address of the service and is usually assigned
	// randomly by the master. If an address is specified manually and is not in
	// use by others, it will be allocated to the service; otherwise, creation
	// of the service will fail. This field can not be changed through updates.
	// Valid values are "None", empty string (""), or a valid IP address. "None"
	// can be specified for headless services when proxying is not required.
	// More info: https://kubernetes.io/docs/concepts/services-networking/service/#virtual-ips-and-service-proxies
	// +optional
	ClusterIP string `json:"clusterIP,omitempty" protobuf:"bytes,2,opt,name=clusterIP"`
}

Service holds the service information eventsource exposes

func (*Service) DeepCopy added in v0.17.0 

func (in *Service) DeepCopy() *Service

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

func (*Service) DeepCopyInto added in v0.17.0 

func (in *Service) DeepCopyInto(out *Service)

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

func (*Service) Descriptor added in v0.17.0 

func (*Service) Descriptor() ([]byte, []int)

func (*Service) Marshal added in v0.17.0 

func (m *Service) Marshal() (dAtA []byte, err error)

func (*Service) MarshalTo added in v0.17.0 

func (m *Service) MarshalTo(dAtA []byte) (int, error)

func (*Service) MarshalToSizedBuffer added in v0.17.0 

func (m *Service) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Service) ProtoMessage added in v0.17.0 

func (*Service) ProtoMessage()

func (*Service) Reset added in v0.17.0 

func (m *Service) Reset()

func (*Service) Size added in v0.17.0 

func (m *Service) Size() (n int)

func (*Service) String added in v0.17.0 

func (this *Service) String() string

func (*Service) Unmarshal added in v0.17.0 

func (m *Service) Unmarshal(dAtA []byte) error

func (*Service) XXX_DiscardUnknown added in v0.17.0 

func (m *Service) XXX_DiscardUnknown()

func (*Service) XXX_Marshal added in v0.17.0 

func (m *Service) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Service) XXX_Merge added in v0.17.0 

func (m *Service) XXX_Merge(src proto.Message)

func (*Service) XXX_Size added in v0.17.0 

func (m *Service) XXX_Size() int

func (*Service) XXX_Unmarshal added in v0.17.0 

func (m *Service) XXX_Unmarshal(b []byte) error

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,opt,name=token"`
	// Webhook holds configuration for a REST endpoint
	Webhook *WebhookContext `json:"webhook,omitempty" protobuf:"bytes,3,opt,name=webhook"`
	// Metadata holds the user defined metadata which will passed along the event payload.
	// +optional
	Metadata map[string]string `json:"metadata,omitempty" protobuf:"bytes,4,rep,name=metadata"`
}

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.

func (*SlackEventSource) Descriptor added in v0.17.0 

func (*SlackEventSource) Descriptor() ([]byte, []int)

func (*SlackEventSource) Marshal added in v0.17.0 

func (m *SlackEventSource) Marshal() (dAtA []byte, err error)

func (*SlackEventSource) MarshalTo added in v0.17.0 

func (m *SlackEventSource) MarshalTo(dAtA []byte) (int, error)

func (*SlackEventSource) MarshalToSizedBuffer added in v0.17.0 

func (m *SlackEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SlackEventSource) ProtoMessage added in v0.17.0 

func (*SlackEventSource) ProtoMessage()

func (*SlackEventSource) Reset added in v0.17.0 

func (m *SlackEventSource) Reset()

func (*SlackEventSource) Size added in v0.17.0 

func (m *SlackEventSource) Size() (n int)

func (*SlackEventSource) String added in v0.17.0 

func (this *SlackEventSource) String() string

func (*SlackEventSource) Unmarshal added in v0.17.0 

func (m *SlackEventSource) Unmarshal(dAtA []byte) error

func (*SlackEventSource) XXX_DiscardUnknown added in v0.17.0 

func (m *SlackEventSource) XXX_DiscardUnknown()

func (*SlackEventSource) XXX_Marshal added in v0.17.0 

func (m *SlackEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SlackEventSource) XXX_Merge added in v0.17.0 

func (m *SlackEventSource) XXX_Merge(src proto.Message)

func (*SlackEventSource) XXX_Size added in v0.17.0 

func (m *SlackEventSource) XXX_Size() int

func (*SlackEventSource) XXX_Unmarshal added in v0.17.0 

func (m *SlackEventSource) XXX_Unmarshal(b []byte) error

type StorageGridEventSource 

type StorageGridEventSource struct {
	// Webhook holds configuration for a REST endpoint
	Webhook *WebhookContext `json:"webhook,omitempty" protobuf:"bytes,1,opt,name=webhook"`

	Events []string `json:"events,omitempty" protobuf:"bytes,2,rep,name=events"`
	// Filter on object key which caused the notification.
	Filter *StorageGridFilter `json:"filter,omitempty" protobuf:"bytes,3,opt,name=filter"`
	// TopicArn
	TopicArn string `json:"topicArn" protobuf:"bytes,4,name=topicArn"`
	// Name of the bucket to register notifications for.
	Bucket string `json:"bucket" protobuf:"bytes,5,name=bucket"`
	// S3 region.
	// Defaults to us-east-1
	// +optional
	Region string `json:"region,omitempty" protobuf:"bytes,6,opt,name=region"`
	// Auth token for storagegrid api
	AuthToken *corev1.SecretKeySelector `json:"authToken" protobuf:"bytes,7,name=authToken"`
	// APIURL is the url of the storagegrid api.
	APIURL string `json:"apiURL" protobuf:"bytes,8,name=apiURL"`
	// Metadata holds the user defined metadata which will passed along the event payload.
	// +optional
	Metadata map[string]string `json:"metadata,omitempty" protobuf:"bytes,9,rep,name=metadata"`
}

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.

func (*StorageGridEventSource) Descriptor added in v0.17.0 

func (*StorageGridEventSource) Descriptor() ([]byte, []int)

func (*StorageGridEventSource) Marshal added in v0.17.0 

func (m *StorageGridEventSource) Marshal() (dAtA []byte, err error)

func (*StorageGridEventSource) MarshalTo added in v0.17.0 

func (m *StorageGridEventSource) MarshalTo(dAtA []byte) (int, error)

func (*StorageGridEventSource) MarshalToSizedBuffer added in v0.17.0 

func (m *StorageGridEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StorageGridEventSource) ProtoMessage added in v0.17.0 

func (*StorageGridEventSource) ProtoMessage()

func (*StorageGridEventSource) Reset added in v0.17.0 

func (m *StorageGridEventSource) Reset()

func (*StorageGridEventSource) Size added in v0.17.0 

func (m *StorageGridEventSource) Size() (n int)

func (*StorageGridEventSource) String added in v0.17.0 

func (this *StorageGridEventSource) String() string

func (*StorageGridEventSource) Unmarshal added in v0.17.0 

func (m *StorageGridEventSource) Unmarshal(dAtA []byte) error

func (*StorageGridEventSource) XXX_DiscardUnknown added in v0.17.0 

func (m *StorageGridEventSource) XXX_DiscardUnknown()

func (*StorageGridEventSource) XXX_Marshal added in v0.17.0 

func (m *StorageGridEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StorageGridEventSource) XXX_Merge added in v0.17.0 

func (m *StorageGridEventSource) XXX_Merge(src proto.Message)

func (*StorageGridEventSource) XXX_Size added in v0.17.0 

func (m *StorageGridEventSource) XXX_Size() int

func (*StorageGridEventSource) XXX_Unmarshal added in v0.17.0 

func (m *StorageGridEventSource) XXX_Unmarshal(b []byte) error

type StorageGridFilter 

type StorageGridFilter struct {
	Prefix string `json:"prefix" protobuf:"bytes,1,opt,name=prefix"`
	Suffix string `json:"suffix" protobuf:"bytes,2,opt,name=suffix"`
}

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

func (*StorageGridFilter) Descriptor added in v0.17.0 

func (*StorageGridFilter) Descriptor() ([]byte, []int)

func (*StorageGridFilter) Marshal added in v0.17.0 

func (m *StorageGridFilter) Marshal() (dAtA []byte, err error)

func (*StorageGridFilter) MarshalTo added in v0.17.0 

func (m *StorageGridFilter) MarshalTo(dAtA []byte) (int, error)

func (*StorageGridFilter) MarshalToSizedBuffer added in v0.17.0 

func (m *StorageGridFilter) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StorageGridFilter) ProtoMessage added in v0.17.0 

func (*StorageGridFilter) ProtoMessage()

func (*StorageGridFilter) Reset added in v0.17.0 

func (m *StorageGridFilter) Reset()

func (*StorageGridFilter) Size added in v0.17.0 

func (m *StorageGridFilter) Size() (n int)

func (*StorageGridFilter) String added in v0.17.0 

func (this *StorageGridFilter) String() string

func (*StorageGridFilter) Unmarshal added in v0.17.0 

func (m *StorageGridFilter) Unmarshal(dAtA []byte) error

func (*StorageGridFilter) XXX_DiscardUnknown added in v0.17.0 

func (m *StorageGridFilter) XXX_DiscardUnknown()

func (*StorageGridFilter) XXX_Marshal added in v0.17.0 

func (m *StorageGridFilter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StorageGridFilter) XXX_Merge added in v0.17.0 

func (m *StorageGridFilter) XXX_Merge(src proto.Message)

func (*StorageGridFilter) XXX_Size added in v0.17.0 

func (m *StorageGridFilter) XXX_Size() int

func (*StorageGridFilter) XXX_Unmarshal added in v0.17.0 

func (m *StorageGridFilter) XXX_Unmarshal(b []byte) error

type StripeEventSource 

type StripeEventSource struct {
	// Webhook holds configuration for a REST endpoint
	Webhook *WebhookContext `json:"webhook,omitempty" protobuf:"bytes,1,opt,name=webhook"`
	// CreateWebhook if specified creates a new webhook programmatically.
	// +optional
	CreateWebhook bool `json:"createWebhook,omitempty" protobuf:"varint,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"`
	// 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
	EventFilter []string `json:"eventFilter,omitempty" protobuf:"bytes,4,rep,name=eventFilter"`
	// Metadata holds the user defined metadata which will passed along the event payload.
	// +optional
	Metadata map[string]string `json:"metadata,omitempty" protobuf:"bytes,5,rep,name=metadata"`
}

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.

func (*StripeEventSource) Descriptor added in v0.17.0 

func (*StripeEventSource) Descriptor() ([]byte, []int)

func (*StripeEventSource) Marshal added in v0.17.0 

func (m *StripeEventSource) Marshal() (dAtA []byte, err error)

func (*StripeEventSource) MarshalTo added in v0.17.0 

func (m *StripeEventSource) MarshalTo(dAtA []byte) (int, error)

func (*StripeEventSource) MarshalToSizedBuffer added in v0.17.0 

func (m *StripeEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StripeEventSource) ProtoMessage added in v0.17.0 

func (*StripeEventSource) ProtoMessage()

func (*StripeEventSource) Reset added in v0.17.0 

func (m *StripeEventSource) Reset()

func (*StripeEventSource) Size added in v0.17.0 

func (m *StripeEventSource) Size() (n int)

func (*StripeEventSource) String added in v0.17.0 

func (this *StripeEventSource) String() string

func (*StripeEventSource) Unmarshal added in v0.17.0 

func (m *StripeEventSource) Unmarshal(dAtA []byte) error

func (*StripeEventSource) XXX_DiscardUnknown added in v0.17.0 

func (m *StripeEventSource) XXX_DiscardUnknown()

func (*StripeEventSource) XXX_Marshal added in v0.17.0 

func (m *StripeEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StripeEventSource) XXX_Merge added in v0.17.0 

func (m *StripeEventSource) XXX_Merge(src proto.Message)

func (*StripeEventSource) XXX_Size added in v0.17.0 

func (m *StripeEventSource) XXX_Size() int

func (*StripeEventSource) XXX_Unmarshal added in v0.17.0 

func (m *StripeEventSource) XXX_Unmarshal(b []byte) error

type Template added in v0.17.0 

type Template struct {
	// Metadata sets the pods's metadata, i.e. annotations and labels
	Metadata *apicommon.Metadata `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`
	// ServiceAccountName is the name of the ServiceAccount to use to run event source pod.
	// More info: https://kubernetes.io/docs/tasks/configure-pod-container/configure-service-account/
	// +optional
	ServiceAccountName string `json:"serviceAccountName,omitempty" protobuf:"bytes,2,opt,name=serviceAccountName"`
	// Container is the main container image to run in the event source pod
	// +optional
	Container *corev1.Container `json:"container,omitempty" protobuf:"bytes,3,opt,name=container"`
	// Volumes is a list of volumes that can be mounted by containers in an eventsource.
	// +patchStrategy=merge
	// +patchMergeKey=name
	// +optional
	Volumes []corev1.Volume `json:"volumes,omitempty" patchStrategy:"merge" patchMergeKey:"name" protobuf:"bytes,4,rep,name=volumes"`
	// SecurityContext holds pod-level security attributes and common container settings.
	// Optional: Defaults to empty.  See type description for default values of each field.
	// +optional
	SecurityContext *corev1.PodSecurityContext `json:"securityContext,omitempty" protobuf:"bytes,5,opt,name=securityContext"`
	// If specified, the pod's scheduling constraints
	// +optional
	Affinity *corev1.Affinity `json:"affinity,omitempty" protobuf:"bytes,6,opt,name=affinity"`
	// If specified, the pod's tolerations.
	// +optional
	Tolerations []corev1.Toleration `json:"tolerations,omitempty" protobuf:"bytes,7,rep,name=tolerations"`
	// NodeSelector is a selector which must be true for the pod to fit on a node.
	// Selector which must match a node's labels for the pod to be scheduled on that node.
	// More info: https://kubernetes.io/docs/concepts/configuration/assign-pod-node/
	// +optional
	NodeSelector map[string]string `json:"nodeSelector,omitempty" protobuf:"bytes,8,rep,name=nodeSelector"`
	// ImagePullSecrets is an optional list of references to secrets in the same namespace to use for pulling any of the images used by this PodSpec.
	// If specified, these secrets will be passed to individual puller implementations for them to use. For example,
	// in the case of docker, only DockerConfig type secrets are honored.
	// More info: https://kubernetes.io/docs/concepts/containers/images#specifying-imagepullsecrets-on-a-pod
	// +optional
	// +patchMergeKey=name
	// +patchStrategy=merge
	ImagePullSecrets []corev1.LocalObjectReference `json:"imagePullSecrets,omitempty" patchStrategy:"merge" patchMergeKey:"name" protobuf:"bytes,9,rep,name=imagePullSecrets"`
	// If specified, indicates the EventSource pod's priority. "system-node-critical"
	// and "system-cluster-critical" are two special keywords which indicate the
	// highest priorities with the former being the highest priority. Any other
	// name must be defined by creating a PriorityClass object with that name.
	// If not specified, the pod priority will be default or zero if there is no
	// default.
	// More info: https://kubernetes.io/docs/concepts/configuration/pod-priority-preemption/
	// +optional
	PriorityClassName string `json:"priorityClassName,omitempty" protobuf:"bytes,10,opt,name=priorityClassName"`
	// The priority value. Various system components use this field to find the
	// priority of the EventSource pod. When Priority Admission Controller is enabled,
	// it prevents users from setting this field. The admission controller populates
	// this field from PriorityClassName.
	// The higher the value, the higher the priority.
	// More info: https://kubernetes.io/docs/concepts/configuration/pod-priority-preemption/
	// +optional
	Priority *int32 `json:"priority,omitempty" protobuf:"bytes,11,opt,name=priority"`
}

Template holds the information of an EventSource deployment template

func (*Template) DeepCopy added in v0.17.0 

func (in *Template) DeepCopy() *Template

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

func (*Template) DeepCopyInto added in v0.17.0 

func (in *Template) DeepCopyInto(out *Template)

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

func (*Template) Descriptor added in v0.17.0 

func (*Template) Descriptor() ([]byte, []int)

func (*Template) Marshal added in v0.17.0 

func (m *Template) Marshal() (dAtA []byte, err error)

func (*Template) MarshalTo added in v0.17.0 

func (m *Template) MarshalTo(dAtA []byte) (int, error)

func (*Template) MarshalToSizedBuffer added in v0.17.0 

func (m *Template) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Template) ProtoMessage added in v0.17.0 

func (*Template) ProtoMessage()

func (*Template) Reset added in v0.17.0 

func (m *Template) Reset()

func (*Template) Size added in v0.17.0 

func (m *Template) Size() (n int)

func (*Template) String added in v0.17.0 

func (this *Template) String() string

func (*Template) Unmarshal added in v0.17.0 

func (m *Template) Unmarshal(dAtA []byte) error

func (*Template) XXX_DiscardUnknown added in v0.17.0 

func (m *Template) XXX_DiscardUnknown()

func (*Template) XXX_Marshal added in v0.17.0 

func (m *Template) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Template) XXX_Merge added in v0.17.0 

func (m *Template) XXX_Merge(src proto.Message)

func (*Template) XXX_Size added in v0.17.0 

func (m *Template) XXX_Size() int

func (*Template) XXX_Unmarshal added in v0.17.0 

func (m *Template) XXX_Unmarshal(b []byte) error

type WatchPathConfig added in v0.17.0 

type WatchPathConfig struct {
	// Directory to watch for events
	Directory string `json:"directory" protobuf:"bytes,1,opt,name=directory"`
	// Path is relative path of object to watch with respect to the directory
	Path string `json:"path,omitempty" protobuf:"bytes,2,opt,name=path"`
	// PathRegexp is regexp of relative path of object to watch with respect to the directory
	PathRegexp string `json:"pathRegexp,omitempty" protobuf:"bytes,3,opt,name=pathRegexp"`
}

func (*WatchPathConfig) DeepCopy added in v0.17.0 

func (in *WatchPathConfig) DeepCopy() *WatchPathConfig

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

func (*WatchPathConfig) DeepCopyInto added in v0.17.0 

func (in *WatchPathConfig) DeepCopyInto(out *WatchPathConfig)

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

func (*WatchPathConfig) Descriptor added in v0.17.0 

func (*WatchPathConfig) Descriptor() ([]byte, []int)

func (*WatchPathConfig) Marshal added in v0.17.0 

func (m *WatchPathConfig) Marshal() (dAtA []byte, err error)

func (*WatchPathConfig) MarshalTo added in v0.17.0 

func (m *WatchPathConfig) MarshalTo(dAtA []byte) (int, error)

func (*WatchPathConfig) MarshalToSizedBuffer added in v0.17.0 

func (m *WatchPathConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*WatchPathConfig) ProtoMessage added in v0.17.0 

func (*WatchPathConfig) ProtoMessage()

func (*WatchPathConfig) Reset added in v0.17.0 

func (m *WatchPathConfig) Reset()

func (*WatchPathConfig) Size added in v0.17.0 

func (m *WatchPathConfig) Size() (n int)

func (*WatchPathConfig) String added in v0.17.0 

func (this *WatchPathConfig) String() string

func (*WatchPathConfig) Unmarshal added in v0.17.0 

func (m *WatchPathConfig) Unmarshal(dAtA []byte) error

func (*WatchPathConfig) Validate added in v0.17.0 

func (c *WatchPathConfig) Validate() error

Validate validates WatchPathConfig

func (*WatchPathConfig) XXX_DiscardUnknown added in v0.17.0 

func (m *WatchPathConfig) XXX_DiscardUnknown()

func (*WatchPathConfig) XXX_Marshal added in v0.17.0 

func (m *WatchPathConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WatchPathConfig) XXX_Merge added in v0.17.0 

func (m *WatchPathConfig) XXX_Merge(src proto.Message)

func (*WatchPathConfig) XXX_Size added in v0.17.0 

func (m *WatchPathConfig) XXX_Size() int

func (*WatchPathConfig) XXX_Unmarshal added in v0.17.0 

func (m *WatchPathConfig) XXX_Unmarshal(b []byte) error

type WebhookContext added in v0.17.0 

type WebhookContext struct {
	// REST API endpoint
	Endpoint string `json:"endpoint" protobuf:"bytes,1,opt,name=endpoint"`
	// Method is HTTP request method that indicates the desired action to be performed for a given resource.
	// See RFC7231 Hypertext Transfer Protocol (HTTP/1.1): Semantics and Content
	Method string `json:"method" protobuf:"bytes,2,opt,name=method"`
	// Port on which HTTP server is listening for incoming events.
	Port string `json:"port" protobuf:"bytes,3,opt,name=port"`
	// URL is the url of the server.
	URL string `json:"url" protobuf:"bytes,4,opt,name=url"`
	// ServerCertPath refers the file that contains the cert.
	ServerCertSecret *corev1.SecretKeySelector `json:"serverCertSecret,omitempty" protobuf:"bytes,5,opt,name=serverCertSecret"`
	// ServerKeyPath refers the file that contains private key
	ServerKeySecret *corev1.SecretKeySelector `json:"serverKeySecret,omitempty" protobuf:"bytes,6,opt,name=serverKeySecret"`
	// Metadata holds the user defined metadata which will passed along the event payload.
	// +optional
	Metadata map[string]string `json:"metadata,omitempty" protobuf:"bytes,7,rep,name=metadata"`
	// AuthSecret holds a secret selector that contains a bearer token for authentication
	// +optional
	AuthSecret *corev1.SecretKeySelector `json:"authSecret,omitempty" protobuf:"bytes,8,opt,name=authSecret"`
	// DeprecatedServerCertPath refers the file that contains the cert.
	DeprecatedServerCertPath string `json:"serverCertPath,omitempty" protobuf:"bytes,9,opt,name=serverCertPath"`
	// DeprecatedServerKeyPath refers the file that contains private key
	DeprecatedServerKeyPath string `json:"serverKeyPath,omitempty" protobuf:"bytes,10,opt,name=serverKeyPath"`
}

WebhookContext holds a general purpose REST API context

func (*WebhookContext) DeepCopy added in v0.17.0 

func (in *WebhookContext) DeepCopy() *WebhookContext

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

func (*WebhookContext) DeepCopyInto added in v0.17.0 

func (in *WebhookContext) DeepCopyInto(out *WebhookContext)

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

func (*WebhookContext) Descriptor added in v0.17.0 

func (*WebhookContext) Descriptor() ([]byte, []int)

func (*WebhookContext) Marshal added in v0.17.0 

func (m *WebhookContext) Marshal() (dAtA []byte, err error)

func (*WebhookContext) MarshalTo added in v0.17.0 

func (m *WebhookContext) MarshalTo(dAtA []byte) (int, error)

func (*WebhookContext) MarshalToSizedBuffer added in v0.17.0 

func (m *WebhookContext) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*WebhookContext) ProtoMessage added in v0.17.0 

func (*WebhookContext) ProtoMessage()

func (*WebhookContext) Reset added in v0.17.0 

func (m *WebhookContext) Reset()

func (*WebhookContext) Size added in v0.17.0 

func (m *WebhookContext) Size() (n int)

func (*WebhookContext) String added in v0.17.0 

func (this *WebhookContext) String() string

func (*WebhookContext) Unmarshal added in v0.17.0 

func (m *WebhookContext) Unmarshal(dAtA []byte) error

func (*WebhookContext) XXX_DiscardUnknown added in v0.17.0 

func (m *WebhookContext) XXX_DiscardUnknown()

func (*WebhookContext) XXX_Marshal added in v0.17.0 

func (m *WebhookContext) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WebhookContext) XXX_Merge added in v0.17.0 

func (m *WebhookContext) XXX_Merge(src proto.Message)

func (*WebhookContext) XXX_Size added in v0.17.0 

func (m *WebhookContext) XXX_Size() int

func (*WebhookContext) XXX_Unmarshal added in v0.17.0 

func (m *WebhookContext) XXX_Unmarshal(b []byte) error

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.