lambda

package

Go to main page

Versions in this module

v1

v1.3.0

Aug 3, 2026

v1.2.0

Aug 3, 2026

Changes in this version

+ var ErrCallbackNotFound = errors.New("ResourceNotFoundException")

+ var ErrPreconditionFailed = errors.New("PreconditionFailedException")

type AddLayerVersionPermissionInput

+ RevisionID string

type AddPermissionInput

+ FunctionURLAuthType string

+ InvokedViaFunctionURL *bool

+ RevisionID string

type CapacityProvider

+ TelemetryConfig *CapacityProviderTelemetryConfig

+ type CapacityProviderLoggingConfig struct

+ LogGroup string

+ SystemLogLevel string

+ type CapacityProviderTelemetryConfig struct

+ LoggingConfig *CapacityProviderLoggingConfig

type CheckpointDurableExecutionInput

+ CheckpointToken *string

+ ClientToken *string

+ Updates []DurableOperationUpdate

type CheckpointDurableExecutionOutput

+ CheckpointToken *string

+ NewExecutionState *CheckpointUpdatedExecutionState

+ type CheckpointUpdatedExecutionState struct

+ NextMarker *string

+ Operations []*DurableOperation

type CreateCapacityProviderInput

+ TelemetryConfig *CapacityProviderTelemetryConfig

type CreateFunctionInput

+ DurableConfig *DurableConfig

+ type DurableConfig struct

+ ExecutionTimeout *int32

+ KMSKeyArn string

+ RetentionPeriodInDays *int32

type DurableExecution

+ ARN string

+ CheckpointToken string

+ DurableConfig *DurableConfig

+ EndTime time.Time

+ Error *ErrorObject

+ Events []DurableExecutionEvent

+ InputPayload string

+ Name string

+ Operations []*DurableOperation

+ Result string

+ TraceHeader *TraceHeader

+ Version string

type DurableExecutionEvent

+ EventID *int32

+ EventTimestamp float64

+ ExecutionFailedDetails *ExecutionFailedDetails

+ ExecutionStartedDetails *ExecutionStartedDetails

+ ExecutionStoppedDetails *ExecutionStoppedDetails

+ ExecutionSucceededDetails *ExecutionSucceededDetails

+ ExecutionTimedOutDetails *ExecutionTimedOutDetails

+ ID *string

+ Name *string

+ ParentID *string

+ SubType *string

type DurableExecutionStatus

+ const DurableExecutionStatusTimedOut

+ type DurableExecutionSummary struct

+ DurableExecutionArn string

+ DurableExecutionName string

+ EndTimestamp *float64

+ FunctionArn string

+ KMSKeyArn *string

+ StartTimestamp float64

+ Status DurableExecutionStatus

+ type DurableOperation struct

+ EndTimestamp *float64

+ ExecutionDetails *DurableOperationExecutionDetails

+ ID string

+ Name *string

+ ParentID *string

+ StartTimestamp float64

+ Status DurableOperationStatus

+ SubType *string

+ Type DurableOperationType

+ type DurableOperationExecutionDetails struct

+ InputPayload *string

+ type DurableOperationStatus string

+ const DurableOperationStatusCancelled

+ const DurableOperationStatusFailed

+ const DurableOperationStatusStarted

+ const DurableOperationStatusStopped

+ const DurableOperationStatusSucceeded

+ type DurableOperationType string

+ const DurableOperationTypeCallback

+ const DurableOperationTypeChainedInvoke

+ const DurableOperationTypeContext

+ const DurableOperationTypeExecution

+ const DurableOperationTypeStep

+ const DurableOperationTypeWait

+ type DurableOperationUpdate struct

+ Action string

+ Error *ErrorObject

+ ID string

+ Name *string

+ ParentID *string

+ Payload *string

+ SubType *string

+ Type string

+ type ErrorObject struct

+ ErrorData *string

+ ErrorMessage *string

+ ErrorType *string

+ StackTrace []string

+ type EventError struct

+ Payload *ErrorObject

+ Truncated *bool

+ type EventInput struct

+ Payload *string

+ Truncated *bool

+ type EventResult struct

+ Payload *string

+ Truncated *bool

+ type ExecutionFailedDetails struct

+ Error *EventError

+ type ExecutionStartedDetails struct

+ ExecutionTimeout *int32

+ Input *EventInput

+ type ExecutionStoppedDetails struct

+ Error *EventError

+ type ExecutionSucceededDetails struct

+ Result *EventResult

+ type ExecutionTimedOutDetails struct

+ Error *EventError

type FunctionConfiguration

+ DurableConfig *DurableConfig

type FunctionPermission

+ FunctionURLAuthType string

+ InvokedViaFunctionURL *bool

type FunctionVersion

+ DurableConfig *DurableConfig

+ type GetDurableExecutionHistoryOutput struct

+ Events []DurableExecutionEvent

+ NextMarker *string

+ type GetDurableExecutionOutput struct

+ DurableConfig *DurableConfig

+ DurableExecutionArn string

+ DurableExecutionName string

+ EndTimestamp *float64

+ Error *ErrorObject

+ ExecutionDataIncluded *bool

+ FunctionArn string

+ InputPayload *string

+ Result *string

+ StartTimestamp float64

+ Status DurableExecutionStatus

+ TraceHeader *TraceHeader

+ Version *string

+ type GetDurableExecutionStateOutput struct

+ NextMarker *string

+ Operations []*DurableOperation

type InMemoryBackend

+ func (b *InMemoryBackend) PublishVersionWithRevision(name, description, revisionID string) (*FunctionVersion, error)

+ type ListDurableExecutionsByFunctionOutput struct

+ DurableExecutions []DurableExecutionSummary

+ NextMarker *string

+ type SendDurableExecutionCallbackFailureOutput struct

+ type SendDurableExecutionCallbackHeartbeatOutput struct

+ type SendDurableExecutionCallbackSuccessOutput struct

+ type StopDurableExecutionOutput struct

+ StopTimestamp float64

+ type TraceHeader struct

+ XAmznTraceID *string

type UpdateAliasInput

+ RevisionID string

type UpdateCapacityProviderInput

+ TelemetryConfig *CapacityProviderTelemetryConfig

type UpdateFunctionCodeInput

+ RevisionID string

type UpdateFunctionConfigurationInput

+ DurableConfig *DurableConfig

+ RevisionID string

v1.1.4

Jul 20, 2026

v1.1.3

Jul 20, 2026

v1.1.2

Jul 20, 2026

v1.1.1

Jul 20, 2026

v1.1.0

Jul 19, 2026

Changes in this version

+ const PackageTypeImage

+ const PackageTypeZip

+ const SnapStartApplyOnNone

+ const SnapStartApplyOnPublishedVersions

+ var ErrAliasAlreadyExists = errors.New("ResourceConflictException")

+ var ErrAliasNotFound = errors.New("ResourceNotFoundException")

+ var ErrCodeSigningConfigNotFound = errors.New("CodeSigningConfigNotFoundException")

+ var ErrDurableExecutionNotFound = errors.New("durable execution not found")

+ var ErrESMNotFound = errors.New("ResourceNotFoundException")

+ var ErrEventInvokeConfigNotFound = errors.New("ResourceNotFoundException")

+ var ErrFISInvocationError = errors.New("FunctionError: FIS fault injection: invocation error")

+ var ErrFunctionAlreadyExists = errors.New("ResourceConflictException")

+ var ErrFunctionConcurrencyNotFound = errors.New("ResourceNotFoundException")

+ var ErrFunctionNotFound = errors.New("ResourceNotFoundException")

+ var ErrFunctionURLForbidden = errors.New("Forbidden")

+ var ErrFunctionURLNotFound = errors.New("ResourceNotFoundException")

+ var ErrInvalidParameterValue = errors.New("InvalidParameterValueException")

+ var ErrInvocationTimeout = errors.New("lambda invocation timed out")

+ var ErrLambdaUnavailable = errors.New("ServiceException")

+ var ErrLayerNotFound = errors.New("ResourceNotFoundException")

+ var ErrLayerVersionNotFound = errors.New("ResourceNotFoundException")

+ var ErrNoPolicyFound = errors.New("ResourceNotFoundException")

+ var ErrProvisionedConcurrencyConfigNotFound = errors.New("ResourceNotFoundException")

+ var ErrTooManyRequests = errors.New("TooManyRequestsException")

+ var ErrVersionNotFound = errors.New("ResourceNotFoundException")

+ var ErrZipSlip = errors.New("zip entry escapes target directory")

+ type AccountLimit struct

+ CodeSizeUnzipped int64

+ CodeSizeZipped int64

+ ConcurrentExecutions int

+ TotalCodeSize int64

+ UnreservedConcurrentExecutions int

+ type AccountSettingsOutput struct

+ AccountLimit *AccountLimit

+ AccountUsage *AccountUsage

+ type AccountUsage struct

+ FunctionCount int

+ TotalCodeSize int64

+ type AddLayerVersionPermissionInput struct

+ Action string

+ OrganizationID string

+ Principal string

+ StatementID string

+ type AddLayerVersionPermissionOutput struct

+ RevisionID string

+ Statement string

+ type AddPermissionInput struct

+ Action string

+ EventSourceToken string

+ Principal string

+ PrincipalOrgID string

+ SourceAccount string

+ SourceArn string

+ StatementID string

+ type AddPermissionOutput struct

+ Statement *string

+ type AliasRoutingConfig struct

+ AdditionalVersionWeights map[string]float64

+ type AllowedPublishers struct

+ SigningProfileVersionArns []string

+ type AmazonManagedKafkaEventSourceConfig struct

+ ConsumerGroupID string

+ type AsyncDestinationDelivery interface

+ DeliverToTarget func(ctx context.Context, targetARN string, payload []byte, ...) error

+ type CWLogsBackend interface

+ EnsureLogGroupAndStream func(groupName, streamName string) error

+ PutLogLines func(groupName, streamName string, messages []string) error

+ type CapacityProvider struct

+ AssignedFunctionVersions []string

+ CapacityProviderArn string

+ LastModifiedTime string

+ Name string

+ Status string

+ TargetOnDemandConcurrency int

+ type CheckpointDurableExecutionInput struct

+ Marker *string

+ type CheckpointDurableExecutionOutput struct

+ type CodeSigningConfig struct

+ AllowedPublishers *AllowedPublishers

+ CodeSigningConfigArn string

+ CodeSigningConfigID string

+ CodeSigningPolicies *CodeSigningPolicies

+ Description string

+ LastModified string

+ type CodeSigningPolicies struct

+ UntrustedArtifactOnDeployment string

+ type CreateAliasInput struct

+ Description string

+ FunctionVersion string

+ Name string

+ RoutingConfig *AliasRoutingConfig

+ type CreateCapacityProviderInput struct

+ Name string

+ TargetOnDemandConcurrency int

+ type CreateCapacityProviderOutput struct

+ CapacityProvider *CapacityProvider

+ type CreateCodeSigningConfigInput struct

+ AllowedPublishers *AllowedPublishers

+ CodeSigningPolicies *CodeSigningPolicies

+ Description string

+ type CreateCodeSigningConfigOutput struct

+ CodeSigningConfig *CodeSigningConfig

+ type CreateEventSourceMappingInput struct

+ AmazonManagedKafkaEventSourceConfig *AmazonManagedKafkaEventSourceConfig

+ BatchSize int

+ BisectBatchOnFunctionError bool

+ DestinationConfig *ESMDestinationConfig

+ DocumentDBEventSourceConfig *DocumentDBEventSourceConfig

+ Enabled bool

+ EventSourceARN string

+ FilterCriteria *FilterCriteria

+ FunctionName string

+ FunctionResponseTypes []string

+ MaximumBatchingWindowInSeconds int

+ MaximumRecordAgeInSeconds int

+ MaximumRetryAttempts int

+ ParallelizationFactor int

+ Queues []string

+ SelfManagedEventSource *SelfManagedEventSource

+ SelfManagedKafkaEventSourceConfig *SelfManagedKafkaEventSourceConfig

+ SourceAccessConfigurations []SourceAccessConfiguration

+ StartingPosition string

+ Topics []string

+ TumblingWindowInSeconds int

+ type CreateFunctionInput struct

+ Architectures []string

+ Code *FunctionCode

+ DeadLetterConfig *DeadLetterConfig

+ Description string

+ Environment *EnvironmentConfig

+ EphemeralStorage *EphemeralStorageConfig

+ FileSystemConfigs []*FileSystemConfig

+ FunctionName string

+ Handler string

+ ImageConfig *ImageConfig

+ Layers []string

+ MemorySize int

+ PackageType string

+ Publish bool

+ Role string

+ Runtime string

+ SnapStart *SnapStart

+ Tags map[string]string

+ Timeout int

+ TracingConfig *TracingConfig

+ VpcConfig *VpcConfig

+ type CreateFunctionURLConfigInput struct

+ AuthType string

+ Cors *FunctionURLCors

+ InvokeMode string

+ type DNSRegistrar interface

+ Deregister func(hostname string)

+ Register func(hostname string)

+ type DeadLetterConfig struct

+ TargetArn string

+ type Destination struct

+ Destination string

+ type DestinationConfig struct

+ OnFailure *Destination

+ OnSuccess *Destination

+ type DocumentDBEventSourceConfig struct

+ CollectionName string

+ DatabaseName string

+ FullDocument string

+ type DurableExecution struct

+ CheckpointData map[string]any

+ ExecutionARN string

+ FunctionARN string

+ History []DurableExecutionEvent

+ StartTime time.Time

+ Status DurableExecutionStatus

+ StopTime *time.Time

+ type DurableExecutionEvent struct

+ Details string

+ EventType string

+ Timestamp time.Time

+ type DurableExecutionState struct

+ ExecutionARN string

+ StateData map[string]any

+ Status DurableExecutionStatus

+ type DurableExecutionStatus string

+ const DurableExecutionStatusFailed

+ const DurableExecutionStatusRunning

+ const DurableExecutionStatusStopped

+ const DurableExecutionStatusSucceeded

+ type DynamoDBStreamRecord struct

+ ApproximateCreationDateTime float64

+ EventID string

+ EventName string

+ Keys map[string]any

+ NewImage map[string]any

+ OldImage map[string]any

+ SequenceNumber string

+ SizeBytes int64

+ StreamViewType string

+ type DynamoDBStreamsReader interface

+ DescribeStreamShards func(streamARN string) ([]string, error)

+ GetStreamRecords func(iteratorToken string, limit int) ([]DynamoDBStreamRecord, string, error)

+ GetStreamShardIterator func(streamARN, shardID, iteratorType string) (string, error)

+ type ESMDestination struct

+ Destination string

+ type ESMDestinationConfig struct

+ OnFailure *ESMDestination

+ type EnvironmentConfig struct

+ Variables map[string]string

+ type EphemeralStorageConfig struct

+ Size int32

+ type Error struct

+ Message string

+ Type string

+ type EventSourceMapping struct

+ AmazonManagedKafkaEventSourceConfig *AmazonManagedKafkaEventSourceConfig

+ BatchSize int

+ BisectBatchOnFunctionError bool

+ DestinationConfig *ESMDestinationConfig

+ DocumentDBEventSourceConfig *DocumentDBEventSourceConfig

+ EventSourceARN string

+ FilterCriteria *FilterCriteria

+ FunctionARN string

+ FunctionResponseTypes []string

+ LastModified time.Time

+ LastProcessingResult string

+ MaximumBatchingWindowInSeconds int

+ MaximumRecordAgeInSeconds int

+ MaximumRetryAttempts int

+ ParallelizationFactor int

+ Queues []string

+ SelfManagedEventSource *SelfManagedEventSource

+ SelfManagedKafkaEventSourceConfig *SelfManagedKafkaEventSourceConfig

+ SourceAccessConfigurations []SourceAccessConfiguration

+ StartingPosition string

+ State EventSourceMappingState

+ Topics []string

+ TumblingWindowInSeconds int

+ UUID string

+ type EventSourceMappingState string

+ const ESMStateDeleting

+ const ESMStateDisabled

+ const ESMStateDisabling

+ const ESMStateEnabled

+ const ESMStateEnabling

+ type EventSourcePoller struct

+ func NewEventSourcePoller(lambdaBackend *InMemoryBackend, kinesisReader KinesisReader) *EventSourcePoller

+ func (p *EventSourcePoller) Notify()

+ func (p *EventSourcePoller) RemoveMapping(uuid string)

+ func (p *EventSourcePoller) SetDynamoDBStreamsReader(r DynamoDBStreamsReader)

+ func (p *EventSourcePoller) SetSQSReader(r SQSReader)

+ func (p *EventSourcePoller) Start(ctx context.Context)

+ type FISInvocationFault struct

+ AddDelayMs int

+ ErrorProbability float64

+ Expiry time.Time

+ type FileSystemConfig struct

+ Arn string

+ LocalMountPath string

+ type Filter struct

+ Pattern string

+ type FilterCriteria struct

+ Filters []Filter

+ type FunctionAlias struct

+ AliasArn string

+ Description string

+ FunctionVersion string

+ Name string

+ RevisionID string

+ RoutingConfig *AliasRoutingConfig

+ type FunctionCode struct

+ ImageURI string

+ S3Bucket string

+ S3Key string

+ ZipFile []byte

+ type FunctionCodeLocation struct

+ ImageURI string

+ Location string

+ RepositoryType string

+ type FunctionConcurrency struct

+ ReservedConcurrentExecutions int

+ type FunctionConfiguration struct

+ Architectures []string

+ CodeSha256 string

+ CodeSize int64

+ CreatedAt time.Time

+ DeadLetterConfig *DeadLetterConfig

+ Description string

+ Environment *EnvironmentConfig

+ EphemeralStorage *EphemeralStorageConfig

+ FileSystemConfigs []*FileSystemConfig

+ FunctionArn string

+ FunctionName string

+ Handler string

+ ImageConfig *ImageConfig

+ ImageURI string

+ LastModified string

+ LastUpdateStatus LastUpdateStatus

+ LastUpdateStatusReason string

+ Layers []*FunctionLayer

+ LoggingConfig *LoggingConfig

+ MasterArn string

+ MemorySize int

+ PackageType string

+ ReservedConcurrentExecutions *int

+ RevisionID string

+ Role string

+ Runtime string

+ S3BucketCode string

+ S3KeyCode string

+ SnapStart *SnapStartResponse

+ State FunctionState

+ StateReason string

+ StateReasonCode string

+ Tags map[string]string

+ Timeout int

+ TracingConfig *TracingConfig

+ Version string

+ VpcConfig *VpcConfig

+ ZipData []byte

+ type FunctionEventInvokeConfig struct

+ DestinationConfig *DestinationConfig

+ FunctionArn string

+ LastModified time.Time

+ MaximumEventAgeInSeconds *int

+ MaximumRetryAttempts *int

+ type FunctionLayer struct

+ Arn string

+ CodeSize int64

+ type FunctionPermission struct

+ Action string

+ Effect string

+ EventSourceToken string

+ FunctionName string

+ Principal string

+ PrincipalOrgID string

+ Qualifier string

+ SourceAccount string

+ SourceArn string

+ StatementID string

+ type FunctionRecursionConfig struct

+ RecursiveLoop string

+ type FunctionScalingConfig struct

+ FunctionArn string

+ MaximumConcurrency *int

+ type FunctionState string

+ const FunctionStateActive

+ const FunctionStateFailed

+ const FunctionStateInactive

+ const FunctionStatePending

+ type FunctionURLConfig struct

+ AuthType string

+ Cors *FunctionURLCors

+ CreationTime string

+ FunctionArn string

+ FunctionURL string

+ InvokeMode string

+ LastModifiedTime string

+ type FunctionURLCors struct

+ AllowCredentials bool

+ AllowHeaders []string

+ AllowMethods []string

+ AllowOrigins []string

+ ExposeHeaders []string

+ MaxAge int

+ type FunctionVersion struct

+ CodeSha256 string

+ CodeSize int64

+ CreatedAt string

+ DeadLetterConfig *DeadLetterConfig

+ Description string

+ Environment *EnvironmentConfig

+ FileSystemConfigs []*FileSystemConfig

+ FunctionArn string

+ FunctionName string

+ Handler string

+ ImageConfig *ImageConfig

+ ImageURI string

+ Layers []*FunctionLayer

+ MemorySize int

+ PackageType string

+ RevisionID string

+ Role string

+ Runtime string

+ SnapStart *SnapStartResponse

+ State FunctionState

+ Timeout int

+ TracingConfig *TracingConfig

+ Version string

+ VpcConfig *VpcConfig

+ type GetFunctionCodeSigningConfigOutput struct

+ CodeSigningConfigArn string

+ FunctionName string

+ type GetFunctionOutput struct

+ Code *FunctionCodeLocation

+ Configuration *FunctionConfiguration

+ type GetLayerVersionOutput struct

+ CompatibleRuntimes []string

+ Content *LayerVersionContent

+ CreatedDate string

+ Description string

+ LayerArn string

+ LayerVersionArn string

+ LicenseInfo string

+ Version int64

+ type GetPolicyOutput struct

+ Policy *string

+ RevisionID *string

+ type Handler struct

+ AccountID string

+ Backend StorageBackend

+ DefaultRegion string

+ func NewHandler(backend StorageBackend) *Handler

+ func (h *Handler) ChaosOperations() []string

+ func (h *Handler) ChaosRegions() []string

+ func (h *Handler) ChaosServiceName() string

+ func (h *Handler) ExecuteFISAction(ctx context.Context, action service.FISActionExecution) error

+ func (h *Handler) ExtractOperation(c *echo.Context) string

+ func (h *Handler) ExtractResource(c *echo.Context) string

+ func (h *Handler) FISActions() []service.FISActionDefinition

+ func (h *Handler) GetSupportedOperations() []string

+ func (h *Handler) Handler() echo.HandlerFunc

+ func (h *Handler) IAMAction(r *http.Request) string

+ func (h *Handler) MatchPriority() int

+ func (h *Handler) Name() string

+ func (h *Handler) Purge(ctx context.Context, cutoff time.Time)

+ func (h *Handler) Reset()

+ func (h *Handler) Restore(ctx context.Context, data []byte) error

+ func (h *Handler) RouteMatcher() service.Matcher

+ func (h *Handler) Snapshot(ctx context.Context) []byte

+ func (h *Handler) StartWorker(ctx context.Context) error

+ func (h *Handler) TagFunctionByARN(_ context.Context, fnARN string, newTags map[string]string) error

+ func (h *Handler) TaggedFunctions(_ context.Context) []TaggedFunctionInfo

+ func (h *Handler) UntagFunctionByARN(_ context.Context, fnARN string, tagKeys []string) error

+ type ImageConfig struct

+ Command []string

+ EntryPoint []string

+ WorkingDirectory string

+ type InMemoryBackend struct

+ func NewInMemoryBackend(dockerClient container.Runtime, portAlloc *portalloc.Allocator, ...) *InMemoryBackend

+ func NewInMemoryBackendWithContext(svcCtx context.Context, dockerClient container.Runtime, ...) *InMemoryBackend

+ func (b *InMemoryBackend) AddLayerVersionPermission(layerName string, version int64, input *AddLayerVersionPermissionInput) (*AddLayerVersionPermissionOutput, error)

+ func (b *InMemoryBackend) AddPermission(functionName, qualifier string, input *AddPermissionInput) (*AddPermissionOutput, error)

+ func (b *InMemoryBackend) Close(ctx context.Context)

+ func (b *InMemoryBackend) CreateAlias(name string, input *CreateAliasInput) (*FunctionAlias, error)

+ func (b *InMemoryBackend) CreateCapacityProvider(input *CreateCapacityProviderInput) (*CapacityProvider, error)

+ func (b *InMemoryBackend) CreateCodeSigningConfig(input *CreateCodeSigningConfigInput) (*CodeSigningConfig, error)

+ func (b *InMemoryBackend) CreateEventSourceMapping(input *CreateEventSourceMappingInput) (*EventSourceMapping, error)

+ func (b *InMemoryBackend) CreateFunction(fn *FunctionConfiguration) error

+ func (b *InMemoryBackend) CreateFunctionURLConfig(ctx context.Context, functionName, authType string, cors *FunctionURLCors, ...) (*FunctionURLConfig, error)

+ func (b *InMemoryBackend) DeleteAlias(name, aliasName string) error

+ func (b *InMemoryBackend) DeleteCapacityProvider(name string) error

+ func (b *InMemoryBackend) DeleteCodeSigningConfig(cscARN string) error

+ func (b *InMemoryBackend) DeleteEventSourceMapping(id string) (*EventSourceMapping, error)

+ func (b *InMemoryBackend) DeleteFunction(name string) error

+ func (b *InMemoryBackend) DeleteFunctionCodeSigningConfig(functionName string) error

+ func (b *InMemoryBackend) DeleteFunctionConcurrency(name string) error

+ func (b *InMemoryBackend) DeleteFunctionEventInvokeConfig(name string) error

+ func (b *InMemoryBackend) DeleteFunctionURLConfig(functionName string) error

+ func (b *InMemoryBackend) DeleteLayerVersion(layerName string, version int64) error

+ func (b *InMemoryBackend) DeleteProvisionedConcurrencyConfig(name, qualifier string) error

+ func (b *InMemoryBackend) GetAccountSettings() *AccountSettingsOutput

+ func (b *InMemoryBackend) GetAlias(name, aliasName string) (*FunctionAlias, error)

+ func (b *InMemoryBackend) GetCapacityProvider(name string) (*CapacityProvider, error)

+ func (b *InMemoryBackend) GetCodeSigningConfig(cscARN string) (*CodeSigningConfig, error)

+ func (b *InMemoryBackend) GetEventSourceMapping(uuid string) (*EventSourceMapping, error)

+ func (b *InMemoryBackend) GetFunction(name string) (*FunctionConfiguration, error)

+ func (b *InMemoryBackend) GetFunctionByQualifier(name, qualifier string) (*FunctionConfiguration, error)

+ func (b *InMemoryBackend) GetFunctionCodeSigningConfig(functionName string) (string, error)

+ func (b *InMemoryBackend) GetFunctionConcurrency(name string) (*FunctionConcurrency, error)

+ func (b *InMemoryBackend) GetFunctionEventInvokeConfig(name string) (*FunctionEventInvokeConfig, error)

+ func (b *InMemoryBackend) GetFunctionRecursionConfig(name string) (*FunctionRecursionConfig, error)

+ func (b *InMemoryBackend) GetFunctionScalingConfig(name string) (*FunctionScalingConfig, error)

+ func (b *InMemoryBackend) GetFunctionURLConfig(functionName string) (*FunctionURLConfig, error)

+ func (b *InMemoryBackend) GetLayerVersion(layerName string, version int64) (*GetLayerVersionOutput, error)

+ func (b *InMemoryBackend) GetLayerVersionByArn(layerVersionARN string) (*GetLayerVersionOutput, error)

+ func (b *InMemoryBackend) GetLayerVersionPolicy(layerName string, version int64) (*LayerVersionPolicy, error)

+ func (b *InMemoryBackend) GetPolicy(functionName, qualifier string) (*GetPolicyOutput, error)

+ func (b *InMemoryBackend) GetProvisionedConcurrencyConfig(name, qualifier string) (*ProvisionedConcurrencyConfig, error)

+ func (b *InMemoryBackend) GetRuntimeManagementConfig(name string) (*RuntimeManagementConfig, error)

+ func (b *InMemoryBackend) GetVersion(name, version string) (*FunctionVersion, error)

+ func (b *InMemoryBackend) InvokeFunction(ctx context.Context, name string, invocationType InvocationType, ...) ([]byte, int, error)

+ func (b *InMemoryBackend) InvokeFunctionWithQualifier(ctx context.Context, name, qualifier, clientContext, logType string, ...) ([]byte, string, string, int, error)

+ func (b *InMemoryBackend) ListAliases(name, functionVersion, marker string, maxItems int) (page.Page[*FunctionAlias], error)

+ func (b *InMemoryBackend) ListCapacityProviders() []*CapacityProvider

+ func (b *InMemoryBackend) ListCodeSigningConfigs() []*CodeSigningConfig

+ func (b *InMemoryBackend) ListEventSourceMappings(functionName, eventSourceARN, marker string, maxItems int) page.Page[*EventSourceMapping]

+ func (b *InMemoryBackend) ListFunctionEventInvokeConfigs(name, marker string, maxItems int) ([]*FunctionEventInvokeConfig, string, error)

+ func (b *InMemoryBackend) ListFunctionURLConfigs() []*FunctionURLConfig

+ func (b *InMemoryBackend) ListFunctionVersionsByCapacityProvider(name, marker string, maxItems int) (page.Page[string], error)

+ func (b *InMemoryBackend) ListFunctions(marker string, maxItems int) page.Page[*FunctionConfiguration]

+ func (b *InMemoryBackend) ListFunctionsAll(marker string, maxItems int) page.Page[*FunctionConfiguration]

+ func (b *InMemoryBackend) ListFunctionsByCodeSigningConfig(cscARN string) ([]string, error)

+ func (b *InMemoryBackend) ListLayerVersions(layerName, compatibleRuntime string) ([]*LayerVersion, error)

+ func (b *InMemoryBackend) ListLayers(compatibleRuntime, marker string, maxItems int) page.Page[*Layer]

+ func (b *InMemoryBackend) ListProvisionedConcurrencyConfigs(name string) ([]*ProvisionedConcurrencyConfig, error)

+ func (b *InMemoryBackend) ListVersionsByFunction(name, marker string, maxItems int) (page.Page[*FunctionVersion], error)

+ func (b *InMemoryBackend) PublishLayerVersion(input *PublishLayerVersionInput) (*PublishLayerVersionOutput, error)

+ func (b *InMemoryBackend) PublishVersion(name, description string) (*FunctionVersion, error)

+ func (b *InMemoryBackend) Purge(ctx context.Context, cutoff time.Time)

+ func (b *InMemoryBackend) PutFunctionCodeSigningConfig(functionName, cscARN string) error

+ func (b *InMemoryBackend) PutFunctionConcurrency(name string, reserved int) (*FunctionConcurrency, error)

+ func (b *InMemoryBackend) PutFunctionEventInvokeConfig(name string, input *PutFunctionEventInvokeConfigInput) (*FunctionEventInvokeConfig, error)

+ func (b *InMemoryBackend) PutFunctionRecursionConfig(name string, input *PutFunctionRecursionConfigInput) (*FunctionRecursionConfig, error)

+ func (b *InMemoryBackend) PutFunctionScalingConfig(name string, input *PutFunctionScalingConfigInput) (*FunctionScalingConfig, error)

+ func (b *InMemoryBackend) PutProvisionedConcurrencyConfig(name, qualifier string, requested int) (*ProvisionedConcurrencyConfig, error)

+ func (b *InMemoryBackend) PutRuntimeManagementConfig(name string, input *PutRuntimeManagementConfigInput) (*RuntimeManagementConfig, error)

+ func (b *InMemoryBackend) RemoveLayerVersionPermission(layerName string, version int64, statementID string) error

+ func (b *InMemoryBackend) RemovePermission(functionName, qualifier, statementID string) error

+ func (b *InMemoryBackend) Reset()

+ func (b *InMemoryBackend) Restore(ctx context.Context, data []byte) error

+ func (b *InMemoryBackend) SeedCapacityProviderFunctionVersions(name string, versions ...string) error

+ func (b *InMemoryBackend) SetActivationDelay(d time.Duration)

+ func (b *InMemoryBackend) SetAsyncDestinationDelivery(d AsyncDestinationDelivery)

+ func (b *InMemoryBackend) SetCWLogsBackend(cwl CWLogsBackend)

+ func (b *InMemoryBackend) SetDNSRegistrar(r DNSRegistrar)

+ func (b *InMemoryBackend) SetDynamoDBStreamsReader(r DynamoDBStreamsReader)

+ func (b *InMemoryBackend) SetKinesisPoller(p *EventSourcePoller)

+ func (b *InMemoryBackend) SetProvisionedConcurrencyDelay(d time.Duration)

+ func (b *InMemoryBackend) SetS3CodeFetcher(f S3CodeFetcher)

+ func (b *InMemoryBackend) SetSQSReader(r SQSReader)

+ func (b *InMemoryBackend) SetSigV4Secret(secret string)

+ func (b *InMemoryBackend) Snapshot(ctx context.Context) []byte

+ func (b *InMemoryBackend) StartKinesisPoller(ctx context.Context)

+ func (b *InMemoryBackend) TagResource(functionName string, tags map[string]string) error

+ func (b *InMemoryBackend) UntagResource(functionName string, tagKeys []string) error

+ func (b *InMemoryBackend) UpdateAlias(name, aliasName string, input *UpdateAliasInput) (*FunctionAlias, error)

+ func (b *InMemoryBackend) UpdateCapacityProvider(name string, input *UpdateCapacityProviderInput) (*CapacityProvider, error)

+ func (b *InMemoryBackend) UpdateCodeSigningConfig(cscARN string, input *UpdateCodeSigningConfigInput) (*CodeSigningConfig, error)

+ func (b *InMemoryBackend) UpdateEventSourceMapping(id string, input *UpdateEventSourceMappingInput) (*EventSourceMapping, error)

+ func (b *InMemoryBackend) UpdateFunction(fn *FunctionConfiguration) error

+ func (b *InMemoryBackend) UpdateFunctionEventInvokeConfig(name string, input *PutFunctionEventInvokeConfigInput) (*FunctionEventInvokeConfig, error)

+ func (b *InMemoryBackend) UpdateFunctionURLConfig(functionName, authType string, cors *FunctionURLCors) (*FunctionURLConfig, error)

+ type InvocationType = string

+ const InvocationTypeDryRun

+ const InvocationTypeEvent

+ const InvocationTypeRequestResponse

+ const LogTypeNone

+ const LogTypeTail

+ type Janitor struct

+ Backend *InMemoryBackend

+ Interval time.Duration

+ TaskTimeout time.Duration

+ func NewJanitor(backend *InMemoryBackend, _ Settings) *Janitor

+ func (j *Janitor) Run(ctx context.Context)

+ type KinesisReader interface

+ GetRecords func(iteratorToken string, limit int) ([]KinesisRecord, string, error)

+ GetShardIDs func(streamName string) ([]string, error)

+ GetShardIterator func(streamName, shardID, iteratorType, startingSeqNum string) (string, error)

+ type KinesisRecord struct

+ ArrivalTime time.Time

+ Data []byte

+ PartitionKey string

+ SequenceNumber string

+ type LastUpdateStatus string

+ const LastUpdateStatusFailed

+ const LastUpdateStatusInProgress

+ const LastUpdateStatusSuccessful

+ type Layer struct

+ LatestMatchingVersion *LayerVersion

+ LayerArn string

+ LayerName string

+ type LayerVersion struct

+ CompatibleRuntimes []string

+ Content *LayerVersionContent

+ CreatedDate string

+ Description string

+ LayerVersionArn string

+ LicenseInfo string

+ Version int64

+ ZipData []byte

+ type LayerVersionContent struct

+ CodeSha256 string

+ CodeSize int64

+ Location string

+ type LayerVersionContentInput struct

+ S3Bucket string

+ S3Key string

+ ZipFile []byte

+ type LayerVersionPolicy struct

+ Policy string

+ RevisionID string

+ type LayerVersionStatement struct

+ Action string

+ Principal string

+ StatementID string

+ type ListAliasesOutput struct

+ Aliases []*FunctionAlias

+ NextMarker string

+ type ListCapacityProvidersOutput struct

+ CapacityProviders []*CapacityProvider

+ NextMarker string

+ type ListCodeSigningConfigsOutput struct

+ CodeSigningConfigs []*CodeSigningConfig

+ NextMarker string

+ type ListFunctionEventInvokeConfigsOutput struct

+ FunctionEventInvokeConfigs []*FunctionEventInvokeConfig

+ NextMarker string

+ type ListFunctionURLConfigsOutput struct

+ FunctionURLConfigs []*FunctionURLConfig

+ type ListFunctionsByCodeSigningConfigOutput struct

+ FunctionArns []string

+ NextMarker string

+ type ListFunctionsOutput struct

+ Functions []*FunctionConfiguration

+ NextMarker string

+ type ListLayerVersionsOutput struct

+ LayerVersions []*LayerVersion

+ NextMarker string

+ type ListLayersOutput struct

+ Layers []*Layer

+ NextMarker string

+ type ListProvisionedConcurrencyConfigsOutput struct

+ NextMarker string

+ ProvisionedConcurrencyConfigs []*ProvisionedConcurrencyConfig

+ type ListVersionsByFunctionOutput struct

+ NextMarker string

+ Versions []*FunctionVersion

+ type LoggingConfig struct

+ ApplicationLogLevel string

+ LogFormat string

+ LogGroup string

+ SystemLogLevel string

+ type Provider struct

+ func (p *Provider) Init(ctx *service.AppContext) (service.Registerable, error)

+ func (p *Provider) Name() string

+ type ProvisionedConcurrencyConfig struct

+ AllocatedProvisionedConcurrentExecutions int

+ AvailableProvisionedConcurrentExecutions int

+ FunctionArn string

+ LastModified string

+ RequestedProvisionedConcurrentExecutions int

+ Status string

+ StatusReason string

+ type PublishLayerVersionInput struct

+ CompatibleRuntimes []string

+ Content *LayerVersionContentInput

+ Description string

+ LayerName string

+ LicenseInfo string

+ type PublishLayerVersionOutput struct

+ CompatibleRuntimes []string

+ Content *LayerVersionContent

+ CreatedDate string

+ Description string

+ LayerArn string

+ LayerVersionArn string

+ LicenseInfo string

+ Version int64

+ type PutFunctionCodeSigningConfigInput struct

+ CodeSigningConfigArn string

+ type PutFunctionCodeSigningConfigOutput struct

+ CodeSigningConfigArn string

+ FunctionName string

+ type PutFunctionConcurrencyInput struct

+ ReservedConcurrentExecutions int

+ type PutFunctionEventInvokeConfigInput struct

+ DestinationConfig *DestinationConfig

+ MaximumEventAgeInSeconds *int

+ MaximumRetryAttempts *int

+ type PutFunctionRecursionConfigInput struct

+ RecursiveLoop string

+ type PutFunctionScalingConfigInput struct

+ MaximumConcurrency *int

+ type PutProvisionedConcurrencyConfigInput struct

+ ProvisionedConcurrentExecutions int

+ type PutRuntimeManagementConfigInput struct

+ RuntimeVersionArn string

+ UpdateRuntimeOn string

+ type QualifierInvoker interface

+ InvokeFunctionWithQualifier func(ctx context.Context, name, qualifier, clientContext, logType string, ...) ([]byte, string, string, int, error)

+ type QualifierResolver interface

+ GetFunctionByQualifier func(name, qualifier string) (*FunctionConfiguration, error)

+ type RuntimeManagementConfig struct

+ FunctionArn string

+ RuntimeVersionArn string

+ UpdateRuntimeOn string

+ type S3CodeFetcher interface

+ GetObjectBytes func(ctx context.Context, bucket, key string) ([]byte, error)

+ type SQSMessage struct

+ Attributes map[string]string

+ Body string

+ MD5OfBody string

+ MD5OfMessageAttributes string

+ MessageAttributes map[string]SQSMessageAttribute

+ MessageID string

+ ReceiptHandle string

+ SentTimestampMillis int64

+ type SQSMessageAttribute struct

+ BinaryValue []byte

+ DataType string

+ StringValue string

+ type SQSReader interface

+ DeleteMessagesLocal func(queueARN string, receiptHandles []string) error

+ ReceiveMessagesLocal func(queueARN string, maxMessages int) ([]*SQSMessage, error)

+ type SelfManagedEventSource struct

+ Endpoints map[string][]string

+ type SelfManagedKafkaEventSourceConfig struct

+ ConsumerGroupID string

+ type Settings struct

+ ContainerRuntime string

+ DockerHost string

+ IdleTimeout time.Duration

+ KeepContainers bool

+ MaxRuntimes int

+ PoolSize int

+ func DefaultSettings() Settings

+ type SettingsProvider interface

+ GetLambdaSettings func() Settings

+ type SnapStart struct

+ ApplyOn string

+ type SnapStartResponse struct

+ ApplyOn string

+ OptimizationStatus string

+ type SourceAccessConfiguration struct

+ Type string

+ URI string

+ type StorageBackend interface

+ CreateFunction func(fn *FunctionConfiguration) error

+ DeleteFunction func(name string) error

+ GetFunction func(name string) (*FunctionConfiguration, error)

+ InvokeFunction func(ctx context.Context, name string, invocationType InvocationType, ...) ([]byte, int, error)

+ ListFunctions func(marker string, maxItems int) page.Page[*FunctionConfiguration]

+ Purge func(ctx context.Context, cutoff time.Time)

+ UpdateFunction func(fn *FunctionConfiguration) error

+ type TaggedFunctionInfo struct

+ ARN string

+ Tags map[string]string

+ type TracingConfig struct

+ Mode string

+ type UpdateAliasInput struct

+ Description string

+ FunctionVersion string

+ RoutingConfig *AliasRoutingConfig

+ type UpdateCapacityProviderInput struct

+ TargetOnDemandConcurrency int

+ type UpdateCapacityProviderOutput struct

+ CapacityProvider *CapacityProvider

+ type UpdateCodeSigningConfigInput struct

+ AllowedPublishers *AllowedPublishers

+ CodeSigningPolicies *CodeSigningPolicies

+ Description string

+ type UpdateCodeSigningConfigOutput struct

+ CodeSigningConfig *CodeSigningConfig

+ type UpdateEventSourceMappingInput struct

+ BatchSize int

+ BisectBatchOnFunctionError *bool

+ DestinationConfig *ESMDestinationConfig

+ Enabled *bool

+ FilterCriteria *FilterCriteria

+ FunctionResponseTypes []string

+ MaximumBatchingWindowInSeconds int

+ MaximumRecordAgeInSeconds int

+ MaximumRetryAttempts int

+ ParallelizationFactor int

+ Queues []string

+ SourceAccessConfigurations []SourceAccessConfiguration

+ Topics []string

+ TumblingWindowInSeconds int

+ UUID string

+ type UpdateFunctionCodeInput struct

+ Architectures []string

+ ImageURI string

+ Publish bool

+ S3Bucket string

+ S3Key string

+ ZipFile []byte

+ type UpdateFunctionConfigurationInput struct

+ DeadLetterConfig *DeadLetterConfig

+ Description string

+ Environment *EnvironmentConfig

+ EphemeralStorage *EphemeralStorageConfig

+ FileSystemConfigs []*FileSystemConfig

+ Handler string

+ Layers []string

+ MemorySize int

+ Role string

+ Runtime string

+ SnapStart *SnapStart

+ Timeout int

+ TracingConfig *TracingConfig

+ VpcConfig *VpcConfig

+ type UpdateFunctionURLConfigInput struct

+ AuthType string

+ Cors *FunctionURLCors

+ type VpcConfig struct

+ Ipv6AllowedForDualStack *bool

+ SecurityGroupIDs []string

+ SubnetIDs []string

+ VpcID string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL