feat(speculation): add parity default impls for the speculation seams

submitqueue/extension/speculation/dependencylimit/static/BUILD.bazel

@@ -0,0 +1,19 @@
+load("@rules_go//go:def.bzl", "go_library", "go_test")
+
+go_library(
+    name = "go_default_library",
+    srcs = ["static.go"],
+    importpath = "github.com/uber/submitqueue/submitqueue/extension/speculation/dependencylimit/static",
+    visibility = ["//visibility:public"],
+    deps = ["//submitqueue/extension/speculation/dependencylimit:go_default_library"],
+)
+
+go_test(
+    name = "go_default_test",
+    srcs = ["static_test.go"],
+    embed = [":go_default_library"],
+    deps = [
+        "@com_github_stretchr_testify//assert:go_default_library",
+        "@com_github_stretchr_testify//require:go_default_library",
+    ],
+)

submitqueue/extension/speculation/dependencylimit/static/README.md

@@ -0,0 +1,3 @@
+# Static Dependency Limit
+
+The static `dependencylimit.DependencyLimit` is constructed with a single integer and returns it, unchanged, from every call to `Limit`. It never errors and never consults any external signal — the simplest possible dependency limit, useful for wiring tests, local development, and any queue whose eligibility bound is a fixed operational constant rather than one derived from live capacity or other signals.

submitqueue/extension/speculation/dependencylimit/static/static.go

@@ -0,0 +1,42 @@
+// Copyright (c) 2025 Uber Technologies, Inc.
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//     http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+// Package static provides a dependencylimit.DependencyLimit that always
+// returns a fixed, construction-time value.
+package static
+
+import (
+	"context"
+
+	"github.com/uber/submitqueue/submitqueue/extension/speculation/dependencylimit"
+)
+
+// staticLimit is a dependencylimit.DependencyLimit that always returns a
+// fixed value.
+type staticLimit struct {
+	// limit is the fixed maximum active-dependency count returned by every
+	// call to Limit.
+	limit int
+}
+
+// New returns a dependencylimit.DependencyLimit whose Limit always returns
+// limit.
+func New(limit int) dependencylimit.DependencyLimit {
+	return staticLimit{limit: limit}
+}
+
+// Limit returns the fixed value given to New. It never errors.
+func (l staticLimit) Limit(_ context.Context) (int, error) {
+	return l.limit, nil
+}

submitqueue/extension/speculation/dependencylimit/static/static_test.go

@@ -0,0 +1,35 @@
+// Copyright (c) 2025 Uber Technologies, Inc.
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//     http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+package static
+
+import (
+	"context"
+	"testing"
+
+	"github.com/stretchr/testify/assert"
+	"github.com/stretchr/testify/require"
+)
+
+func TestLimit_ReturnsConfiguredValue(t *testing.T) {
+	got, err := New(4).Limit(context.Background())
+	require.NoError(t, err)
+	assert.Equal(t, 4, got)
+}
+
+func TestLimit_ZeroValue(t *testing.T) {
+	got, err := New(0).Limit(context.Background())
+	require.NoError(t, err)
+	assert.Equal(t, 0, got)
+}

submitqueue/extension/speculation/enumerator/chain/BUILD.bazel

@@ -0,0 +1,23 @@
+load("@rules_go//go:def.bzl", "go_library", "go_test")
+
+go_library(
+    name = "go_default_library",
+    srcs = ["chain.go"],
+    importpath = "github.com/uber/submitqueue/submitqueue/extension/speculation/enumerator/chain",
+    visibility = ["//visibility:public"],
+    deps = [
+        "//submitqueue/entity:go_default_library",
+        "//submitqueue/extension/speculation/enumerator:go_default_library",
+    ],
+)
+
+go_test(
+    name = "go_default_test",
+    srcs = ["chain_test.go"],
+    embed = [":go_default_library"],
+    deps = [
+        "//submitqueue/entity:go_default_library",
+        "@com_github_stretchr_testify//assert:go_default_library",
+        "@com_github_stretchr_testify//require:go_default_library",
+    ],
+)

submitqueue/extension/speculation/enumerator/chain/README.md

@@ -0,0 +1,7 @@
+# Chain Enumerator
+
+Given a batch and its active dependency batches in arrival order, the chain `enumerator.Enumerator` produces exactly one candidate path: the batch built directly on top of the full chain of those dependencies, in the order given. It never branches, so a batch's tree only ever contains this single path. An empty dependency list still yields one path, whose base is empty — the batch built directly on the target branch.
+
+This is deliberately the least interesting enumerator: it does not weigh which dependencies to include or exclude, does not consider dropping a shaky predecessor, and does not produce a "build alone" alternative alongside the chained one. It is the working, deterministic single-chain baseline — a richer enumerator (for example, one that also offers a build-alone fallback path per dependency) can replace or supplement it without changing the contract.
+
+As with any `enumerator.Enumerator`, the returned path carries structure only: `Score` and `Status` are left at their zero values for the controller to fill in.

submitqueue/extension/speculation/enumerator/chain/chain.go

@@ -0,0 +1,62 @@
+// Copyright (c) 2025 Uber Technologies, Inc.
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//     http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+// Package chain provides an enumerator.Enumerator that enumerates a batch
+// as exactly one path, built directly on top of the full ordered chain of
+// its active dependencies. It is the single-chain baseline; a multi-path
+// enumerator (e.g. one adding build-alone fallback paths) can replace or
+// supplement it without changing the contract.
+package chain
+
+import (
+	"context"
+
+	"github.com/uber/submitqueue/submitqueue/entity"
+	"github.com/uber/submitqueue/submitqueue/extension/speculation/enumerator"
+)
+
+// chainEnumerator is an enumerator.Enumerator that always enumerates a single
+// path per batch.
+type chainEnumerator struct{}
+
+// New returns an enumerator.Enumerator that enumerates exactly one path per
+// batch: the path's Base is deps in the given order and its Head is the
+// batch itself.
+func New() enumerator.Enumerator {
+	return chainEnumerator{}
+}
+
+// Enumerate returns a tree for the batch with exactly one path whose Base
+// preserves deps' order and whose Head is the batch — including when deps is
+// empty, in which case the single path has an empty Base (the batch builds
+// directly on the target branch). Score and Status are left at their zero
+// values; the controller stamps Status on persist and calls the scorer to
+// fill Score. Version is left zero; the controller owns it.
+func (chainEnumerator) Enumerate(_ context.Context, batch entity.Batch, deps []entity.Batch) (entity.SpeculationTree, error) {
+	var base []string
+	for _, dep := range deps {
+		base = append(base, dep.ID)
+	}
+	return entity.SpeculationTree{
+		BatchID: batch.ID,
+		Paths: []entity.SpeculationPathInfo{
+			{
+				Path: entity.SpeculationPath{
+					Base: base,
+					Head: batch.ID,
+				},
+			},
+		},
+	}, nil
+}

submitqueue/extension/speculation/enumerator/chain/chain_test.go

@@ -0,0 +1,78 @@
+// Copyright (c) 2025 Uber Technologies, Inc.
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//     http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+package chain
+
+import (
+	"context"
+	"testing"
+
+	"github.com/stretchr/testify/assert"
+	"github.com/stretchr/testify/require"
+	"github.com/uber/submitqueue/submitqueue/entity"
+)
+
+func TestEnumerate(t *testing.T) {
+	tests := []struct {
+		name    string
+		batchID string
+		deps    []entity.Batch
+		want    entity.SpeculationTree
+	}{
+		{
+			name:    "no deps yields one path with an empty base",
+			batchID: "q/batch/1",
+			deps:    nil,
+			want: entity.SpeculationTree{
+				BatchID: "q/batch/1",
+				Paths: []entity.SpeculationPathInfo{
+					{Path: entity.SpeculationPath{Head: "q/batch/1"}},
+				},
+			},
+		},
+		{
+			name:    "deps preserve input order in base",
+			batchID: "q/batch/4",
+			deps: []entity.Batch{
+				{ID: "q/batch/3"},
+				{ID: "q/batch/1"},
+				{ID: "q/batch/2"},
+			},
+			want: entity.SpeculationTree{
+				BatchID: "q/batch/4",
+				Paths: []entity.SpeculationPathInfo{
+					{Path: entity.SpeculationPath{
+						Base: []string{"q/batch/3", "q/batch/1", "q/batch/2"},
+						Head: "q/batch/4",
+					}},
+				},
+			},
+		},
+	}
+
+	e := New()
+	for _, tt := range tests {
+		t.Run(tt.name, func(t *testing.T) {
+			got, err := e.Enumerate(context.Background(), entity.Batch{ID: tt.batchID}, tt.deps)
+			require.NoError(t, err)
+			assert.Equal(t, tt.want, got)
+			require.Len(t, got.Paths, 1)
+			assert.Equal(t, tt.batchID, got.BatchID)
+			assert.Equal(t, tt.batchID, got.Paths[0].Path.Head)
+			assert.Zero(t, got.Paths[0].Score)
+			assert.Empty(t, got.Paths[0].Status)
+			assert.Zero(t, got.Version)
+		})
+	}
+}

submitqueue/extension/speculation/prioritizationlimit/static/BUILD.bazel

@@ -0,0 +1,19 @@
+load("@rules_go//go:def.bzl", "go_library", "go_test")
+
+go_library(
+    name = "go_default_library",
+    srcs = ["static.go"],
+    importpath = "github.com/uber/submitqueue/submitqueue/extension/speculation/prioritizationlimit/static",
+    visibility = ["//visibility:public"],
+    deps = ["//submitqueue/extension/speculation/prioritizationlimit:go_default_library"],
+)
+
+go_test(
+    name = "go_default_test",
+    srcs = ["static_test.go"],
+    embed = [":go_default_library"],
+    deps = [
+        "@com_github_stretchr_testify//assert:go_default_library",
+        "@com_github_stretchr_testify//require:go_default_library",
+    ],
+)

submitqueue/extension/speculation/prioritizationlimit/static/README.md

@@ -0,0 +1,3 @@
+# Static Prioritization Limit
+
+The static `prioritizationlimit.PrioritizationLimit` is constructed with a single integer and returns it, unchanged, from every call to `Limit`. It never errors and never consults any external signal — the simplest possible prioritization limit, useful for wiring tests, local development, and any queue whose concurrent-build budget is a fixed operational constant rather than one derived from live CI capacity or cost signals.

submitqueue/extension/speculation/prioritizationlimit/static/static.go

@@ -0,0 +1,42 @@
+// Copyright (c) 2025 Uber Technologies, Inc.
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//     http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+// Package static provides a prioritizationlimit.PrioritizationLimit that
+// always returns a fixed, construction-time value.
+package static
+
+import (
+	"context"
+
+	"github.com/uber/submitqueue/submitqueue/extension/speculation/prioritizationlimit"
+)
+
+// staticLimit is a prioritizationlimit.PrioritizationLimit that always
+// returns a fixed value.
+type staticLimit struct {
+	// limit is the fixed concurrent-build budget returned by every call to
+	// Limit.
+	limit int
+}
+
+// New returns a prioritizationlimit.PrioritizationLimit whose Limit always
+// returns limit.
+func New(limit int) prioritizationlimit.PrioritizationLimit {
+	return staticLimit{limit: limit}
+}
+
+// Limit returns the fixed value given to New. It never errors.
+func (l staticLimit) Limit(_ context.Context) (int, error) {
+	return l.limit, nil
+}

submitqueue/extension/speculation/prioritizationlimit/static/static_test.go

@@ -0,0 +1,35 @@
+// Copyright (c) 2025 Uber Technologies, Inc.
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//     http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+package static
+
+import (
+	"context"
+	"testing"
+
+	"github.com/stretchr/testify/assert"
+	"github.com/stretchr/testify/require"
+)
+
+func TestLimit_ReturnsConfiguredValue(t *testing.T) {
+	got, err := New(5).Limit(context.Background())
+	require.NoError(t, err)
+	assert.Equal(t, 5, got)
+}
+
+func TestLimit_ZeroValue(t *testing.T) {
+	got, err := New(0).Limit(context.Background())
+	require.NoError(t, err)
+	assert.Equal(t, 0, got)
+}