source

Documentation

Index

• type APIGatewayCustomAuthorizerRequestHandler
• type APIGatewayProxyRequestHandler
• type CloudWatchEventHandler
• type CloudwatchLogsEventHandler
• type CognitoPostConfirmHandler
• type CognitoPreSignUpHandler
• type CognitoPreTokenHandler
• type DynamoDBStreamHandler
• type FirehoseHandler
• type Handler
  • func NewAPIGatewayCustomAuthorizerRequestHandler(handler APIGatewayCustomAuthorizerRequestHandler) *Handler
  • func NewAPIGatewayProxyRequestHandler(handler APIGatewayProxyRequestHandler) *Handler
  • func NewCloudWatchEventHandler(handler CloudWatchEventHandler) *Handler
  • func NewCloudwatchLogsEventHandler(handler CloudwatchLogsEventHandler) *Handler
  • func NewCognitoPostConfirmHandler(handler CognitoPostConfirmHandler) *Handler
  • func NewCognitoPreSignUpHandler(handler CognitoPreSignUpHandler) *Handler
  • func NewCognitoPreTokenHandler(handler CognitoPreTokenHandler) *Handler
  • func NewDynamoDBStreamHandler(handler DynamoDBStreamHandler) *Handler
  • func NewFirehoseHandler(handler FirehoseHandler) *Handler
  • func NewJSONHandler(handler JSONHandler) *Handler
  • func NewKinesisHandler(handler KinesisHandler) *Handler
  • func NewLexEventHandler(handler LexEventHandler) *Handler
  • func NewS3EventHandler(handler S3EventHandler) *Handler
  • func NewSNSHandler(handler SNSHandler) *Handler
  • func NewSQSHandler(handler SQSHandler) *Handler
  • func (h *Handler) BatchHandler(ctx context.Context, sources interface{}) (interface{}, error)
  • func (h *Handler) Handler(ctx context.Context, source interface{}) (interface{}, error)
  • func (h *Handler) ParseSource(ctx context.Context, payload json.RawMessage) interface{}
  • func (h *Handler) ParseSources(ctx context.Context, payload json.RawMessage) interface{}
• type JSONHandler
• type KinesisHandler
• type LexEventHandler
• type S3EventHandler
• type SNSHandler
• type SQSHandler

Types

type APIGatewayCustomAuthorizerRequestHandler

type APIGatewayCustomAuthorizerRequestHandler func(ctx context.Context, src *events.APIGatewayCustomAuthorizerRequest) (*events.APIGatewayCustomAuthorizerResponse, error)

type APIGatewayProxyRequestHandler

type APIGatewayProxyRequestHandler func(ctx context.Context, src *events.APIGatewayProxyRequest) (*events.APIGatewayProxyResponse, error)

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 CognitoPostConfirmHandler

type CognitoPostConfirmHandler func(ctx context.Context, src *events.CognitoEventUserPoolsPostConfirmation) *events.CognitoEventUserPoolsPostConfirmation

type CognitoPreSignUpHandler

type CognitoPreSignUpHandler func(ctx context.Context, src *events.CognitoEventUserPoolsPreSignup) *events.CognitoEventUserPoolsPreSignup

type CognitoPreTokenHandler

type CognitoPreTokenHandler func(ctx context.Context, src *events.CognitoEventUserPoolsPreTokenGen) *events.CognitoEventUserPoolsPreTokenGen

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)