common

Documentation

Overview

+k8s:deepcopy-gen=package +k8s:openapi-gen=true

Index

• func GetGatewayImageNameMapping() map[EventSourceType]string
• func GetOpenAPIDefinitions(ref common.ReferenceCallback) map[string]common.OpenAPIDefinition
• type EventSourceType
• type S3Artifact
  • func (in *S3Artifact) DeepCopy() *S3Artifact
  • func (in *S3Artifact) DeepCopyInto(out *S3Artifact)
• type S3Bucket
  • func (in *S3Bucket) DeepCopy() *S3Bucket
  • func (in *S3Bucket) DeepCopyInto(out *S3Bucket)
• type S3Filter
  • func (in *S3Filter) DeepCopy() *S3Filter
  • func (in *S3Filter) DeepCopyInto(out *S3Filter)

Functions

func GetGatewayImageNameMapping

func GetGatewayImageNameMapping() map[EventSourceType]string

GetGatewayImageNameMapping returns eventTyp -> imageName mapping TODO: temporarily solution, need to figure out a better way

func GetOpenAPIDefinitions

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

Types

type EventSourceType

type EventSourceType string

EventSourceType is the type of event source supported by the gateway

var (
	MinioEvent       EventSourceType = "minio"
	CalendarEvent    EventSourceType = "calendar"
	FileEvent        EventSourceType = "file"
	ResourceEvent    EventSourceType = "resource"
	WebhookEvent     EventSourceType = "webhook"
	AMQPEvent        EventSourceType = "amqp"
	KafkaEvent       EventSourceType = "kafka"
	MQTTEvent        EventSourceType = "mqtt"
	NATSEvent        EventSourceType = "nats"
	SNSEvent         EventSourceType = "sns"
	SQSEvent         EventSourceType = "sqs"
	PubSubEvent      EventSourceType = "pubsub"
	GitHubEvent      EventSourceType = "github"
	GitLabEvent      EventSourceType = "gitlab"
	HDFSEvent        EventSourceType = "hdfs"
	SlackEvent       EventSourceType = "slack"
	StorageGridEvent EventSourceType = "storagegrid"
	AzureEventsHub   EventSourceType = "azureEventsHub"
	StripeEvent      EventSourceType = "stripe"
	EmitterEvent     EventSourceType = "emitter"
	RedisEvent       EventSourceType = "redis"
	NSQEvent         EventSourceType = "nsq"
	GenericEvent     EventSourceType = "generic"
)

possible event source types

type S3Artifact

type S3Artifact struct {
	Endpoint  string                    `json:"endpoint" protobuf:"bytes,1,opt,name=endpoint"`
	Bucket    *S3Bucket                 `json:"bucket" protobuf:"bytes,2,opt,name=bucket"`
	Region    string                    `json:"region,omitempty" protobuf:"bytes,3,opt,name=region"`
	Insecure  bool                      `json:"insecure,omitempty" protobuf:"varint,4,opt,name=insecure"`
	AccessKey *corev1.SecretKeySelector `json:"accessKey" protobuf:"bytes,5,opt,name=accessKey"`
	SecretKey *corev1.SecretKeySelector `json:"secretKey" protobuf:"bytes,6,opt,name=secretKey"`
	// +listType=string
	Events []string  `json:"events,omitempty" protobuf:"bytes,7,opt,name=events"`
	Filter *S3Filter `json:"filter,omitempty" protobuf:"bytes,8,opt,name=filter"`
}

S3Artifact contains information about an S3 connection and bucket

func (*S3Artifact) DeepCopy

func (in *S3Artifact) DeepCopy() *S3Artifact

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

func (*S3Artifact) DeepCopyInto

func (in *S3Artifact) DeepCopyInto(out *S3Artifact)

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

type S3Bucket

type S3Bucket struct {
	Key  string `json:"key,omitempty" protobuf:"bytes,1,opt,name=key"`
	Name string `json:"name" protobuf:"bytes,2,opt,name=name"`
}

S3Bucket contains information to describe an S3 Bucket

func (*S3Bucket) DeepCopy

func (in *S3Bucket) DeepCopy() *S3Bucket

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

func (*S3Bucket) DeepCopyInto

func (in *S3Bucket) DeepCopyInto(out *S3Bucket)

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

type S3Filter

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

S3Filter represents filters to apply to bucket nofifications for specifying constraints on objects

func (*S3Filter) DeepCopy

func (in *S3Filter) DeepCopy() *S3Filter

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

func (*S3Filter) DeepCopyInto

func (in *S3Filter) DeepCopyInto(out *S3Filter)

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