job

type Job struct {
	FactoryName string
	ID          string
	Data        []byte
}

type JobsChangedEvent struct {
	common.DaemonEvent
	BlockHeight int64
}

type Manager struct {
	common.Context
	// contains filtered or unexported fields
}

type MemberJobsChangedEvent struct {
	common.DaemonEvent
	NodeID string
	JobIDs []string
}

type Organizer interface {
	Distribute(allJobs map[string]Job, aliveMembers []string, membJobMap map[string][]string) (membJobs map[string][]string, err error)
}

type Repository interface {
	PutJob(job Job) error
	PutJobIfNotExist(job Job) error
	RemoveJob(jobID string) error
	RemoveAllJobs() error
	GetJob(jobID string) (job Job, err error)
	ContainsJob(jobID string) bool
	GetAllJobIDs() (jobIDs []string, err error)
	GetAllJobs() (jobs map[string]Job, err error)
	GetMemberJobIDs(membID string) (jobIDs []string, err error)
	GetAllMemberJobIDs() (membJobMap map[string][]string, err error)
	PutMemberJobIDs(membID string, jobIDs []string) (err error)
	GetMemberJobs(membID string) (jobs []Job, err error)
	Commit() error
}