MCPcopy Create free account

hub / github.com/aws-samples/aws-lambda-extensions / functions

Functions395 in github.com/aws-samples/aws-lambda-extensions

⨍ Functions 395◇ Types & classes 170
↓ 30 callersMethodString
String function
go-example-adaptive-batching-extension/agent/metrics.go:133
↓ 17 callersMethodGet
Get number of items off the queue
go-example-adaptive-batching-extension/queuewrapper/queuewrapper.go:43
↓ 10 callersMethodsend
(self, payload)
python-example-elasticsearch-extension/extensions/logs_api_elasticsearch_extension/elasticsearch_producer.py:14
↓ 9 callersMethodstart
()
nodejs-example-lambda-runtime-api-proxy-extension/nodejs-example-lambda-runtime-api-proxy-extension/runtime-api-proxy.mjs:13
↓ 7 callersMethodlen
Get the content length of the buffer
rust-example-lambda-runtime-api-proxy-extension/src/util/limited_buffer.rs:41
↓ 6 callersMethodLen
The number of elements in the queue
go-example-adaptive-batching-extension/queuewrapper/queuewrapper.go:66
↓ 6 callersMethodPut
Abstracts the put function, still puts item on queue in a thread safe manner
go-example-adaptive-batching-extension/queuewrapper/queuewrapper.go:30
↓ 6 callersFunctionprettyPrint
(v interface{})
go-example-crash-uploader-extension/main.go:100
↓ 5 callersMethodEmpty
Is the queue empty?
go-example-adaptive-batching-extension/queuewrapper/queuewrapper.go:73
↓ 4 callersMethodExitError
ExitError reports an error to the platform before exiting. Call it when you encounter an unexpected failure
go-example-crash-uploader-extension/extension/client.go:173
↓ 4 callersFunctionsandbox_runtime_api
()
rust-example-lambda-runtime-api-proxy-extension/src/env.rs:49
↓ 3 callersMethodInitError
InitError reports an initialization error to the platform. Call it when you registered but failed to initialize
go-example-crash-uploader-extension/extension/client.go:142
↓ 3 callersMethodSize
How much the queue is storing in bytes
go-example-adaptive-batching-extension/queuewrapper/queuewrapper.go:59
↓ 3 callersMethodStart
Start initiates the server in a goroutine where the logs will be sent
go-example-logs-api-extension/agent/http.go:49
↓ 3 callersFunctionasync_invoke
(f: F)
rust-example-lambda-runtime-api-proxy-extension/src/util/limited_buffer.rs:225
↓ 3 callersFunctionhandleShutdown
(event)
nodejs-example-extension/nodejs-example-extension/index.js:9
↓ 3 callersFunctionhandleShutdown
(event)
nodejs-example-logs-api-extension/nodejs-example-logs-api-extension/index.js:27
↓ 3 callersFunctionhandleShutdown
(event)
nodejs-example-telemetry-api-extension/nodejs-example-telemetry-api-extension/index.js:70
↓ 3 callersFunctionlatch_runtime_env
()
rust-example-lambda-runtime-api-proxy-extension/src/env.rs:22
↓ 3 callersFunctionproxyPost
(w http.ResponseWriter, headers http.Header, url string, body io.ReadCloser)
go-example-lambda-runtime-api-proxy-extension/src/proxy/proxy.go:127
↓ 3 callersFunctionreadBody
(bodyBuffer io.ReadCloser)
go-example-lambda-runtime-api-proxy-extension/src/proxy/proxy.go:161
↓ 3 callersFunctionretrieveEnvironmentVariable
Helper function Given an environment variable, read it in and set the proper value Returns the value received, value will never exceed the maximum val
go-example-adaptive-batching-extension/agent/metrics.go:99
↓ 3 callersFunctionsend_request
Send a request through a {hyper::Client}
rust-example-lambda-runtime-api-proxy-extension/src/sandbox.rs:44
↓ 3 callersMethodwriteLogs
Send logs to kinesis firehose
kinesisfirehose-logs-extension-demo/agent/kinesisfirehose.go:60
↓ 3 callersMethodwriteLogs
Send logs to kinesis stream
kinesis-stream-logs-extension-demo/agent/kinesisstream.go:62
↓ 2 callersMethodDispatch
(ctx context.Context, logEventsQueue *queue.Queue, force bool)
go-example-telemetry-api-extension/telemetryApi/dispatcher.go:42
↓ 2 callersMethodFlushLog
FlushLog writes the log buffer to S3 in a file
go-example-adaptive-batching-extension/agent/logger.go:105
↓ 2 callersFunctionGetAttributeValue
Supports attributeValue with data types "S" and "N"
cache-extension-demo/plugins/dynamodb.go:140
↓ 2 callersFunctionGetCacheExpiry
Return cache expiry timestamp based on "time.Now() + CACHE_EXTENSION_TTL"
cache-extension-demo/plugins/utils.go:33
↓ 2 callersFunctionGetData
Read data from Dynamodb
cache-extension-demo/plugins/dynamodb.go:51
↓ 2 callersFunctionGetKey
Generate key to store in map based with a format "tableName+"-"+hashKeyValue+"-"+sortKeyValue"
cache-extension-demo/plugins/dynamodb.go:113
↓ 2 callersFunctionGetParameter
Initialize parameter cache
cache-extension-demo/plugins/parameters.go:51
↓ 2 callersFunctionGetSsmClient
Get SSM Client and cache it based on region
cache-extension-demo/plugins/parameters.go:76
↓ 2 callersFunctionIsExpired
Check whether cache has expired
cache-extension-demo/plugins/utils.go:28
↓ 2 callersFunctionPrettyPrint
Method for pretty printing objects in logs
cache-extension-demo/plugins/utils.go:49
↓ 2 callersMethodReset
Reset the monitor. Zero out all the counters, set time to current time
go-example-adaptive-batching-extension/agent/metrics.go:90
↓ 2 callersMethodShutdown
Shutdown finalizes the logging and terminates the listener
kinesisfirehose-logs-extension-demo/agent/http.go:160
↓ 2 callersMethodShutdown
Shutdown finalizes the logging and terminates the listener
kinesis-stream-logs-extension-demo/agent/http.go:160
↓ 2 callersMethodShutdown
Shutdown finalizes the logging and terminates the listener
go-example-adaptive-batching-extension/agent/http.go:213
↓ 2 callersMethodShutdown
Shutdown finalizes the logging and terminates the listener
go-example-logs-api-extension/agent/http.go:161
↓ 2 callersFunctioncopyHeaders
(original http.Header, target http.Header)
go-example-lambda-runtime-api-proxy-extension/src/proxy/proxy.go:146
↓ 2 callersFunctiondispatch_telmetery
(queue, force)
python-example-telemetry-prometheus-extension/python-example-telemetry-prometheus-extension/telemetry_dispatcher.py:95
↓ 2 callersFunctiondispatch_telmetery
(queue, force)
python-example-telemetry-api-extension/python_example_telemetry_api_extension/telemetry_dispatcher.py:8
↓ 2 callersFunctiondispatch_telmetery
(queue, force)
python-example-telemetry-opensearch-extension/python-example-telemetry-opensearch-extension/telemetry_dispatcher.py:66
↓ 2 callersFunctionfinalizeResponse
(w http.ResponseWriter, body []byte, headers http.Header)
go-example-lambda-runtime-api-proxy-extension/src/proxy/proxy.go:152
↓ 2 callersFunctiongenerateFileName
Create a unique file name Format: {function-name}-{timestamp}-{uuid}
go-example-adaptive-batching-extension/agent/logger.go:176
↓ 2 callersFunctiongetFilesWithSubstring
(rootDirectory string, substring string)
go-example-crash-uploader-extension/files_with_substring.go:36
↓ 2 callersFunctionlistenerPort
()
kinesisfirehose-logs-extension-demo/agent/http.go:169
↓ 2 callersFunctionlistenerPort
()
kinesis-stream-logs-extension-demo/agent/http.go:169
↓ 2 callersFunctionmake_uri
(path: &str)
rust-example-lambda-runtime-api-proxy-extension/src/sandbox.rs:94
↓ 2 callersFunctionnext
(extensionId)
nodejs-example-logs-api-extension/nodejs-example-logs-api-extension/extensions-api.js:30
↓ 2 callersMethodnext
()
nodejs-example-lambda-runtime-api-proxy-extension/nodejs-example-lambda-runtime-api-proxy-extension/extensions-api-client.mjs:42
↓ 2 callersFunctionprettyPrint
(v interface{})
go-example-extension/main.go:70
↓ 2 callersFunctionprettyPrint
(v interface{})
go-example-ipc-extension/main.go:79
↓ 2 callersMethodregister
()
nodejs-example-lambda-runtime-api-proxy-extension/nodejs-example-lambda-runtime-api-proxy-extension/extensions-api-client.mjs:21
↓ 2 callersFunctionrequest
(verb string, url string, body io.Reader, headers http.Header)
go-example-lambda-runtime-api-proxy-extension/src/proxy/proxy.go:181
↓ 2 callersMethodreset
ResetLogger resets the log buffer and generates a new file name
go-example-adaptive-batching-extension/agent/logger.go:92
↓ 2 callersMethodsubscribe
(self, agent_id, subscription_body)
python-example-logs-api-extension/extensions/logs_api_http_extension/logs_api_client.py:23
↓ 2 callersFunctionunmarshalBody
(body []byte)
go-example-lambda-runtime-api-proxy-extension/src/proxy/proxy.go:171
↓ 2 callersFunctionuploadLogs
()
nodejs-example-logs-api-extension/nodejs-example-logs-api-extension/index.js:86
↓ 2 callersMethoduploadPart
(buffer []byte)
go-example-logs-api-extension/agent/logger.go:210
↓ 1 callersMethodAbortMultipartUpload
AbortMultipartUpload terminates the multi part upload process and discard any parts uploaded to S3 so far. This function is to be called whenever comp
go-example-logs-api-extension/agent/logger.go:276
↓ 1 callersMethodCountInvoke
Count a new invoke
go-example-adaptive-batching-extension/agent/metrics.go:62
↓ 1 callersFunctionGetDynamoDbClient
Get Dynamodb to read data
cache-extension-demo/plugins/dynamodb.go:122
↓ 1 callersMethodInit
Init initializes the configuration for the Logs API and subscribes to the Logs API for HTTP
kinesisfirehose-logs-extension-demo/agent/http.go:123
↓ 1 callersMethodInit
Init initializes the configuration for the Logs API and subscribes to the Logs API for HTTP
kinesis-stream-logs-extension-demo/agent/http.go:123
↓ 1 callersMethodInit
Init initializes the configuration for the Logs API and subscribes to the Logs API for HTTP
go-example-adaptive-batching-extension/agent/http.go:125
↓ 1 callersMethodInit
Init initializes the configuration for the Logs API and subscribes to the Logs API for HTTP
go-example-logs-api-extension/agent/http.go:122
↓ 1 callersFunctionInitCache
Initialize individual cache
cache-extension-demo/extension/entry.go:48
↓ 1 callersFunctionListenOnAddress
()
kinesisfirehose-logs-extension-demo/agent/http.go:39
↓ 1 callersFunctionListenOnAddress
()
kinesis-stream-logs-extension-demo/agent/http.go:39
↓ 1 callersFunctionListenOnAddress
()
go-example-adaptive-batching-extension/agent/http.go:42
↓ 1 callersFunctionListenOnAddress
()
go-example-logs-api-extension/agent/http.go:39
↓ 1 callersFunctionLoadConfigFile
Load the config file
cache-extension-demo/extension/entry.go:81
↓ 1 callersFunctionNewLogsApiHttpListener
NewLogsApiHttpListener returns a LogsApiHttpListener with the given log queue
kinesisfirehose-logs-extension-demo/agent/http.go:31
↓ 1 callersFunctionNewLogsApiHttpListener
NewLogsApiHttpListener returns a LogsApiHttpListener with the given log queue
kinesis-stream-logs-extension-demo/agent/http.go:31
↓ 1 callersFunctionNewLogsApiHttpListener
NewLogsApiHttpListener returns a LogsApiHttpListener with the given log queue
go-example-adaptive-batching-extension/agent/http.go:34
↓ 1 callersFunctionNewLogsApiHttpListener
NewLogsApiHttpListener returns a LogsApiHttpListener with the given log queue
go-example-logs-api-extension/agent/http.go:31
↓ 1 callersFunctionNewMultiPartsData
NewMultiPartsData returns a new MultiPartsData
go-example-logs-api-extension/agent/logger.go:53
↓ 1 callersMethodNextEvent
NextEvent blocks while long polling for the next lambda invoke or shutdown
go-example-extension/extension/client.go:112
↓ 1 callersMethodNextEvent
NextEvent blocks while long polling for the next lambda invoke or shutdown
kinesisfirehose-logs-extension-demo/extension/client.go:112
↓ 1 callersMethodNextEvent
NextEvent blocks while long polling for the next lambda invoke or shutdown
go-example-lambda-runtime-api-proxy-extension/src/extension/client.go:125
↓ 1 callersMethodNextEvent
NextEvent blocks while long polling for the next lambda invoke or shutdown
kinesis-stream-logs-extension-demo/extension/client.go:112
↓ 1 callersMethodNextEvent
NextEvent blocks while long polling for the next lambda invoke or shutdown
go-example-crash-uploader-extension/extension/client.go:112
↓ 1 callersMethodNextEvent
NextEvent blocks while long polling for the next lambda invoke or shutdown
go-example-adaptive-batching-extension/extension/client.go:112
↓ 1 callersMethodNextEvent
NextEvent blocks while long polling for the next lambda invoke or shutdown
go-example-ipc-extension/extension/client.go:105
↓ 1 callersMethodNextEvent
Blocks while long polling for the next Lambda invoke or shutdown
go-example-telemetry-api-extension/extensionApi/client.go:126
↓ 1 callersMethodNextEvent
NextEvent blocks while long polling for the next lambda invoke or shutdown
cache-extension-demo/extension/client.go:105
↓ 1 callersMethodNextEvent
NextEvent blocks while long polling for the next lambda invoke or shutdown
go-example-logs-api-extension/extension/client.go:112
↓ 1 callersMethodProcessEvents
<summary> Extension registration and event loop handling </summary> <param name="onInit">Optional lambda extension that is invoked when extension has
csharp-example-extension/ExtensionClient.cs:138
↓ 1 callersMethodPushLog
PushLog converts to byte array and pushes it to kinesis firehose
kinesisfirehose-logs-extension-demo/agent/kinesisfirehose.go:42
↓ 1 callersMethodPushLog
PushLog converts to byte array and pushes it to kinesis stream
kinesis-stream-logs-extension-demo/agent/kinesisstream.go:44
↓ 1 callersMethodPushLog
PushLog writes the received logs to a buffer and takes actions depending on the current state of the logger.
go-example-logs-api-extension/agent/logger.go:97
↓ 1 callersMethodRegister
Register will register the extension with the Extensions API
go-example-extension/extension/client.go:74
↓ 1 callersMethodRegister
Register will register the extension with the Extensions API
kinesisfirehose-logs-extension-demo/extension/client.go:74
↓ 1 callersMethodRegister
Register will register the extension with the Extensions API
go-example-lambda-runtime-api-proxy-extension/src/extension/client.go:78
↓ 1 callersMethodRegister
Register will register the extension with the Extensions API
kinesis-stream-logs-extension-demo/extension/client.go:74
↓ 1 callersMethodRegister
Register will register the extension with the Extensions API
go-example-crash-uploader-extension/extension/client.go:74
↓ 1 callersMethodRegister
Register will register the extension with the Extensions API
go-example-adaptive-batching-extension/extension/client.go:74
↓ 1 callersMethodRegister
Register will register the extension with the Extensions API
go-example-ipc-extension/extension/client.go:68
next →1–100 of 395, ranked by callers