Skip to content

Commit aa51c3b

Browse files
committed
[usage] Refactor controller package into scheduler
1 parent bf636f5 commit aa51c3b

File tree

2 files changed

+4
-1
lines changed

2 files changed

+4
-1
lines changed

components/ide-metrics/pkg/server/server_test.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -119,7 +119,7 @@ func Test_allowListCollector_Reconcile(t *testing.T) {
119119
for _, tt := range tests {
120120
t.Run(tt.name, func(t *testing.T) {
121121
if got := c.Reconcile(tt.args.labels); !reflect.DeepEqual(got, tt.want) {
122-
t.Errorf("allowListCollector.Run() = %v, want %v", got, tt.want)
122+
t.Errorf("allowListCollector.Reconcile() = %v, want %v", got, tt.want)
123123
}
124124
})
125125
}

components/usage/pkg/server/server.go

+3
Original file line numberDiff line numberDiff line change
@@ -108,6 +108,9 @@ func Start(cfg Config) error {
108108
jobSpec, err := scheduler.NewLedgerTriggerJobSpec(schedule,
109109
scheduler.NewLedgerTrigger(v1.NewUsageServiceClient(selfConnection), v1.NewBillingServiceClient(selfConnection)),
110110
)
111+
if err != nil {
112+
return fmt.Errorf("failed to setup ledger trigger job: %w", err)
113+
}
111114

112115
sched := scheduler.New(jobSpec)
113116
sched.Start()

0 commit comments

Comments
 (0)