example

Documentation

Index

• Variables
• func NewClient() (*redis.Client, error)
• func WaitSignal() os.Signal
• type EndpointError
  • func (e *EndpointError) Delay() time.Duration
  • func (e *EndpointError) Error() string
• type MsgValue
• type RedisBroker
  • func NewBroker(c *redis.Client, concurency int, name string) *RedisBroker
• type Worker
  • func NewWorker(c *redis.Client, brokers []disq.Broker) *Worker

Variables

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

create task

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

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

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

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

var (
	Redis, _ = NewClient()
)

Functions

func NewClient

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

Create Redis client

func WaitSignal

func WaitSignal() os.Signal

Types

type EndpointError

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

func (*EndpointError) Delay

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

func (*EndpointError) Error

func (e *EndpointError) Error() string

type MsgValue

type MsgValue struct {
	Name  string
	Value string
}

type RedisBroker

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

func NewBroker

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

Create new broker

type Worker

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

func NewWorker

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

create new worker