Documentation ¶
Index ¶
- func GetRequestID(ctx context.Context) string
- type Config
- type DynamoDBEventHandler
- type DynamoDBRecordHandler
- type Handler
- type KinesisEventHandler
- type KinesisRecordHandler
- type LambdaHandlerFunc
- type SQSEventHandler
- type SQSMessageHandler
- type Server
- func NewDynamoDBEventServer(handler DynamoDBEventHandler) *Server
- func NewDynamoDBRecordServer(handler DynamoDBRecordHandler) *Server
- func NewKinesisEventServer(handler KinesisEventHandler) *Server
- func NewKinesisRecordServer(handler KinesisRecordHandler) *Server
- func NewSQSEventServer(handler SQSEventHandler) *Server
- func NewSQSRecordServer(handler SQSMessageHandler) *Server
- func NewServer(handler Handler) *Server
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetRequestID ¶
Types ¶
type Config ¶
type Config struct {
LambdaServerPort int `env:"_lambda_server_port" required:"true"`
}
type DynamoDBEventHandler ¶
type DynamoDBEventHandler interface {
Handle(ctx context.Context, batch []events.DynamoDBEventRecord, logger nacelle.Logger) error
}
type DynamoDBRecordHandler ¶
type DynamoDBRecordHandler interface {
Handle(ctx context.Context, record events.DynamoDBEventRecord, logger nacelle.Logger) error
}
type KinesisEventHandler ¶
type KinesisEventHandler interface {
Handle(ctx context.Context, batch []events.KinesisEventRecord, logger nacelle.Logger) error
}
type KinesisRecordHandler ¶
type KinesisRecordHandler interface {
Handle(ctx context.Context, record events.KinesisEventRecord, logger nacelle.Logger) error
}
type LambdaHandlerFunc ¶
type SQSEventHandler ¶
type SQSEventHandler interface {
Handle(ctx context.Context, batch []events.SQSMessage, logger nacelle.Logger) error
}
type SQSMessageHandler ¶
type SQSMessageHandler interface {
Handle(ctx context.Context, message events.SQSMessage, logger nacelle.Logger) error
}
type Server ¶
type Server struct { Config *nacelle.Config `service:"config"` Logger nacelle.Logger `service:"logger"` Services *nacelle.ServiceContainer `service:"services"` Health *nacelle.Health `service:"health"` // contains filtered or unexported fields }
func NewDynamoDBEventServer ¶
func NewDynamoDBEventServer(handler DynamoDBEventHandler) *Server
func NewDynamoDBRecordServer ¶
func NewDynamoDBRecordServer(handler DynamoDBRecordHandler) *Server
func NewKinesisEventServer ¶
func NewKinesisEventServer(handler KinesisEventHandler) *Server
func NewKinesisRecordServer ¶
func NewKinesisRecordServer(handler KinesisRecordHandler) *Server
func NewSQSEventServer ¶
func NewSQSEventServer(handler SQSEventHandler) *Server
func NewSQSRecordServer ¶
func NewSQSRecordServer(handler SQSMessageHandler) *Server
Click to show internal directories.
Click to hide internal directories.