sched

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

type BaseEvent struct {
	ops.Op
	// contains filtered or unexported fields
}

type BaseEventHandler struct {
	ops.OpWorker
}

type BaseResource struct {
	EventHandler
	// contains filtered or unexported fields
}

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

type BaseScheduler struct {
	ops.OpWorker
	// contains filtered or unexported fields
}

type CommandType uint16

type Dispatcher interface {
	io.Closer
	Dispatch(Event)
}

type Event interface {
	iops.IOp
	AttachID(uint64)
	ID() uint64
	Type() EventType
	Cancel() error
}

type EventHandler interface {
	Start()
	io.Closer
	Enqueue(Event)
	ExecuteEvent(Event)
}

type EventType uint16

type IDAllocFunc func() uint64

type PreSubmitExec func(iops.IOp) bool

type Resource interface {
	EventHandler
	Type() ResourceType
	Name() string
}

type ResourceMgr interface {
	EventHandler
	GetResource(name string) Resource
	ResourceCount() int
	ResourceCountByType(ResourceType) int
	Add(Resource) error
}

type ResourceType uint16

type Scheduler interface {
	Start()
	Stop()
	Schedule(Event) error
	ExecCmd(CommandType) error
}