scheduler

Documentation

Overview

Package scheduler contém os jobs que serão executados para consumir os serviços da urbs

Index

• Constants
• type AppScheduler
  • func NewAppScheduler(config config.Configurer) *AppScheduler
  • func (as *AppScheduler) Execute()
  • func (as *AppScheduler) Terminate()
• type Error
  • func (e Error) Error() string
• type Job
  • func NewJob(spec string, task func()) *Job
  • func (j *Job) Spec() string
  • func (j *Job) Task() func()
• type Jobs
• type Scheduler
• type UrbsScheduler
  • func NewUrbsScheduler(store store.Storer, config config.Configurer) (*UrbsScheduler, error)
  • func (us *UrbsScheduler) Execute()
  • func (us *UrbsScheduler) Terminate()

Constants

const (
	// ErrNoCron : "Cron não informado"
	ErrNoCron = Error("Cron não informado")
	// ErrNoUrbsCode : "Código de acesso aos serviços da urbs não encontrado."
	ErrNoUrbsCode = Error("Código de acesso aos serviços da urbs não encontrado.")
	// ErrNoServiceURL : "URL do serviço da urbs não informado."
	ErrNoServiceURL = Error("URL do serviço da urbs não informado.")
)

Types

type AppScheduler

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

AppScheduler é um scheduler para jobs da aplicação que não são referentes aos serviços da urbs.

func NewAppScheduler

func NewAppScheduler(config config.Configurer) *AppScheduler

NewAppScheduler é um construtor de um AppScheduler

func (*AppScheduler) Execute

func (as *AppScheduler) Execute()

Execute inicia a execução dos jobs do AppScheduler

func (*AppScheduler) Terminate

func (as *AppScheduler) Terminate()

Terminate finaliza a execução dos jobs do AppScheduler

type Error

type Error string

Error é um erro do pacote scheduler

func (Error) Error

func (e Error) Error() string

type Job

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

Job é um trabalho que será executado de acordo com sua especificação.

func NewJob

func NewJob(spec string, task func()) *Job

NewJob é um construtor de Job

func (*Job) Spec

func (j *Job) Spec() string

Spec getter

func (*Job) Task

func (j *Job) Task() func()

Task getter

type Jobs

type Jobs []*Job

Jobs é uma lista de jobs

type Scheduler

type Scheduler interface {
	Execute()
	Terminate()
}

Scheduler é uma interface para os agendadores de tarefas

type UrbsScheduler

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

UrbsScheduler é um agenda os jobs referentes ao serviço da urbs que serão executados.

func NewUrbsScheduler

func NewUrbsScheduler(store store.Storer, config config.Configurer) (*UrbsScheduler, error)

NewUrbsScheduler é um construtor da estrutura UrbsScheduler

func (*UrbsScheduler) Execute

func (us *UrbsScheduler) Execute()

Execute inicia a execução dos jobs do scheduler

func (*UrbsScheduler) Terminate

func (us *UrbsScheduler) Terminate()

Terminate para a execução do scheduler