notifications

Apr 29, 2022

Changes in this version

+ const EventVersion21

+ const EventVersion22

+ const EventVersion23

+ type Bucket struct

+ Arn string

+ Name string

+ OwnerIdentity UserIdentity

type Controller

+ func (c *Controller) Listen(ctx context.Context)

+ func (c *Controller) SendNotifications(topics map[string]string, p *layer.SendNotificationParams) error

+ func (c *Controller) SendTestNotification(topic, bucketName, requestID, HostID string) error

+ func (c *Controller) Subscribe(ctx context.Context, topic string, handler layer.MsgHandler) error

+ type Event struct

+ Records []EventRecord

+ type EventRecord struct

+ AWSRegion string

+ EventName string

+ EventSource string

+ EventTime time.Time

+ EventVersion string

+ RequestParameters RequestParameters

+ ResponseElements map[string]string

+ S3 S3Entity

+ UserIdentity UserIdentity

+ type Object struct

+ ETag string

+ Key string

+ Sequencer string

+ Size int64

+ VersionID string

+ type RequestParameters struct

+ SourceIPAddress string

+ type S3Entity struct

+ Bucket Bucket

+ ConfigurationID string

+ Object Object

+ SchemaVersion string

+ type Stream struct

+ type TestEvent struct

+ Bucket string

+ Event string

+ HostID string

+ RequestID string

+ Service string

+ Time time.Time

+ type UserIdentity struct

+ PrincipalID string

Mar 16, 2022

Changes in this version

+ const DefaultTimeout

+ type Controller struct

+ func NewController(p *Options) (*Controller, error)

+ type Options struct

+ RootCAFiles []string

+ TLSAuthPrivateKeyFilePath string

+ TLSCertFilepath string

+ Timeout time.Duration

+ URL string