store

type CommandsHandler interface {
	GetHandlers() map[uint64]func(WritableState, []byte) (interface{}, error)
}

type JobInfo struct {
	State jobs.State
	// contains filtered or unexported fields
}

type ReadonlyState interface {
	GetJob(key string) (*JobInfo, error)
	GetJobsByType(jobType string) []JobInfo
	GetAllJobs() []JobInfo
	GetPeerJobsKeys(peerID string) []string
	GetUnassignedJobsKeys() []string
	GetPeers() []string
}

type Store struct {
	// contains filtered or unexported fields
}

type WritableState interface {
	ReadonlyState
	InsertJob(job jobs.Job) error
	AcquireJob(key string, peerID string)
	DeleteJob(key string)
	UnassignPeer(peerID string)
	ApplyPostExecution(jobKey, err string, executedTime time.Time)
	AddPeer(peerID string)
	RemovePeer(peerID string)
}