rie

package
v0.0.0-...-4fa2157 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 2, 2026 License: Apache-2.0 Imports: 22 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GetenvWithDefault

func GetenvWithDefault(key string, defaultValue string) string

func InitHandler

func InitHandler(sandbox Sandbox, functionVersion string, timeout int64, bs interop.Bootstrap) (time.Time, time.Time)

func InvokeHandler

func InvokeHandler(w http.ResponseWriter, r *http.Request, sandbox Sandbox, bs interop.Bootstrap)

func NewSimpleBootstrap

func NewSimpleBootstrap(cmd []string, currentWorkingDir string) interop.Bootstrap

func Run

func Run()

Types

type ErrorType

type ErrorType int
const (
	ClientInvalidRequest ErrorType = iota
)

func (ErrorType) String

func (t ErrorType) String() string

type InteropServer

type InteropServer interface {
	Init(i *interop.Init, invokeTimeoutMs int64) error
	AwaitInitialized() error
	FastInvoke(w http.ResponseWriter, i *interop.Invoke, direct bool) error
	Reserve(id string, traceID, lambdaSegmentID string) (*rapidcore.ReserveResponse, error)
	Reset(reason string, timeoutMs int64) (*statejson.ResetDescription, error)
	AwaitRelease() (*statejson.InternalStateDescription, error)
	Shutdown(shutdown *interop.Shutdown) *statejson.InternalStateDescription
	InternalState() (*statejson.InternalStateDescription, error)
	CurrentToken() *interop.Token
	Restore(restore *interop.Restore) error
}

type ResponseWriterProxy

type ResponseWriterProxy struct {
	Body       []byte
	StatusCode int
}

func (*ResponseWriterProxy) Header

func (w *ResponseWriterProxy) Header() http.Header

func (*ResponseWriterProxy) IsError

func (w *ResponseWriterProxy) IsError() bool

func (*ResponseWriterProxy) Write

func (w *ResponseWriterProxy) Write(b []byte) (int, error)

func (*ResponseWriterProxy) WriteHeader

func (w *ResponseWriterProxy) WriteHeader(statusCode int)

type Sandbox

type Sandbox interface {
	Init(i *interop.Init, invokeTimeoutMs int64)
	Invoke(responseWriter http.ResponseWriter, invoke *interop.Invoke) error
}

Jump to

Keyboard shortcuts

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