worker

package

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

Details

This section is empty.

This section is empty.

This section is empty.

type Worker struct {
	// contains filtered or unexported fields
}

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