orchestrator

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

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

type Notifier interface {
	Notify(builder string, blockNum uint64)
}

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

type PriorityQueue []*QueueItem

type QueueItem struct {
	Priority int // The Priority of the item in the queue.
	// contains filtered or unexported fields
}

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

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

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

type SplitWorkModules map[string]*SplitWork

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

type Squashable struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

type Squashables []*Squashable

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

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

type Waiter interface {
	Wait(ctx context.Context) <-chan interface{}
	Signal(storeName string, blockNum uint64)
	Order() int
	String() string
}

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

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