work

type DelayedMsgScheduleNextJob struct {
	loop.IsMsg
	TriggerBy string
}

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

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

type MsgPendingShutdown struct {
	loop.IsMsg
}

type MsgScheduleNextJob struct {
	loop.IsMsg
	TriggerBy string
}

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

type Result struct {
	Error error
}

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

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

type SessionWorkerPoolFactory 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, streamOutput bool) loop.Cmd // *Result
}

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

type WorkerPoolFactory func(ctx context.Context) WorkerPool