redis

Oct 28, 2019

Changes in this version

type Broker

+ func (b *Broker) ConsumeHeartbeat() (*monitor.Heartbeat, error)

+ func (b *Broker) SendHeartbeat(ctx context.Context, heartbeat *monitor.Heartbeat) error

type BrokerGR

+ func (b *BrokerGR) ConsumeHeartbeat() (*monitor.Heartbeat, error)

+ func (b *BrokerGR) SendHeartbeat(ctx context.Context, heartbeat *monitor.Heartbeat) error

Oct 24, 2019

Changes in this version

type Broker

+ func (b *Broker) AddCycleTask(signature *tasks.Signature) (*tasks.Signature, error)

+ func (b *Broker) DeleteCycleTask(uuid string) error

+ func (b *Broker) GetCycleTasks(queue string) ([]*tasks.Signature, error)

type BrokerGR

+ func (b *BrokerGR) AddCycleTask(signature *tasks.Signature) (*tasks.Signature, error)

+ func (b *BrokerGR) DeleteCycleTask(uuid string) error

+ func (b *BrokerGR) GetCycleTasks(queue string) ([]*tasks.Signature, error)

Oct 15, 2019

Changes in this version

+ func New(cnf *config.Config, host, password, socketPath string, db int) iface.Broker

+ func NewGR(cnf *config.Config, addrs []string, db int) iface.Broker

+ type Broker struct

+ func (b *Broker) GetPendingTasks(queue string) ([]*tasks.Signature, error)

+ func (b *Broker) Publish(ctx context.Context, signature *tasks.Signature) error

+ func (b *Broker) StartConsuming(consumerTag string, concurrency int, taskProcessor iface.TaskProcessor) (bool, error)

+ func (b *Broker) StopConsuming()

+ type BrokerGR struct

+ func (b *BrokerGR) GetPendingTasks(queue string) ([]*tasks.Signature, error)

+ func (b *BrokerGR) Publish(ctx context.Context, signature *tasks.Signature) error

+ func (b *BrokerGR) StartConsuming(consumerTag string, concurrency int, taskProcessor iface.TaskProcessor) (bool, error)

+ func (b *BrokerGR) StopConsuming()