README
¶
What's in the pkg
api
High-level calls used by Toolbelt and Webapi
cql
CQL query builder. Focused purely on the language side, all connectivity functionality in pkg/db.
ctx
Processing context used across all levels of RabbitMQ message processing
custom
Custom processors:
db
Cassandra-specific
dpc
env
Environment configuration for Capillaries binaries
eval
Go expression evaluation engine
exe
Capillaries binaries
l
Logging
proc
Core script node processor
sc
Capillaries Script configuration objects
storage
Working with external media (files, maybe databases in the future)
wf
RabbitMQ messages handled here
wfdb
Workflow db access functions
wfmodel
Workflow model
xfer
SSH/HTTP/SFTP utility functions used by processors
Directories
¶
| Path | Synopsis |
|---|---|
|
Package api contains functions used by Toolbelt, Webapi and third party solutions to start/stop runs and to analyze process state by reading node and batch status.
|
Package api contains functions used by Toolbelt, Webapi and third party solutions to start/stop runs and to analyze process state by reading node and batch status. |
|
Package cql contains functions for building CQL statements
|
Package cql contains functions for building CQL statements |
|
Package ctx contains definition of the message processing context object that holds batch message information, database connection, current script node definition and logging details.
|
Package ctx contains definition of the message processing context object that holds batch message information, database connection, current script node definition and logging details. |
|
Package custom contains definitions of Capillaries custom processors
|
Package custom contains definitions of Capillaries custom processors |
|
py_calc
Package py_calc contains definition of the custom processor py_calc
|
Package py_calc contains definition of the custom processor py_calc |
|
tag_and_denormalize
Package tag_and_denormalize contains definition of the custom processor tag_and_denormalize
|
Package tag_and_denormalize contains definition of the custom processor tag_and_denormalize |
|
Package db contains helper functions for working with Cassandra
|
Package db contains helper functions for working with Cassandra |
|
Package dpc contains definition of dependency policy checker
|
Package dpc contains definition of dependency policy checker |
|
Package env contains functions for working with environment configuration (capidaemon.json, capitoolbelt.json, capiwebapi.json)
|
Package env contains functions for working with environment configuration (capidaemon.json, capitoolbelt.json, capiwebapi.json) |
|
Package eval contains functions and classes used for evaluating Go expressions used in Capillaries scripts
|
Package eval contains functions and classes used for evaluating Go expressions used in Capillaries scripts |
|
Directory exe contains source code for Capillaries binaries: capidaemon, capiwebapi, capitoolbelt
|
Directory exe contains source code for Capillaries binaries: capidaemon, capiwebapi, capitoolbelt |
|
daemon
Directory daemon contains source code for Capillaries daemon
|
Directory daemon contains source code for Capillaries daemon |
|
toolbelt
Directory toolbelt contains source code for Capillaries toolbelt
|
Directory toolbelt contains source code for Capillaries toolbelt |
|
webapi
Directory webapi contains source code for Capillaries webapi
|
Directory webapi contains source code for Capillaries webapi |
|
Package l contains helper logging functions
|
Package l contains helper logging functions |
|
Package proc contains classes and functions that process script nodes and write results to tables or files
|
Package proc contains classes and functions that process script nodes and write results to tables or files |
|
Package sc contains definitions and functions for parsing Capillaries scripts
|
Package sc contains definitions and functions for parsing Capillaries scripts |
|
Package storage contains functions that work with external data
|
Package storage contains functions that work with external data |
|
Package wf contains functions that implement node processing workflow based on RabbitMQ messages
|
Package wf contains functions that implement node processing workflow based on RabbitMQ messages |
|
Package wfdb contains functions for saving/retrieving workflow model classes to/from the database
|
Package wfdb contains functions for saving/retrieving workflow model classes to/from the database |
|
Package wfmodel contains definitions of workflow model
|
Package wfmodel contains definitions of workflow model |
|
Package xfer contains functions for secure file stransfer
|
Package xfer contains functions for secure file stransfer |
Click to show internal directories.
Click to hide internal directories.