actrs

Documentation

Index

• Constants
• func NewMetric() actor.Receiver
• func NewRuntime(store storage.Store, cache storage.ModCacher) actor.Producer
• func NewRuntimeLog() actor.Receiver
• func NewRuntimeManager(c *cluster.Cluster) actor.Producer
• func NewWasmServer(addr string, cluster *cluster.Cluster, store storage.Store, ...) actor.Producer
• type Metric
  • func (m *Metric) Receive(c *actor.Context)
• type Runtime
  • func (r *Runtime) Receive(c *actor.Context)
• type RuntimeLog
  • func (rl *RuntimeLog) Receive(c *actor.Context)
• type RuntimeManager
  • func (rm *RuntimeManager) 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 KindMetric = "runtime_metric"

const KindRuntime = "runtime"

const KindRuntimeLog = "runtime_log"

const KindRuntimeManager = "runtime_manager"

const KindWasmServer = "wasm_server"

Functions

func NewMetric

func NewMetric() actor.Receiver

func NewRuntime

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

func NewRuntimeLog

func NewRuntimeLog() actor.Receiver

func NewRuntimeManager

func NewRuntimeManager(c *cluster.Cluster) 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 Metric

type Metric struct{}

func (*Metric) Receive

func (m *Metric) Receive(c *actor.Context)

TODO: Store metrics where they belong

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 RuntimeLog

type RuntimeLog struct{}

func (*RuntimeLog) Receive

func (rl *RuntimeLog) Receive(c *actor.Context)

type RuntimeManager

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

RuntimeManager is an actor/receiver that is responsible for managing runtimes across the cluster.

func (*RuntimeManager) Receive

func (rm *RuntimeManager) 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)

TODO(anthdm): Handle the favicon.ico