example

package

v0.1.8 Latest Latest Go to latest Published: May 30, 2022 License: MIT Imports: 10 Imported by: 0

Details

This section is empty.

View Source

var CountHandler, _ = disq.RegisterTask(&disq.TaskOptions{
	Name:       "CountHandler",
	Handler:    counthandler(),
	RetryLimit: 3,
})

create task

View Source

var RBroker1 = NewBroker(Redis, 1000, "disq10")

View Source

var RBroker2 = NewBroker(Redis, 100, "disq9")

View Source

var RBroker3 = NewBroker(Redis, 10, "disq8")

View Source

var RWorker = NewWorker(Redis, []disq.Broker{RBroker1.Broker, RBroker2.Broker, RBroker3.Broker})

View Source

var (
	Redis, _ = NewClient()
)

func NewClient() (*redis.Client, error)

Create Redis client

func WaitSignal() os.Signal

type EndpointError struct {
	Err error
	// contains filtered or unexported fields
}

func (e *EndpointError) Delay() time.Duration

func (e *EndpointError) Error() string

type MsgValue struct {
	Name  string
	Value string
}

type RedisBroker struct {
	Name   string
	Broker disq.Broker
	// contains filtered or unexported fields
}

func NewBroker(c *redis.Client, concurency int, name string) *RedisBroker

Create new broker

type Worker struct {
	Worker *worker.Worker
	// contains filtered or unexported fields
}

func NewWorker(c *redis.Client, brokers []disq.Broker) *Worker

create new worker

Path	Synopsis
consumer
publisher