grpcworker

type Server struct {
	workerapipb.UnimplementedWorkerServiceServer

	Pull *pullapi.Server

	// ResolveQueue maps a worker endpoint to the queue it reads from. A route
	// with consumer groups serves one endpoint per group, so the route alone no
	// longer identifies the queue.
	ResolveQueue func(endpoint string) (pullapi.Queue, bool)

	Authorize     workerapi.Authorizer
	MaxLeaseBatch int
}