qdo

command module

v0.2.1 Latest Latest Go to latest Published: Oct 31, 2013 License: MIT Imports: 4 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/alemic/qdo

Links

Open Source Insights

README ¶

QDo

A Redis queue implementation written in Golang.

Create conveyor

curl http://127.0.0.1:8080/api/conveyor \
   -d conveyor_id=foo \
   -d workers=2 \
   -d throttle=100 \
   -d task_t_limit=60 \
   -d task_max_tries=10 \
   -d log_size=100

Update conveyor

curl http://127.0.0.1:8080/api/conveyor/foo \
   -d paused=true

Delete conveyor

curl -X DELETE http://127.0.0.1:8080/api/conveyor/foo

Create task

curl http://127.0.0.1:8080/api/conveyor/foo/task \
   -d target=http://127.0.0.1/mytask \
   -d "payload={'foo': 'bar'}"

Create scheduled task

curl http://127.0.0.1:8080/api/conveyor/foo/task \
   -d target=http://127.0.0.1/mytask \
   -d scheduled=1399999999 \
   -d "payload={'foo': 'bar'}"

Create recurring task

curl http://127.0.0.1:8080/api/conveyor/foo/task \
   -d target=http://127.0.0.1/mytask \
   -d recurring=60 \
   -d "payload={'foo': 'bar'}"

Delete all tasks

curl -X DELETE http://127.0.0.1:8080/api/conveyor/foo/task

Documentation ¶

There is no documentation for this package.

Source Files ¶

View all Source files

qdo.go

Directories ¶

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL

Path	Synopsis
lib
log gist.github.com/alphazero/2718939 a very thin convenience wrapper over go's log package that also alters the semantics of go log's Error and Fatal: none of the functions of this package will ever panic() or call os.Exit().	gist.github.com/alphazero/2718939 a very thin convenience wrapper over go's log package that also alters the semantics of go log's Error and Fatal: none of the functions of this package will ever panic() or call os.Exit().
queue
web
third_party
code.google.com/p/snappy-go/snappy Package snappy implements the snappy block-based compression format.	Package snappy implements the snappy block-based compression format.
github.com/gorilla/context Package gorilla/context stores values shared during a request lifetime.	Package gorilla/context stores values shared during a request lifetime.
github.com/gorilla/mux Package gorilla/mux implements a request router and dispatcher.	Package gorilla/mux implements a request router and dispatcher.
github.com/syndtr/goleveldb/leveldb Package leveldb provides implementation of LevelDB key/value database.	Package leveldb provides implementation of LevelDB key/value database.
github.com/syndtr/goleveldb/leveldb/cache Package cache provides interface and implementation of a cache algorithms.	Package cache provides interface and implementation of a cache algorithms.
github.com/syndtr/goleveldb/leveldb/comparer Package comparer provides interface and implementation for ordering sets of data.	Package comparer provides interface and implementation for ordering sets of data.
github.com/syndtr/goleveldb/leveldb/filter Package filter provides interface and implementation of probabilistic data structure.	Package filter provides interface and implementation of probabilistic data structure.
github.com/syndtr/goleveldb/leveldb/iterator Package iterator provides interface and implementation to traverse over contents of a database.	Package iterator provides interface and implementation to traverse over contents of a database.
github.com/syndtr/goleveldb/leveldb/journal Package journal reads and writes sequences of journals.	Package journal reads and writes sequences of journals.
github.com/syndtr/goleveldb/leveldb/memdb Package memdb provides in-memory key/value database implementation.	Package memdb provides in-memory key/value database implementation.
github.com/syndtr/goleveldb/leveldb/opt Package opt provides sets of options used by LevelDB.	Package opt provides sets of options used by LevelDB.
github.com/syndtr/goleveldb/leveldb/storage Package storage provides storage abstraction for LevelDB.	Package storage provides storage abstraction for LevelDB.
github.com/syndtr/goleveldb/leveldb/table Package table allows read and write sorted key/value.	Package table allows read and write sorted key/value.
github.com/syndtr/goleveldb/leveldb/util Package util provides utilities used throughout leveldb.	Package util provides utilities used throughout leveldb.
github.com/syndtr/goleveldb/manualtest/filelock