lib_gc_runner

type Runner_I interface {
	Start() error
	Shutdown() error
	WakeUpTask(Task_I, ...interface{}) error
	IsTaskRunning(int64) (bool, error)
	GetRunningTasksIDs() ([]int64, error)
	FinishTaskById(int64) error
}

type RunningTask struct {
	Task          Task_I
	Args          []interface{}
	FirstWakingUp time.Time
	RunningFrom   []time.Time
}

type TASK_IMPLEMENTATION func(chan struct{}, TaskManager_I, []interface{}) ([]interface{}, error)

type Task struct {
	Id             int64
	Duration       time.Duration
	Implementation TASK_IMPLEMENTATION

	Eot          chan struct{}
	Response     *TaskResponse
	ResponseChan chan *TaskResponse
	// contains filtered or unexported fields
}

type TaskManager_I interface {
	Finish()
	Flush()
}

type TaskResponse struct {
	Result interface{}
	Err    error
}

type Task_I interface {
	GetID() int64
	GetDuration() time.Duration
	GetResponseChan() chan *TaskResponse
	Run(args []interface{}) error
	IsRunning() bool
	IsFinished() bool
	Finalize() error
	Flush()
}