jobs

Documentation

Index

• type Service
  • func New(connector *view.Connector) *Service
  • func (s *Service) AddFailedJob(job *async.Job)
  • func (s *Service) CreateJob(ctx context.Context, job *async.Job) error
  • func (s *Service) EnsureJobTables(ctx context.Context) error
  • func (s *Service) Init(ctx context.Context) error
  • func (s *Service) JobById(ctx context.Context, jobID string) (*async.Job, error)
  • func (s *Service) JobByMatchKey(ctx context.Context, matchKey string, ttl time.Duration, ttlErr time.Duration) (*async.Job, error)
  • func (s *Service) UpdateJob(ctx context.Context, job *async.Job) error

Types

type Service

type Service struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func New

func New(connector *view.Connector) *Service

New returns a service

func (*Service) AddFailedJob

func (s *Service) AddFailedJob(job *async.Job)

func (*Service) CreateJob

func (s *Service) CreateJob(ctx context.Context, job *async.Job) error

func (*Service) EnsureJobTables

func (s *Service) EnsureJobTables(ctx context.Context) error

func (*Service) Init

func (s *Service) Init(ctx context.Context) error

func (*Service) JobById

func (s *Service) JobById(ctx context.Context, jobID string) (*async.Job, error)

func (*Service) JobByMatchKey

func (s *Service) JobByMatchKey(ctx context.Context, matchKey string, ttl time.Duration, ttlErr time.Duration) (*async.Job, error)

func (*Service) UpdateJob

func (s *Service) UpdateJob(ctx context.Context, job *async.Job) error

default ->, description -> validate: required, ptr vs non-ptr