Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func New ¶
func New(provider *resource.AwsResourceService) (gateway.GatewayService, error)
func NewWithRuntime ¶
func NewWithRuntime(provider resource.AwsResourceProvider, runtime LambdaRuntimeHandler) (gateway.GatewayService, error)
Types ¶
type Event ¶
type Event struct { events.APIGatewayV2HTTPRequest events.APIGatewayWebsocketProxyRequest Records []Record // contains filtered or unexported fields }
An event struct that embeds the AWS event types that we handle
func (*Event) UnmarshalJSON ¶
type LambdaGateway ¶
type LambdaGateway struct { gateway.UnimplementedGatewayPlugin // contains filtered or unexported fields }
func (*LambdaGateway) Start ¶
func (s *LambdaGateway) Start(opts *gateway.GatewayStartOpts) error
Start polling the lambda runtime for events and route the to workers for processing
func (*LambdaGateway) Stop ¶
func (s *LambdaGateway) Stop() error
Stop will block until the lambda runtime is finished
type LambdaRuntimeHandler ¶
type LambdaRuntimeHandler func(interface{})
type Record ¶
type Record struct { EventSource string EventSourceArn string EventName string ResponseElements map[string]string S3 events.S3Entity SNS events.SNSEntity }
An event struct that embeds the AWS event types that we handle
type ScheduleMessage ¶
type ScheduleMessage struct {
Schedule string
}
Click to show internal directories.
Click to hide internal directories.