worker

package

v0.2.0 Latest Latest Go to latest Published: Sep 19, 2024 License: GPL-3.0 Imports: 11 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 New(cfg *lib.Config, log *zap.Logger) (*Worker, error)

func (wrk *Worker) ExecuteXMPP(args map[string]string, m messages.Request) error

func (wrk *Worker) HandleMessage(ctx context.Context, t *asynq.Task) error

func (wrk *Worker) Run()

func (wrk *Worker) Shutdown() error