Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Handler ¶
type Handler struct {
// contains filtered or unexported fields
}
Handler can be used to process events.
func NewHandler ¶
func NewHandler(handler *cloudevents.HandlerWrapper, options *Options) *Handler
NewHandler creates a new handler wrapped in middleware.
type Helper ¶
type Helper struct {
// contains filtered or unexported fields
}
Helper assists in creating event handlers.
func NewDefaultHelper ¶
func NewDefaultHelper(handler *cloudevents.HandlerWrapper) *Helper
NewHelper returns a new Helper with default options.
func NewHelper ¶
func NewHelper(handler *cloudevents.HandlerWrapper, options *Options) *Helper
NewHelper returns a new Helper with options.
type Options ¶
type Options struct {
Skip bool
}
Options can be used to create customized handler.
func DefaultOptions ¶
DefaultOptions returns options based in config.
type Record ¶
type Record struct {
EventVersion string `json:"eventVersion"`
EventSubscriptionArn string `json:"eventSubscriptionArn"`
EventSource string `json:"eventSource"`
EventName string `json:"eventName"`
EventID string `json:"eventID"`
SNS events.SNSEntity `json:"sns"`
S3 events.S3Entity `json:"s3"`
Kinesis events.KinesisRecord `json:"kinesis"`
DynamoDB events.DynamoDBStreamRecord `json:"dynamodb"`
MessageId string `json:"messageId"`
ReceiptHandle string `json:"receiptHandle"`
Body string `json:"body"`
Md5OfBody string `json:"md5OfBody"`
Md5OfMessageAttributes string `json:"md5OfMessageAttributes"`
Attributes map[string]string `json:"attributes"`
MessageAttributes map[string]events.SQSMessageAttribute `json:"messageAttributes"`
EventSourceARN string `json:"eventSourceARN"`
AWSRegion string `json:"awsRegion"`
UserIdentity interface{} `json:"userIdentity"`
}
Click to show internal directories.
Click to hide internal directories.