Documentation
¶
Index ¶
- func Filter(vs []string, f func(string) bool) []string
- func KMap(vs []string, f func(string) string) map[string]string
- func ListFiles(dir string) []string
- func Map(vs []string, f func(string) string) []string
- func NewKeepAliveManager(taskname string, zmqAddress string) *keepAliveManager
- func ZmqPubSubProxy(host string, portIn int, portOut int, logger *log.Logger)
- func ZmqReadPartN(s *zmq.Socket, n int, buf *[]byte)
- func ZmqRecvMulti(s *zmq.Socket) []string
- func ZmqSendMulti(s *zmq.Socket, msg []string)
- type JobqueueHTTPClient
- func (client *JobqueueHTTPClient) List() (string, error)
- func (client *JobqueueHTTPClient) ListAsList() []string
- func (client *JobqueueHTTPClient) ListWorkers(name string) (string, error)
- func (client *JobqueueHTTPClient) Open(url string) (string, error)
- func (client *JobqueueHTTPClient) Set(name string, param string, value string) (string, error)
- func (client *JobqueueHTTPClient) Start(name string) (string, error)
- func (client *JobqueueHTTPClient) Status(name string) (string, error)
- func (client *JobqueueHTTPClient) Stop(name string) (string, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func KMap ¶
KMap calls a function on all the items in a string array and returns the results as a map, containing the original string as key
func NewKeepAliveManager ¶
NewKeepAliveManager initialise a ZeroMQ socket and the keep-alive message to send
func ZmqPubSubProxy ¶
ZmqPubSubProxy Implements a many-to-many device on a zmq PUB-SUB connection
func ZmqReadPartN ¶
ZmqReadPartN reads a multi-part message but only writes the requested part into the provided buffer
func ZmqRecvMulti ¶
ZmqRecvMulti Receives a multi-part message and return it as a slice of strings
func ZmqSendMulti ¶
ZmqSendMulti Sends a slice of strings as a multi-part message
Types ¶
type JobqueueHTTPClient ¶
JobqueueHTTPClient provides some utility methods to communicate with the Task Manager runner via HTTP
func (*JobqueueHTTPClient) List ¶
func (client *JobqueueHTTPClient) List() (string, error)
List the task managers listening at this address
func (*JobqueueHTTPClient) ListAsList ¶
func (client *JobqueueHTTPClient) ListAsList() []string
ListAsList returns a list of task names (as a string slice)
func (*JobqueueHTTPClient) ListWorkers ¶
func (client *JobqueueHTTPClient) ListWorkers(name string) (string, error)
ListWorkers gets the status of each worker process for a given task
func (*JobqueueHTTPClient) Open ¶
func (client *JobqueueHTTPClient) Open(url string) (string, error)
Open an HTTP connection to control the task manager runner
func (*JobqueueHTTPClient) Start ¶
func (client *JobqueueHTTPClient) Start(name string) (string, error)
Start a stopped task
Source Files