cron

README

gsf-cron

cron config json

{
  "resize_enable" : 1,
  "channel_buffer" : 100,
  "resize_duration" : 1800,
  "resize_threshold_ratio" : 3,
  "resize_threshold_limit" : 5000,
  "resize_threshold_times" : 3
}

--cron-resize-enable value           cron resize enable (default: 1)
--cron-channel-buffer value          cron change event channel buffer size (default: 100)
--cron-resize-duration value         cron resize duration (default: 1800)
--cron-resize-threshold-ratio value  cron resize threshold ratio(cap/len > ratio) (default: 3)
--cron-resize-threshold-limit value  cron resize threshold max size(cap-len > max size) (default: 3000)
--cron-resize-threshold-times value  cron resize threshold hold times (default: 3)

Documentation

Index

• Constants
• type Component
  • func (s *Component) CliFlags() []cli.Flag
  • func (s *Component) Close() error
  • func (s *Component) FreeCron(name string) error
  • func (s *Component) Init(_ logger.Interface, _ *gsf.AppConfig, _ *cli.Context) error
  • func (s *Component) NewCron(name string) (*Cron, error)
  • func (s *Component) NewCronEx(name string, bSize int) (*Cron, error)
  • func (s *Component) Run() error
• type ComponentConfig
• type Cron
  • func NewCron(h Resize, chgBuff int) *Cron
  • func (s *Cron) AddFunc(name string, sch schedule.Interface, cmd ScheduleRun)
  • func (s *Cron) AddJob(name string, sch schedule.Interface, cmd Job)
  • func (s *Cron) AddScheduleJob(name string, cmd ScheduleJob)
  • func (s *Cron) Entries() entries
  • func (s *Cron) Entry(name string) *entry
  • func (s *Cron) Job(name string) ScheduleJob
  • func (s *Cron) Remove(name string)
  • func (s *Cron) Resize()
  • func (s *Cron) Start()
  • func (s *Cron) Stop()
• type Job
• type Resize
• type ResizeIterm
  • func (r *ResizeIterm) Check(cap, len int) bool
  • func (r *ResizeIterm) NewCap(len int) int
• type ScheduleJob
• type ScheduleRun
• type WrapJob
  • func (f WrapJob) Destroy()
  • func (f WrapJob) Init()
  • func (f WrapJob) Run(t time.Time)
• type WrapScheduleJob

Constants

const (
	ScheduleEventAdd    = 1
	ScheduleEventChange = 2
	ScheduleEventRemove = 3
	ScheduleEventResize = 4
)

Types

type Component

type Component struct {
	Cfg ComponentConfig
	// contains filtered or unexported fields
}

func (*Component) CliFlags

func (s *Component) CliFlags() []cli.Flag

func (*Component) Close

func (s *Component) Close() error

func (*Component) FreeCron

func (s *Component) FreeCron(name string) error

func (*Component) Init

func (s *Component) Init(_ logger.Interface, _ *gsf.AppConfig, _ *cli.Context) error

func (*Component) NewCron

func (s *Component) NewCron(name string) (*Cron, error)

func (*Component) NewCronEx

func (s *Component) NewCronEx(name string, bSize int) (*Cron, error)

func (*Component) Run

func (s *Component) Run() error

type ComponentConfig

type ComponentConfig struct {
	ResizeEnable         int `json:"resize_enable"          yaml:"resize_enable"`
	ChannelBuffer        int `json:"channel_buffer"         yaml:"channel_buffer"`
	ResizeDuration       int `json:"resize_duration"        yaml:"resize_duration"`
	ResizeThresholdRatio int `json:"resize_threshold_ratio" yaml:"resize_threshold_ratio"`
	ResizeThresholdLimit int `json:"resize_threshold_limit" yaml:"resize_threshold_limit"`
	ResizeThresholdTimes int `json:"resize_threshold_times" yaml:"resize_threshold_times"`
}

type Cron

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

func NewCron

func NewCron(h Resize, chgBuff int) *Cron

func (*Cron) AddFunc

func (s *Cron) AddFunc(name string, sch schedule.Interface, cmd ScheduleRun)

func (*Cron) AddJob

func (s *Cron) AddJob(name string, sch schedule.Interface, cmd Job)

func (*Cron) AddScheduleJob

func (s *Cron) AddScheduleJob(name string, cmd ScheduleJob)

func (*Cron) Entries

func (s *Cron) Entries() entries

func (*Cron) Entry

func (s *Cron) Entry(name string) *entry

func (*Cron) Job

func (s *Cron) Job(name string) ScheduleJob

func (*Cron) Remove

func (s *Cron) Remove(name string)

func (*Cron) Resize

func (s *Cron) Resize()

func (*Cron) Start

func (s *Cron) Start()

func (*Cron) Stop

func (s *Cron) Stop()

type Job

type Job interface {
	Init()
	Run(time.Time)
	Destroy()
}

type Resize

type Resize interface {
	Check(cap, len int) bool
	NewCap(len int) int
}

type ResizeIterm

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

func (*ResizeIterm) Check

func (r *ResizeIterm) Check(cap, len int) bool

func (*ResizeIterm) NewCap

func (r *ResizeIterm) NewCap(len int) int

type ScheduleJob

type ScheduleJob interface {
	schedule.Interface
	Job
}

type ScheduleRun

type ScheduleRun func(t time.Time)

type WrapJob

type WrapJob ScheduleRun

func (WrapJob) Destroy

func (f WrapJob) Destroy()

func (WrapJob) Init

func (f WrapJob) Init()

func (WrapJob) Run

func (f WrapJob) Run(t time.Time)

type WrapScheduleJob

type WrapScheduleJob struct {
	Job
	schedule.Interface
}