dynamo

Documentation

Overview

Package dynamo provides structs for working with AWS Dynamo 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
• type StreamRecord

Functions

func Handle

func Handle(h Handler)

Handle Dynamo events with handler.

func HandleFunc

func HandleFunc(h HandlerFunc)

HandleFunc handles Dynamo events with callback function.

Types

type Event

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

Event represents a Dynamo event with one or more records.

type Handler

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

Handler handles Dynamo events.

type HandlerFunc

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

HandlerFunc unmarshals Dynamo 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 {
	EventID        string        `json:"eventID"`
	EventName      string        `json:"eventName"`
	EventSource    string        `json:"eventSource"`
	EventSourceARN string        `json:"eventSourceARN"`
	EventVersion   string        `json:"eventVersion"`
	AWSRegion      string        `json:"awsRegion"`
	Dynamodb       *StreamRecord `json:"dynamodb"`
}

Record represents a single Dynamo record.

type StreamRecord

type StreamRecord struct {
	ApproximateCreationDateTime int64
	Keys                        map[string]*dynamodb.AttributeValue
	NewImage                    map[string]*dynamodb.AttributeValue
	OldImage                    map[string]*dynamodb.AttributeValue
	SequenceNumber              string
	SizeBytes                   int64
	StreamViewType              string
}

StreamRecord represents a Dynamo stream records