Package lambda_proc

import "github.com/jasonmoo/lambda_proc"

Overview
Index
Subdirectories

Overview

Index

func Run(handler Handler)
func RunStream(handler Handler, Stdin io.Reader, Stdout io.Writer)
type Context
type Handler
type Payload
type Response
func NewErrorResponse(err error) *Response
func NewResponse(data interface{}) *Response

Package files

lambda_proc.go

func Run

func Run(handler Handler)

func RunStream

func RunStream(handler Handler, Stdin io.Reader, Stdout io.Writer)

type Context

type Context struct {
    AwsRequestID             string `json:"awsRequestId"`
    FunctionName             string `json:"functionName"`
    FunctionVersion          string `json:"functionVersion"`
    Invokeid                 string `json:"invokeid"`
    IsDefaultFunctionVersion bool   `json:"isDefaultFunctionVersion"`
    LogGroupName             string `json:"logGroupName"`
    LogStreamName            string `json:"logStreamName"`
    MemoryLimitInMB          string `json:"memoryLimitInMB"`
}

type Handler

type Handler func(*Context, json.RawMessage) (interface{}, error)

type Payload

type Payload struct {
    // custom event fields
    Event json.RawMessage `json:"event"`

    // default context object
    Context *Context `json:"context"`
}

type Response

type Response struct {
    // Request id is an incremental integer
    // representing the request that has been
    // received by this go proc during it's
    // lifetime
    RequestId int `json:"proc_req_id"`
    // Any errors that occur during processing
    // or are returned by handlers are returned
    Error *string `json:"error"`
    // General purpose output data
    Data interface{} `json:"data"`
}

func NewErrorResponse

func NewErrorResponse(err error) *Response

func NewResponse

func NewResponse(data interface{}) *Response

Subdirectories

Name	Synopsis

example

github.com/jasonmoo/lambda_proc