Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/aws-samples/aws-lambda-extensions
/ functions
Functions
395 in github.com/aws-samples/aws-lambda-extensions
⨍
Functions
395
◇
Types & classes
170
↓ 1 callers
Method
register
(self, agent_unique_name, registration_body)
s3-logs-extension-demo-container-image/extension/extensionssrc/extensions/logs_api_http_extension/extensions_api_client.py:23
↓ 1 callers
Method
register
(self, agent_unique_name, registration_body)
python-example-elasticsearch-extension/extensions/logs_api_elasticsearch_extension/extensions_api_client.py:24
↓ 1 callers
Method
registerExtension
Registers the external extension to listen to "INVOKE" and "SHUTDOWN" @return ID of the registered extension
java-example-extension/src/main/java/example/ExtensionClient.java:34
↓ 1 callers
Function
register_extension
()
python-example-extension/python-example-extension/extension.py:31
↓ 1 callers
Function
register_extension
(extension_name)
python-example-telemetry-prometheus-extension/python-example-telemetry-prometheus-extension/extensions_api_client.py:14
↓ 1 callers
Function
register_extension
(extension_name)
python-example-telemetry-api-extension/python_example_telemetry_api_extension/extensions_api_client.py:14
↓ 1 callers
Function
register_extension
(extension_name)
python-example-telemetry-opensearch-extension/python-example-telemetry-opensearch-extension/extensions_api_client.py:14
↓ 1 callers
Method
remaining
space remaining
rust-example-lambda-runtime-api-proxy-extension/src/util/limited_buffer.rs:51
↓ 1 callers
Function
renameFilesWithSubstring
(rootDirectory string, substring string, newName string)
go-example-crash-uploader-extension/files_with_substring.go:13
↓ 1 callers
Method
retryPut
Perform exponential backoff
kinesisfirehose-logs-extension-demo/agent/kinesisfirehose.go:92
↓ 1 callers
Method
retryPut
Perform exponential backoff
kinesis-stream-logs-extension-demo/agent/kinesisstream.go:95
↓ 1 callers
Method
run_forever
(self)
python-example-logs-api-extension/extensions/logs_api_http_extension.py:52
↓ 1 callers
Method
run_forever
(self)
s3-logs-extension-demo-zip-archive/extensionssrc/extensions/logs_api_http_extension.py:64
↓ 1 callers
Method
run_forever
(self)
s3-logs-extension-demo-container-image/extension/extensionssrc/extensions/logs_api_http_extension.py:64
↓ 1 callers
Method
run_forever
(self)
python-example-elasticsearch-extension/extensions/logs_api_elasticsearch_extension.py:57
↓ 1 callers
Function
searchForFilesAndUploadAndDelete
(ctx context.Context, s3bucket string, rootDirectory string, substringToMatch string, creds credentials.Value)
go-example-crash-uploader-extension/upload.go:18
↓ 1 callers
Method
seek_to
Move the cursor to a byte offset within the buffer
rust-example-lambda-runtime-api-proxy-extension/src/util/limited_buffer.rs:136
↓ 1 callers
Function
startHTTPServer
(port string)
go-example-ipc-extension/ipc/ipc.go:36
↓ 1 callers
Function
startHTTPServer
Method that responds back with the cached values
cache-extension-demo/ipc/ipc.go:19
↓ 1 callers
Function
start_http_listener
(queue)
python-example-telemetry-prometheus-extension/python-example-telemetry-prometheus-extension/telemetry_http_listener.py:13
↓ 1 callers
Function
start_http_listener
(queue)
python-example-telemetry-api-extension/python_example_telemetry_api_extension/telemetry_http_listener.py:13
↓ 1 callers
Function
start_http_listener
(queue)
python-example-telemetry-opensearch-extension/python-example-telemetry-opensearch-extension/telemetry_http_listener.py:13
↓ 1 callers
Function
subscibe_listener
(extension_id, listener_url)
python-example-telemetry-prometheus-extension/python-example-telemetry-prometheus-extension/telemetery_api_client.py:16
↓ 1 callers
Function
subscibe_listener
(extension_id, listener_url)
python-example-telemetry-api-extension/python_example_telemetry_api_extension/telemetery_api_client.py:16
↓ 1 callers
Function
subscibe_listener
(extension_id, listener_url)
python-example-telemetry-opensearch-extension/python-example-telemetry-opensearch-extension/telemetery_api_client.py:16
↓ 1 callers
Function
subscribe
(extensionId, subscriptionBody, server)
nodejs-example-logs-api-extension/nodejs-example-logs-api-extension/logs-api.js:5
↓ 1 callers
Method
subscribe
(self, agent_id, subscription_body)
s3-logs-extension-demo-zip-archive/extensionssrc/extensions/logs_api_http_extension/logs_api_client.py:22
↓ 1 callers
Method
subscribe
(self, agent_id, subscription_body)
s3-logs-extension-demo-container-image/extension/extensionssrc/extensions/logs_api_http_extension/logs_api_client.py:22
↓ 1 callers
Method
subscribe
(self, agent_id, subscription_body)
python-example-elasticsearch-extension/extensions/logs_api_elasticsearch_extension/logs_api_client.py:23
↓ 1 callers
Function
uploadFile
(svc *s3.S3, s3bucket string, key string, filename string)
go-example-crash-uploader-extension/upload.go:59
↓ 1 callers
Function
validate_and_mangle_next_event
Process the next invocation event from the Lambda Runtime API Event context, payload is in `response` On Error, create a [`Request<Body>`] to send t
rust-example-lambda-runtime-api-proxy-extension/src/route.rs:175
↓ 1 callers
Function
writeToFileSystem
(filename string, data string)
go-example-ipc-extension/ipc/ipc.go:19
Method
Dispose
<summary> Dispose of instance Disposable variables </summary>
csharp-example-extension/ExtensionClient.cs:291
Method
ExitError
ExitError reports an error to the platform before exiting. Call it when you encounter an unexpected failure
go-example-extension/extension/client.go:173
Method
ExitError
ExitError reports an error to the platform before exiting. Call it when you encounter an unexpected failure
kinesisfirehose-logs-extension-demo/extension/client.go:173
Method
ExitError
ExitError reports an error to the platform before exiting. Call it when you encounter an unexpected failure
kinesis-stream-logs-extension-demo/extension/client.go:173
Method
ExitError
ExitError reports an error to the platform before exiting. Call it when you encounter an unexpected failure
go-example-adaptive-batching-extension/extension/client.go:173
Method
ExitError
Reports an error to the platform before exiting. Call it when you encounter an unexpected failure
go-example-telemetry-api-extension/extensionApi/client.go:187
Method
ExitError
ExitError reports an error to the platform before exiting. Call it when you encounter an unexpected failure
go-example-logs-api-extension/extension/client.go:173
Method
ExtensionClient
<summary> Constructor </summary>
csharp-example-extension/ExtensionClient.cs:102
Function
GetDynamodbCache
Fetch Dynamodb cache
cache-extension-demo/plugins/dynamodb.go:150
Method
GetNextAsync
<summary> Long poll for the next event from Extension API </summary> <returns>Awaitable tuple having event type and event details fields</returns> <re
csharp-example-extension/ExtensionClient.cs:229
Function
GetParameterCache
Fetch Parameter cache
cache-extension-demo/plugins/parameters.go:94
Function
InitCacheExtensions
Initialize cache and start the background process to refresh cache
cache-extension-demo/extension/entry.go:32
Function
InitDynamodb
Initialize map and cache data (only if requested)
cache-extension-demo/plugins/dynamodb.go:36
Method
InitError
InitError reports an initialization error to the platform. Call it when you registered but failed to initialize
go-example-extension/extension/client.go:142
Method
InitError
InitError reports an initialization error to the platform. Call it when you registered but failed to initialize
kinesisfirehose-logs-extension-demo/extension/client.go:142
Method
InitError
InitError reports an initialization error to the platform. Call it when you registered but failed to initialize
kinesis-stream-logs-extension-demo/extension/client.go:142
Method
InitError
InitError reports an initialization error to the platform. Call it when you registered but failed to initialize
go-example-adaptive-batching-extension/extension/client.go:142
Method
InitError
Reports an initialization error to the platform. Call it when you registered but failed to initialize
go-example-telemetry-api-extension/extensionApi/client.go:156
Method
InitError
InitError reports an initialization error to the platform. Call it when you registered but failed to initialize
go-example-logs-api-extension/extension/client.go:142
Function
InitParameters
Initialize map and cache objects (if requested)
cache-extension-demo/plugins/parameters.go:29
Method
Main
(string[] args)
csharp-example-extension/Program.cs:12
Function
New
Create and initialize the queue
go-example-adaptive-batching-extension/queuewrapper/queuewrapper.go:20
Function
NewClient
NewClient returns a Lambda Extensions API client
go-example-extension/extension/client.go:65
Function
NewClient
NewClient returns a new Client with the given URL
kinesisfirehose-logs-extension-demo/logsapi/client.go:25
Function
NewClient
NewClient returns a Lambda Extensions API client
kinesisfirehose-logs-extension-demo/extension/client.go:65
Function
NewClient
NewClient returns a Lambda Extensions API client
go-example-lambda-runtime-api-proxy-extension/src/extension/client.go:68
Function
NewClient
NewClient returns a new Client with the given URL
kinesis-stream-logs-extension-demo/logsapi/client.go:25
Function
NewClient
NewClient returns a Lambda Extensions API client
kinesis-stream-logs-extension-demo/extension/client.go:65
Function
NewClient
NewClient returns a Lambda Extensions API client
go-example-crash-uploader-extension/extension/client.go:65
Function
NewClient
NewClient returns a new Client with the given URL
go-example-adaptive-batching-extension/logsapi/client.go:25
Function
NewClient
NewClient returns a Lambda Extensions API client
go-example-adaptive-batching-extension/extension/client.go:65
Function
NewClient
NewClient returns a Lambda Extensions API client
go-example-ipc-extension/extension/client.go:59
Function
NewClient
()
go-example-telemetry-api-extension/telemetryApi/client.go:30
Function
NewClient
Returns a Lambda Extensions API client
go-example-telemetry-api-extension/extensionApi/client.go:70
Function
NewClient
NewClient returns a Lambda Extensions API client
cache-extension-demo/extension/client.go:59
Function
NewClient
NewClient returns a new Client with the given URL
go-example-logs-api-extension/logsapi/client.go:25
Function
NewClient
NewClient returns a Lambda Extensions API client
go-example-logs-api-extension/extension/client.go:65
Function
NewDispatcher
()
go-example-telemetry-api-extension/telemetryApi/dispatcher.go:23
Function
NewHttpAgent
NewHttpAgent returns an agent to listen and handle logs coming from Logs API for HTTP Make sure the agent is initialized by calling Init(agentId) befo
kinesisfirehose-logs-extension-demo/agent/http.go:109
Function
NewHttpAgent
NewHttpAgent returns an agent to listen and handle logs coming from Logs API for HTTP Make sure the agent is initialized by calling Init(agentId) befo
kinesis-stream-logs-extension-demo/agent/http.go:109
Function
NewHttpAgent
NewHttpAgent returns an agent to listen and handle logs coming from Logs API for HTTP Make sure the agent is initialized by calling Init(agentId) befo
go-example-adaptive-batching-extension/agent/http.go:111
Function
NewHttpAgent
NewHttpAgent returns an agent to listen and handle logs coming from Logs API for HTTP Make sure the agent is initialized by calling Init(agentId) befo
go-example-logs-api-extension/agent/http.go:108
Function
NewKinesisFirehoseLogger
NewKinesisFirehoseLogger returns an Kinesis Logger
kinesisfirehose-logs-extension-demo/agent/kinesisfirehose.go:34
Function
NewKinesisStreamLogger
NewKinesisStreamLogger returns an Kinesis Logger
kinesis-stream-logs-extension-demo/agent/kinesisstream.go:36
Function
NewMetricsMonitor
Creates a new MetricsMonitor
go-example-adaptive-batching-extension/agent/metrics.go:38
Function
NewS3Logger
NewS3Logger returns an S3 Logger
go-example-adaptive-batching-extension/agent/logger.go:44
Function
NewS3Logger
NewS3Logger returns an S3 Logger
go-example-logs-api-extension/agent/logger.go:72
Function
NewTelemetryApiListener
()
go-example-telemetry-api-extension/telemetryApi/listener.go:28
Method
RegisterExtensionAsync
<summary> Register extension with Extension API </summary> <param name="events">Event types to by notified with</param> <returns>Awaitable void</retur
csharp-example-extension/ExtensionClient.cs:184
Method
ReportErrorAsync
<summary> Report initialization or shutdown error </summary> <param name="url"><see cref="initErrorUrl"/> or <see cref="shutdownErrorUrl"/></param> <p
csharp-example-extension/ExtensionClient.cs:249
Function
RouteCache
Route request to corresponding cache handlers
cache-extension-demo/extension/entry.go:69
Method
SafeInvoke
<summary> Try to invoke <paramref name="func"/> and call <paramref name="onException"/> if <paramref name="func"/> threw an exception </summary> <para
csharp-example-extension/ExtensionClient.cs:270
Method
Shutdown
Shutdown calls the function that should be executed before the program terminates
kinesisfirehose-logs-extension-demo/agent/kinesisfirehose.go:48
Method
Shutdown
Shutdown calls the function that should be executed before the program terminates
kinesis-stream-logs-extension-demo/agent/kinesisstream.go:50
Method
Shutdown
Shutdown calls the function that should be executed before the program terminates
go-example-adaptive-batching-extension/agent/logger.go:140
Method
Shutdown
Shutdown calls the function that should be executed before the program terminates
go-example-logs-api-extension/agent/logger.go:128
Function
Start
Start begins running the sidecar
go-example-ipc-extension/ipc/ipc.go:14
Function
Start
Start begins running the sidecar
cache-extension-demo/ipc/ipc.go:14
Function
StartProxy
NewProxy returns a Lambda Extensions API client
go-example-lambda-runtime-api-proxy-extension/src/proxy/proxy.go:33
Method
__init__
(self, agent_name, registration_body, subscription_body)
python-example-logs-api-extension/extensions/logs_api_http_extension.py:38
Method
__init__
(self)
python-example-logs-api-extension/extensions/logs_api_http_extension/extensions_api_client.py:16
Method
__init__
(self)
python-example-logs-api-extension/extensions/logs_api_http_extension/logs_api_client.py:15
Method
__init__
(self, queue, *args)
python-example-logs-api-extension/extensions/logs_api_http_extension/http_listener.py:40
Method
__init__
(self, agent_name, registration_body, subscription_body)
s3-logs-extension-demo-zip-archive/extensionssrc/extensions/logs_api_http_extension.py:49
Method
__init__
(self)
s3-logs-extension-demo-zip-archive/extensionssrc/extensions/logs_api_http_extension/extensions_api_client.py:15
Method
__init__
(self)
s3-logs-extension-demo-zip-archive/extensionssrc/extensions/logs_api_http_extension/logs_api_client.py:14
Method
__init__
(self, queue, *args)
s3-logs-extension-demo-zip-archive/extensionssrc/extensions/logs_api_http_extension/http_listener.py:38
Method
__init__
(self, agent_name, registration_body, subscription_body)
s3-logs-extension-demo-container-image/extension/extensionssrc/extensions/logs_api_http_extension.py:49
← previous
next →
201–300 of 395, ranked by callers