GenerateJobID creates a deterministic job ID from partition and offsets.

NewGRPCTransportFromAddress creates a new gRPC transport instance from an address and dial options.

NewJob creates a new job with the given partition and offsets.

NewMemoryTransport creates a new in-memory transport instance.

NewSchedulerServer creates a new gRPC server that delegates to the provided handler.

Job failed too many times or is too old.

Job failed and may be retried.

zero value, largely unused.

Request/Response message types.

GRPCTransport implements the Transport interface using gRPC.

Job represents a block building task.

MemoryTransport implements Transport interface for in-memory communication.

Offsets represents the range of offsets to process [Min,Max) exclusivity.

BuilderTransport is for calls originating from the builder.

SchedulerHandler defines the business logic for handling builder requests.

JobStatus represents the current state of a job.