chore: update readme (#3)
parent
d626b2d623
commit
8d8a7a12f5
53
README.md
53
README.md
|
@ -1 +1,52 @@
|
|||
# machinery-plugins
|
||||
# machinery-plugins
|
||||
|
||||
This project is intended to provide multi broker, lock, backend for the [RichardKnop/machinery](https://github.com/RichardKnop/machinery) library. About
|
||||
Machinery is an asynchronous task queue/job queue based on distributed message passing. This plugins library offers additional functionalities and tools to help you better utilize and customize Machinery.
|
||||
|
||||
## Features
|
||||
This library provides the following features:
|
||||
|
||||
- `Brokers`: add etcd / mysql
|
||||
- `Locks`: add etcd / mysql
|
||||
- `Backends`: add etcd / mysql
|
||||
|
||||
you can combine whatever you want
|
||||
|
||||
## Quick Start
|
||||
|
||||
Install the library:
|
||||
|
||||
```
|
||||
go get github.com/ifooth/machinery-plugins@latest
|
||||
```
|
||||
|
||||
Import the library in your code and use it to create tasks:
|
||||
|
||||
|
||||
```go
|
||||
import (
|
||||
"github.com/RichardKnop/machinery/v2"
|
||||
redisbackend "github.com/RichardKnop/machinery/v2/backends/redis"
|
||||
eagerlock "github.com/RichardKnop/machinery/v2/locks/eager"
|
||||
etcdbroker "github.com/ifooth/machinery-plugins/brokers/etcd"
|
||||
)
|
||||
|
||||
func main() {
|
||||
// Create server instance
|
||||
// broker := redisbroker.NewGR(cnf, []string{"localhost:6379"}, 1)
|
||||
broker, err := etcdbroker.New(cnf, "http://127.0.0.1:2379")
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
lock := eagerlock.New()
|
||||
backend := redisbackend.NewGR(cnf, []string{"localhost:6379"}, 3)
|
||||
server := machinery.NewServer(cnf, broker, backend, lock)
|
||||
}
|
||||
```
|
||||
|
||||
## Contributing
|
||||
We welcome contributions in any form! If you have any issues, suggestions, or wish to add new features, let us know by creating an issue or pull request.
|
||||
|
||||
## License
|
||||
machinery-plugins is based on the Apache 2.0 protocol. Please refer to [LICENSE](./LICENSE) for details.
|
Loading…
Reference in New Issue