scheduler

Documentation

Index

• Constants
• Variables
• func NewLoggingService(logger zerolog.Logger, s schedulingpb.SchedulingServer) schedulingpb.SchedulingServer
• func NewService(logger zerolog.Logger, repository Repository, queue *nats.EncodedConn) (schedulingpb.SchedulingServer, error)
• type Repository
  • func NewRepository(url string) (Repository, error)
• type Scheduler
  • func NewScheduler(logger zerolog.Logger, queue *nats.EncodedConn) Scheduler

Constants

const (
	DatabaseName = "treediagram_scheduler"
)

Variables

var (
	JobsSubject          = "jobs"
	SchedulerTickSubject = "scheduler.tick"
	SchedulerQueueGroup  = "scheduler"
)

Functions

func NewLoggingService

func NewLoggingService(logger zerolog.Logger, s schedulingpb.SchedulingServer) schedulingpb.SchedulingServer

func NewService

func NewService(logger zerolog.Logger, repository Repository, queue *nats.EncodedConn) (schedulingpb.SchedulingServer, error)

Types

type Repository

type Repository interface {
	Create(*schedulingpb.Job) error
	Jobs(*schedulingpb.Schedule) ([]*schedulingpb.Job, error)
	Disable(id string) error
	Migrate() error
}

func NewRepository

func NewRepository(url string) (Repository, error)

type Scheduler

type Scheduler interface {
	Start()
	Stop()
}

func NewScheduler

func NewScheduler(logger zerolog.Logger, queue *nats.EncodedConn) Scheduler