Documentation
¶
Index ¶
- Constants
- func NewAgentExitErrorHandler(registrationService core.RegistrationService) http.Handler
- func NewAgentInitErrorHandler(registrationService core.RegistrationService) http.Handler
- func NewAgentNextHandler(registrationService core.RegistrationService, ...) http.Handler
- func NewAgentRegisterHandler(registrationService core.RegistrationService) http.Handler
- func NewCredentialsHandler(credentialsService core.CredentialsService) http.Handler
- func NewInitErrorHandler(registrationService core.RegistrationService) http.Handler
- func NewInvocationErrorHandler(registrationService core.RegistrationService) http.Handler
- func NewInvocationNextHandler(registrationService core.RegistrationService, ...) http.Handler
- func NewInvocationResponseHandler(registrationService core.RegistrationService) http.Handler
- func NewPingHandler() http.Handler
- func NewRestoreErrorHandler(registrationService core.RegistrationService) http.Handler
- func NewRestoreNextHandler(registrationService core.RegistrationService, ...) http.Handler
- func NewRuntimeLogsAPIStubHandler() http.Handler
- func NewRuntimeTelemetryAPIStubHandler() http.Handler
- func NewRuntimeTelemetrySubscriptionHandler(registrationService core.RegistrationService, ...) http.Handler
- type CtxKey
- type ErrAgentIdentifierUnknown
- type RegisterRequest
Constants ¶
const ( // LambdaAgentIdentifier is the header key for passing agent's id LambdaAgentIdentifier string = "Lambda-Extension-Identifier" LambdaAgentFunctionErrorType string = "Lambda-Extension-Function-Error-Type" // LambdaAgentName is agent name, provided by user (internal agents) or equal to executable basename (external agents) LambdaAgentName string = "Lambda-Extension-Name" ErrAgentIdentifierMissing string = "Extension.MissingExtensionIdentifier" ErrAgentIdentifierInvalid string = "Extension.InvalidExtensionIdentifier" StateTransitionFailedForExtensionMessageFormat string = "State transition from %s to %s failed for extension %s. Error: %s" StateTransitionFailedForRuntimeMessageFormat string = "State transition from %s to %s failed for runtime. Error: %s" )
const (
StreamingFunctionResponseMode = "streaming"
)
Variables ¶
This section is empty.
Functions ¶
func NewAgentExitErrorHandler ¶
func NewAgentExitErrorHandler(registrationService core.RegistrationService) http.Handler
NewAgentExitErrorHandler returns a new instance of http handler for serving /extension/exit/error
func NewAgentInitErrorHandler ¶
func NewAgentInitErrorHandler(registrationService core.RegistrationService) http.Handler
NewAgentInitErrorHandler returns a new instance of http handler for serving /extension/init/error
func NewAgentNextHandler ¶
func NewAgentNextHandler(registrationService core.RegistrationService, renderingService *rendering.EventRenderingService) http.Handler
NewAgentNextHandler returns a new instance of http handler for serving /extension/event/next
func NewAgentRegisterHandler ¶
func NewAgentRegisterHandler(registrationService core.RegistrationService) http.Handler
NewAgentRegisterHandler returns a new instance of http handler for serving /extension/register
func NewCredentialsHandler ¶
func NewCredentialsHandler(credentialsService core.CredentialsService) http.Handler
func NewInitErrorHandler ¶
func NewInitErrorHandler(registrationService core.RegistrationService) http.Handler
NewInitErrorHandler returns a new instance of http handler for serving /runtime/init/error.
func NewInvocationErrorHandler ¶
func NewInvocationErrorHandler(registrationService core.RegistrationService) http.Handler
NewInvocationErrorHandler returns a new instance of http handler for serving /runtime/invocation/{awsrequestid}/error.
func NewInvocationNextHandler ¶
func NewInvocationNextHandler(registrationService core.RegistrationService, renderingService *rendering.EventRenderingService) http.Handler
NewInvocationNextHandler returns a new instance of http handler for serving /runtime/invocation/next.
func NewInvocationResponseHandler ¶
func NewInvocationResponseHandler(registrationService core.RegistrationService) http.Handler
NewInvocationResponseHandler returns a new instance of http handler for serving /runtime/invocation/{awsrequestid}/response.
func NewPingHandler ¶
NewPingHandler returns a new instance of http handler for serving /ping.
func NewRestoreErrorHandler ¶
func NewRestoreErrorHandler(registrationService core.RegistrationService) http.Handler
func NewRestoreNextHandler ¶
func NewRestoreNextHandler(registrationService core.RegistrationService, renderingService *rendering.EventRenderingService) http.Handler
func NewRuntimeLogsAPIStubHandler ¶
NewRuntimeLogsAPIStubHandler returns a new instance of http handler for serving /runtime/logs when a telemetry service implementation is absent
func NewRuntimeTelemetryAPIStubHandler ¶
NewRuntimeTelemetryAPIStubHandler returns a new instance of http handler for serving /runtime/logs when a telemetry service implementation is absent
func NewRuntimeTelemetrySubscriptionHandler ¶
func NewRuntimeTelemetrySubscriptionHandler(registrationService core.RegistrationService, telemetrySubscription telemetry.SubscriptionAPI) http.Handler
NewRuntimeTelemetrySubscriptionHandler returns a new instance of http handler for serving /runtime/logs
Types ¶
type CtxKey ¶
type CtxKey int
A CtxKey type is used as a key for storing values in the request context.
type ErrAgentIdentifierUnknown ¶
type ErrAgentIdentifierUnknown struct {
// contains filtered or unexported fields
}
func NewErrAgentIdentifierUnknown ¶
func NewErrAgentIdentifierUnknown(agentID uuid.UUID) *ErrAgentIdentifierUnknown
func (*ErrAgentIdentifierUnknown) Error ¶
func (e *ErrAgentIdentifierUnknown) Error() string
type RegisterRequest ¶
RegisterRequest represent /extension/register JSON body
Source Files