cronscheduler

Documentation

Index

• func AsynqPauseQueues(ctx context.Context) error
• func AsynqUnpauseQueues(ctx context.Context) error
• func InitFileServerDatabase()
• func RunDisplayError(ctx context.Context, session neo4j.SessionWithContext, statement string)
• type AsynqQueueState
  • func NewAsynqQueueState(ns directory.NamespaceID, timeout time.Duration) *AsynqQueueState
  • func (qs *AsynqQueueState) Run()
• type CronJobs
• type Jobs
• type ScheduledJobs
• type Scheduler
  • func NewScheduler() (*Scheduler, error)
  • func (s *Scheduler) AddJobs(ctx context.Context) error
  • func (s *Scheduler) Init()
  • func (s *Scheduler) RemoveJobs(ctx context.Context) error
  • func (s *Scheduler) Run()

Functions

func AsynqPauseQueues

func AsynqPauseQueues(ctx context.Context) error

func AsynqUnpauseQueues

func AsynqUnpauseQueues(ctx context.Context) error

func InitFileServerDatabase

func InitFileServerDatabase()

func RunDisplayError

func RunDisplayError(ctx context.Context, session neo4j.SessionWithContext, statement string)

Types

type AsynqQueueState

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

func NewAsynqQueueState

func NewAsynqQueueState(ns directory.NamespaceID, timeout time.Duration) *AsynqQueueState

func (*AsynqQueueState) Run

func (qs *AsynqQueueState) Run()

type CronJobs

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

type Jobs

type Jobs struct {
	CronJobs           map[directory.NamespaceID]CronJobs
	CronJobsMutex      sync.Mutex
	ScheduledJobs      map[directory.NamespaceID]ScheduledJobs
	ScheduledJobsMutex sync.Mutex
}

type ScheduledJobs

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

type Scheduler

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

func NewScheduler

func NewScheduler() (*Scheduler, error)

func (*Scheduler) AddJobs

func (s *Scheduler) AddJobs(ctx context.Context) error

func (*Scheduler) Init

func (s *Scheduler) Init()

func (*Scheduler) RemoveJobs

func (s *Scheduler) RemoveJobs(ctx context.Context) error

func (*Scheduler) Run

func (s *Scheduler) Run()