package
3.4.2
Repository: https://github.com/grafana/loki.git
Documentation: pkg.go.dev

# Packages

# Functions

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.

# Constants

Job failed too many times or is too old.
Job failed and may be retried.
zero value, largely unused.

# Structs

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.

# Interfaces

BuilderTransport is for calls originating from the builder.
SchedulerHandler defines the business logic for handling builder requests.

# Type aliases

JobStatus represents the current state of a job.