Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

workermanager

package

Go to main page

Versions in this module

v0

v0.7.3

Jan 5, 2024

Changes in this version

type Config

+ DeleteJobTimeout time.Duration

+ IndexJobTimeout time.Duration

+ SyncJobTimeout time.Duration

v0.7.2

Jan 4, 2024

v0.7.1

Dec 12, 2023

v0.7.0

Dec 11, 2023

Changes in this version

type Deps

+ AssetRepo asset.Repository

type DiscoveryRepository

+ SyncAssets func(ctx context.Context, indexName string) (cleanupFn func() error, err error)

type InSituWorker

+ func (m *InSituWorker) EnqueueSyncAssetJob(ctx context.Context, service string) error

type Manager

+ func (m *Manager) EnqueueSyncAssetJob(ctx context.Context, service string) error

+ func (m *Manager) SyncAssets(ctx context.Context, job worker.JobSpec) error

type Worker

+ GetSyncJobsByService func(ctx context.Context, service string) ([]worker.Job, error)

v0.6.5

Nov 8, 2023

v0.6.4

Oct 23, 2023

v0.6.3

Oct 9, 2023

v0.6.2

Oct 6, 2023

v0.6.1

Aug 21, 2023

v0.6.0

Aug 16, 2023

Changes in this version

+ type Config struct

+ ActivePollPercent float64

+ Enabled bool

+ JobManagerPort int

+ PGQ pgq.Config

+ PollInterval time.Duration

+ WorkerCount int

+ type Deps struct

+ Config Config

+ DiscoveryRepo DiscoveryRepository

+ Logger log.Logger

+ type DiscoveryRepository interface

+ DeleteByURN func(ctx context.Context, assetURN string) error

+ Upsert func(context.Context, asset.Asset) error

+ type InSituWorker struct

+ func NewInSituWorker(deps Deps) *InSituWorker

+ func (*InSituWorker) Close() error

+ func (m *InSituWorker) EnqueueDeleteAssetJob(ctx context.Context, urn string) error

+ func (m *InSituWorker) EnqueueIndexAssetJob(ctx context.Context, ast asset.Asset) error

+ type Manager struct

+ func New(ctx context.Context, deps Deps) (*Manager, error)

+ func NewWithWorker(w Worker, deps Deps) *Manager

+ func (m *Manager) Close() error

+ func (m *Manager) DeleteAsset(ctx context.Context, job worker.JobSpec) error

+ func (m *Manager) EnqueueDeleteAssetJob(ctx context.Context, urn string) error

+ func (m *Manager) EnqueueIndexAssetJob(ctx context.Context, ast asset.Asset) error

+ func (m *Manager) IndexAsset(ctx context.Context, job worker.JobSpec) error

+ func (m *Manager) Run(ctx context.Context) error

+ type Worker interface

+ Enqueue func(ctx context.Context, jobs ...worker.JobSpec) error

+ Register func(typ string, h worker.JobHandler) error

+ Run func(ctx context.Context) error