Skip to content

baobab.actor #

fn new_client #

fn new_client(config ClientConfig) !Client

struct Client #

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

Processor struct for managing procedure calls

fn (Client) monologue #

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

Process the procedure call

fn (Client) call_to_action #

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

Process the procedure call

struct ClientConfig #

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

struct Params #

@[params]
struct Params {
pub:
	timeout int = 60 // Timeout in seconds
}

Parameters for processing a procedure call