cmn

type App struct {
	Database        *database.Database
	Channel         chan os.Signal
	Config          *model.Config
	Logger          *utils.Logger
	ChannelRabbitMq *ChannelRabbitMq
	ChannelRedis    *ChannelRedis
	Scheduler       *Scheduler
	Mode            model.MODE
	Job             *Job
	Node            *model2.Node
}

type ChannelInterface interface {
	Start()
	Subscribe()
	Receive()
}

type ChannelRabbitMq struct {
	ChannelInterface
	App     *App
	Conn    *amqp.Connection
	Channel *amqp.Channel
}

type ChannelRedis struct {
	ChannelInterface
	App    *App
	Client *redis.Client
	PubSub *redis.PubSub
}

type Job struct {
	App    *App
	Name   string
	Detail interface{}
}

type Scheduler struct {
	App     *App
	Package SchedulerInterface
}

type SchedulerGoCron struct {
	SchedulerInterface `json:"-"`
	*Scheduler
	GoCron *gocron.Scheduler
	Jobs   []Job
}

type SchedulerInterface interface {
	Up()
	Down()
	Start()
	List()
	Add(args ...interface{})
	Update(args ...interface{})
	Delete(args ...interface{})
	Run()
	Stop()
}

type SchedulerJob struct {
	Data interface{} `json:"data"`
}

type SchedulerJobRunner struct {
	SchedulerInterface `json:"-"`
	*Scheduler
}