actrs

Documentation

Index

• Constants
• func NewRuntime(store storage.Store, metricStore storage.MetricStore, cache storage.ModCacher) actor.Producer
• func NewWasmServer(addr string, cluster *cluster.Cluster, store storage.Store, ...) actor.Producer
• type RequestModule
  • func NewRequestModule(req *proto.HTTPRequest) (*RequestModule, error)
  • func (r *RequestModule) Close(ctx context.Context) error
  • func (r *RequestModule) Instantiate(ctx context.Context, runtime wazero.Runtime) error
  • func (r *RequestModule) WriteResponse(w io.Writer) (int, error)
• type Runtime
  • func (r *Runtime) Receive(c *actor.Context)
• type WasmServer
  • func (s *WasmServer) Receive(c *actor.Context)
  • func (s *WasmServer) ServeHTTP(w http.ResponseWriter, r *http.Request)

Constants

const KindRuntime = "runtime"

const KindWasmServer = "wasm_server"

Functions

func NewRuntime

func NewRuntime(store storage.Store, metricStore storage.MetricStore, cache storage.ModCacher) actor.Producer

func NewWasmServer

func NewWasmServer(addr string, cluster *cluster.Cluster, store storage.Store, metricStore storage.MetricStore, cache storage.ModCacher) actor.Producer

NewWasmServer return a new wasm server given a storage and a mod cache.

Types

type RequestModule

type RequestModule struct {
	// contains filtered or unexported fields
}

func NewRequestModule

func NewRequestModule(req *proto.HTTPRequest) (*RequestModule, error)

func (*RequestModule) Close

func (r *RequestModule) Close(ctx context.Context) error

func (*RequestModule) Instantiate

func (r *RequestModule) Instantiate(ctx context.Context, runtime wazero.Runtime) error

func (*RequestModule) WriteResponse

func (r *RequestModule) WriteResponse(w io.Writer) (int, error)

type Runtime

type Runtime struct {
	// contains filtered or unexported fields
}

Runtime is an actor that can execute compiled WASM blobs in a distributed cluster.

func (*Runtime) Receive

func (r *Runtime) Receive(c *actor.Context)

type WasmServer

type WasmServer struct {
	// contains filtered or unexported fields
}

WasmServer is an HTTP server that will proxy and route the request to the corresponding function.

func (*WasmServer) Receive

func (s *WasmServer) Receive(c *actor.Context)

func (*WasmServer) ServeHTTP

func (s *WasmServer) ServeHTTP(w http.ResponseWriter, r *http.Request)