kinesis

Jan 4, 2016

Changes in this version

+ type Event struct

+ Records []*Record

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

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

+ type Record struct

+ AWSRegion string

+ EventID string

+ EventName string

+ EventSource string

+ EventSourceARN string

+ EventVersion string

+ InvokeIdentityARN string

+ Kinesis struct{ ... }

+ func (r *Record) Data() []byte