monitor

type Blockchain interface {
	// task operation
	ListTask(opt *blockchain.ListFLTaskOptions) (blockchain.FLTasks, error)
	ExecuteTask(opt *blockchain.FLTaskExeStatusOptions) error
	ConfirmTask(opt *blockchain.FLTaskConfirmOptions) error
	RejectTask(opt *blockchain.FLTaskConfirmOptions) error
	// query the list of authorization applications
	ListFileAuthApplications(opt *xdbchain.ListFileAuthOptions) (xdbchain.FileAuthApplications, error)
	// publish sample file's authorization application
	PublishFileAuthApplication(opt *xdbchain.PublishFileAuthOptions) error
}

type MpcHandler interface {
	// TaskStartPrepare prepare resources before starting local MPC task, like parameters and sample data
	TaskStartPrepare(task blockchain.FLTask) (*pbCom.StartTaskRequest, error)
	// StartLocalMpcTask start local mpc task
	// task required parameters passed when starting local task training
	StartLocalMpcTask(task *pbCom.StartTaskRequest, isSendTaskToOthers bool) error
	// GetAvailableTasksNum get available numbers of task execution resources
	// used check how many tasks could be handled this round
	GetAvailableTasksNum() (int, int)
	// CheckMpcTimeOutTasks checks tasks in execution pool if they're expired,
	// and stops expired tasks
	CheckMpcTimeOutTasks()
}

type TaskMonitor struct {
	ExecutionType   string // mode for downloading sample files during tasks execution
	PrivateKey      ecdsa.PrivateKey
	PublicKey       ecdsa.PublicKey
	RequestInterval time.Duration // task loop interval

	Blockchain Blockchain // task contract invoke
	MpcHandler MpcHandler
	// contains filtered or unexported fields
}