worker

Documentation

Index

• Constants
• Variables
• type Worker
  • func NewWorker(config config.WorkerConfig, logger log.Logger, ...) *Worker
  • func (w *Worker) OnStart(ctx context.Context) error
  • func (w *Worker) OnStop(ctx context.Context) error

Constants

const (
	TaskQueue = "ticketfu-queue"
)

Variables

var Module = fx.Options(
	fx.Provide(NewWorker),
	fx.Provide(temporal.NewClient),
	fx.Provide(zendesk.NewClient),
	fx.Provide(genai.NewAPI),
	fx.Provide(webhook.NewActivity),
	fx.Provide(ticket.NewActivity),
	fx.Provide(org.NewActivity),
	fx.Invoke(func(lc fx.Lifecycle, worker *Worker) {
		lc.Append(fx.Hook{
			OnStart: worker.OnStart,
			OnStop:  worker.OnStop,
		})
	}),
)

Module registers the worker with fx

Types

type Worker

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

func NewWorker

func NewWorker(
	config config.WorkerConfig,
	logger log.Logger,
	webhookActivity *webhook.Activity,
	ticketActivity *ticket.Activity,
	organizationActivity *org.Activity,
	tClient client.Client,
) *Worker

func (*Worker) OnStart

func (w *Worker) OnStart(ctx context.Context) error

Start initializes and starts the worker

func (*Worker) OnStop

func (w *Worker) OnStop(ctx context.Context) error

Stop gracefully shuts down the worker