heartbeat

Documentation

Index

• type Cron
  • func (c Cron) NewCronJob(month, day, weekday, hour, minute, second int8, task func(time.Time))
• type Croner
• type Heartbeat
  • func (x *Heartbeat) Process(e transistor.Event) error
  • func (x *Heartbeat) Start(e chan transistor.Event) error
  • func (x *Heartbeat) Stop()
  • func (x *Heartbeat) Subscribe() []string

Types

type Cron

type Cron struct{}

func (Cron) NewCronJob

func (c Cron) NewCronJob(month, day, weekday, hour, minute, second int8, task func(time.Time))

type Croner

type Croner interface {
	NewCronJob(month, day, weekday, hour, minute, second int8, task func(time.Time))
}

type Heartbeat

type Heartbeat struct {
	Croner
	// contains filtered or unexported fields
}

func (*Heartbeat) Process

func (x *Heartbeat) Process(e transistor.Event) error

func (*Heartbeat) Start

func (x *Heartbeat) Start(e chan transistor.Event) error

func (*Heartbeat) Stop

func (x *Heartbeat) Stop()

func (*Heartbeat) Subscribe

func (x *Heartbeat) Subscribe() []string