Versions in this module Expand all Collapse all v0 v0.1.8 May 30, 2022 Changes in this version + type Worker struct + func NewWorker(brokers []disq.Broker) *Worker + func (w *Worker) AddMany(ctx context.Context, brokers []disq.Broker) error + func (w *Worker) AddOne(ctx context.Context, broker disq.Broker) error + func (w *Worker) Contains(name string) bool + func (w *Worker) DeleteMany(names []string) error + func (w *Worker) DeleteOne(name string) error + func (w *Worker) GetAllStats() map[string]*disq.Stats + func (w *Worker) GetOneStat(name string) (*disq.Stats, error) + func (w *Worker) LoadAll() map[string]disq.Broker + func (w *Worker) LoadOne(name string) (disq.Broker, error) + func (w *Worker) Name() string + func (w *Worker) SetName(name string) + func (w *Worker) StartAll(ctx context.Context) + func (w *Worker) StartOne(ctx context.Context, name string) error + func (w *Worker) StopAll() error + func (w *Worker) StopOne(name string) error + func (w *Worker) UpdateMany(ctx context.Context, brokers []disq.Broker) error + func (w *Worker) UpdateOne(ctx context.Context, broker disq.Broker) error
Go to main page