work

type DelayedMsgScheduleNextJob struct {
	loop.IsMsg
	TriggerBy string
}

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

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

type MsgJobFailed struct {
	loop.IsMsg
	Unit   stage.Unit
	Worker Worker
	Error  error
}

type MsgJobSucceeded struct {
	loop.IsMsg
	Unit   stage.Unit
	Worker Worker
}

type MsgPendingShutdown struct {
	loop.IsMsg
}

type MsgScheduleNextJob struct {
	loop.IsMsg
	TriggerBy string
}

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

type Result struct {
	PartialFilesWritten store.FileInfos
	Error               error
}

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

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

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

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

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

type Worker interface {
	ID() string
	Work(ctx context.Context, unit stage.Unit, startBlock uint64, moduleNames []string, upstream *response.Stream) loop.Cmd // *Result
	StartKeepAlive(ctx context.Context, delay time.Duration, remoteWorkerPoolClient pbworker.WorkerPoolClient)
	StopKeepAlive()
}

type WorkerPool interface {
	Borrow(ctx context.Context) (Worker, error)
	Return(ctx context.Context, worker Worker)
	RampingUp() bool
}

type WorkerPoolFactory func(ctx context.Context) WorkerPool

type WorkerState int