cron

Documentation

Index

• type Config
• type Struct
  • func Start(config Config) *Struct
  • func (cron *Struct) AddTask(dataInterface interface{}) error
• type TaskStruct
• type Worker

Types

type Config

type Config struct {
	MaxQueueSize int    // максимальное количество задач, которое может быть в очереди
	WorkerCount  int    // количество воркеров
	WorkerFunc   Worker // воркер
}

конфигурация крона

type Struct

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

структура крона

func Start

func Start(config Config) *Struct

запускаем крон

func (*Struct) AddTask

func (cron *Struct) AddTask(dataInterface interface{}) error

добавляем задачу в крон

type TaskStruct

type TaskStruct struct {
	DataInterface interface{} // интерфес содержащий любые данные
}

структура задачи

type Worker

type Worker func(*TaskStruct)

функция воркера