hero.baobab.actor #

fn new(name string) Actor

fn new_client(config ClientConfig) !Client

fn new_openapi_proxy(proxy OpenAPIProxy) OpenAPIProxy

creates and OpenAPI Proxy Controller

fn new_server(cfg ServerConfig) !&Server

interface IActor {
	name string
mut:
	handle(string, string) !string
}

fn (mut actor IActor) run() !

Actor listens to the Redis queue for method invocations

struct Actor {
pub:
	name string
}

struct Client {
pub mut:
	rpc redisclient.RedisRpc // Redis RPC mechanism
}

Processor struct for managing procedure calls

fn (mut p Client) monologue(call ProcedureCall, params Params) !

Process the procedure call

fn (mut p Client) call_to_action(action Procedure, params Params) !ProcedureResponse

Process the procedure call

struct ClientConfig {
pub:
	redis_url   string // url to redis server running
	redis_queue string // name of redis queue
}

struct Context {
	veb.Context
}

struct Handler {
pub mut:
	client Client
}

struct OpenAPIProxy {
	client        Client
	specification OpenAPI
}

fn (proxy OpenAPIProxy) controller() &Controller

creates and OpenAPI Proxy Controller

struct Params {
pub:
	timeout int // Timeout in seconds
}

Parameters for processing a procedure call

struct RunParams {
pub:
	port int = 8080
}

struct Server {
	veb.Controller
}

fn (mut server Server) run(params RunParams)

struct ServerConfig {
	ClientConfig
pub:
	openapi_spec OpenAPI
}