worker

Documentation

Index

• type Params
• type Worker
  • func NewWorker(p Params) (*Worker, error)
  • func (w *Worker) ResumeCluster(ch <-chan amqp.Delivery) error

Types

type Params

type Params struct {
	fx.In

	LC fx.Lifecycle

	Logger     *slog.Logger
	RabbitMQ   *rabbitmq.Client
	DB         *database.DB
	Notifier   notification.Notifier
	ClusterSvc *cluster.Service
}

type Worker

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

func NewWorker

func NewWorker(p Params) (*Worker, error)

func (*Worker) ResumeCluster

func (w *Worker) ResumeCluster(ch <-chan amqp.Delivery) error