The monomyth Reference Manual

Table of Contents

Next: , Previous: , Up: (dir)   [Contents][Index]

The monomyth Reference Manual

This is the monomyth Reference Manual, version 0.3.1, generated automatically by Declt version 3.0 "Montgomery Scott" on Mon Apr 19 17:08:18 2021 GMT+0.


Next: , Previous: , Up: Top   [Contents][Index]

1 Introduction

Monomyth

Monomyth is a distributed data processing system built using Common Lisp and based heavily on Broadway. It is designed to split the messaging systems into two, one defined and controlled by Monomyth, and one defined and controlled by the user. The messaging controlled by the user pertains only to data, which moves between persisted data streams and node threads. The structure and manipulation of this data is largely defined by the user (though there are data stream specific aspects certain node types might handle). Monomyth itself handles all aspects of system orchestration via the Monomyth Orchestration Protocol (MMOP). The work itself is done on a group of distributed workers that use concurrent, user defined nodes to process the data and are controlled by a single master server.

Design documentation can be found at design/doc.org.

Tests

To run the tests you will need to have roswell and qlot installed, the tests have been verified on SBCL 2.0.3. Then perform the following:

source test_env.sh
docker-compose up -d
qlot install
qlot exec ./bin/test.ros

Example

The example right now is pretty arbitrary, both in set up and the computations involved. In one process start qlot exec ./bin/example-master.ros, and then in a few others run qlot exec ./bin/example-worker.ros. Once all the workers have connected to the master (you will see log entries), press the return button in the first process.

Status

This project has its basic architecture set up, but lacks most of the functionality needed for a 1.0 release.

The features likely to be targeted for a 1.0 release:


Next: , Previous: , Up: Top   [Contents][Index]

2 Systems

The main system appears first, followed by any subsystem dependency.


Previous: , Up: Systems   [Contents][Index]

2.1 monomyth

Author

Paul Ricks

License

MPL 2.0

Description

A distributed data processing library for CL

Version

0.3.1

Dependencies
Source

monomyth.asd (file)

Component

src (module)


Next: , Previous: , Up: Top   [Contents][Index]

3 Modules

Modules are listed depth-first from the system components tree.


Previous: , Up: Modules   [Contents][Index]

3.1 monomyth/src

Parent

monomyth (system)

Location

src/

Components

Next: , Previous: , Up: Top   [Contents][Index]

4 Files

Files are sorted by type and then listed depth-first from the systems components trees.


Previous: , Up: Files   [Contents][Index]

4.1 Lisp


Next: , Previous: , Up: Lisp files   [Contents][Index]

4.1.1 monomyth.asd

Location

monomyth.asd

Systems

monomyth (system)


Next: , Previous: , Up: Lisp files   [Contents][Index]

4.1.2 monomyth/src/node-recipe.lisp

Parent

src (module)

Location

src/node-recipe.lisp

Packages

monomyth/node-recipe

Exported Definitions

Next: , Previous: , Up: Lisp files   [Contents][Index]

4.1.3 monomyth/src/mmop.lisp

Parent

src (module)

Location

src/mmop.lisp

Packages

monomyth/mmop

Exported Definitions
Internal Definitions

handle-libzmq-error (macro)


Next: , Previous: , Up: Lisp files   [Contents][Index]

4.1.4 monomyth/src/mmop-worker.lisp

Parent

src (module)

Location

src/mmop-worker.lisp

Packages

monomyth/mmop-worker

Exported Definitions
Internal Definitions

Next: , Previous: , Up: Lisp files   [Contents][Index]

4.1.5 monomyth/src/mmop-master.lisp

Parent

src (module)

Location

src/mmop-master.lisp

Packages

monomyth/mmop-master

Exported Definitions
Internal Definitions

Next: , Previous: , Up: Lisp files   [Contents][Index]

4.1.6 monomyth/src/mmop-control.lisp

Parent

src (module)

Location

src/mmop-control.lisp

Packages

monomyth/mmop-control

Exported Definitions
Internal Definitions

Next: , Previous: , Up: Lisp files   [Contents][Index]

4.1.7 monomyth/src/node.lisp

Parent

src (module)

Location

src/node.lisp

Packages

monomyth/node

Exported Definitions
Internal Definitions

Next: , Previous: , Up: Lisp files   [Contents][Index]

4.1.8 monomyth/src/rmq-node.lisp

Dependency

node.lisp (file)

Parent

src (module)

Location

src/rmq-node.lisp

Packages

monomyth/rmq-node

Exported Definitions
Internal Definitions

Next: , Previous: , Up: Lisp files   [Contents][Index]

4.1.9 monomyth/src/rmq-node-recipe.lisp

Dependency

node-recipe.lisp (file)

Parent

src (module)

Location

src/rmq-node-recipe.lisp

Packages

monomyth/rmq-node-recipe

Exported Definitions

Next: , Previous: , Up: Lisp files   [Contents][Index]

4.1.10 monomyth/src/worker.lisp

Dependencies
Parent

src (module)

Location

src/worker.lisp

Packages

monomyth/worker

Exported Definitions
Internal Definitions

Next: , Previous: , Up: Lisp files   [Contents][Index]

4.1.11 monomyth/src/rmq-worker.lisp

Dependencies
Parent

src (module)

Location

src/rmq-worker.lisp

Packages

monomyth/rmq-worker

Exported Definitions

Next: , Previous: , Up: Lisp files   [Contents][Index]

4.1.12 monomyth/src/master.lisp

Parent

src (module)

Location

src/master.lisp

Packages

monomyth/master

Exported Definitions
Internal Definitions

Previous: , Up: Lisp files   [Contents][Index]

4.1.13 monomyth/src/dsl.lisp

Dependencies
Parent

src (module)

Location

src/dsl.lisp

Packages

monomyth/dsl

Exported Definitions
Internal Definitions

Next: , Previous: , Up: Top   [Contents][Index]

5 Packages

Packages are listed by definition order.


Next: , Previous: , Up: Packages   [Contents][Index]

5.1 monomyth/node-recipe

Source

node-recipe.lisp (file)

Use List
Used By List
Exported Definitions

Next: , Previous: , Up: Packages   [Contents][Index]

5.2 monomyth/mmop

Source

mmop.lisp (file)

Use List
Used By List
Exported Definitions
Internal Definitions

handle-libzmq-error (macro)


Next: , Previous: , Up: Packages   [Contents][Index]

5.3 monomyth/mmop-worker

Source

mmop-worker.lisp (file)

Nickname

mmop-w

Use List
Used By List

monomyth/worker

Exported Definitions
Internal Definitions

Next: , Previous: , Up: Packages   [Contents][Index]

5.4 monomyth/mmop-master

Source

mmop-master.lisp (file)

Nickname

mmop-m

Use List
Used By List

monomyth/master

Exported Definitions
Internal Definitions

Next: , Previous: , Up: Packages   [Contents][Index]

5.5 monomyth/mmop-control

Source

mmop-control.lisp (file)

Nickname

mmop-c

Use List
Exported Definitions
Internal Definitions

Next: , Previous: , Up: Packages   [Contents][Index]

5.6 monomyth/node

Source

node.lisp (file)

Use List
Used By List
Exported Definitions
Internal Definitions

Next: , Previous: , Up: Packages   [Contents][Index]

5.7 monomyth/rmq-node

Source

rmq-node.lisp (file)

Use List
Used By List
Exported Definitions
Internal Definitions

Next: , Previous: , Up: Packages   [Contents][Index]

5.8 monomyth/rmq-node-recipe

Source

rmq-node-recipe.lisp (file)

Use List
Used By List
Exported Definitions

Next: , Previous: , Up: Packages   [Contents][Index]

5.9 monomyth/worker

Source

worker.lisp (file)

Use List
Used By List
Exported Definitions
Internal Definitions

Next: , Previous: , Up: Packages   [Contents][Index]

5.10 monomyth/rmq-worker

Source

rmq-worker.lisp (file)

Use List
Used By List

monomyth/dsl

Exported Definitions

Next: , Previous: , Up: Packages   [Contents][Index]

5.11 monomyth/master

Source

master.lisp (file)

Use List
Used By List

monomyth/dsl

Exported Definitions
Internal Definitions

Previous: , Up: Packages   [Contents][Index]

5.12 monomyth/dsl

Source

dsl.lisp (file)

Use List
Exported Definitions
Internal Definitions

Next: , Previous: , Up: Top   [Contents][Index]

6 Definitions

Definitions are sorted by export status, category, package, and then by lexicographic order.


Next: , Previous: , Up: Definitions   [Contents][Index]

6.1 Exported definitions


Next: , Previous: , Up: Exported definitions   [Contents][Index]

6.1.1 Constants

Constant: ping-v0
Package

monomyth/mmop-control

Source

mmop-control.lisp (file)

Constant: pong-v0
Package

monomyth/mmop-control

Source

mmop-control.lisp (file)

Constant: recipe-info-v0
Package

monomyth/mmop-control

Source

mmop-control.lisp (file)

Constant: shutdown-worker-v0
Package

monomyth/mmop-worker

Source

mmop-worker.lisp (file)

Constant: start-node-request-success-v0
Package

monomyth/mmop-control

Source

mmop-control.lisp (file)

Constant: stop-worker-request-success-v0
Package

monomyth/mmop-control

Source

mmop-control.lisp (file)

Constant: worker-info-v0
Package

monomyth/mmop-control

Source

mmop-control.lisp (file)

Constant: worker-ready-v0
Package

monomyth/mmop-worker

Source

mmop-worker.lisp (file)


Next: , Previous: , Up: Exported definitions   [Contents][Index]

6.1.2 Special variables

Special Variable: *mmop-v0*
Package

monomyth/mmop

Source

mmop.lisp (file)

Special Variable: *mmop-versions*
Package

monomyth/mmop

Source

mmop.lisp (file)


Next: , Previous: , Up: Exported definitions   [Contents][Index]

6.1.3 Macros

Macro: define-rmq-node NAME TRANSFORM-FUNC SOURCE-QUEUE DEST-QUEUE SIZE

Defines all classes, methods, and functions for a new node type.

Package

monomyth/dsl

Source

dsl.lisp (file)

Macro: define-system &rest NODES

Takes a list of plist (:name :fn :batch-size) and turns them into rmq nodes
that work in sequential order.
All recipes are also set up to be loaded into master server via the add-recipes method.

Package

monomyth/dsl

Source

dsl.lisp (file)


Next: , Previous: , Up: Exported definitions   [Contents][Index]

6.1.4 Functions

Function: ack-message NODE MESSAGE

acks a message as complete

Package

monomyth/rmq-node

Source

rmq-node.lisp (file)

Function: add-recipe MASTER RECIPE

adds a recipe to the master records

Package

monomyth/master

Source

master.lisp (file)

Function: ask-to-shutdown-worker MASTER SOCKET CLIENT-ID WORKER-ID

uses a master to tell a worker to shutdown via MMOP.
No state in the master is currently changes, returns t if the call seems to have been sent, nil otherwise

Package

monomyth/master

Source

master.lisp (file)

Function: ask-to-start-node MASTER SOCKET CLIENT-ID TYPE-ID

attempts to start a node of type-id on one of the masters workers. returns t if it works, nil otherwise

Package

monomyth/master

Source

master.lisp (file)

Function: build-queues NODES

turns the linear list of edges into queue names

Package

monomyth/dsl

Source

dsl.lisp (file)

Function: build-rmq-message &key (BODY BODY) (DELIVERY-TAG DELIVERY-TAG)
Package

monomyth/rmq-node

Source

rmq-node.lisp (file)

Function: build-rmq-worker &key HOST PORT USERNAME PASSWORD
Package

monomyth/rmq-worker

Source

rmq-worker.lisp (file)

Function: deserialize-recipe BUFFER

turns a serialized buffer back into a recipe

Package

monomyth/node-recipe

Source

node-recipe.lisp (file)

Function: get-message NODE

gets a message off the source queue and changes the message to be a string (as opposed to a byte array)
return :success t with the :result if things go well

Package

monomyth/rmq-node

Source

rmq-node.lisp (file)

Function: json-info-response-v0 %0 %1
Package

monomyth/mmop-master

Source

mmop-master.lisp (file)

Function: json-info-response-v0 %0
Package

monomyth/mmop-control

Source

mmop-control.lisp (file)

Function: mashup-symbol &rest OBJECTS

takes a bunch of symbols and combines them

Package

monomyth/dsl

Source

dsl.lisp (file)

Function: master-context INSTANCE
Package

monomyth/master

Source

master.lisp (file)

Function: master-recipes INSTANCE
Package

monomyth/master

Source

master.lisp (file)

Function: master-workers INSTANCE
Package

monomyth/master

Source

master.lisp (file)

Function: nack-message NODE MESSAGE REQUEUE

nacks a message as incomplete, re-queues message if asked to

Package

monomyth/rmq-node

Source

rmq-node.lisp (file)

Function: ping-v0 %0
Package

monomyth/mmop-master

Source

mmop-master.lisp (file)

Function: pong-v0 %0
Package

monomyth/mmop-master

Source

mmop-master.lisp (file)

Function: pull-control-message SOCKET

pulls down a message designed for the control server and attempts to translate it into the correct adt

Package

monomyth/mmop-control

Source

mmop-control.lisp (file)

Function: pull-master-message SOCKET

pulls down a message designed for the master router socket and attempts to translate it into an equivalent struct

Package

monomyth/mmop-master

Source

mmop-master.lisp (file)

Function: pull-msg SOCKET

Pulls down all message frames

Package

monomyth/mmop

Source

mmop.lisp (file)

Function: pull-worker-message SOCKET

pulls down a message designed for the worker dealer socket and attempts to translate it into an equivalent struct

Package

monomyth/mmop-worker

Source

mmop-worker.lisp (file)

Function: recipe-info-v0 %0
Package

monomyth/mmop-master

Source

mmop-master.lisp (file)

Function: rmq-message-body INSTANCE
Function: (setf rmq-message-body) VALUE INSTANCE
Package

monomyth/rmq-node

Source

rmq-node.lisp (file)

Function: rmq-message-delivery-tag INSTANCE
Package

monomyth/rmq-node

Source

rmq-node.lisp (file)

Function: run-worker WORKER

main event loop for the worker

Package

monomyth/worker

Source

worker.lisp (file)

Function: send-message NODE QUEUE MESSAGE

sends a message to the specified queue

Package

monomyth/rmq-node

Source

rmq-node.lisp (file)

Function: send-msg SOCKET VERSION MSG

translates a message struct into frames, and then sends them

Package

monomyth/mmop

Source

mmop.lisp (file)

Function: send-msg-frames SOCKET VERSION FRAMES

Helper function that sends a set of frames as single message

Package

monomyth/mmop

Source

mmop.lisp (file)

Function: serialize-recipe RECIPE

turns the recipe into a buffer acceptable to ZMQ

Package

monomyth/node-recipe

Source

node-recipe.lisp (file)

Function: setup-connection &key HOST PORT USERNAME PASSWORD VHOST

builds a new connection, sets up the socket, and logs in defaults are the local rabbit-mq defaults

Package

monomyth/rmq-node

Source

rmq-node.lisp (file)

Function: shutdown-worker-v0 %0
Package

monomyth/mmop-master

Source

mmop-master.lisp (file)

Function: start-master THREAD-COUNT CLIENT-PORT

starts up all worker threads and the router loop for load balancing

Package

monomyth/master

Source

master.lisp (file)

Function: start-node-failure-v0 %0 %1 %2
Package

monomyth/mmop-worker

Source

mmop-worker.lisp (file)

Function: start-node-failure-v0 %0 %1 %2 %3
Package

monomyth/mmop-master

Source

mmop-master.lisp (file)

Function: start-node-request-failure-v0 %0 %1 %2
Package

monomyth/mmop-master

Source

mmop-master.lisp (file)

Function: start-node-request-failure-v0 %0 %1
Package

monomyth/mmop-control

Source

mmop-control.lisp (file)

Function: start-node-request-success-v0 %0
Package

monomyth/mmop-master

Source

mmop-master.lisp (file)

Function: start-node-request-v0 %0 %1
Package

monomyth/mmop-master

Source

mmop-master.lisp (file)

Function: start-node-request-v0 %0
Package

monomyth/mmop-control

Source

mmop-control.lisp (file)

Function: start-node-success-v0 %0
Package

monomyth/mmop-worker

Source

mmop-worker.lisp (file)

Function: start-node-success-v0 %0 %1
Package

monomyth/mmop-master

Source

mmop-master.lisp (file)

Function: start-node-v0 %0 %1
Package

monomyth/mmop-worker

Source

mmop-worker.lisp (file)

Function: start-node-v0 %0 %1
Package

monomyth/mmop-master

Source

mmop-master.lisp (file)

Function: stop-master MASTER
Package

monomyth/master

Source

master.lisp (file)

Function: stop-worker-request-failure-v0 %0 %1 %2
Package

monomyth/mmop-master

Source

mmop-master.lisp (file)

Function: stop-worker-request-failure-v0 %0 %1
Package

monomyth/mmop-control

Source

mmop-control.lisp (file)

Function: stop-worker-request-success-v0 %0
Package

monomyth/mmop-master

Source

mmop-master.lisp (file)

Function: stop-worker-request-v0 %0 %1
Package

monomyth/mmop-master

Source

mmop-master.lisp (file)

Function: stop-worker-request-v0 %0
Package

monomyth/mmop-control

Source

mmop-control.lisp (file)

Function: worker-info-outstanding-request-counts INSTANCE
Package

monomyth/master

Source

master.lisp (file)

Function: worker-info-type-counts INSTANCE
Package

monomyth/master

Source

master.lisp (file)

Function: worker-info-v0 %0
Package

monomyth/mmop-master

Source

mmop-master.lisp (file)

Function: worker-ready-v0 %0
Package

monomyth/mmop-master

Source

mmop-master.lisp (file)


Next: , Previous: , Up: Exported definitions   [Contents][Index]

6.1.5 Generic functions

Generic Function: add-recipes MASTER

add all recipes created by the define system macro

Package

monomyth/master

Source

master.lisp (file)

Generic Function: build-node WORKER RECIPE

uses a worker and recipe to build a new node

Package

monomyth/worker

Source

worker.lisp (file)

Generic Function: create-frames MESSAGE

takes a message struct and builds a list of zmq frames to be sent

Package

monomyth/mmop

Source

mmop.lisp (file)

Methods
Method: create-frames (MESSAGE stop-worker-request-v0)
Source

mmop-control.lisp (file)

Method: create-frames (MESSAGE start-node-request-v0)
Source

mmop-control.lisp (file)

Method: create-frames (MESSAGE worker-info-v0)
Source

mmop-control.lisp (file)

Method: create-frames (MESSAGE recipe-info-v0)
Source

mmop-control.lisp (file)

Method: create-frames (MESSAGE ping-v0)
Source

mmop-control.lisp (file)

Method: create-frames (MESSAGE shutdown-worker-v0)
Source

mmop-master.lisp (file)

Method: create-frames (MESSAGE start-node-v0)
Source

mmop-master.lisp (file)

Method: create-frames (MESSAGE stop-worker-request-failure-v0)
Source

mmop-master.lisp (file)

Method: create-frames (MESSAGE stop-worker-request-success-v0)
Source

mmop-master.lisp (file)

Method: create-frames (MESSAGE start-node-request-failure-v0)
Source

mmop-master.lisp (file)

Method: create-frames (MESSAGE start-node-request-success-v0)
Source

mmop-master.lisp (file)

Method: create-frames (MESSAGE json-info-response-v0)
Source

mmop-master.lisp (file)

Method: create-frames (MESSAGE pong-v0)
Source

mmop-master.lisp (file)

Method: create-frames (MESSAGE start-node-failure-v0)
Source

mmop-worker.lisp (file)

Method: create-frames (MESSAGE start-node-success-v0)
Source

mmop-worker.lisp (file)

Method: create-frames (MESSAGE worker-ready-v0)
Source

mmop-worker.lisp (file)

Generic Function: handle-failure NODE STEP RESULT

actions to take if the returned plist contains :success false expects an explanation under :error in the result
the step can be :pull, :transform, or :place
the result is the full payload sent by the last step

Package

monomyth/node

Source

node.lisp (file)

Methods
Method: handle-failure (NODE rmq-node) STEP RESULT
Source

rmq-node.lisp (file)

Generic Function: mmop-error/message CONDITION
Package

monomyth/mmop

Methods
Method: mmop-error/message (CONDITION mmop-error)
Source

mmop.lisp (file)

Generic Function: mmop-error/version CONDITION
Package

monomyth/mmop

Methods
Method: mmop-error/version (CONDITION mmop-error)
Source

mmop.lisp (file)

Generic Function: name-fail-queue RECIPE

uses the node type to name the fail queue in a deterministic manor

Package

monomyth/rmq-node-recipe

Source

rmq-node-recipe.lisp (file)

Methods
Method: name-fail-queue (RECIPE rmq-node-recipe)
Generic Function: name-node RECIPE

takes a recipe and produces a unique node name

Package

monomyth/node-recipe

Source

node-recipe.lisp (file)

Methods
Method: name-node (RECIPE node-recipe)
Generic Function: node-error/items CONDITION
Package

monomyth/node

Methods
Method: node-error/items (CONDITION node-error)
Source

node.lisp (file)

Generic Function: node-error/step CONDITION
Package

monomyth/node

Methods
Method: node-error/step (CONDITION node-error)
Source

node.lisp (file)

Generic Function: node-recipe/batch-size OBJECT
Package

monomyth/node-recipe

Methods
Method: node-recipe/batch-size (NODE-RECIPE node-recipe)

the batch size that is passed directly to the node if not set uses the default (10)

Source

node-recipe.lisp (file)

Generic Function: node-recipe/type OBJECT
Package

monomyth/node-recipe

Methods
Method: node-recipe/type (NODE-RECIPE node-recipe)

node ’type’, often used to name nodes

Source

node-recipe.lisp (file)

Generic Function: node/batch-size OBJECT
Package

monomyth/node

Methods
Method: node/batch-size (NODE node)

number of items to pull in pull-items at a time

Source

node.lisp (file)

Generic Function: node/node-name OBJECT
Package

monomyth/node

Methods
Method: node/node-name (NODE node)

name of the node

Source

node.lisp (file)

Generic Function: node/type OBJECT
Package

monomyth/node

Methods
Method: node/type (NODE node)

the node type corresponds to the node recipe type

Source

node.lisp (file)

Generic Function: place-items NODE RESULT

places the finished items on the message bus
takes the entire payload sent by transorm
assumes that the items are passed under :items should return a plist with one of the slots as :success

Package

monomyth/node

Source

node.lisp (file)

Methods
Method: place-items (NODE rmq-node) RESULT
Source

rmq-node.lisp (file)

Generic Function: pull-items NODE

tells the node to pull count items from the message bus should return a plist with one of the slots as :success

Package

monomyth/node

Source

node.lisp (file)

Methods
Method: pull-items (NODE rmq-node)
Source

rmq-node.lisp (file)

Generic Function: rmq-node-recipe/dest-queue OBJECT
Package

monomyth/rmq-node-recipe

Methods
Method: rmq-node-recipe/dest-queue (RMQ-NODE-RECIPE rmq-node-recipe)

automatically generated reader method

Source

rmq-node-recipe.lisp (file)

Generic Function: rmq-node-recipe/source-queue OBJECT
Package

monomyth/rmq-node-recipe

Methods
Method: rmq-node-recipe/source-queue (RMQ-NODE-RECIPE rmq-node-recipe)

automatically generated reader method

Source

rmq-node-recipe.lisp (file)

Generic Function: rmq-worker/host OBJECT
Package

monomyth/rmq-worker

Methods
Method: rmq-worker/host (RMQ-WORKER rmq-worker)

rabbit mq host

Source

rmq-worker.lisp (file)

Generic Function: rmq-worker/password OBJECT
Package

monomyth/rmq-worker

Methods
Method: rmq-worker/password (RMQ-WORKER rmq-worker)

automatically generated reader method

Source

rmq-worker.lisp (file)

Generic Function: rmq-worker/port OBJECT
Package

monomyth/rmq-worker

Methods
Method: rmq-worker/port (RMQ-WORKER rmq-worker)

rabbit mq port

Source

rmq-worker.lisp (file)

Generic Function: rmq-worker/username OBJECT
Package

monomyth/rmq-worker

Methods
Method: rmq-worker/username (RMQ-WORKER rmq-worker)

rabbit mq username

Source

rmq-worker.lisp (file)

Generic Function: run-iteration NODE

runs an entire operation start to finish

Package

monomyth/node

Source

node.lisp (file)

Methods
Method: run-iteration (NODE node)
Generic Function: shutdown NODE

graceful shutdown of the node

Package

monomyth/node

Source

node.lisp (file)

Methods
Method: shutdown (NODE rmq-node)

closes the channel and then destroys the connections.
note that this means that once an rmq-node is shutdown, it cannot be started up again

Source

rmq-node.lisp (file)

Method: shutdown (NODE node) before
Generic Function: start-worker WORKER MASTER-ADDRESS

starts the worker processes, by the time this method is done it should be okay start a node

Package

monomyth/worker

Source

worker.lisp (file)

Methods
Method: start-worker (WORKER worker) MASTER-ADDRESS
Generic Function: startup NODE &optional BUILD-WORKER-THREAD

performs any initial start up to ensure the node is working as corrected. The build worker thread option exists for testing purposes

Package

monomyth/node

Source

node.lisp (file)

Methods
Method: startup (NODE rmq-node) &optional BUILD-WORKER-THREAD

opens a channel using the nodes connections after setting up the socket.
also ensures all three queues are up and sets up basic consume for the source queue

Source

rmq-node.lisp (file)

Method: startup (NODE node) &optional BUILD-WORKER-THREAD after
Generic Function: stop-worker WORKER

stops the worker processes and frees all resources and connections

Package

monomyth/worker

Source

worker.lisp (file)

Methods
Method: stop-worker (WORKER worker)
Generic Function: transform-fn NODE ITEM

the core transform function

Package

monomyth/node

Source

node.lisp (file)

Generic Function: transform-items NODE PULLED

extracts the items from the pull step (provided it was successful) and applies the transform function to each one

Package

monomyth/node

Source

node.lisp (file)

Methods
Method: transform-items (NODE rmq-node) PULLED
Source

rmq-node.lisp (file)

Method: transform-items (NODE node) PULLED
Generic Function: worker/name OBJECT
Package

monomyth/worker

Methods
Method: worker/name (WORKER worker)

a unique worker name set before startup

Source

worker.lisp (file)


Next: , Previous: , Up: Exported definitions   [Contents][Index]

6.1.6 Conditions

Condition: mmop-error ()

an error that happens in the mmop protocol

Package

monomyth/mmop

Source

mmop.lisp (file)

Direct superclasses

error (condition)

Direct methods
Direct slots
Slot: message
Initargs

:message

Initform

(quote (error "mmop-error message must be set"))

Readers

mmop-error/message (generic function)

Slot: mmop-version
Initargs

:version

Initform

(quote "undefined")

Readers

mmop-error/version (generic function)

Condition: node-error ()

an internal node error, handled by run-iteration

Package

monomyth/node

Source

node.lisp (file)

Direct superclasses

error (condition)

Direct methods
Direct slots
Slot: step

the step the node failed on
should be :place, :transform, or :pull if handle failure will take it

Initargs

:step

Initform

(quote (error "node error step must be set"))

Readers

node-error/step (generic function)

Slot: message
Initargs

:message

Initform

(quote (error "node error message must be set"))

Readers

node-error/message (generic function)

Slot: items

the items to be reprocessed

Initargs

:items

Initform

(quote nil)

Readers

node-error/items (generic function)


Next: , Previous: , Up: Exported definitions   [Contents][Index]

6.1.7 Structures

Structure: json-info-response-v0 ()
Package

monomyth/mmop-master

Source

mmop-master.lisp (file)

Direct superclasses

sent-mmop (structure)

Direct methods
  • create-frames (method)
  • make-load-form (method)
  • print-object (method)
Direct slots
Slot: %0
Type

string

Initform

(error "unspecified field.")

Readers

json-info-response-v0%0 (function)

Writers

(setf json-info-response-v0%0) (function)

Slot: %1
Type

string

Initform

(error "unspecified field.")

Readers

json-info-response-v0%1 (function)

Writers

(setf json-info-response-v0%1) (function)

Structure: json-info-response-v0 ()
Package

monomyth/mmop-control

Source

mmop-control.lisp (file)

Direct superclasses

received-mmop (structure)

Direct methods
  • make-load-form (method)
  • print-object (method)
Direct slots
Slot: %0
Type

string

Initform

(error "unspecified field.")

Readers

json-info-response-v0%0 (function)

Writers

(setf json-info-response-v0%0) (function)

Structure: master ()

the master system only has two fields, a table of worker identifiers to worker infos, and a table of node type symbols to node recipes

Package

monomyth/master

Source

master.lisp (file)

Direct superclasses

structure-object (structure)

Direct slots
Slot: workers
Initform

(stmx::tstruct-slot-initialize (quote monomyth/master:master) (quote monomyth/master::workers) (quote (make-instance (quote stmx.util:thash-table) :test (quote equal))))

Readers

%stmx-impl/tstruct/master-workers (function)

Writers

(setf %stmx-impl/tstruct/master-workers) (function)

Slot: recipes
Initform

(stmx::tstruct-slot-initialize (quote monomyth/master:master) (quote monomyth/master::recipes) (quote (make-instance (quote stmx.util:thash-table) :test (quote equal))))

Readers

%stmx-impl/tstruct/master-recipes (function)

Writers

(setf %stmx-impl/tstruct/master-recipes) (function)

Slot: context
Initform

(stmx::tstruct-slot-initialize (quote monomyth/master:master) (quote monomyth/master::context) (quote (pzmq:ctx-new)))

Readers

%stmx-impl/tstruct/master-context (function)

Writers

(setf %stmx-impl/tstruct/master-context) (function)

Slot: running
Type

(stmx:transactional t)

Initform

(stmx::tstruct-slot-initialize (quote monomyth/master:master) (quote monomyth/master::running) (quote t))

Readers

%stmx-impl/tstruct/master-running (function)

Writers

(setf %stmx-impl/tstruct/master-running) (function)

Structure: ping-v0 ()
Package

monomyth/mmop-master

Source

mmop-master.lisp (file)

Direct superclasses

received-mmop (structure)

Direct methods
  • make-load-form (method)
  • print-object (method)
Direct slots
Slot: %0
Type

string

Initform

(error "unspecified field.")

Readers

ping-v0%0 (function)

Writers

(setf ping-v0%0) (function)

Structure: ping-v0 ()
Package

monomyth/mmop-control

Source

mmop-control.lisp (file)

Direct superclasses

sent-mmop (structure)

Direct methods
  • create-frames (method)
  • make-load-form (method)
  • print-object (method)
Structure: pong-v0 ()
Package

monomyth/mmop-master

Source

mmop-master.lisp (file)

Direct superclasses

sent-mmop (structure)

Direct methods
  • create-frames (method)
  • make-load-form (method)
  • print-object (method)
Direct slots
Slot: %0
Type

string

Initform

(error "unspecified field.")

Readers

pong-v0%0 (function)

Writers

(setf pong-v0%0) (function)

Structure: pong-v0 ()
Package

monomyth/mmop-control

Source

mmop-control.lisp (file)

Direct superclasses

received-mmop (structure)

Direct methods
  • make-load-form (method)
  • print-object (method)
Structure: received-mmop ()
Package

monomyth/mmop-worker

Source

mmop-worker.lisp (file)

Direct superclasses

algebraic-data-type (structure)

Direct subclasses
Structure: received-mmop ()
Package

monomyth/mmop-master

Source

mmop-master.lisp (file)

Direct superclasses

algebraic-data-type (structure)

Direct subclasses
Structure: received-mmop ()
Package

monomyth/mmop-control

Source

mmop-control.lisp (file)

Direct superclasses

algebraic-data-type (structure)

Direct subclasses
Structure: recipe-info-v0 ()
Package

monomyth/mmop-master

Source

mmop-master.lisp (file)

Direct superclasses

received-mmop (structure)

Direct methods
  • make-load-form (method)
  • print-object (method)
Direct slots
Slot: %0
Type

string

Initform

(error "unspecified field.")

Readers

recipe-info-v0%0 (function)

Writers

(setf recipe-info-v0%0) (function)

Structure: recipe-info-v0 ()
Package

monomyth/mmop-control

Source

mmop-control.lisp (file)

Direct superclasses

sent-mmop (structure)

Direct methods
  • create-frames (method)
  • make-load-form (method)
  • print-object (method)
Structure: sent-mmop ()
Package

monomyth/mmop-worker

Source

mmop-worker.lisp (file)

Direct superclasses

algebraic-data-type (structure)

Direct subclasses
Structure: sent-mmop ()
Package

monomyth/mmop-master

Source

mmop-master.lisp (file)

Direct superclasses

algebraic-data-type (structure)

Direct subclasses
Structure: sent-mmop ()
Package

monomyth/mmop-control

Source

mmop-control.lisp (file)

Direct superclasses

algebraic-data-type (structure)

Direct subclasses
Structure: shutdown-worker-v0 ()
Package

monomyth/mmop-worker

Source

mmop-worker.lisp (file)

Direct superclasses

received-mmop (structure)

Direct methods
  • make-load-form (method)
  • print-object (method)
Structure: shutdown-worker-v0 ()
Package

monomyth/mmop-master

Source

mmop-master.lisp (file)

Direct superclasses

sent-mmop (structure)

Direct methods
  • create-frames (method)
  • make-load-form (method)
  • print-object (method)
Direct slots
Slot: %0
Type

string

Initform

(error "unspecified field.")

Readers

shutdown-worker-v0%0 (function)

Writers

(setf shutdown-worker-v0%0) (function)

Structure: start-node-failure-v0 ()
Package

monomyth/mmop-worker

Source

mmop-worker.lisp (file)

Direct superclasses

sent-mmop (structure)

Direct methods
  • create-frames (method)
  • make-load-form (method)
  • print-object (method)
Direct slots
Slot: %0
Type

string

Initform

(error "unspecified field.")

Readers

start-node-failure-v0%0 (function)

Writers

(setf start-node-failure-v0%0) (function)

Slot: %1
Type

string

Initform

(error "unspecified field.")

Readers

start-node-failure-v0%1 (function)

Writers

(setf start-node-failure-v0%1) (function)

Slot: %2
Type

string

Initform

(error "unspecified field.")

Readers

start-node-failure-v0%2 (function)

Writers

(setf start-node-failure-v0%2) (function)

Structure: start-node-failure-v0 ()
Package

monomyth/mmop-master

Source

mmop-master.lisp (file)

Direct superclasses

received-mmop (structure)

Direct methods
  • make-load-form (method)
  • print-object (method)
Direct slots
Slot: %0
Type

string

Initform

(error "unspecified field.")

Readers

start-node-failure-v0%0 (function)

Writers

(setf start-node-failure-v0%0) (function)

Slot: %1
Type

string

Initform

(error "unspecified field.")

Readers

start-node-failure-v0%1 (function)

Writers

(setf start-node-failure-v0%1) (function)

Slot: %2
Type

string

Initform

(error "unspecified field.")

Readers

start-node-failure-v0%2 (function)

Writers

(setf start-node-failure-v0%2) (function)

Slot: %3
Type

string

Initform

(error "unspecified field.")

Readers

start-node-failure-v0%3 (function)

Writers

(setf start-node-failure-v0%3) (function)

Structure: start-node-request-failure-v0 ()
Package

monomyth/mmop-master

Source

mmop-master.lisp (file)

Direct superclasses

sent-mmop (structure)

Direct methods
  • create-frames (method)
  • make-load-form (method)
  • print-object (method)
Direct slots
Slot: %0
Type

string

Initform

(error "unspecified field.")

Readers

start-node-request-failure-v0%0 (function)

Writers

(setf start-node-request-failure-v0%0) (function)

Slot: %1
Type

string

Initform

(error "unspecified field.")

Readers

start-node-request-failure-v0%1 (function)

Writers

(setf start-node-request-failure-v0%1) (function)

Slot: %2
Type

integer

Initform

(error "unspecified field.")

Readers

start-node-request-failure-v0%2 (function)

Writers

(setf start-node-request-failure-v0%2) (function)

Structure: start-node-request-failure-v0 ()
Package

monomyth/mmop-control

Source

mmop-control.lisp (file)

Direct superclasses

received-mmop (structure)

Direct methods
  • make-load-form (method)
  • print-object (method)
Direct slots
Slot: %0
Type

string

Initform

(error "unspecified field.")

Readers

start-node-request-failure-v0%0 (function)

Writers

(setf start-node-request-failure-v0%0) (function)

Slot: %1
Type

integer

Initform

(error "unspecified field.")

Readers

start-node-request-failure-v0%1 (function)

Writers

(setf start-node-request-failure-v0%1) (function)

Structure: start-node-request-success-v0 ()
Package

monomyth/mmop-master

Source

mmop-master.lisp (file)

Direct superclasses

sent-mmop (structure)

Direct methods
  • create-frames (method)
  • make-load-form (method)
  • print-object (method)
Direct slots
Slot: %0
Type

string

Initform

(error "unspecified field.")

Readers

start-node-request-success-v0%0 (function)

Writers

(setf start-node-request-success-v0%0) (function)

Structure: start-node-request-success-v0 ()
Package

monomyth/mmop-control

Source

mmop-control.lisp (file)

Direct superclasses

received-mmop (structure)

Direct methods
  • make-load-form (method)
  • print-object (method)
Structure: start-node-request-v0 ()
Package

monomyth/mmop-master

Source

mmop-master.lisp (file)

Direct superclasses

received-mmop (structure)

Direct methods
  • make-load-form (method)
  • print-object (method)
Direct slots
Slot: %0
Type

string

Initform

(error "unspecified field.")

Readers

start-node-request-v0%0 (function)

Writers

(setf start-node-request-v0%0) (function)

Slot: %1
Type

string

Initform

(error "unspecified field.")

Readers

start-node-request-v0%1 (function)

Writers

(setf start-node-request-v0%1) (function)

Structure: start-node-request-v0 ()
Package

monomyth/mmop-control

Source

mmop-control.lisp (file)

Direct superclasses

sent-mmop (structure)

Direct methods
  • create-frames (method)
  • make-load-form (method)
  • print-object (method)
Direct slots
Slot: %0
Type

string

Initform

(error "unspecified field.")

Readers

start-node-request-v0%0 (function)

Writers

(setf start-node-request-v0%0) (function)

Structure: start-node-success-v0 ()
Package

monomyth/mmop-worker

Source

mmop-worker.lisp (file)

Direct superclasses

sent-mmop (structure)

Direct methods
  • create-frames (method)
  • make-load-form (method)
  • print-object (method)
Direct slots
Slot: %0
Type

string

Initform

(error "unspecified field.")

Readers

start-node-success-v0%0 (function)

Writers

(setf start-node-success-v0%0) (function)

Structure: start-node-success-v0 ()
Package

monomyth/mmop-master

Source

mmop-master.lisp (file)

Direct superclasses

received-mmop (structure)

Direct methods
  • make-load-form (method)
  • print-object (method)
Direct slots
Slot: %0
Type

string

Initform

(error "unspecified field.")

Readers

start-node-success-v0%0 (function)

Writers

(setf start-node-success-v0%0) (function)

Slot: %1
Type

string

Initform

(error "unspecified field.")

Readers

start-node-success-v0%1 (function)

Writers

(setf start-node-success-v0%1) (function)

Structure: start-node-v0 ()
Package

monomyth/mmop-worker

Source

mmop-worker.lisp (file)

Direct superclasses

received-mmop (structure)

Direct methods
  • make-load-form (method)
  • print-object (method)
Direct slots
Slot: %0
Type

string

Initform

(error "unspecified field.")

Readers

start-node-v0%0 (function)

Writers

(setf start-node-v0%0) (function)

Slot: %1
Type

monomyth/node-recipe:node-recipe

Initform

(error "unspecified field.")

Readers

start-node-v0%1 (function)

Writers

(setf start-node-v0%1) (function)

Structure: start-node-v0 ()
Package

monomyth/mmop-master

Source

mmop-master.lisp (file)

Direct superclasses

sent-mmop (structure)

Direct methods
  • create-frames (method)
  • make-load-form (method)
  • print-object (method)
Direct slots
Slot: %0
Type

string

Initform

(error "unspecified field.")

Readers

start-node-v0%0 (function)

Writers

(setf start-node-v0%0) (function)

Slot: %1
Type

monomyth/node-recipe:node-recipe

Initform

(error "unspecified field.")

Readers

start-node-v0%1 (function)

Writers

(setf start-node-v0%1) (function)

Structure: stop-worker-request-failure-v0 ()
Package

monomyth/mmop-master

Source

mmop-master.lisp (file)

Direct superclasses

sent-mmop (structure)

Direct methods
  • create-frames (method)
  • make-load-form (method)
  • print-object (method)
Direct slots
Slot: %0
Type

string

Initform

(error "unspecified field.")

Readers

stop-worker-request-failure-v0%0 (function)

Writers

(setf stop-worker-request-failure-v0%0) (function)

Slot: %1
Type

string

Initform

(error "unspecified field.")

Readers

stop-worker-request-failure-v0%1 (function)

Writers

(setf stop-worker-request-failure-v0%1) (function)

Slot: %2
Type

integer

Initform

(error "unspecified field.")

Readers

stop-worker-request-failure-v0%2 (function)

Writers

(setf stop-worker-request-failure-v0%2) (function)

Structure: stop-worker-request-failure-v0 ()
Package

monomyth/mmop-control

Source

mmop-control.lisp (file)

Direct superclasses

received-mmop (structure)

Direct methods
  • make-load-form (method)
  • print-object (method)
Direct slots
Slot: %0
Type

string

Initform

(error "unspecified field.")

Readers

stop-worker-request-failure-v0%0 (function)

Writers

(setf stop-worker-request-failure-v0%0) (function)

Slot: %1
Type

integer

Initform

(error "unspecified field.")

Readers

stop-worker-request-failure-v0%1 (function)

Writers

(setf stop-worker-request-failure-v0%1) (function)

Structure: stop-worker-request-success-v0 ()
Package

monomyth/mmop-master

Source

mmop-master.lisp (file)

Direct superclasses

sent-mmop (structure)

Direct methods
  • create-frames (method)
  • make-load-form (method)
  • print-object (method)
Direct slots
Slot: %0
Type

string

Initform

(error "unspecified field.")

Readers

stop-worker-request-success-v0%0 (function)

Writers

(setf stop-worker-request-success-v0%0) (function)

Structure: stop-worker-request-success-v0 ()
Package

monomyth/mmop-control

Source

mmop-control.lisp (file)

Direct superclasses

received-mmop (structure)

Direct methods
  • make-load-form (method)
  • print-object (method)
Structure: stop-worker-request-v0 ()
Package

monomyth/mmop-master

Source

mmop-master.lisp (file)

Direct superclasses

received-mmop (structure)

Direct methods
  • make-load-form (method)
  • print-object (method)
Direct slots
Slot: %0
Type

string

Initform

(error "unspecified field.")

Readers

stop-worker-request-v0%0 (function)

Writers

(setf stop-worker-request-v0%0) (function)

Slot: %1
Type

string

Initform

(error "unspecified field.")

Readers

stop-worker-request-v0%1 (function)

Writers

(setf stop-worker-request-v0%1) (function)

Structure: stop-worker-request-v0 ()
Package

monomyth/mmop-control

Source

mmop-control.lisp (file)

Direct superclasses

sent-mmop (structure)

Direct methods
  • create-frames (method)
  • make-load-form (method)
  • print-object (method)
Direct slots
Slot: %0
Type

string

Initform

(error "unspecified field.")

Readers

stop-worker-request-v0%0 (function)

Writers

(setf stop-worker-request-v0%0) (function)

Structure: worker-info-v0 ()
Package

monomyth/mmop-master

Source

mmop-master.lisp (file)

Direct superclasses

received-mmop (structure)

Direct methods
  • make-load-form (method)
  • print-object (method)
Direct slots
Slot: %0
Type

string

Initform

(error "unspecified field.")

Readers

worker-info-v0%0 (function)

Writers

(setf worker-info-v0%0) (function)

Structure: worker-info-v0 ()
Package

monomyth/mmop-control

Source

mmop-control.lisp (file)

Direct superclasses

sent-mmop (structure)

Direct methods
  • create-frames (method)
  • make-load-form (method)
  • print-object (method)
Structure: worker-ready-v0 ()
Package

monomyth/mmop-worker

Source

mmop-worker.lisp (file)

Direct superclasses

sent-mmop (structure)

Direct methods
  • create-frames (method)
  • make-load-form (method)
  • print-object (method)
Structure: worker-ready-v0 ()
Package

monomyth/mmop-master

Source

mmop-master.lisp (file)

Direct superclasses

received-mmop (structure)

Direct methods
  • make-load-form (method)
  • print-object (method)
Direct slots
Slot: %0
Type

string

Initform

(error "unspecified field.")

Readers

worker-ready-v0%0 (function)

Writers

(setf worker-ready-v0%0) (function)


Previous: , Up: Exported definitions   [Contents][Index]

6.1.8 Classes

Class: node ()

base node class for the monomyth flow system

Package

monomyth/node

Source

node.lisp (file)

Direct superclasses

transactional-object (class)

Direct subclasses

rmq-node (class)

Direct methods
Direct slots
Slot: name

name of the node

Initargs

:name

Initform

(format nil "node-~a" (uuid:make-v4-uuid))

Readers

node/node-name (generic function)

Slot: type

the node type corresponds to the node recipe type

Initargs

:type

Initform

(error "node type must be set")

Readers

node/type (generic function)

Slot: batch-size

number of items to pull in pull-items at a time

Initargs

:batch-size

Initform

10

Readers

node/batch-size (generic function)

Slot: running

transactional condition that allows for safe shutdown

Initform

t

Readers

node/running (generic function)

Writers

(setf node/running) (generic function)

Class: node-recipe ()

everything the systems needs to make a new node

Package

monomyth/node-recipe

Source

node-recipe.lisp (file)

Direct superclasses

standard-object (class)

Direct subclasses

rmq-node-recipe (class)

Direct methods
Direct slots
Slot: type

node ’type’, often used to name nodes

Initargs

:type

Initform

(error "recipe type must be set")

Readers

node-recipe/type (generic function)

Slot: batch-size

the batch size that is passed directly to the node if not set uses the default (10)

Initargs

:batch-size

Initform

10

Readers

node-recipe/batch-size (generic function)

Class: rmq-node ()

a node type specially designed to work with rabbit mq

Package

monomyth/rmq-node

Source

rmq-node.lisp (file)

Direct superclasses

node (class)

Direct methods
Direct slots
Slot: conn

the rmq connection, there should only be one per machine. Due to the library we are using, there will be one per node

Initargs

:conn

Initform

(error "connection must be supplied")

Readers

rmq-node/conn (generic function)

Slot: exchange
Initargs

:exchange

Initform

""

Readers

rmq-node/exchange (generic function)

Slot: source-queue
Initargs

:source

Initform

(error "source queue must be set")

Readers

rmq-node/source-queue (generic function)

Slot: dest-queue
Initargs

:dest

Initform

(error "destination queue must be set")

Readers

rmq-node/dest-queue (generic function)

Slot: fail-queue
Initargs

:fail

Initform

(error "failure queue must be set")

Readers

rmq-node/fail-queue (generic function)

Class: rmq-node-recipe ()

recipe with the added fields needed to build an rmq-node

Package

monomyth/rmq-node-recipe

Source

rmq-node-recipe.lisp (file)

Direct superclasses

node-recipe (class)

Direct methods
Direct slots
Slot: source-queue
Initargs

:source

Initform

(error "source queue must be set")

Readers

rmq-node-recipe/source-queue (generic function)

Slot: dest-queue
Initargs

:dest

Initform

(error "destination queue must be set")

Readers

rmq-node-recipe/dest-queue (generic function)

Class: rmq-worker ()

a worker designed to work directly with rabbit mq nodes

Package

monomyth/rmq-worker

Source

rmq-worker.lisp (file)

Direct superclasses

worker (class)

Direct methods
Direct slots
Slot: host

rabbit mq host

Initargs

:host

Initform

(error "rmq host must be set")

Readers

rmq-worker/host (generic function)

Slot: port

rabbit mq port

Initargs

:port

Initform

(error "rmq port must be set")

Readers

rmq-worker/port (generic function)

Slot: username

rabbit mq username

Initargs

:username

Initform

(error "rmq username must be set")

Readers

rmq-worker/username (generic function)

Slot: password
Initargs

:password

Initform

(error "rmq password")

Readers

rmq-worker/password (generic function)

Class: worker ()

defines a single machine with its own threads, nodes, and connections

Package

monomyth/worker

Source

worker.lisp (file)

Direct superclasses

standard-object (class)

Direct subclasses

rmq-worker (class)

Direct methods
Direct slots
Slot: context

the zmq context used for the MMOP

Initform

(pzmq:ctx-new)

Readers

worker/context (generic function)

Slot: socket

the zmq dealer socket used for the MMOP

Readers

worker/socket (generic function)

Writers

(setf worker/socket) (generic function)

Slot: name

a unique worker name set before startup

Initform

(monomyth/worker::name-worker)

Readers

worker/name (generic function)

Slot: mmop-version

the MMOP version the worker is using

Initform

monomyth/mmop:*mmop-v0*

Readers

worker/mmop-version (generic function)

Slot: nodes

a hash table of node names to nodes

Initform

(make-hash-table :test (function equal))

Readers

worker/nodes (generic function)


Previous: , Up: Definitions   [Contents][Index]

6.2 Internal definitions


Next: , Previous: , Up: Internal definitions   [Contents][Index]

6.2.1 Special variables

Special Variable: *channel*
Package

monomyth/rmq-node

Source

rmq-node.lisp (file)

Special Variable: *end-message*
Package

monomyth/master

Source

master.lisp (file)

Special Variable: *end-name*
Package

monomyth/dsl

Source

dsl.lisp (file)

Special Variable: *get-timeout*
Package

monomyth/rmq-node

Source

rmq-node.lisp (file)

Special Variable: *internal-conn-name*
Package

monomyth/master

Source

master.lisp (file)

Special Variable: *router-thread-name*
Package

monomyth/master

Source

master.lisp (file)

Special Variable: *shutdown-pause*
Package

monomyth/master

Source

master.lisp (file)

Special Variable: *start-name*
Package

monomyth/dsl

Source

dsl.lisp (file)

Special Variable: *worker-thread-prefix*
Package

monomyth/master

Source

master.lisp (file)


Next: , Previous: , Up: Internal definitions   [Contents][Index]

6.2.2 Macros

Macro: handle-libzmq-error VERSION &body BODY

wraps a zmq call in an error handler

Package

monomyth/mmop

Source

mmop.lisp (file)

Macro: rabbit-mq-call STEP REQUEST &optional ITEMS

wraps a rmq call to look for a standard error

Package

monomyth/rmq-node

Source

rmq-node.lisp (file)


Next: , Previous: , Up: Internal definitions   [Contents][Index]

6.2.3 Functions

Function: %stmx-impl/notx-set/master-running VALUE INSTANCE
Package

monomyth/master

Source

master.lisp (file)

Function: %stmx-impl/notx/master-running INSTANCE
Package

monomyth/master

Source

master.lisp (file)

Setf Expander

(setf %stmx-impl/notx/master-running) (setf expander)

Setf Expander: (setf %stmx-impl/notx/master-running) INSTANCE
Package

monomyth/master

Source

master.lisp (file)

Reader

%stmx-impl/notx/master-running (function)

Function: %stmx-impl/swtx-set/master-running VALUE INSTANCE
Package

monomyth/master

Source

master.lisp (file)

Function: %stmx-impl/swtx/master-running INSTANCE
Package

monomyth/master

Source

master.lisp (file)

Setf Expander

(setf %stmx-impl/swtx/master-running) (setf expander)

Setf Expander: (setf %stmx-impl/swtx/master-running) INSTANCE
Package

monomyth/master

Source

master.lisp (file)

Reader

%stmx-impl/swtx/master-running (function)

Function: %stmx-impl/tstruct/build-master &key (WORKERS WORKERS) (RECIPES RECIPES) (CONTEXT CONTEXT) (RUNNING RUNNING)
Package

monomyth/master

Source

master.lisp (file)

Function: %stmx-impl/tstruct/master-context INSTANCE
Package

monomyth/master

Source

master.lisp (file)

Function: %stmx-impl/tstruct/master-recipes INSTANCE
Package

monomyth/master

Source

master.lisp (file)

Function: %stmx-impl/tstruct/master-running INSTANCE
Function: (setf %stmx-impl/tstruct/master-running) VALUE INSTANCE
Package

monomyth/master

Source

master.lisp (file)

Function: %stmx-impl/tstruct/master-workers INSTANCE
Package

monomyth/master

Source

master.lisp (file)

Function: %stmx-impl/tx-set/master-running VALUE INSTANCE
Package

monomyth/master

Source

master.lisp (file)

Function: add-worker MASTER CLIENT-ID

adds a worker info and id to the master

Package

monomyth/master

Source

master.lisp (file)

Function: build-error-response STEP ITEMS C

helper function that constructs the error

Package

monomyth/rmq-node

Source

rmq-node.lisp (file)

Function: build-master &key WORKERS RECIPES CONTEXT RUNNING
Package

monomyth/master

Source

master.lisp (file)

Function: build-worker-info ()
Package

monomyth/master

Source

master.lisp (file)

Function: combine-type-plist L1 L2

takes two type count plists and combines the counts

Package

monomyth/master

Source

master.lisp (file)

Function: confirm-start-node-failure SOCKET CLIENT-ID MESSAGE CODE

Sends a request failure message to the client with the supplied message.

Package

monomyth/master

Source

master.lisp (file)

Function: copy-master OLD-INSTANCE-17
Package

monomyth/master

Source

master.lisp (file)

Function: copy-rmq-message INSTANCE
Package

monomyth/rmq-node

Source

rmq-node.lisp (file)

Function: copy-worker-info INSTANCE
Package

monomyth/master

Source

master.lisp (file)

Function: define-rmq-node-internal NAME TRANSFORM-FUNC SOURCE-QUEUE DEST-QUEUE SIZE NAME-KEY

Internal function that creates the rmq node top level forms.

Package

monomyth/dsl

Source

dsl.lisp (file)

Function: determine-worker-for-node MASTER TYPE-ID

determines the best worker id for the recipe type

Package

monomyth/master

Source

master.lisp (file)

Function: find-worker-lowest-node-type-count MASTER TYPE-ID

finds the worker id with the smallest number of those nodes running

Package

monomyth/master

Source

master.lisp (file)

Function: forward-frames-to-client SOCKET FRAMES

drops unneeded frames and sends them to the client

Package

monomyth/master

Source

master.lisp (file)

Function: forward-frames-to-worker SOCKET THREAD-ID FRAMES

constructs the message frames and sends them on to the thread

Package

monomyth/master

Source

master.lisp (file)

Function: get-all-worker-type-info MASTER

translates all workers into plists with node information

Package

monomyth/master

Source

master.lisp (file)

Function: get-worker-type-info WORKER

translates a worker type count map object into an equivalent list of plists

Package

monomyth/master

Source

master.lisp (file)

Function: handle-message WORKER MMOP-MSG

handles a specific message for the worker, return t if the worker should continue

Package

monomyth/worker

Source

worker.lisp (file)

Function: handle-message MASTER SOCKET MMOP-MSG

handles a specific message for the master

Package

monomyth/master

Source

master.lisp (file)

Function: handle-pull-msg SOCKET STEP

wraps the pull msg call in an appropriate handler

Package

monomyth/master

Source

master.lisp (file)

Function: json-info-response-v0%0 INSTANCE
Package

monomyth/mmop-master

Source

mmop-master.lisp (file)

Function: json-info-response-v0%0 INSTANCE
Package

monomyth/mmop-control

Source

mmop-control.lisp (file)

Function: json-info-response-v0%1 INSTANCE
Package

monomyth/mmop-master

Source

mmop-master.lisp (file)

Function: master-p OBJECT
Package

monomyth/master

Source

master.lisp (file)

Function: master-running INSTANCE
Package

monomyth/master

Source

master.lisp (file)

Setf Expander

(setf master-running) (setf expander)

Setf Expander: (setf master-running) INSTANCE
Package

monomyth/master

Source

master.lisp (file)

Reader

master-running (function)

Function: name-worker ()

creates the name that zmq uses for routing

Package

monomyth/worker

Source

worker.lisp (file)

Function: ping-v0%0 INSTANCE
Package

monomyth/mmop-master

Source

mmop-master.lisp (file)

Function: pong-v0%0 INSTANCE
Package

monomyth/mmop-master

Source

mmop-master.lisp (file)

Function: pull-master-type-info MASTER

takes a master object and produces an fset map that links each recipe type to a plist with :running and :queued

Package

monomyth/master

Source

master.lisp (file)

Function: pull-worker-type-info WORKER

takes a worker-info and produces an fset map that links each recipe type to a plist with :running and :queued

Package

monomyth/master

Source

master.lisp (file)

Function: pull-worker-type-queued-info WORKER

takes a worker-info and produces an fset map that links each recipe type to a plist with :queued

Package

monomyth/master

Source

master.lisp (file)

Function: pull-worker-type-running-info WORKER

takes a worker-info and produces an fset map that links each recipe type to a plist with :running

Package

monomyth/master

Source

master.lisp (file)

Function: recipe-info-v0%0 INSTANCE
Package

monomyth/mmop-master

Source

mmop-master.lisp (file)

Function: rmq-message-p OBJECT
Package

monomyth/rmq-node

Source

rmq-node.lisp (file)

Function: route-incoming-message CLIENTS THREADS WORKER-ID
Package

monomyth/master

Source

master.lisp (file)

Function: route-outgoing-message CLIENTS THREADS
Package

monomyth/master

Source

master.lisp (file)

Function: send-pong-v0 SOCKET CLIENT-ID
Package

monomyth/master

Source

master.lisp (file)

Function: send-recipe-info MASTER SOCKET CLIENT-ID
Package

monomyth/master

Source

master.lisp (file)

Function: send-worker-info MASTER SOCKET CLIENT-ID

responds to a worker-info message by pulling the info and turning it into json

Package

monomyth/master

Source

master.lisp (file)

Function: shutdown-worker-v0%0 INSTANCE
Package

monomyth/mmop-master

Source

mmop-master.lisp (file)

Function: start-handler-thread MASTER

starts up a handler thread listening for a router to send it messages

Package

monomyth/master

Source

master.lisp (file)

Function: start-node MASTER SOCKET CLIENT-ID TYPE-ID RECIPE

Sends the start node request to a client with the supplied recipe

Package

monomyth/master

Source

master.lisp (file)

Function: start-node-failure-v0%0 INSTANCE
Package

monomyth/mmop-worker

Source

mmop-worker.lisp (file)

Function: start-node-failure-v0%0 INSTANCE
Package

monomyth/mmop-master

Source

mmop-master.lisp (file)

Function: start-node-failure-v0%1 INSTANCE
Package

monomyth/mmop-worker

Source

mmop-worker.lisp (file)

Function: start-node-failure-v0%1 INSTANCE
Package

monomyth/mmop-master

Source

mmop-master.lisp (file)

Function: start-node-failure-v0%2 INSTANCE
Package

monomyth/mmop-worker

Source

mmop-worker.lisp (file)

Function: start-node-failure-v0%2 INSTANCE
Package

monomyth/mmop-master

Source

mmop-master.lisp (file)

Function: start-node-failure-v0%3 INSTANCE
Package

monomyth/mmop-master

Source

mmop-master.lisp (file)

Function: start-node-request-failure-v0%0 INSTANCE
Package

monomyth/mmop-master

Source

mmop-master.lisp (file)

Function: start-node-request-failure-v0%0 INSTANCE
Package

monomyth/mmop-control

Source

mmop-control.lisp (file)

Function: start-node-request-failure-v0%1 INSTANCE
Package

monomyth/mmop-master

Source

mmop-master.lisp (file)

Function: start-node-request-failure-v0%1 INSTANCE
Package

monomyth/mmop-control

Source

mmop-control.lisp (file)

Function: start-node-request-failure-v0%2 INSTANCE
Package

monomyth/mmop-master

Source

mmop-master.lisp (file)

Function: start-node-request-success-v0%0 INSTANCE
Package

monomyth/mmop-master

Source

mmop-master.lisp (file)

Function: start-node-request-v0%0 INSTANCE
Package

monomyth/mmop-master

Source

mmop-master.lisp (file)

Function: start-node-request-v0%0 INSTANCE
Package

monomyth/mmop-control

Source

mmop-control.lisp (file)

Function: start-node-request-v0%1 INSTANCE
Package

monomyth/mmop-master

Source

mmop-master.lisp (file)

Function: start-node-success-v0%0 INSTANCE
Package

monomyth/mmop-worker

Source

mmop-worker.lisp (file)

Function: start-node-success-v0%0 INSTANCE
Package

monomyth/mmop-master

Source

mmop-master.lisp (file)

Function: start-node-success-v0%1 INSTANCE
Package

monomyth/mmop-master

Source

mmop-master.lisp (file)

Function: start-node-v0%0 INSTANCE
Package

monomyth/mmop-worker

Source

mmop-worker.lisp (file)

Function: start-node-v0%0 INSTANCE
Package

monomyth/mmop-master

Source

mmop-master.lisp (file)

Function: start-node-v0%1 INSTANCE
Package

monomyth/mmop-worker

Source

mmop-worker.lisp (file)

Function: start-node-v0%1 INSTANCE
Package

monomyth/mmop-master

Source

mmop-master.lisp (file)

Function: start-router-loop MASTER CLIENT-PORT THREAD-COUNT THREAD-NAMES

runs the thread router’s event loop in a new thread

Package

monomyth/master

Source

master.lisp (file)

Function: start-successful MASTER CLIENT-ID TYPE-ID

removes the record of the outstanding request and increments the type count for that client

Package

monomyth/master

Source

master.lisp (file)

Function: start-unsuccessful MASTER CLIENT-ID TYPE-ID CAT MSG

removes the record of the outstanding request

Package

monomyth/master

Source

master.lisp (file)

Function: stop-worker-request-failure-v0%0 INSTANCE
Package

monomyth/mmop-master

Source

mmop-master.lisp (file)

Function: stop-worker-request-failure-v0%0 INSTANCE
Package

monomyth/mmop-control

Source

mmop-control.lisp (file)

Function: stop-worker-request-failure-v0%1 INSTANCE
Package

monomyth/mmop-master

Source

mmop-master.lisp (file)

Function: stop-worker-request-failure-v0%1 INSTANCE
Package

monomyth/mmop-control

Source

mmop-control.lisp (file)

Function: stop-worker-request-failure-v0%2 INSTANCE
Package

monomyth/mmop-master

Source

mmop-master.lisp (file)

Function: stop-worker-request-success-v0%0 INSTANCE
Package

monomyth/mmop-master

Source

mmop-master.lisp (file)

Function: stop-worker-request-v0%0 INSTANCE
Package

monomyth/mmop-master

Source

mmop-master.lisp (file)

Function: stop-worker-request-v0%0 INSTANCE
Package

monomyth/mmop-control

Source

mmop-control.lisp (file)

Function: stop-worker-request-v0%1 INSTANCE
Package

monomyth/mmop-master

Source

mmop-master.lisp (file)

Function: total-posible-nodes WORKER TYPE-ID

calculates the total possible worker threads of that type

Package

monomyth/master

Source

master.lisp (file)

Function: translate-v0 ARGS

attempts to translate the arg frames into MMOP/0 structs

Package

monomyth/mmop-worker

Source

mmop-worker.lisp (file)

Function: translate-v0 ID ARGS

attempts to translate the arg frames into MMOP/0 structs

Package

monomyth/mmop-master

Source

mmop-master.lisp (file)

Function: translate-v0 ARGS

attempts to translate the arg frames into MMOP/0 adts

Package

monomyth/mmop-control

Source

mmop-control.lisp (file)

Function: worker-info-p OBJECT
Package

monomyth/master

Source

master.lisp (file)

Function: worker-info-v0%0 INSTANCE
Package

monomyth/mmop-master

Source

mmop-master.lisp (file)

Function: worker-ready-v0%0 INSTANCE
Package

monomyth/mmop-master

Source

mmop-master.lisp (file)


Next: , Previous: , Up: Internal definitions   [Contents][Index]

6.2.4 Generic functions

Generic Function: node-error/message CONDITION
Package

monomyth/node

Methods
Method: node-error/message (CONDITION node-error)
Source

node.lisp (file)

Generic Function: node/running OBJECT
Generic Function: (setf node/running) NEW-VALUE OBJECT
Package

monomyth/node

Methods
Method: node/running (NODE node)
Method: (setf node/running) NEW-VALUE (NODE node)

transactional condition that allows for safe shutdown

Source

node.lisp (file)

Generic Function: rmq-node/conn OBJECT
Package

monomyth/rmq-node

Methods
Method: rmq-node/conn (RMQ-NODE rmq-node)

the rmq connection, there should only be one per machine. Due to the library we are using, there will be one per node

Source

rmq-node.lisp (file)

Generic Function: rmq-node/dest-queue OBJECT
Package

monomyth/rmq-node

Methods
Method: rmq-node/dest-queue (RMQ-NODE rmq-node)

automatically generated reader method

Source

rmq-node.lisp (file)

Generic Function: rmq-node/exchange OBJECT
Package

monomyth/rmq-node

Methods
Method: rmq-node/exchange (RMQ-NODE rmq-node)

automatically generated reader method

Source

rmq-node.lisp (file)

Generic Function: rmq-node/fail-queue OBJECT
Package

monomyth/rmq-node

Methods
Method: rmq-node/fail-queue (RMQ-NODE rmq-node)

automatically generated reader method

Source

rmq-node.lisp (file)

Generic Function: rmq-node/source-queue OBJECT
Package

monomyth/rmq-node

Methods
Method: rmq-node/source-queue (RMQ-NODE rmq-node)

automatically generated reader method

Source

rmq-node.lisp (file)

Generic Function: worker/context OBJECT
Package

monomyth/worker

Methods
Method: worker/context (WORKER worker)

the zmq context used for the MMOP

Source

worker.lisp (file)

Generic Function: worker/mmop-version OBJECT
Package

monomyth/worker

Methods
Method: worker/mmop-version (WORKER worker)

the MMOP version the worker is using

Source

worker.lisp (file)

Generic Function: worker/nodes OBJECT
Package

monomyth/worker

Methods
Method: worker/nodes (WORKER worker)

a hash table of node names to nodes

Source

worker.lisp (file)

Generic Function: worker/socket OBJECT
Generic Function: (setf worker/socket) NEW-VALUE OBJECT
Package

monomyth/worker

Methods
Method: worker/socket (WORKER worker)
Method: (setf worker/socket) NEW-VALUE (WORKER worker)

the zmq dealer socket used for the MMOP

Source

worker.lisp (file)


Previous: , Up: Internal definitions   [Contents][Index]

6.2.5 Structures

Structure: rmq-message ()

central structure passed through the node

Package

monomyth/rmq-node

Source

rmq-node.lisp (file)

Direct superclasses

structure-object (structure)

Direct slots
Slot: body
Readers

rmq-message-body (function)

Writers

(setf rmq-message-body) (function)

Slot: delivery-tag
Readers

rmq-message-delivery-tag (function)

Writers

(setf rmq-message-delivery-tag) (function)

Structure: worker-info ()

the only info tracked by a worker is the number of worker nodes of each type and the number of outstanding requests of each type

Package

monomyth/master

Source

master.lisp (file)

Direct superclasses

structure-object (structure)

Direct slots
Slot: type-counts
Initform

(make-instance (quote stmx.util:thash-table) :test (quote equal))

Readers

worker-info-type-counts (function)

Writers

(setf worker-info-type-counts) (function)

Slot: outstanding-request-counts
Initform

(make-instance (quote stmx.util:thash-table) :test (quote equal))

Readers

worker-info-outstanding-request-counts (function)

Writers

(setf worker-info-outstanding-request-counts) (function)


Previous: , Up: Top   [Contents][Index]

Appendix A Indexes


Next: , Previous: , Up: Indexes   [Contents][Index]

A.1 Concepts

Jump to:   F   L   M  
Index Entry  Section

F
File, Lisp, monomyth.asd: The monomyth․asd file
File, Lisp, monomyth/src/dsl.lisp: The monomyth/src/dsl․lisp file
File, Lisp, monomyth/src/master.lisp: The monomyth/src/master․lisp file
File, Lisp, monomyth/src/mmop-control.lisp: The monomyth/src/mmop-control․lisp file
File, Lisp, monomyth/src/mmop-master.lisp: The monomyth/src/mmop-master․lisp file
File, Lisp, monomyth/src/mmop-worker.lisp: The monomyth/src/mmop-worker․lisp file
File, Lisp, monomyth/src/mmop.lisp: The monomyth/src/mmop․lisp file
File, Lisp, monomyth/src/node-recipe.lisp: The monomyth/src/node-recipe․lisp file
File, Lisp, monomyth/src/node.lisp: The monomyth/src/node․lisp file
File, Lisp, monomyth/src/rmq-node-recipe.lisp: The monomyth/src/rmq-node-recipe․lisp file
File, Lisp, monomyth/src/rmq-node.lisp: The monomyth/src/rmq-node․lisp file
File, Lisp, monomyth/src/rmq-worker.lisp: The monomyth/src/rmq-worker․lisp file
File, Lisp, monomyth/src/worker.lisp: The monomyth/src/worker․lisp file

L
Lisp File, monomyth.asd: The monomyth․asd file
Lisp File, monomyth/src/dsl.lisp: The monomyth/src/dsl․lisp file
Lisp File, monomyth/src/master.lisp: The monomyth/src/master․lisp file
Lisp File, monomyth/src/mmop-control.lisp: The monomyth/src/mmop-control․lisp file
Lisp File, monomyth/src/mmop-master.lisp: The monomyth/src/mmop-master․lisp file
Lisp File, monomyth/src/mmop-worker.lisp: The monomyth/src/mmop-worker․lisp file
Lisp File, monomyth/src/mmop.lisp: The monomyth/src/mmop․lisp file
Lisp File, monomyth/src/node-recipe.lisp: The monomyth/src/node-recipe․lisp file
Lisp File, monomyth/src/node.lisp: The monomyth/src/node․lisp file
Lisp File, monomyth/src/rmq-node-recipe.lisp: The monomyth/src/rmq-node-recipe․lisp file
Lisp File, monomyth/src/rmq-node.lisp: The monomyth/src/rmq-node․lisp file
Lisp File, monomyth/src/rmq-worker.lisp: The monomyth/src/rmq-worker․lisp file
Lisp File, monomyth/src/worker.lisp: The monomyth/src/worker․lisp file

M
Module, monomyth/src: The monomyth/src module
monomyth.asd: The monomyth․asd file
monomyth/src: The monomyth/src module
monomyth/src/dsl.lisp: The monomyth/src/dsl․lisp file
monomyth/src/master.lisp: The monomyth/src/master․lisp file
monomyth/src/mmop-control.lisp: The monomyth/src/mmop-control․lisp file
monomyth/src/mmop-master.lisp: The monomyth/src/mmop-master․lisp file
monomyth/src/mmop-worker.lisp: The monomyth/src/mmop-worker․lisp file
monomyth/src/mmop.lisp: The monomyth/src/mmop․lisp file
monomyth/src/node-recipe.lisp: The monomyth/src/node-recipe․lisp file
monomyth/src/node.lisp: The monomyth/src/node․lisp file
monomyth/src/rmq-node-recipe.lisp: The monomyth/src/rmq-node-recipe․lisp file
monomyth/src/rmq-node.lisp: The monomyth/src/rmq-node․lisp file
monomyth/src/rmq-worker.lisp: The monomyth/src/rmq-worker․lisp file
monomyth/src/worker.lisp: The monomyth/src/worker․lisp file

Jump to:   F   L   M  

Next: , Previous: , Up: Indexes   [Contents][Index]

A.2 Functions

Jump to:   %   (  
A   B   C   D   F   G   H   J   M   N   P   R   S   T   W  
Index Entry  Section

%
%stmx-impl/notx-set/master-running: Internal functions
%stmx-impl/notx/master-running: Internal functions
%stmx-impl/swtx-set/master-running: Internal functions
%stmx-impl/swtx/master-running: Internal functions
%stmx-impl/tstruct/build-master: Internal functions
%stmx-impl/tstruct/master-context: Internal functions
%stmx-impl/tstruct/master-recipes: Internal functions
%stmx-impl/tstruct/master-running: Internal functions
%stmx-impl/tstruct/master-workers: Internal functions
%stmx-impl/tx-set/master-running: Internal functions

(
(setf %stmx-impl/notx/master-running): Internal functions
(setf %stmx-impl/swtx/master-running): Internal functions
(setf %stmx-impl/tstruct/master-running): Internal functions
(setf master-running): Internal functions
(setf node/running): Internal generic functions
(setf node/running): Internal generic functions
(setf rmq-message-body): Exported functions
(setf worker/socket): Internal generic functions
(setf worker/socket): Internal generic functions

A
ack-message: Exported functions
add-recipe: Exported functions
add-recipes: Exported generic functions
add-worker: Internal functions
ask-to-shutdown-worker: Exported functions
ask-to-start-node: Exported functions

B
build-error-response: Internal functions
build-master: Internal functions
build-node: Exported generic functions
build-queues: Exported functions
build-rmq-message: Exported functions
build-rmq-worker: Exported functions
build-worker-info: Internal functions

C
combine-type-plist: Internal functions
confirm-start-node-failure: Internal functions
copy-master: Internal functions
copy-rmq-message: Internal functions
copy-worker-info: Internal functions
create-frames: Exported generic functions
create-frames: Exported generic functions
create-frames: Exported generic functions
create-frames: Exported generic functions
create-frames: Exported generic functions
create-frames: Exported generic functions
create-frames: Exported generic functions
create-frames: Exported generic functions
create-frames: Exported generic functions
create-frames: Exported generic functions
create-frames: Exported generic functions
create-frames: Exported generic functions
create-frames: Exported generic functions
create-frames: Exported generic functions
create-frames: Exported generic functions
create-frames: Exported generic functions
create-frames: Exported generic functions

D
define-rmq-node: Exported macros
define-rmq-node-internal: Internal functions
define-system: Exported macros
deserialize-recipe: Exported functions
determine-worker-for-node: Internal functions

F
find-worker-lowest-node-type-count: Internal functions
forward-frames-to-client: Internal functions
forward-frames-to-worker: Internal functions
Function, %stmx-impl/notx-set/master-running: Internal functions
Function, %stmx-impl/notx/master-running: Internal functions
Function, %stmx-impl/swtx-set/master-running: Internal functions
Function, %stmx-impl/swtx/master-running: Internal functions
Function, %stmx-impl/tstruct/build-master: Internal functions
Function, %stmx-impl/tstruct/master-context: Internal functions
Function, %stmx-impl/tstruct/master-recipes: Internal functions
Function, %stmx-impl/tstruct/master-running: Internal functions
Function, %stmx-impl/tstruct/master-workers: Internal functions
Function, %stmx-impl/tx-set/master-running: Internal functions
Function, (setf %stmx-impl/tstruct/master-running): Internal functions
Function, (setf rmq-message-body): Exported functions
Function, ack-message: Exported functions
Function, add-recipe: Exported functions
Function, add-worker: Internal functions
Function, ask-to-shutdown-worker: Exported functions
Function, ask-to-start-node: Exported functions
Function, build-error-response: Internal functions
Function, build-master: Internal functions
Function, build-queues: Exported functions
Function, build-rmq-message: Exported functions
Function, build-rmq-worker: Exported functions
Function, build-worker-info: Internal functions
Function, combine-type-plist: Internal functions
Function, confirm-start-node-failure: Internal functions
Function, copy-master: Internal functions
Function, copy-rmq-message: Internal functions
Function, copy-worker-info: Internal functions
Function, define-rmq-node-internal: Internal functions
Function, deserialize-recipe: Exported functions
Function, determine-worker-for-node: Internal functions
Function, find-worker-lowest-node-type-count: Internal functions
Function, forward-frames-to-client: Internal functions
Function, forward-frames-to-worker: Internal functions
Function, get-all-worker-type-info: Internal functions
Function, get-message: Exported functions
Function, get-worker-type-info: Internal functions
Function, handle-message: Internal functions
Function, handle-message: Internal functions
Function, handle-pull-msg: Internal functions
Function, json-info-response-v0: Exported functions
Function, json-info-response-v0: Exported functions
Function, json-info-response-v0%0: Internal functions
Function, json-info-response-v0%0: Internal functions
Function, json-info-response-v0%1: Internal functions
Function, mashup-symbol: Exported functions
Function, master-context: Exported functions
Function, master-p: Internal functions
Function, master-recipes: Exported functions
Function, master-running: Internal functions
Function, master-workers: Exported functions
Function, nack-message: Exported functions
Function, name-worker: Internal functions
Function, ping-v0: Exported functions
Function, ping-v0%0: Internal functions
Function, pong-v0: Exported functions
Function, pong-v0%0: Internal functions
Function, pull-control-message: Exported functions
Function, pull-master-message: Exported functions
Function, pull-master-type-info: Internal functions
Function, pull-msg: Exported functions
Function, pull-worker-message: Exported functions
Function, pull-worker-type-info: Internal functions
Function, pull-worker-type-queued-info: Internal functions
Function, pull-worker-type-running-info: Internal functions
Function, recipe-info-v0: Exported functions
Function, recipe-info-v0%0: Internal functions
Function, rmq-message-body: Exported functions
Function, rmq-message-delivery-tag: Exported functions
Function, rmq-message-p: Internal functions
Function, route-incoming-message: Internal functions
Function, route-outgoing-message: Internal functions
Function, run-worker: Exported functions
Function, send-message: Exported functions
Function, send-msg: Exported functions
Function, send-msg-frames: Exported functions
Function, send-pong-v0: Internal functions
Function, send-recipe-info: Internal functions
Function, send-worker-info: Internal functions
Function, serialize-recipe: Exported functions
Function, setup-connection: Exported functions
Function, shutdown-worker-v0: Exported functions
Function, shutdown-worker-v0%0: Internal functions
Function, start-handler-thread: Internal functions
Function, start-master: Exported functions
Function, start-node: Internal functions
Function, start-node-failure-v0: Exported functions
Function, start-node-failure-v0: Exported functions
Function, start-node-failure-v0%0: Internal functions
Function, start-node-failure-v0%0: Internal functions
Function, start-node-failure-v0%1: Internal functions
Function, start-node-failure-v0%1: Internal functions
Function, start-node-failure-v0%2: Internal functions
Function, start-node-failure-v0%2: Internal functions
Function, start-node-failure-v0%3: Internal functions
Function, start-node-request-failure-v0: Exported functions
Function, start-node-request-failure-v0: Exported functions
Function, start-node-request-failure-v0%0: Internal functions
Function, start-node-request-failure-v0%0: Internal functions
Function, start-node-request-failure-v0%1: Internal functions
Function, start-node-request-failure-v0%1: Internal functions
Function, start-node-request-failure-v0%2: Internal functions
Function, start-node-request-success-v0: Exported functions
Function, start-node-request-success-v0%0: Internal functions
Function, start-node-request-v0: Exported functions
Function, start-node-request-v0: Exported functions
Function, start-node-request-v0%0: Internal functions
Function, start-node-request-v0%0: Internal functions
Function, start-node-request-v0%1: Internal functions
Function, start-node-success-v0: Exported functions
Function, start-node-success-v0: Exported functions
Function, start-node-success-v0%0: Internal functions
Function, start-node-success-v0%0: Internal functions
Function, start-node-success-v0%1: Internal functions
Function, start-node-v0: Exported functions
Function, start-node-v0: Exported functions
Function, start-node-v0%0: Internal functions
Function, start-node-v0%0: Internal functions
Function, start-node-v0%1: Internal functions
Function, start-node-v0%1: Internal functions
Function, start-router-loop: Internal functions
Function, start-successful: Internal functions
Function, start-unsuccessful: Internal functions
Function, stop-master: Exported functions
Function, stop-worker-request-failure-v0: Exported functions
Function, stop-worker-request-failure-v0: Exported functions
Function, stop-worker-request-failure-v0%0: Internal functions
Function, stop-worker-request-failure-v0%0: Internal functions
Function, stop-worker-request-failure-v0%1: Internal functions
Function, stop-worker-request-failure-v0%1: Internal functions
Function, stop-worker-request-failure-v0%2: Internal functions
Function, stop-worker-request-success-v0: Exported functions
Function, stop-worker-request-success-v0%0: Internal functions
Function, stop-worker-request-v0: Exported functions
Function, stop-worker-request-v0: Exported functions
Function, stop-worker-request-v0%0: Internal functions
Function, stop-worker-request-v0%0: Internal functions
Function, stop-worker-request-v0%1: Internal functions
Function, total-posible-nodes: Internal functions
Function, translate-v0: Internal functions
Function, translate-v0: Internal functions
Function, translate-v0: Internal functions
Function, worker-info-outstanding-request-counts: Exported functions
Function, worker-info-p: Internal functions
Function, worker-info-type-counts: Exported functions
Function, worker-info-v0: Exported functions
Function, worker-info-v0%0: Internal functions
Function, worker-ready-v0: Exported functions
Function, worker-ready-v0%0: Internal functions

G
Generic Function, (setf node/running): Internal generic functions
Generic Function, (setf worker/socket): Internal generic functions
Generic Function, add-recipes: Exported generic functions
Generic Function, build-node: Exported generic functions
Generic Function, create-frames: Exported generic functions
Generic Function, handle-failure: Exported generic functions
Generic Function, mmop-error/message: Exported generic functions
Generic Function, mmop-error/version: Exported generic functions
Generic Function, name-fail-queue: Exported generic functions
Generic Function, name-node: Exported generic functions
Generic Function, node-error/items: Exported generic functions
Generic Function, node-error/message: Internal generic functions
Generic Function, node-error/step: Exported generic functions
Generic Function, node-recipe/batch-size: Exported generic functions
Generic Function, node-recipe/type: Exported generic functions
Generic Function, node/batch-size: Exported generic functions
Generic Function, node/node-name: Exported generic functions
Generic Function, node/running: Internal generic functions
Generic Function, node/type: Exported generic functions
Generic Function, place-items: Exported generic functions
Generic Function, pull-items: Exported generic functions
Generic Function, rmq-node-recipe/dest-queue: Exported generic functions
Generic Function, rmq-node-recipe/source-queue: Exported generic functions
Generic Function, rmq-node/conn: Internal generic functions
Generic Function, rmq-node/dest-queue: Internal generic functions
Generic Function, rmq-node/exchange: Internal generic functions
Generic Function, rmq-node/fail-queue: Internal generic functions
Generic Function, rmq-node/source-queue: Internal generic functions
Generic Function, rmq-worker/host: Exported generic functions
Generic Function, rmq-worker/password: Exported generic functions
Generic Function, rmq-worker/port: Exported generic functions
Generic Function, rmq-worker/username: Exported generic functions
Generic Function, run-iteration: Exported generic functions
Generic Function, shutdown: Exported generic functions
Generic Function, start-worker: Exported generic functions
Generic Function, startup: Exported generic functions
Generic Function, stop-worker: Exported generic functions
Generic Function, transform-fn: Exported generic functions
Generic Function, transform-items: Exported generic functions
Generic Function, worker/context: Internal generic functions
Generic Function, worker/mmop-version: Internal generic functions
Generic Function, worker/name: Exported generic functions
Generic Function, worker/nodes: Internal generic functions
Generic Function, worker/socket: Internal generic functions
get-all-worker-type-info: Internal functions
get-message: Exported functions
get-worker-type-info: Internal functions

H
handle-failure: Exported generic functions
handle-failure: Exported generic functions
handle-libzmq-error: Internal macros
handle-message: Internal functions
handle-message: Internal functions
handle-pull-msg: Internal functions

J
json-info-response-v0: Exported functions
json-info-response-v0: Exported functions
json-info-response-v0%0: Internal functions
json-info-response-v0%0: Internal functions
json-info-response-v0%1: Internal functions

M
Macro, define-rmq-node: Exported macros
Macro, define-system: Exported macros
Macro, handle-libzmq-error: Internal macros
Macro, rabbit-mq-call: Internal macros
mashup-symbol: Exported functions
master-context: Exported functions
master-p: Internal functions
master-recipes: Exported functions
master-running: Internal functions
master-workers: Exported functions
Method, (setf node/running): Internal generic functions
Method, (setf worker/socket): Internal generic functions
Method, create-frames: Exported generic functions
Method, create-frames: Exported generic functions
Method, create-frames: Exported generic functions
Method, create-frames: Exported generic functions
Method, create-frames: Exported generic functions
Method, create-frames: Exported generic functions
Method, create-frames: Exported generic functions
Method, create-frames: Exported generic functions
Method, create-frames: Exported generic functions
Method, create-frames: Exported generic functions
Method, create-frames: Exported generic functions
Method, create-frames: Exported generic functions
Method, create-frames: Exported generic functions
Method, create-frames: Exported generic functions
Method, create-frames: Exported generic functions
Method, create-frames: Exported generic functions
Method, handle-failure: Exported generic functions
Method, mmop-error/message: Exported generic functions
Method, mmop-error/version: Exported generic functions
Method, name-fail-queue: Exported generic functions
Method, name-node: Exported generic functions
Method, node-error/items: Exported generic functions
Method, node-error/message: Internal generic functions
Method, node-error/step: Exported generic functions
Method, node-recipe/batch-size: Exported generic functions
Method, node-recipe/type: Exported generic functions
Method, node/batch-size: Exported generic functions
Method, node/node-name: Exported generic functions
Method, node/running: Internal generic functions
Method, node/type: Exported generic functions
Method, place-items: Exported generic functions
Method, pull-items: Exported generic functions
Method, rmq-node-recipe/dest-queue: Exported generic functions
Method, rmq-node-recipe/source-queue: Exported generic functions
Method, rmq-node/conn: Internal generic functions
Method, rmq-node/dest-queue: Internal generic functions
Method, rmq-node/exchange: Internal generic functions
Method, rmq-node/fail-queue: Internal generic functions
Method, rmq-node/source-queue: Internal generic functions
Method, rmq-worker/host: Exported generic functions
Method, rmq-worker/password: Exported generic functions
Method, rmq-worker/port: Exported generic functions
Method, rmq-worker/username: Exported generic functions
Method, run-iteration: Exported generic functions
Method, shutdown: Exported generic functions
Method, shutdown: Exported generic functions
Method, start-worker: Exported generic functions
Method, startup: Exported generic functions
Method, startup: Exported generic functions
Method, stop-worker: Exported generic functions
Method, transform-items: Exported generic functions
Method, transform-items: Exported generic functions
Method, worker/context: Internal generic functions
Method, worker/mmop-version: Internal generic functions
Method, worker/name: Exported generic functions
Method, worker/nodes: Internal generic functions
Method, worker/socket: Internal generic functions
mmop-error/message: Exported generic functions
mmop-error/message: Exported generic functions
mmop-error/version: Exported generic functions
mmop-error/version: Exported generic functions

N
nack-message: Exported functions
name-fail-queue: Exported generic functions
name-fail-queue: Exported generic functions
name-node: Exported generic functions
name-node: Exported generic functions
name-worker: Internal functions
node-error/items: Exported generic functions
node-error/items: Exported generic functions
node-error/message: Internal generic functions
node-error/message: Internal generic functions
node-error/step: Exported generic functions
node-error/step: Exported generic functions
node-recipe/batch-size: Exported generic functions
node-recipe/batch-size: Exported generic functions
node-recipe/type: Exported generic functions
node-recipe/type: Exported generic functions
node/batch-size: Exported generic functions
node/batch-size: Exported generic functions
node/node-name: Exported generic functions
node/node-name: Exported generic functions
node/running: Internal generic functions
node/running: Internal generic functions
node/type: Exported generic functions
node/type: Exported generic functions

P
ping-v0: Exported functions
ping-v0%0: Internal functions
place-items: Exported generic functions
place-items: Exported generic functions
pong-v0: Exported functions
pong-v0%0: Internal functions
pull-control-message: Exported functions
pull-items: Exported generic functions
pull-items: Exported generic functions
pull-master-message: Exported functions
pull-master-type-info: Internal functions
pull-msg: Exported functions
pull-worker-message: Exported functions
pull-worker-type-info: Internal functions
pull-worker-type-queued-info: Internal functions
pull-worker-type-running-info: Internal functions

R
rabbit-mq-call: Internal macros
recipe-info-v0: Exported functions
recipe-info-v0%0: Internal functions
rmq-message-body: Exported functions
rmq-message-delivery-tag: Exported functions
rmq-message-p: Internal functions
rmq-node-recipe/dest-queue: Exported generic functions
rmq-node-recipe/dest-queue: Exported generic functions
rmq-node-recipe/source-queue: Exported generic functions
rmq-node-recipe/source-queue: Exported generic functions
rmq-node/conn: Internal generic functions
rmq-node/conn: Internal generic functions
rmq-node/dest-queue: Internal generic functions
rmq-node/dest-queue: Internal generic functions
rmq-node/exchange: Internal generic functions
rmq-node/exchange: Internal generic functions
rmq-node/fail-queue: Internal generic functions
rmq-node/fail-queue: Internal generic functions
rmq-node/source-queue: Internal generic functions
rmq-node/source-queue: Internal generic functions
rmq-worker/host: Exported generic functions
rmq-worker/host: Exported generic functions
rmq-worker/password: Exported generic functions
rmq-worker/password: Exported generic functions
rmq-worker/port: Exported generic functions
rmq-worker/port: Exported generic functions
rmq-worker/username: Exported generic functions
rmq-worker/username: Exported generic functions
route-incoming-message: Internal functions
route-outgoing-message: Internal functions
run-iteration: Exported generic functions
run-iteration: Exported generic functions
run-worker: Exported functions

S
send-message: Exported functions
send-msg: Exported functions
send-msg-frames: Exported functions
send-pong-v0: Internal functions
send-recipe-info: Internal functions
send-worker-info: Internal functions
serialize-recipe: Exported functions
Setf Expander, (setf %stmx-impl/notx/master-running): Internal functions
Setf Expander, (setf %stmx-impl/swtx/master-running): Internal functions
Setf Expander, (setf master-running): Internal functions
setup-connection: Exported functions
shutdown: Exported generic functions
shutdown: Exported generic functions
shutdown: Exported generic functions
shutdown-worker-v0: Exported functions
shutdown-worker-v0%0: Internal functions
start-handler-thread: Internal functions
start-master: Exported functions
start-node: Internal functions
start-node-failure-v0: Exported functions
start-node-failure-v0: Exported functions
start-node-failure-v0%0: Internal functions
start-node-failure-v0%0: Internal functions
start-node-failure-v0%1: Internal functions
start-node-failure-v0%1: Internal functions
start-node-failure-v0%2: Internal functions
start-node-failure-v0%2: Internal functions
start-node-failure-v0%3: Internal functions
start-node-request-failure-v0: Exported functions
start-node-request-failure-v0: Exported functions
start-node-request-failure-v0%0: Internal functions
start-node-request-failure-v0%0: Internal functions
start-node-request-failure-v0%1: Internal functions
start-node-request-failure-v0%1: Internal functions
start-node-request-failure-v0%2: Internal functions
start-node-request-success-v0: Exported functions
start-node-request-success-v0%0: Internal functions
start-node-request-v0: Exported functions
start-node-request-v0: Exported functions
start-node-request-v0%0: Internal functions
start-node-request-v0%0: Internal functions
start-node-request-v0%1: Internal functions
start-node-success-v0: Exported functions
start-node-success-v0: Exported functions
start-node-success-v0%0: Internal functions
start-node-success-v0%0: Internal functions
start-node-success-v0%1: Internal functions
start-node-v0: Exported functions
start-node-v0: Exported functions
start-node-v0%0: Internal functions
start-node-v0%0: Internal functions
start-node-v0%1: Internal functions
start-node-v0%1: Internal functions
start-router-loop: Internal functions
start-successful: Internal functions
start-unsuccessful: Internal functions
start-worker: Exported generic functions
start-worker: Exported generic functions
startup: Exported generic functions
startup: Exported generic functions
startup: Exported generic functions
stop-master: Exported functions
stop-worker: Exported generic functions
stop-worker: Exported generic functions
stop-worker-request-failure-v0: Exported functions
stop-worker-request-failure-v0: Exported functions
stop-worker-request-failure-v0%0: Internal functions
stop-worker-request-failure-v0%0: Internal functions
stop-worker-request-failure-v0%1: Internal functions
stop-worker-request-failure-v0%1: Internal functions
stop-worker-request-failure-v0%2: Internal functions
stop-worker-request-success-v0: Exported functions
stop-worker-request-success-v0%0: Internal functions
stop-worker-request-v0: Exported functions
stop-worker-request-v0: Exported functions
stop-worker-request-v0%0: Internal functions
stop-worker-request-v0%0: Internal functions
stop-worker-request-v0%1: Internal functions

T
total-posible-nodes: Internal functions
transform-fn: Exported generic functions
transform-items: Exported generic functions
transform-items: Exported generic functions
transform-items: Exported generic functions
translate-v0: Internal functions
translate-v0: Internal functions
translate-v0: Internal functions

W
worker-info-outstanding-request-counts: Exported functions
worker-info-p: Internal functions
worker-info-type-counts: Exported functions
worker-info-v0: Exported functions
worker-info-v0%0: Internal functions
worker-ready-v0: Exported functions
worker-ready-v0%0: Internal functions
worker/context: Internal generic functions
worker/context: Internal generic functions
worker/mmop-version: Internal generic functions
worker/mmop-version: Internal generic functions
worker/name: Exported generic functions
worker/name: Exported generic functions
worker/nodes: Internal generic functions
worker/nodes: Internal generic functions
worker/socket: Internal generic functions
worker/socket: Internal generic functions

Jump to:   %   (  
A   B   C   D   F   G   H   J   M   N   P   R   S   T   W  

Next: , Previous: , Up: Indexes   [Contents][Index]

A.3 Variables

Jump to:   %   *  
B   C   D   E   F   H   I   M   N   O   P   R   S   T   U   W  
Index Entry  Section

%
%0: Exported structures
%0: Exported structures
%0: Exported structures
%0: Exported structures
%0: Exported structures
%0: Exported structures
%0: Exported structures
%0: Exported structures
%0: Exported structures
%0: Exported structures
%0: Exported structures
%0: Exported structures
%0: Exported structures
%0: Exported structures
%0: Exported structures
%0: Exported structures
%0: Exported structures
%0: Exported structures
%0: Exported structures
%0: Exported structures
%0: Exported structures
%0: Exported structures
%0: Exported structures
%0: Exported structures
%1: Exported structures
%1: Exported structures
%1: Exported structures
%1: Exported structures
%1: Exported structures
%1: Exported structures
%1: Exported structures
%1: Exported structures
%1: Exported structures
%1: Exported structures
%1: Exported structures
%1: Exported structures
%2: Exported structures
%2: Exported structures
%2: Exported structures
%2: Exported structures
%3: Exported structures

*
*channel*: Internal special variables
*end-message*: Internal special variables
*end-name*: Internal special variables
*get-timeout*: Internal special variables
*internal-conn-name*: Internal special variables
*mmop-v0*: Exported special variables
*mmop-versions*: Exported special variables
*router-thread-name*: Internal special variables
*shutdown-pause*: Internal special variables
*start-name*: Internal special variables
*worker-thread-prefix*: Internal special variables

B
batch-size: Exported classes
batch-size: Exported classes
body: Internal structures

C
conn: Exported classes
Constant, ping-v0: Exported constants
Constant, pong-v0: Exported constants
Constant, recipe-info-v0: Exported constants
Constant, shutdown-worker-v0: Exported constants
Constant, start-node-request-success-v0: Exported constants
Constant, stop-worker-request-success-v0: Exported constants
Constant, worker-info-v0: Exported constants
Constant, worker-ready-v0: Exported constants
context: Exported structures
context: Exported classes

D
delivery-tag: Internal structures
dest-queue: Exported classes
dest-queue: Exported classes

E
exchange: Exported classes

F
fail-queue: Exported classes

H
host: Exported classes

I
items: Exported conditions

M
message: Exported conditions
message: Exported conditions
mmop-version: Exported conditions
mmop-version: Exported classes

N
name: Exported classes
name: Exported classes
nodes: Exported classes

O
outstanding-request-counts: Internal structures

P
password: Exported classes
ping-v0: Exported constants
pong-v0: Exported constants
port: Exported classes

R
recipe-info-v0: Exported constants
recipes: Exported structures
running: Exported structures
running: Exported classes

S
shutdown-worker-v0: Exported constants
Slot, %0: Exported structures
Slot, %0: Exported structures
Slot, %0: Exported structures
Slot, %0: Exported structures
Slot, %0: Exported structures
Slot, %0: Exported structures
Slot, %0: Exported structures
Slot, %0: Exported structures
Slot, %0: Exported structures
Slot, %0: Exported structures
Slot, %0: Exported structures
Slot, %0: Exported structures
Slot, %0: Exported structures
Slot, %0: Exported structures
Slot, %0: Exported structures
Slot, %0: Exported structures
Slot, %0: Exported structures
Slot, %0: Exported structures
Slot, %0: Exported structures
Slot, %0: Exported structures
Slot, %0: Exported structures
Slot, %0: Exported structures
Slot, %0: Exported structures
Slot, %0: Exported structures
Slot, %1: Exported structures
Slot, %1: Exported structures
Slot, %1: Exported structures
Slot, %1: Exported structures
Slot, %1: Exported structures
Slot, %1: Exported structures
Slot, %1: Exported structures
Slot, %1: Exported structures
Slot, %1: Exported structures
Slot, %1: Exported structures
Slot, %1: Exported structures
Slot, %1: Exported structures
Slot, %2: Exported structures
Slot, %2: Exported structures
Slot, %2: Exported structures
Slot, %2: Exported structures
Slot, %3: Exported structures
Slot, batch-size: Exported classes
Slot, batch-size: Exported classes
Slot, body: Internal structures
Slot, conn: Exported classes
Slot, context: Exported structures
Slot, context: Exported classes
Slot, delivery-tag: Internal structures
Slot, dest-queue: Exported classes
Slot, dest-queue: Exported classes
Slot, exchange: Exported classes
Slot, fail-queue: Exported classes
Slot, host: Exported classes
Slot, items: Exported conditions
Slot, message: Exported conditions
Slot, message: Exported conditions
Slot, mmop-version: Exported conditions
Slot, mmop-version: Exported classes
Slot, name: Exported classes
Slot, name: Exported classes
Slot, nodes: Exported classes
Slot, outstanding-request-counts: Internal structures
Slot, password: Exported classes
Slot, port: Exported classes
Slot, recipes: Exported structures
Slot, running: Exported structures
Slot, running: Exported classes
Slot, socket: Exported classes
Slot, source-queue: Exported classes
Slot, source-queue: Exported classes
Slot, step: Exported conditions
Slot, type: Exported classes
Slot, type: Exported classes
Slot, type-counts: Internal structures
Slot, username: Exported classes
Slot, workers: Exported structures
socket: Exported classes
source-queue: Exported classes
source-queue: Exported classes
Special Variable, *channel*: Internal special variables
Special Variable, *end-message*: Internal special variables
Special Variable, *end-name*: Internal special variables
Special Variable, *get-timeout*: Internal special variables
Special Variable, *internal-conn-name*: Internal special variables
Special Variable, *mmop-v0*: Exported special variables
Special Variable, *mmop-versions*: Exported special variables
Special Variable, *router-thread-name*: Internal special variables
Special Variable, *shutdown-pause*: Internal special variables
Special Variable, *start-name*: Internal special variables
Special Variable, *worker-thread-prefix*: Internal special variables
start-node-request-success-v0: Exported constants
step: Exported conditions
stop-worker-request-success-v0: Exported constants

T
type: Exported classes
type: Exported classes
type-counts: Internal structures

U
username: Exported classes

W
worker-info-v0: Exported constants
worker-ready-v0: Exported constants
workers: Exported structures

Jump to:   %   *  
B   C   D   E   F   H   I   M   N   O   P   R   S   T   U   W  

Previous: , Up: Indexes   [Contents][Index]

A.4 Data types

Jump to:   C   J   M   N   P   R   S   W  
Index Entry  Section

C
Class, node: Exported classes
Class, node-recipe: Exported classes
Class, rmq-node: Exported classes
Class, rmq-node-recipe: Exported classes
Class, rmq-worker: Exported classes
Class, worker: Exported classes
Condition, mmop-error: Exported conditions
Condition, node-error: Exported conditions

J
json-info-response-v0: Exported structures
json-info-response-v0: Exported structures

M
master: Exported structures
mmop-error: Exported conditions
monomyth: The monomyth system
monomyth/dsl: The monomyth/dsl package
monomyth/master: The monomyth/master package
monomyth/mmop: The monomyth/mmop package
monomyth/mmop-control: The monomyth/mmop-control package
monomyth/mmop-master: The monomyth/mmop-master package
monomyth/mmop-worker: The monomyth/mmop-worker package
monomyth/node: The monomyth/node package
monomyth/node-recipe: The monomyth/node-recipe package
monomyth/rmq-node: The monomyth/rmq-node package
monomyth/rmq-node-recipe: The monomyth/rmq-node-recipe package
monomyth/rmq-worker: The monomyth/rmq-worker package
monomyth/worker: The monomyth/worker package

N
node: Exported classes
node-error: Exported conditions
node-recipe: Exported classes

P
Package, monomyth/dsl: The monomyth/dsl package
Package, monomyth/master: The monomyth/master package
Package, monomyth/mmop: The monomyth/mmop package
Package, monomyth/mmop-control: The monomyth/mmop-control package
Package, monomyth/mmop-master: The monomyth/mmop-master package
Package, monomyth/mmop-worker: The monomyth/mmop-worker package
Package, monomyth/node: The monomyth/node package
Package, monomyth/node-recipe: The monomyth/node-recipe package
Package, monomyth/rmq-node: The monomyth/rmq-node package
Package, monomyth/rmq-node-recipe: The monomyth/rmq-node-recipe package
Package, monomyth/rmq-worker: The monomyth/rmq-worker package
Package, monomyth/worker: The monomyth/worker package
ping-v0: Exported structures
ping-v0: Exported structures
pong-v0: Exported structures
pong-v0: Exported structures

R
received-mmop: Exported structures
received-mmop: Exported structures
received-mmop: Exported structures
recipe-info-v0: Exported structures
recipe-info-v0: Exported structures
rmq-message: Internal structures
rmq-node: Exported classes
rmq-node-recipe: Exported classes
rmq-worker: Exported classes

S
sent-mmop: Exported structures
sent-mmop: Exported structures
sent-mmop: Exported structures
shutdown-worker-v0: Exported structures
shutdown-worker-v0: Exported structures
start-node-failure-v0: Exported structures
start-node-failure-v0: Exported structures
start-node-request-failure-v0: Exported structures
start-node-request-failure-v0: Exported structures
start-node-request-success-v0: Exported structures
start-node-request-success-v0: Exported structures
start-node-request-v0: Exported structures
start-node-request-v0: Exported structures
start-node-success-v0: Exported structures
start-node-success-v0: Exported structures
start-node-v0: Exported structures
start-node-v0: Exported structures
stop-worker-request-failure-v0: Exported structures
stop-worker-request-failure-v0: Exported structures
stop-worker-request-success-v0: Exported structures
stop-worker-request-success-v0: Exported structures
stop-worker-request-v0: Exported structures
stop-worker-request-v0: Exported structures
Structure, json-info-response-v0: Exported structures
Structure, json-info-response-v0: Exported structures
Structure, master: Exported structures
Structure, ping-v0: Exported structures
Structure, ping-v0: Exported structures
Structure, pong-v0: Exported structures
Structure, pong-v0: Exported structures
Structure, received-mmop: Exported structures
Structure, received-mmop: Exported structures
Structure, received-mmop: Exported structures
Structure, recipe-info-v0: Exported structures
Structure, recipe-info-v0: Exported structures
Structure, rmq-message: Internal structures
Structure, sent-mmop: Exported structures
Structure, sent-mmop: Exported structures
Structure, sent-mmop: Exported structures
Structure, shutdown-worker-v0: Exported structures
Structure, shutdown-worker-v0: Exported structures
Structure, start-node-failure-v0: Exported structures
Structure, start-node-failure-v0: Exported structures
Structure, start-node-request-failure-v0: Exported structures
Structure, start-node-request-failure-v0: Exported structures
Structure, start-node-request-success-v0: Exported structures
Structure, start-node-request-success-v0: Exported structures
Structure, start-node-request-v0: Exported structures
Structure, start-node-request-v0: Exported structures
Structure, start-node-success-v0: Exported structures
Structure, start-node-success-v0: Exported structures
Structure, start-node-v0: Exported structures
Structure, start-node-v0: Exported structures
Structure, stop-worker-request-failure-v0: Exported structures
Structure, stop-worker-request-failure-v0: Exported structures
Structure, stop-worker-request-success-v0: Exported structures
Structure, stop-worker-request-success-v0: Exported structures
Structure, stop-worker-request-v0: Exported structures
Structure, stop-worker-request-v0: Exported structures
Structure, worker-info: Internal structures
Structure, worker-info-v0: Exported structures
Structure, worker-info-v0: Exported structures
Structure, worker-ready-v0: Exported structures
Structure, worker-ready-v0: Exported structures
System, monomyth: The monomyth system

W
worker: Exported classes
worker-info: Internal structures
worker-info-v0: Exported structures
worker-info-v0: Exported structures
worker-ready-v0: Exported structures
worker-ready-v0: Exported structures

Jump to:   C   J   M   N   P   R   S   W