handler

Documentation

Overview

Lambda Handler Data Structures and types

Index

• func CallHandler(reflection TaskReflection, ctx context.Context, input []byte) (ret interface{}, err error)
• func CallHandlerFunction(handlerSymbol interface{}, ctx context.Context, input interface{}) (interface{}, error)
• func CreateHandler(tm *TaskHandlers) (func(context context.Context, input *RawMessage) (interface{}, error), error)
• func ValidateHandler(handlerSymbol interface{}) error
• type RawMessage
  • func (message *RawMessage) UnmarshalJSON(data []byte) error
• type TaskError
  • func (t *TaskError) Error() string
• type TaskHandlers
  • func (t *TaskHandlers) Reflect() map[string]TaskReflection
  • func (t *TaskHandlers) Tasks() []string
  • func (t *TaskHandlers) Validate() error
• type TaskReflection
  • func CreateTaskReflection(handlerSymbol interface{}) TaskReflection

Functions

func CallHandler

func CallHandler(reflection TaskReflection, ctx context.Context, input []byte) (ret interface{}, err error)

CallHandler calls a TaskReflections Handler with the correct objects using reflection Mostly borrowed from the aws-lambda-go package

func CallHandlerFunction

func CallHandlerFunction(handlerSymbol interface{}, ctx context.Context, input interface{}) (interface{}, error)

CallHandlerFunction does reflection inline and should only be used for testing

func CreateHandler

func CreateHandler(tm *TaskHandlers) (func(context context.Context, input *RawMessage) (interface{}, error), error)

CreateHandler returns the handler passed to the lambda.Start function

func ValidateHandler

func ValidateHandler(handlerSymbol interface{}) error

ValidateHandler checks a handler is a function with the correct arguments and return values

Types

type RawMessage

type RawMessage struct {
	Task  *string
	Input json.RawMessage
	// contains filtered or unexported fields
}

RawMessage is the struct passed to the Lambda Handler It contains the name of the Task and the Inputs Raw message

func (*RawMessage) UnmarshalJSON

func (message *RawMessage) UnmarshalJSON(data []byte) error

type TaskError

type TaskError struct {
	ErrorString string
	Task        *string
	Tasks       []string
}

TaskError is a error type a task function may throw handling it in the state machine is a good idea

func (*TaskError) Error

func (t *TaskError) Error() string

type TaskHandlers

type TaskHandlers map[string]interface{}

TaskHandlers maps a Task Name String to a function <pre>ahsufasiu</pre>

func (*TaskHandlers) Reflect

func (t *TaskHandlers) Reflect() map[string]TaskReflection

TaskHandlers Returns a map of TaskReflections from TaskHandlers

func (*TaskHandlers) Tasks

func (t *TaskHandlers) Tasks() []string

Tasks returns all Task names from a TaskHandlers Map

func (*TaskHandlers) Validate

func (t *TaskHandlers) Validate() error

TaskHandlers validates all handlers in a TaskHandlers map

type TaskReflection

type TaskReflection struct {
	Handler   reflect.Value
	Type      reflect.Type
	EventType reflect.Type
}

TaskReflection caches lots of the reflected values from the Task functions in order to speed up calls

func CreateTaskReflection

func CreateTaskReflection(handlerSymbol interface{}) TaskReflection

CreateTaskReflection creates a TaskReflection from a handler function