lambda

package

Go to main page

Versions in this module

v1

v1.5.0

Aug 24, 2026

Changes in this version

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

type InMemoryBackend

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

+ type QualifierDeleter interface

+ DeleteFunctionVersion func(name, qualifier string) error

v1.4.0

Aug 19, 2026

v1.3.5

Aug 19, 2026

v1.3.4

Aug 18, 2026

v1.3.3

Aug 17, 2026

v1.3.2

Aug 16, 2026

v1.3.1

Aug 16, 2026

Changes in this version

+ const CapacityProviderStateActive

+ const CapacityProviderStateDeleting

+ const CapacityProviderStateFailed

+ const CapacityProviderStatePending

type CapacityProvider

+ CapacityProviderScalingConfig *CapacityProviderScalingConfig

+ InstanceRequirements *InstanceRequirements

+ KmsKeyArn string

+ LastModified string

+ PermissionsConfig *CapacityProviderPermissionsConfig

+ PropagateTags *PropagateTags

+ State string

+ VpcConfig *CapacityProviderVpcConfig

+ type CapacityProviderPermissionsConfig struct

+ CapacityProviderOperatorRoleArn string

+ type CapacityProviderScalingConfig struct

+ MaxVCpuCount *int32

+ ScalingMode string

+ ScalingPolicies []TargetTrackingScalingPolicy

+ type CapacityProviderVpcConfig struct

+ SecurityGroupIDs []string

+ SubnetIDs []string

type CreateCapacityProviderInput

+ CapacityProviderName string

+ CapacityProviderScalingConfig *CapacityProviderScalingConfig

+ InstanceRequirements *InstanceRequirements

+ KmsKeyArn string

+ PermissionsConfig *CapacityProviderPermissionsConfig

+ PropagateTags *PropagateTags

+ Tags map[string]string

+ VpcConfig *CapacityProviderVpcConfig

+ type DeleteCapacityProviderOutput struct

+ CapacityProvider *CapacityProvider

type FunctionConfiguration

+ ImageConfigResponse *ImageConfigResponse

type FunctionVersion

+ ImageConfigResponse *ImageConfigResponse

type GetFunctionOutput

+ Tags map[string]string

+ type ImageConfigResponse struct

+ ImageConfig *ImageConfig

+ type InstanceRequirements struct

+ AllowedInstanceTypes []string

+ Architectures []string

+ ExcludedInstanceTypes []string

+ type PropagateTags struct

+ ExplicitTags map[string]string

+ Mode string

+ type TargetTrackingScalingPolicy struct

+ PredefinedMetricType string

+ TargetValue float64

type UpdateCapacityProviderInput

+ CapacityProviderScalingConfig *CapacityProviderScalingConfig

+ PropagateTags *PropagateTags

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