domain

Documentation

Index

• Constants
• type CloudFunction
  • func (c CloudFunction) Invoke(invoker CloudFunctionInvoker) func(interface{})
• type CloudFunctionConfiguration
  • func (c CloudFunctionConfiguration) CreateObservable(source rxgo.Observable) rxgo.Observable
  • func (c CloudFunctionConfiguration) FilterEvents(i interface{}) bool
• type CloudFunctionInvoker
• type EventFunction
• type Filter
  • func (f Filter) FilterEvents(i interface{}) bool
• type FilterRule
  • func (f FilterRule) FilterKey(key string) bool
• type JsonTime
  • func (t JsonTime) MarshalJSON() ([]byte, error)
  • func (t *JsonTime) UnmarshalJSON(bytes []byte) error
• type LambdaRecord
• type LambdaRequestParameters
• type LambdaResponseElements
• type LambdaUserIdentity
• type NotificationConfiguration
  • func (n NotificationConfiguration) Start(invoker CloudFunctionInvoker) (chan rxgo.Item, context.Context)
• type NotificationEvent
• type S3Bucket
• type S3BucketOwnerIdentity
• type S3Key
• type S3Object
• type S3Record

Constants

const (
	ObjectCreatedEvent = "s3:ObjectCreated"
	ObjectRemovedEvent = "s3:ObjectRemoved"
)

const (
	ObjectCreatedFilter = "s3:ObjectCreated:*"
	ObjectRemovedFilter = "s3:ObjectRemoved:*"
	PrefixFilter        = "prefix"
	SuffixFilter        = "suffix"
)

Types

type CloudFunction

type CloudFunction string

func (CloudFunction) Invoke

func (c CloudFunction) Invoke(invoker CloudFunctionInvoker) func(interface{})

type CloudFunctionConfiguration

type CloudFunctionConfiguration struct {
	Events        []string `xml:"Event"`
	Filter        Filter
	Id            string
	CloudFunction CloudFunction
}

func (CloudFunctionConfiguration) CreateObservable

func (c CloudFunctionConfiguration) CreateObservable(source rxgo.Observable) rxgo.Observable

func (CloudFunctionConfiguration) FilterEvents

func (c CloudFunctionConfiguration) FilterEvents(i interface{}) bool

type CloudFunctionInvoker

type CloudFunctionInvoker interface {
	Invoke(string) func(interface{})
}

type EventFunction

type EventFunction func(string, interface{})

type Filter

type Filter struct {
	S3Key S3Key
}

func (Filter) FilterEvents

func (f Filter) FilterEvents(i interface{}) bool

type FilterRule

type FilterRule struct {
	Name  string
	Value string
}

func (FilterRule) FilterKey

func (f FilterRule) FilterKey(key string) bool

type JsonTime

type JsonTime time.Time

func (JsonTime) MarshalJSON

func (t JsonTime) MarshalJSON() ([]byte, error)

func (*JsonTime) UnmarshalJSON

func (t *JsonTime) UnmarshalJSON(bytes []byte) error

type LambdaRecord

type LambdaRecord struct {
	EventVersion      string                  `json:"eventVersion"`
	EventSource       string                  `json:"eventSource"`
	AwsRegion         string                  `json:"awsRegion"`
	EventTime         JsonTime                `json:"eventTime"`
	EventName         string                  `json:"eventName"`
	UserIdentity      LambdaUserIdentity      `json:"userIdentity"`
	RequestParameters LambdaRequestParameters `json:"requestParameters"`
	ResponseElements  LambdaResponseElements  `json:"responseElements"`
	S3                S3Record                `json:"s3"`
}

type LambdaRequestParameters

type LambdaRequestParameters struct {
	SourceIPAddress string `json:"sourceIPAddress"`
}

type LambdaResponseElements

type LambdaResponseElements struct {
	RequestId string `json:"x-amz-request-id"`
	Id2       string `json:"x-amz-id-2"`
}

type LambdaUserIdentity

type LambdaUserIdentity struct {
	PrincipalId string `json:"principalId"`
}

type NotificationConfiguration

type NotificationConfiguration struct {
	CloudFunctionConfigurations []CloudFunctionConfiguration `xml:"CloudFunctionConfiguration"`
}

func (NotificationConfiguration) Start

func (n NotificationConfiguration) Start(invoker CloudFunctionInvoker) (chan rxgo.Item, context.Context)

type NotificationEvent

type NotificationEvent struct {
	Bucket   string
	Key      string // S3 Object key
	Event    string // S3 event (i.e. s3:ObjectCreated", "s3:ObjectRemoved", etc.)
	SourceIp string
	Size     int64
}

type S3Bucket

type S3Bucket struct {
	Name          string                `json:"name"`
	OwnerIdentity S3BucketOwnerIdentity `json:"ownerIdentity"`
	Arn           string                `json:"arn"`
}

type S3BucketOwnerIdentity

type S3BucketOwnerIdentity struct {
	PrincipalId string `json:"principalId"`
}

type S3Key

type S3Key struct {
	FilterRules []FilterRule `xml:"FilterRule"`
}

type S3Object

type S3Object struct {
	Key       string `json:"key"`
	Size      int64  `json:"size"`
	ETag      string `json:"eTag"`
	Sequencer string `json:"sequencer"`
}

type S3Record

type S3Record struct {
	S3SchemaVersion string   `json:"s3SchemaVersion"`
	ConfigurationId string   `json:"configurationId"`
	Bucket          S3Bucket `json:"bucket"`
	Object          S3Object `json:"object"`
}