sns

Documentation

Overview

Package sns provides structs for working with AWS SNS records.

Index

• func Handle(h Handler)
• func HandleFunc(h HandlerFunc)
• type Event
• type Handler
• type HandlerFunc
  • func (h HandlerFunc) Handle(data json.RawMessage, ctx *apex.Context) (interface{}, error)
• type Record

Functions

func Handle

func Handle(h Handler)

Handle SNS events with handler.

func HandleFunc

func HandleFunc(h HandlerFunc)

HandleFunc handles SNS events with callback function.

Types

type Event

type Event struct {
	Records []*Record `json:"Records"`
}

Event represents a SNS event. It is safe to assume a single record will be present, as AWS will not send more than one.

type Handler

type Handler interface {
	HandleSNS(*Event, *apex.Context) error
}

Handler handles SNS events.

type HandlerFunc

type HandlerFunc func(*Event, *apex.Context) error

HandlerFunc unmarshals SNS events before passing control.

func (HandlerFunc) Handle

func (h HandlerFunc) Handle(data json.RawMessage, ctx *apex.Context) (interface{}, error)

Handle implements apex.Handler.

type Record

type Record struct {
	EventSource  string `json:"EventSource"`
	EventVersion string `json:"EventVersion"`
	SNS          struct {
		Type              string                 `json:"Type"`
		MessageID         string                 `json:"MessageID"`
		TopicARN          string                 `json:"TopicArn"`
		Subject           string                 `json:"Subject"`
		Message           string                 `json:"Message"`
		Timestamp         time.Time              `json:"Timestamp"`
		SignatureVersion  string                 `json:"SignatureVersion"`
		Signature         string                 `json:"Signature"`
		SignatureCertURL  string                 `json:"SignatureCertURL"`
		UnsubscribeURL    string                 `json:"UnsubscribeURL"`
		MessageAttributes map[string]interface{} `json:"MessageAttributes"`
	} `json:"Sns"`
}

Record represents a single SNS record.