golambda

Documentation

Index

• func NewErrorLambdaResponse(eventId string, err error, stderr string) *liblambda.Response
• func NewLambdaClient(target string) (lambda.LambdaClient, error)
• func NewSimpleLambdaEvent(event string) *liblambda.Event
• func NewSimpleLambdaResponse(eventId, stdout, stderr, responseString string, err error) (response *liblambda.Response)
• type BasicCodeExecutor
• type ContainerExecutor
  • func NewContainerExecutor(function *Function) ContainerExecutor
  • func (executor *ContainerExecutor) StartContainer(tempDir string) error
  • func (executor *ContainerExecutor) StopContainer()
• type DockerContainerManager
  • func (manager *DockerContainerManager) Init() error
• type Function
  • func NewContainerLambdaFunction(name, codeUri, runtime, handler string) *Function
  • func NewLocalOsLambdaFunction(name, codeUri, argument string) Function
  • func (function *Function) CalculateArn(awsAccountNumber int64) string
  • func (function *Function) Invoke(event *liblambda.Event) (response *liblambda.Response, err error)
• type LambdaExecutor
• type LocalOsExecutor
  • func NewLocalOsExecutor(function Function) *LocalOsExecutor

Functions

func NewErrorLambdaResponse

func NewErrorLambdaResponse(eventId string, err error, stderr string) *liblambda.Response

func NewLambdaClient

func NewLambdaClient(target string) (lambda.LambdaClient, error)

func NewSimpleLambdaEvent

func NewSimpleLambdaEvent(event string) *liblambda.Event

func NewSimpleLambdaResponse

func NewSimpleLambdaResponse(eventId, stdout, stderr, responseString string, err error) (response *liblambda.Response)

Types

type BasicCodeExecutor

type BasicCodeExecutor struct {
	// contains filtered or unexported fields
}

type ContainerExecutor

type ContainerExecutor struct {
	Env         map[string]string
	State       string
	ContainerId string
	// contains filtered or unexported fields
}

func NewContainerExecutor

func NewContainerExecutor(function *Function) ContainerExecutor

func (*ContainerExecutor) StartContainer

func (executor *ContainerExecutor) StartContainer(tempDir string) error

func (*ContainerExecutor) StopContainer

func (executor *ContainerExecutor) StopContainer()

type DockerContainerManager

type DockerContainerManager struct {
	// contains filtered or unexported fields
}

func (*DockerContainerManager) Init

func (manager *DockerContainerManager) Init() error

type Function

type Function struct {
	Name           string `json:"name"`
	Description    string `json:"description"`
	Executor       LambdaExecutor
	CodeUri        string `json:"codeuri"`
	Handler        string `json:"handler"`
	Timeout        time.Duration
	TimeoutSeconds string            `json:"timeout-seconds"`
	Runtime        string            `json:"runtime"`
	Arn            string            `json:"arn"`
	Tags           map[string]string `json:"tags"`
	Env            map[string]string `json:"env"`
}

func NewContainerLambdaFunction

func NewContainerLambdaFunction(name, codeUri, runtime, handler string) *Function

func NewLocalOsLambdaFunction

func NewLocalOsLambdaFunction(name, codeUri, argument string) Function

func (*Function) CalculateArn

func (function *Function) CalculateArn(awsAccountNumber int64) string

func (*Function) Invoke

func (function *Function) Invoke(event *liblambda.Event) (response *liblambda.Response, err error)

type LambdaExecutor

type LambdaExecutor interface {
	// contains filtered or unexported methods
}

type LocalOsExecutor

type LocalOsExecutor struct {
	// contains filtered or unexported fields
}

func NewLocalOsExecutor

func NewLocalOsExecutor(function Function) *LocalOsExecutor