queue

package

v1.0.0 Latest Latest Go to latest Published: May 24, 2026 License: MIT Imports: 14 Imported by: 0

Details

View Source

const (
	TopicExtraction = "extraction-tasks"
	TopicSync       = "sync-tasks"
	TopicHealth     = "health-check-tasks"
)

This section is empty.

This section is empty.

type ExtractionTask struct {
	Platform string `json:"platform"`
}

type Queue struct {
	Producer *kafka.Writer
	DB       *pgxpool.Pool
	Syncer   *sync.Syncer
	// contains filtered or unexported fields
}

func New(cfg *config.Config, db *pgxpool.Pool, syncer *sync.Syncer) (*Queue, error)

func (q *Queue) Close() error

func (q *Queue) Drain()

func (q *Queue) Health(ctx context.Context) error

func (q *Queue) PublishExtractionTask(ctx context.Context, platform string) error

func (q *Queue) PublishSyncTask(ctx context.Context, userID int) error

func (q *Queue) StartConsumers(ctx context.Context, cfg *config.Config)

type SyncTask struct {
	UserID int `json:"user_id"`
}

type TaskType string

const (
	TaskExtraction TaskType = "extraction"
	TaskSync       TaskType = "sync"
)