channel_info_worker

Documentation

Index

• type ChannelInfoWorker
  • func New(slackClient *slack.Client, db *pgxpool.Pool) *ChannelInfoWorker
  • func (w *ChannelInfoWorker) Work(ctx context.Context, job *river.Job[background.ChannelInfoWorkerArgs]) error

Types

type ChannelInfoWorker

type ChannelInfoWorker struct {
	river.WorkerDefaults[background.ChannelInfoWorkerArgs]
	// contains filtered or unexported fields
}

func New

func New(slackClient *slack.Client, db *pgxpool.Pool) *ChannelInfoWorker

func (*ChannelInfoWorker) Work

func (w *ChannelInfoWorker) Work(ctx context.Context, job *river.Job[background.ChannelInfoWorkerArgs]) error