handler

package

v0.0.0-...-4fa2157 Latest Latest Go to latest Published: Jan 2, 2026 License: Apache-2.0 Imports: 21 Imported by: 0

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 NewInitErrorHandler(registrationService core.RegistrationService) http.Handler
func NewInvocationErrorHandler(runtimeErrHandler RuntimeErrorHandler) http.Handler
func NewInvocationNextHandler(registrationService core.RegistrationService, nextHandler RuntimeNextHandler) http.Handler
func NewInvocationResponseHandler(runtimeRespHandler RuntimeResponseHandler) http.Handler
func NewPingHandler() http.Handler
func NewRuntimeLogsAPIStubHandler() http.Handler
func NewRuntimeTelemetryAPIStubHandler() http.Handler
func NewRuntimeTelemetrySubscriptionHandler(registrationService core.RegistrationService, ...) http.Handler
type ErrAgentIdentifierUnknown
- func NewErrAgentIdentifierUnknown(agentID uuid.UUID) *ErrAgentIdentifierUnknown
- func (e *ErrAgentIdentifierUnknown) Error() string
type RegisterRequest
type RuntimeErrorHandler
type RuntimeNextHandler
type RuntimeResponseHandler

Constants ¶

const (
	LambdaAgentFunctionErrorType string = "Lambda-Extension-Function-Error-Type"

	LambdaAgentName string = "Lambda-Extension-Name"

	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"
)

Variables ¶

This section is empty.

Functions ¶

func NewAgentExitErrorHandler ¶

func NewAgentExitErrorHandler(registrationService core.RegistrationService) http.Handler

func NewAgentInitErrorHandler ¶

func NewAgentInitErrorHandler(registrationService core.RegistrationService) http.Handler

func NewAgentNextHandler ¶

func NewAgentNextHandler(registrationService core.RegistrationService, renderingService *rendering.EventRenderingService) http.Handler

func NewAgentRegisterHandler ¶

func NewAgentRegisterHandler(registrationService core.RegistrationService) http.Handler

func NewInitErrorHandler ¶

func NewInitErrorHandler(registrationService core.RegistrationService) http.Handler

func NewInvocationErrorHandler ¶

func NewInvocationErrorHandler(runtimeErrHandler RuntimeErrorHandler) http.Handler

func NewInvocationNextHandler ¶

func NewInvocationNextHandler(registrationService core.RegistrationService, nextHandler RuntimeNextHandler) http.Handler

func NewInvocationResponseHandler ¶

func NewInvocationResponseHandler(runtimeRespHandler RuntimeResponseHandler) http.Handler

func NewPingHandler ¶

func NewPingHandler() http.Handler

func NewRuntimeLogsAPIStubHandler ¶

func NewRuntimeLogsAPIStubHandler() http.Handler

func NewRuntimeTelemetryAPIStubHandler ¶

func NewRuntimeTelemetryAPIStubHandler() http.Handler

func NewRuntimeTelemetrySubscriptionHandler ¶

func NewRuntimeTelemetrySubscriptionHandler(registrationService core.RegistrationService, telemetrySubscription telemetry.SubscriptionAPI) http.Handler

Types ¶

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 ¶

type RegisterRequest struct {
	Events []core.Event `json:"events"`
}

type RuntimeErrorHandler ¶

type RuntimeErrorHandler interface {
	RuntimeError(ctx context.Context, runtimeErrReq invoke.RuntimeErrorRequest) model.AppError
}

type RuntimeNextHandler ¶

type RuntimeNextHandler interface {
	RuntimeNext(ctx context.Context, runtimeReq http.ResponseWriter) (model.RuntimeNextWaiter, model.AppError)
}

type RuntimeResponseHandler ¶

type RuntimeResponseHandler interface {
	RuntimeResponse(ctx context.Context, runtimeRespReq invoke.RuntimeResponseRequest) model.AppError
}

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL