source

package
v1.0.16 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 27, 2019 License: MIT Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type CloudWatchEventHandler

type CloudWatchEventHandler func(ctx context.Context, src *events.CloudWatchEvent) (interface{}, error)

type CloudwatchLogsEventHandler

type CloudwatchLogsEventHandler func(ctx context.Context, src *events.CloudwatchLogsEvent) (interface{}, error)

type DynamoDBStreamHandler

type DynamoDBStreamHandler func(ctx context.Context, src *events.DynamoDBEvent) (interface{}, error)

type FirehoseHandler

type FirehoseHandler func(ctx context.Context, src *events.KinesisFirehoseEvent) (interface{}, error)

type Handler

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

noinspection GoNameStartsWithPackageName

func NewAPIGatewayCustomAuthorizerRequestHandler

func NewAPIGatewayCustomAuthorizerRequestHandler(handler APIGatewayCustomAuthorizerRequestHandler) *Handler

func NewAPIGatewayProxyRequestHandler

func NewAPIGatewayProxyRequestHandler(handler APIGatewayProxyRequestHandler) *Handler

func NewCloudWatchEventHandler

func NewCloudWatchEventHandler(handler CloudWatchEventHandler) *Handler

func NewCloudwatchLogsEventHandler

func NewCloudwatchLogsEventHandler(handler CloudwatchLogsEventHandler) *Handler

func NewCognitoPostConfirmHandler

func NewCognitoPostConfirmHandler(handler CognitoPostConfirmHandler) *Handler

func NewCognitoPreSignUpHandler

func NewCognitoPreSignUpHandler(handler CognitoPreSignUpHandler) *Handler

func NewCognitoPreTokenHandler

func NewCognitoPreTokenHandler(handler CognitoPreTokenHandler) *Handler

func NewDynamoDBStreamHandler

func NewDynamoDBStreamHandler(handler DynamoDBStreamHandler) *Handler

func NewFirehoseHandler

func NewFirehoseHandler(handler FirehoseHandler) *Handler

func NewJSONHandler

func NewJSONHandler(handler JSONHandler) *Handler

func NewKinesisHandler

func NewKinesisHandler(handler KinesisHandler) *Handler

func NewLexEventHandler

func NewLexEventHandler(handler LexEventHandler) *Handler

func NewS3EventHandler

func NewS3EventHandler(handler S3EventHandler) *Handler

func NewSNSHandler

func NewSNSHandler(handler SNSHandler) *Handler

func NewSQSHandler

func NewSQSHandler(handler SQSHandler) *Handler

func (*Handler) BatchHandler

func (h *Handler) BatchHandler(ctx context.Context, sources interface{}) (interface{}, error)

func (*Handler) Handler

func (h *Handler) Handler(ctx context.Context, source interface{}) (interface{}, error)

func (*Handler) ParseSource

func (h *Handler) ParseSource(ctx context.Context, payload json.RawMessage) interface{}

func (*Handler) ParseSources

func (h *Handler) ParseSources(ctx context.Context, payload json.RawMessage) interface{}

type JSONHandler

type JSONHandler func(ctx context.Context, src json.RawMessage) (interface{}, error)

type KinesisHandler

type KinesisHandler func(ctx context.Context, src *events.KinesisEvent) (interface{}, error)

type LexEventHandler

type LexEventHandler func(ctx context.Context, src *events.LexEvent) (interface{}, error)

type S3EventHandler

type S3EventHandler func(ctx context.Context, src *events.S3Event) (interface{}, error)

type SNSHandler

type SNSHandler func(ctx context.Context, src *events.SNSEvent) (interface{}, error)

type SQSHandler

type SQSHandler func(ctx context.Context, src *events.SQSEvent) (interface{}, error)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL