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
↓ 1 callersMethodRegister
Registers the extension with Extensions API
go-example-telemetry-api-extension/extensionApi/client.go:79
↓ 1 callersMethodRegister
Register will register the extension with the Extensions API
cache-extension-demo/extension/client.go:68
↓ 1 callersMethodRegister
Register will register the extension with the Extensions API
go-example-logs-api-extension/extension/client.go:74
↓ 1 callersMethodShouldShip
Returns whether logs should be shipped or not based on the rates
go-example-adaptive-batching-extension/agent/metrics.go:67
↓ 1 callersMethodShutdown
Shutdown terminates the HTTP server listening for logs
kinesisfirehose-logs-extension-demo/agent/http.go:89
↓ 1 callersMethodShutdown
Shutdown terminates the HTTP server listening for logs
kinesis-stream-logs-extension-demo/agent/http.go:89
↓ 1 callersMethodShutdown
Shutdown terminates the HTTP server listening for logs
go-example-adaptive-batching-extension/agent/http.go:91
↓ 1 callersMethodShutdown
Terminates the HTTP server listening for logs
go-example-telemetry-api-extension/telemetryApi/listener.go:91
↓ 1 callersMethodShutdown
Shutdown terminates the HTTP server listening for logs
go-example-logs-api-extension/agent/http.go:88
↓ 1 callersMethodStart
Start initiates the server in a goroutine where the logs will be sent
kinesisfirehose-logs-extension-demo/agent/http.go:50
↓ 1 callersMethodStart
Start initiates the server in a goroutine where the logs will be sent
kinesis-stream-logs-extension-demo/agent/http.go:50
↓ 1 callersMethodStart
Start initiates the server in a goroutine where the logs will be sent
go-example-adaptive-batching-extension/agent/http.go:52
↓ 1 callersMethodStart
Starts the server in a goroutine where the log events will be sent
go-example-telemetry-api-extension/telemetryApi/listener.go:48
↓ 1 callersMethodSubscribe
Subscribe calls the Logs API to subscribe for the log events.
kinesisfirehose-logs-extension-demo/logsapi/client.go:117
↓ 1 callersMethodSubscribe
Subscribe calls the Logs API to subscribe for the log events.
kinesis-stream-logs-extension-demo/logsapi/client.go:117
↓ 1 callersMethodSubscribe
Subscribe calls the Logs API to subscribe for the log events.
go-example-adaptive-batching-extension/logsapi/client.go:102
↓ 1 callersMethodSubscribe
Subscribes to the Telemetry API to start receiving the log events
go-example-telemetry-api-extension/telemetryApi/client.go:117
↓ 1 callersMethodSubscribe
Subscribe calls the Logs API to subscribe for the log events.
go-example-logs-api-extension/logsapi/client.go:117
↓ 1 callersFunctionUpdateAttributeMap
Create attributeValue based on key type and presence of sortKey definition
cache-extension-demo/plugins/dynamodb.go:132
↓ 1 callersMethodWriteLog
PushLog writes the received logs to a buffer
go-example-adaptive-batching-extension/agent/logger.go:100
↓ 1 callersFunctionapp_start
()
rust-example-lambda-runtime-api-proxy-extension/src/stats.rs:21
↓ 1 callersMethodbootstrap
()
nodejs-example-lambda-runtime-api-proxy-extension/nodejs-example-lambda-runtime-api-proxy-extension/extensions-api-client.mjs:15
↓ 1 callersMethodcompleteMultipartUpload
()
go-example-logs-api-extension/agent/logger.go:241
↓ 1 callersFunctioncreateBucket
createBucket creates an S3 bucket to write the received logs from Logs API. If bucket creation is not successful or the bucket is not owned by the sam
go-example-adaptive-batching-extension/agent/logger.go:146
↓ 1 callersMethodcreateBucket
createBucket creates an S3 bucket to write the received logs from Logs API. If bucket creation is not successful or the bucket is not owned by the sam
go-example-logs-api-extension/agent/logger.go:134
↓ 1 callersMethodcreateMultiPartUpload
createMultiPartUpload initiates multipart upload process to S3 After the multipart upload is initiated, parts can start to be uploaded.
go-example-logs-api-extension/agent/logger.go:160
↓ 1 callersFunctioncreateS3Client
(creds credentials.Value)
go-example-crash-uploader-extension/use-aws-sdk.go:16
↓ 1 callersFunctiondispatch_to_opensearch
(batch)
python-example-telemetry-opensearch-extension/python-example-telemetry-opensearch-extension/telemetry_dispatcher.py:54
↓ 1 callersFunctiondispatch_to_prometheus
(batch)
python-example-telemetry-prometheus-extension/python-example-telemetry-prometheus-extension/telemetry_dispatcher.py:64
↓ 1 callersFunctionerror
(extensionId, phase, err)
nodejs-example-extension/nodejs-example-extension/extensions-api.js:45
↓ 1 callersFunctionevent_start
()
rust-example-lambda-runtime-api-proxy-extension/src/stats.rs:52
↓ 1 callersFunctionexecute_custom_processing
(event)
python-example-extension/python-example-extension/extension.py:19
↓ 1 callersFunctionextension_id
()
rust-example-lambda-runtime-api-proxy-extension/src/sandbox.rs:88
↓ 1 callersMethodfinalizeLogsAndCreateS3File
finalizeLogsAndCreateS3File finalizes uploading process or aborts if completion fails. If completion fails, uploading will be cancelled. Any part that
go-example-logs-api-extension/agent/logger.go:256
↓ 1 callersFunctionfinalize_telemetry
()
python-example-telemetry-prometheus-extension/python-example-telemetry-prometheus-extension/telemetry_dispatcher.py:90
↓ 1 callersFunctionfind_extension_name
()
rust-example-lambda-runtime-api-proxy-extension/src/sandbox.rs:84
↓ 1 callersFunctiongetConfiguration
(application, environment, configuration)
awsappconfig-extension-demo/src/AppConfigExtensionDemoFunction.js:11
↓ 1 callersFunctiongetListenerPort
()
go-example-lambda-runtime-api-proxy-extension/src/main.go:60
↓ 1 callersMethodgetNext
Get next event as we have registered for INVOKE event @param extensionId ID of the extension received as response from registration event @return eve
java-example-extension/src/main/java/example/ExtensionClient.java:63
↓ 1 callersFunctiongetRuntimeApiEndpoint
()
go-example-lambda-runtime-api-proxy-extension/src/main.go:69
↓ 1 callersFunctionget_listener_address
()
python-example-logs-api-extension/extensions/logs_api_http_extension/http_listener.py:17
↓ 1 callersFunctionget_listener_address
()
s3-logs-extension-demo-zip-archive/extensionssrc/extensions/logs_api_http_extension/http_listener.py:16
↓ 1 callersFunctionget_listener_address
()
python-example-elasticsearch-extension/extensions/logs_api_elasticsearch_extension/http_listener.py:17
↓ 1 callersFunctionget_next
Get next event from the Lambda Extensions API
rust-example-lambda-runtime-api-proxy-extension/src/sandbox.rs:138
↓ 1 callersFunctionget_next_event
()
rust-example-lambda-runtime-api-proxy-extension/src/stats.rs:26
↓ 1 callersFunctionhandleInvoke
(event)
nodejs-example-extension/nodejs-example-extension/index.js:14
↓ 1 callersFunctionhandleInvoke
(r *extensionApi.NextEventResponse)
go-example-telemetry-api-extension/main.go:108
↓ 1 callersFunctionhandleInvoke
(event)
nodejs-example-logs-api-extension/nodejs-example-logs-api-extension/index.js:32
↓ 1 callersFunctionhandleInvoke
(event)
nodejs-example-telemetry-api-extension/nodejs-example-telemetry-api-extension/index.js:75
↓ 1 callersMethodhandleInvoke
Process payload @param payload event payload
java-example-extension/src/main/java/example/ExtensionMain.java:60
↓ 1 callersMethodhandleShutDown
Shutdown extension if we receive a shutdown event from lambda container
java-example-extension/src/main/java/example/ExtensionMain.java:50
↓ 1 callersFunctionhandleShutdown
(r *extensionApi.NextEventResponse)
go-example-telemetry-api-extension/main.go:112
↓ 1 callersFunctionhttpPutWithHeaders
(client *http.Client, url string, data []byte, headers *map[string]string)
kinesisfirehose-logs-extension-demo/logsapi/client.go:155
↓ 1 callersFunctionhttpPutWithHeaders
(client *http.Client, url string, data []byte, headers *map[string]string)
kinesis-stream-logs-extension-demo/logsapi/client.go:155
↓ 1 callersFunctionhttpPutWithHeaders
(client *http.Client, url string, data []byte, headers *map[string]string)
go-example-adaptive-batching-extension/logsapi/client.go:139
↓ 1 callersFunctionhttpPutWithHeaders
(ctx context.Context, client *http.Client, url string, data []byte, headers *map[string]string)
go-example-telemetry-api-extension/telemetryApi/client.go:178
↓ 1 callersFunctionhttpPutWithHeaders
(client *http.Client, url string, data []byte, headers *map[string]string)
go-example-logs-api-extension/logsapi/client.go:155
↓ 1 callersFunctionhttp_server_init
(queue)
python-example-logs-api-extension/extensions/logs_api_http_extension/http_listener.py:20
↓ 1 callersFunctionhttp_server_init
(queue)
s3-logs-extension-demo-zip-archive/extensionssrc/extensions/logs_api_http_extension/http_listener.py:19
↓ 1 callersFunctionhttp_server_init
(queue)
s3-logs-extension-demo-container-image/extension/extensionssrc/extensions/logs_api_http_extension/http_listener.py:14
↓ 1 callersFunctionhttp_server_init
(queue)
python-example-elasticsearch-extension/extensions/logs_api_elasticsearch_extension/http_listener.py:20
↓ 1 callersFunctioninit_opensearch
()
python-example-telemetry-opensearch-extension/python-example-telemetry-opensearch-extension/telemetry_dispatcher.py:31
↓ 1 callersFunctioninit_start
()
rust-example-lambda-runtime-api-proxy-extension/src/stats.rs:18
↓ 1 callersFunctionlisten
(address, port)
nodejs-example-logs-api-extension/nodejs-example-logs-api-extension/http-listener.js:3
↓ 1 callersFunctionlistenOnAddress
()
go-example-telemetry-api-extension/telemetryApi/listener.go:35
↓ 1 callersFunctionlrap_api
Gets the new LRAP_API.
rust-example-lambda-runtime-api-proxy-extension/src/env.rs:63
↓ 1 callersFunctionmain
()
python-example-logs-api-extension/extensions/logs_api_http_extension.py:92
↓ 1 callersFunctionmain
()
s3-logs-extension-demo-zip-archive/extensionssrc/extensions/logs_api_http_extension.py:127
↓ 1 callersFunctionmain
()
s3-logs-extension-demo-container-image/extension/extensionssrc/extensions/logs_api_http_extension.py:127
↓ 1 callersFunctionmain
()
python-example-extension/python-example-extension/extension.py:72
↓ 1 callersFunctionmain
()
python-example-telemetry-prometheus-extension/python-example-telemetry-prometheus-extension/extension.py:15
↓ 1 callersFunctionmain
()
python-example-telemetry-api-extension/python_example_telemetry_api_extension/extension.py:14
↓ 1 callersFunctionmain
()
python-example-elasticsearch-extension/extensions/logs_api_elasticsearch_extension.py:97
↓ 1 callersFunctionmain
()
python-example-telemetry-opensearch-extension/python-example-telemetry-opensearch-extension/extension.py:15
↓ 1 callersFunctionmake_route
()
rust-example-lambda-runtime-api-proxy-extension/src/route.rs:18
↓ 1 callersFunctionnext
(extension_id)
python-example-telemetry-prometheus-extension/python-example-telemetry-prometheus-extension/extensions_api_client.py:50
↓ 1 callersFunctionnext
(headers: &HeaderMap, path: &str)
rust-example-lambda-runtime-api-proxy-extension/src/sandbox.rs:15
↓ 1 callersFunctionnext
(extensionId)
nodejs-example-extension/nodejs-example-extension/extensions-api.js:28
↓ 1 callersFunctionnext
(extension_id)
python-example-telemetry-api-extension/python_example_telemetry_api_extension/extensions_api_client.py:50
↓ 1 callersFunctionnext
(extension_id)
python-example-telemetry-opensearch-extension/python-example-telemetry-opensearch-extension/extensions_api_client.py:50
↓ 1 callersMethodnext
(self, agent_id)
python-example-logs-api-extension/extensions/logs_api_http_extension/extensions_api_client.py:47
↓ 1 callersMethodnext
(self, agent_id)
s3-logs-extension-demo-zip-archive/extensionssrc/extensions/logs_api_http_extension/extensions_api_client.py:47
↓ 1 callersMethodnext
(self, agent_id)
s3-logs-extension-demo-container-image/extension/extensionssrc/extensions/logs_api_http_extension/extensions_api_client.py:47
↓ 1 callersMethodnext
(self, agent_id)
python-example-elasticsearch-extension/extensions/logs_api_elasticsearch_extension/extensions_api_client.py:47
↓ 1 callersFunctionpassthru_proxy
(req: Request<Body>)
rust-example-lambda-runtime-api-proxy-extension/src/route.rs:42
↓ 1 callersFunctionprocessEvents
(ctx context.Context)
go-example-extension/main.go:46
↓ 1 callersFunctionprocessEvents
(ctx context.Context)
go-example-crash-uploader-extension/main.go:66
↓ 1 callersFunctionprocessEvents
(ctx context.Context)
go-example-ipc-extension/main.go:54
↓ 1 callersFunctionprocessEvents
Method to process events
cache-extension-demo/main.go:49
↓ 1 callersFunctionprocessRequest
Assumes body is a JSON object. Expand as needed
go-example-lambda-runtime-api-proxy-extension/src/proxy/proxy.go:209
↓ 1 callersFunctionprocessResponse
Assumes body is a JSON object. Expand as needed
go-example-lambda-runtime-api-proxy-extension/src/proxy/proxy.go:227
↓ 1 callersFunctionprocess_events
(ext_id)
python-example-extension/python-example-extension/extension.py:53
↓ 1 callersMethodputLogParts
putLogParts uploads a MAX_PART_SIZE sized part if the logBuffer's size is at least MAX_PART_SIZE.
go-example-logs-api-extension/agent/logger.go:176
↓ 1 callersMethodputLogPartsComplete
putLogPartsComplete uploads all the remaining buffer in a single part and completes the multipart upload process.
go-example-logs-api-extension/agent/logger.go:193
↓ 1 callersFunctionreceiverAddress
()
nodejs-example-logs-api-extension/nodejs-example-logs-api-extension/index.js:39
↓ 1 callersFunctionregister
Register the extension with the Lambda Extensions API
rust-example-lambda-runtime-api-proxy-extension/src/sandbox.rs:104
↓ 1 callersFunctionregister
()
nodejs-example-extension/nodejs-example-extension/extensions-api.js:6
↓ 1 callersFunctionregister
()
nodejs-example-logs-api-extension/nodejs-example-logs-api-extension/extensions-api.js:6
↓ 1 callersMethodregister
(self, agent_unique_name, registration_body)
python-example-logs-api-extension/extensions/logs_api_http_extension/extensions_api_client.py:24
↓ 1 callersMethodregister
(self, agent_unique_name, registration_body)
s3-logs-extension-demo-zip-archive/extensionssrc/extensions/logs_api_http_extension/extensions_api_client.py:23
← previousnext →101–200 of 395, ranked by callers