Help us shape the future of Go! Take the 2026 Go Developer Survey

lambda

package
v0.2.0-rc.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 26, 2026 License: MIT Imports: 40 Imported by: 0

Documentation

Overview

Package lambda emulates AWS Lambda (REST-JSON): functions, versions, aliases, layers, permissions, function URLs and event source mappings. Python and Node.js handlers run as warm local processes behind an embedded Runtime API client; other runtimes and container images run in Docker.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func HTTPEvent 

func HTTPEvent(r *http.Request, apiID, routeKey string) []byte

HTTPEvent builds an API Gateway HTTP API / function URL payload (version 2.0).

func SDKDir 

func SDKDir(dataDir string) string

SDKDir holds the AWS SDKs native runtimes lack (see `pogi lambda-sdks`): node_modules for Node.js, python/ for boto3. Function code is unpacked below it, so Node's module lookup finds the SDK without NODE_PATH.

func WriteHTTPResult 

func WriteHTTPResult(w http.ResponseWriter, result []byte)

WriteHTTPResult maps a function result to an HTTP response (payload 2.0 rules): an object with statusCode is a full response, anything else is a JSON body.

Types

type Alias 

type Alias struct {
	Name        string             `json:"name"`
	Version     string             `json:"version"`
	Description string             `json:"description,omitempty"`
	Weights     map[string]float64 `json:"weights,omitempty"`
	RevisionID  string             `json:"revisionId"`
}

Alias points at a version, optionally splitting traffic.

type Config 

type Config struct {
	Version       string            `json:"version"`
	Runtime       string            `json:"runtime,omitempty"`
	Handler       string            `json:"handler,omitempty"`
	Role          string            `json:"role"`
	Description   string            `json:"description,omitempty"`
	Timeout       int               `json:"timeout"`
	MemorySize    int               `json:"memorySize"`
	Env           map[string]string `json:"env,omitempty"`
	PackageType   string            `json:"packageType"`
	ImageURI      string            `json:"imageUri,omitempty"`
	ImageConfig   *ImageConfig      `json:"imageConfig,omitempty"`
	Code          []byte            `json:"code,omitempty"`
	CodeDir       string            `json:"codeDir,omitempty"` // hot reload
	CodeSha256    string            `json:"codeSha256"`
	CodeSize      int64             `json:"codeSize"`
	Layers        []string          `json:"layers,omitempty"`
	Architectures []string          `json:"architectures,omitempty"`
	DeadLetterArn string            `json:"deadLetterArn,omitempty"`
	TracingMode   string            `json:"tracingMode,omitempty"`
	Ephemeral     int               `json:"ephemeral,omitempty"`
	Vpc           json.RawMessage   `json:"vpc,omitempty"`
	Modified      time.Time         `json:"modified"`
	RevisionID    string            `json:"revisionId"`
}

Config is one immutable (or $LATEST) function configuration.

type Function 

type Function struct {
	Name        string                  `json:"name"`
	Account     string                  `json:"account"`
	Region      string                  `json:"region"`
	Latest      *Config                 `json:"latest"`
	Versions    map[string]*Config      `json:"versions,omitempty"`
	NextVersion int                     `json:"nextVersion"`
	Aliases     map[string]*Alias       `json:"aliases,omitempty"`
	Policy      []map[string]any        `json:"policy,omitempty"`
	Tags        map[string]string       `json:"tags,omitempty"`
	Reserved    *int                    `json:"reserved,omitempty"`
	Provisioned map[string]*Provisioned `json:"provisioned,omitempty"` // version or alias → provisioned concurrency
	URL         *URLConfig              `json:"url,omitempty"`
	EventInvoke map[string]any          `json:"eventInvoke,omitempty"`
}

Function is a function with its $LATEST config, versions and aliases.

type ImageConfig 

type ImageConfig struct {
	EntryPoint       []string `json:",omitempty"`
	Command          []string `json:",omitempty"`
	WorkingDirectory string   `json:",omitempty"`
}

ImageConfig overrides a container image's entrypoint, command and working directory.

type InvokeResult 

type InvokeResult struct {
	Payload string
	Error   string
	Logs    string
	Elapsed time.Duration
}

InvokeResult is what the console shows after a test invoke.

type Layer 

type Layer struct {
	Name     string                `json:"name"`
	Account  string                `json:"account"`
	Region   string                `json:"region"`
	Versions map[int]*LayerVersion `json:"versions"`
	Next     int                   `json:"next"`
}

Layer holds the versions of one layer.

type LayerVersion 

type LayerVersion struct {
	Version     int       `json:"version"`
	Zip         []byte    `json:"zip"`
	Sha         string    `json:"sha"`
	Description string    `json:"description,omitempty"`
	License     string    `json:"license,omitempty"`
	Runtimes    []string  `json:"runtimes,omitempty"`
	Archs       []string  `json:"archs,omitempty"`
	Created     time.Time `json:"created"`
}

LayerVersion is one published layer version.

type Mapping 

type Mapping struct {
	UUID              string            `json:"uuid"`
	Account           string            `json:"account"`
	Region            string            `json:"region"`
	FunctionArn       string            `json:"functionArn"`
	SourceArn         string            `json:"sourceArn"`
	BatchSize         int               `json:"batchSize"`
	Window            int               `json:"window"`
	StartingPosition  string            `json:"startingPosition,omitempty"`
	StartingTimestamp float64           `json:"startingTimestamp,omitempty"`
	Enabled           bool              `json:"enabled"`
	Filters           []string          `json:"filters,omitempty"`
	ResponseTypes     []string          `json:"responseTypes,omitempty"`
	MaxRetry          int               `json:"maxRetry"`
	Bisect            bool              `json:"bisect,omitempty"`
	MaxConcurrency    int               `json:"maxConcurrency,omitempty"` // ScalingConfig.MaximumConcurrency, kept but not used to limit polling
	OnFailure         string            `json:"onFailure,omitempty"`
	Topics            []string          `json:"topics,omitempty"`        // self-managed Kafka
	Endpoints         []string          `json:"endpoints,omitempty"`     // its KAFKA_BOOTSTRAP_SERVERS
	Access            []accessConfig    `json:"access,omitempty"`        // its SourceAccessConfigurations
	ConsumerGroup     string            `json:"consumerGroup,omitempty"` // its consumer group id
	Modified          time.Time         `json:"modified"`
	LastResult        string            `json:"lastResult"`
	Tags              map[string]string `json:"tags,omitempty"`
}

Mapping is an event source mapping (SQS, DynamoDB Streams, Kinesis or self-managed Kafka → function).

type Provisioned 

type Provisioned struct {
	Requested int       `json:"requested"`
	Status    string    `json:"status"` // IN_PROGRESS, READY or FAILED
	Reason    string    `json:"reason,omitempty"`
	Modified  time.Time `json:"modified"`
}

Provisioned is the provisioned concurrency of a version or alias.

type Service 

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

Service is the Lambda emulator.

func New 

func New(hub *core.Hub) *Service

New creates the Lambda service.

func (*Service) BodyLimit 

func (s *Service) BodyLimit(r *http.Request) int64

BodyLimit raises the upload limit for function code: CreateFunction, UpdateFunctionCode and PublishLayerVersion carry a zip of up to 50 MB as base64 in JSON.

func (*Service) Close 

func (s *Service) Close() error

Close stops every runtime process and poller.

func (*Service) Info 

func (s *Service) Info() core.Info

func (*Service) Inspect 

func (s *Service) Inspect(table, id string) any

Inspect returns a function's configuration, versions, aliases, policy and recent logs.

func (*Service) Invoke 

func (s *Service) Invoke(account, region, name string, payload []byte) (InvokeResult, error)

Invoke runs a function synchronously from the console. 

func (s *Service) Links() []core.Link

Links are the event source mappings, from the stream or queue to the function.

func (*Service) Load 

func (s *Service) Load(b []byte) error

func (*Service) RecentLogs 

func (s *Service) RecentLogs(account, region, name string) []string

RecentLogs returns the last log lines of a function.

func (*Service) Reset 

func (s *Service) Reset()

func (*Service) Resources 

func (s *Service) Resources() []core.Table

Resources lists functions and event source mappings.

func (*Service) Save 

func (s *Service) Save() ([]byte, error)

func (*Service) ServeHTTP 

func (s *Service) ServeHTTP(w http.ResponseWriter, r *http.Request)

func (*Service) TaggedResources 

func (s *Service) TaggedResources(account, region string) map[string]map[string]string

TaggedResources lists functions (ARN → tags) for the tagging API and Resource Explorer.

func (*Service) Tick 

func (s *Service) Tick(now time.Time)

Tick keeps provisioned environments started, then stops idle environments unused for keepAlive. New runs it every 5 seconds; tests call it with any time.

type URLConfig 

type URLConfig struct {
	ID       string          `json:"id"`
	AuthType string          `json:"authType"`
	Cors     json.RawMessage `json:"cors,omitempty"`
	Mode     string          `json:"mode,omitempty"`
	Created  time.Time       `json:"created"`
}

URLConfig is a function URL.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.