workermanager

type Config struct {
	Enabled           bool          `mapstructure:"enabled"`
	WorkerCount       int           `mapstructure:"worker_count" default:"3"`
	PollInterval      time.Duration `mapstructure:"poll_interval" default:"500ms"`
	ActivePollPercent float64       `mapstructure:"active_poll_percent" default:"20"`
	PGQ               pgq.Config    `mapstructure:"pgq"`
	JobManagerPort    int           `mapstructure:"job_manager_port"`
	SyncJobTimeout    time.Duration `mapstructure:"sync_job_timeout" default:"15m"`
	IndexJobTimeout   time.Duration `mapstructure:"index_job_timeout" default:"5s"`
	DeleteJobTimeout  time.Duration `mapstructure:"delete_job_timeout" default:"5s"`
	MaxAttemptRetry   int           `mapstructure:"max_attempt_retry" default:"3"`
}

type Deps struct {
	Config        Config
	DiscoveryRepo DiscoveryRepository
	AssetRepo     asset.Repository
	Logger        log.Logger
}

type DiscoveryRepository interface {
	Upsert(context.Context, asset.Asset) error
	DeleteByURN(ctx context.Context, assetURN string) error
	SoftDeleteByURN(ctx context.Context, params asset.SoftDeleteAssetParams) error
	DeleteByQueryExpr(ctx context.Context, queryExpr queryexpr.ExprStr) error
	DeleteByIsDeletedAndServicesAndUpdatedAt(ctx context.Context, isDeleted bool, services []string, expiryThreshold time.Time) error
	SoftDeleteAssets(ctx context.Context, assets []asset.Asset, doUpdateVersion bool) error
	SyncAssets(ctx context.Context, indexName string) (cleanupFn func() error, err error)
}

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

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

type Worker interface {
	Register(typ string, h worker.JobHandler) error
	Run(ctx context.Context) error
	Enqueue(ctx context.Context, jobs ...worker.JobSpec) error
	GetSyncJobsByService(ctx context.Context, service string) ([]worker.Job, error)
}