scheduledjobs

Documentation

Index

• type Partitioner
• type Service
  • func New(cfg ServiceConfig) *Service
  • func (s *Service) Get(ctx context.Context, u entities.User, uid string) (entities.ScheduledJob, []entities.Execution, error)
  • func (s *Service) Schedule(ctx context.Context, job entities.ScheduledJob) (entities.ScheduledJob, error)
• type ServiceConfig

Types

type Partitioner

type Partitioner interface {
	RLock()
	Pick() int
	RUnlock()
}

type Service

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

func New

func New(cfg ServiceConfig) *Service

func (*Service) Get

func (s *Service) Get(ctx context.Context, u entities.User, uid string) (entities.ScheduledJob, []entities.Execution, error)

func (*Service) Schedule

func (s *Service) Schedule(ctx context.Context, job entities.ScheduledJob) (entities.ScheduledJob, error)

type ServiceConfig

type ServiceConfig struct {
	Log         zerolog.Logger
	DB          *storage.DB
	Partitioner Partitioner
}