orchestrator

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

type LinearStrategy 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 {
	Request  *pbsubstreams.Request // The value of the item; arbitrary.
	Priority int                   // The Priority of the item in the queue.
	// contains filtered or unexported fields
}

type RequestGetter interface {
	Get(ctx context.Context) (*pbsubstreams.Request, error)
	Count() int
}

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

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

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

type Squashables []*Squashable

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

type SquasherOption func(s *Squasher)

type Strategy interface {
	GetNextRequest(ctx context.Context) (*pbsubstreams.Request, error)
	RequestCount() int
}

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