metre

type Master struct {
	Cron       cron.Cron
	SchInpChan chan *SchInput
	TaskMap    map[string]*Task
	// contains filtered or unexported fields
}

type Metre struct {
	MessageChannel chan string
	MasterIns      *Master
	SlaveIns       *Slave
}

type MetreMessage struct {
	// JobGUID is the low-level unique id that metre will track between master and slaves.
	JobGUID string `json:"job_guid"`
	// UID is the application level unique id that the app can track for it's own purpose.
	UID         string  `json:"uid"`
	MessageType msgType `json:"msg_type"`
	TaskId      string  `json:"task_id"`
	Message     string  `json:"message"`
}

type SchInput struct {
	Input     string
	RespChan  chan string
	ErrorChan chan error
}

type Slave struct {
	TaskMap map[string]*Task
	// contains filtered or unexported fields
}

type Task struct {
	sync.Mutex
	MessageChannel chan string
	StartTime      time.Time
	ID             string // Type Type of task (user as class prefix in cache)
	Interval       string // Schedule String in cron notation
	Schedule       func(*Master) error
	Process        func(*MetreMessage) (string, error)
}