top

Package jobqueue provides server/client functions to interact with the queue structure provided by the queue package over a network.

It provides a job queue and running system which guarantees: # Created jobs are never lost accidentally. # The same job will not run more than once simultaneously:

- Duplicate jobs are not created
- Each job is handled by only a single client

# Jobs are handled in the desired order (user priority and fifo). # Jobs still get run despite crashing clients. # Completed jobs are kept forever for historical purposes.

This file contains all the functions for clients to interact with the server. See server.go for the functions needed to implement a server executable.

Imported by 1 package(s)

  1. github.com/VertebrateResequencing/wr/cmd

Imports 13 package(s)

  1. github.com/hashicorp/golang-lru
  2. github.com/gorilla/websocket
  3. github.com/grafov/bcast
  4. github.com/go-mangos/mangos
  5. github.com/ugorji/go/codec
  6. github.com/boltdb/bolt
  7. github.com/satori/go.uuid
  8. github.com/go-mangos/mangos/protocol/rep
  9. github.com/VertebrateResequencing/wr/jobqueue/scheduler
  10. github.com/go-mangos/mangos/protocol/req
  11. github.com/VertebrateResequencing/wr/queue
  12. github.com/go-mangos/mangos/transport/tcp
  13. github.com/dgryski/go-farm

Test imports 3 package(s)

  1. github.com/sevlyar/go-daemon
  2. github.com/smartystreets/goconvey/convey
  3. github.com/VertebrateResequencing/wr/internal