snsevents

Documentation

Index

• type CloudtrailSNSEvent
• type Processor
  • func NewProcessor(cfg flags.S3Processor, awscfg *aws.Config) *Processor
  • func (ps *Processor) Handler(ctx context.Context, payload []byte) ([]byte, error)

Types

type CloudtrailSNSEvent

type CloudtrailSNSEvent struct {
	S3Bucket     string   `json:"s3Bucket,omitempty"`
	S3ObjectKeys []string `json:"s3ObjectKey,omitempty"`
}

CloudtrailSNSEvent event provided in the default SNS topic when a new file is written to the s3 bucket

type Processor

type Processor struct {
	// contains filtered or unexported fields
}

Processor translates s3 events into sns messages

func NewProcessor

func NewProcessor(cfg flags.S3Processor, awscfg *aws.Config) *Processor

NewProcessor setup a new s3 event processor

func (*Processor) Handler

func (ps *Processor) Handler(ctx context.Context, payload []byte) ([]byte, error)

Handler send s3 events to sns