activeruling

Documentation

Index

• func ReadAndExecuteFowInstructions(a ...interface{})
• type Action
  • func (acn *Action) DBManager() *lnksworks.DbManager
• type ActionHandler
• type Flow
  • func NewFlow(name string, interval time.Duration) (flw *Flow)
  • func (flw *Flow) DBManager() *lnksworks.DbManager
• type FlowHandler
• type Schedule
  • func FindSchedule(schdlname string) (schdl *Schedule)
  • func RegisterSchedule(schdlname string, monduration time.Duration, ...) (schdl *Schedule)
  • func (schdl *Schedule) DisableSchedule()
  • func (schdl *Schedule) EnableSchedule()
• type Step
  • func (stp *Step) DBManager() *lnksworks.DbManager
• type StepHandler

Functions

func ReadAndExecuteFowInstructions

func ReadAndExecuteFowInstructions(a ...interface{})

Types

type Action

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

func (*Action) DBManager

func (acn *Action) DBManager() *lnksworks.DbManager

type ActionHandler

type ActionHandler = func(action *Action, step *Step, flow *Flow) (nxtaction *Action)

type Flow

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

func NewFlow

func NewFlow(name string, interval time.Duration) (flw *Flow)

func (*Flow) DBManager

func (flw *Flow) DBManager() *lnksworks.DbManager

type FlowHandler

type FlowHandler = func(flow *Flow) (nxtflow *Flow)

type Schedule

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

func FindSchedule

func FindSchedule(schdlname string) (schdl *Schedule)

func RegisterSchedule

func RegisterSchedule(schdlname string, monduration time.Duration, actions ...func(string, time.Time)) (schdl *Schedule)

func (*Schedule) DisableSchedule

func (schdl *Schedule) DisableSchedule()

func (*Schedule) EnableSchedule

func (schdl *Schedule) EnableSchedule()

type Step

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

func (*Step) DBManager

func (stp *Step) DBManager() *lnksworks.DbManager

type StepHandler

type StepHandler = func(step *Step, flow *Flow) (nxtstep *Step)