Skip to content

feat(block-scheduler): adds service and basic planner support for scheduler #15200

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
merged 9 commits into from
Dec 3, 2024
Merged

feat(block-scheduler): adds service and basic planner support for scheduler #15200

Show file tree
Hide file tree
Changes from 1 commit
Commits
Show all changes
9 commits
Select commit Hold shift + click to select a range
7af3c28
add scaffolding
ashwanthgoli Nov 28, 2024
58ce162
time span planner
ashwanthgoli Nov 29, 2024
a689048
Merge branch 'main' into block-scheduler
ashwanthgoli Dec 2, 2024
96f97e6
tie in planner changes with the new pkg
ashwanthgoli Dec 2, 2024
07e7245
enqueue planned jobs
ashwanthgoli Dec 2, 2024
acbe602
lint
ashwanthgoli Dec 2, 2024
c9d4403
review suggestions
ashwanthgoli Dec 2, 2024
ca094ee
fix tests
ashwanthgoli Dec 2, 2024
d3a3377
make format
ashwanthgoli Dec 2, 2024
File filter

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
make format
  • Loading branch information
@ashwanthgoli
ashwanthgoli committed Dec 2, 2024
commit d3a337788c4a3a9af93f648f73f426e19934f56f
3 changes: 2 additions & 1 deletion pkg/blockbuilder/scheduler/scheduler.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -10,9 +10,10 @@ import (
"github.com/go-kit/log"
"github.com/go-kit/log/level"
"github.com/grafana/dskit/services"
"github.com/grafana/loki/v3/pkg/blockbuilder/types"
"github.com/prometheus/client_golang/prometheus"
"github.com/twmb/franz-go/pkg/kadm"

"github.com/grafana/loki/v3/pkg/blockbuilder/types"
)

var (
Expand Down
3 changes: 2 additions & 1 deletion pkg/blockbuilder/scheduler/strategy.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,8 +6,9 @@ import (

"github.com/go-kit/log"
"github.com/go-kit/log/level"
"github.com/grafana/loki/v3/pkg/blockbuilder/types"
"github.com/twmb/franz-go/pkg/kadm"

"github.com/grafana/loki/v3/pkg/blockbuilder/types"
)

// OffsetReader is an interface to list offsets for all partitions of a topic from Kafka.
Expand Down
Loading