Skip to content

Commit 7ce9191

Browse files
committed
move pod_reconciler into the example
Signed-off-by: Maroon Ayoub <[email protected]>
1 parent 147f01f commit 7ce9191

File tree

2 files changed

+3
-4
lines changed

2 files changed

+3
-4
lines changed

examples/kv_events/pod_reconciler/main.go

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -30,7 +30,6 @@ import (
3030

3131
"github.com/llm-d/llm-d-kv-cache/pkg/kvcache/kvblock"
3232
"github.com/llm-d/llm-d-kv-cache/pkg/kvevents"
33-
"github.com/llm-d/llm-d-kv-cache/pkg/kvevents/controller"
3433
)
3534

3635
func main() {
@@ -90,7 +89,7 @@ func run(ctx context.Context) error {
9089
subscriberManager := kvevents.NewSubscriberManager(pool)
9190

9291
// Convert to internal reconciler config
93-
reconcilerConfig, err := controller.NewPodReconcilerConfig(
92+
reconcilerConfig, err := NewPodReconcilerConfig(
9493
poolConfig.PodDiscoveryConfig,
9594
poolConfig.TopicFilter,
9695
)
@@ -100,7 +99,7 @@ func run(ctx context.Context) error {
10099
}
101100

102101
// Create and register the pod reconciler
103-
podReconciler := &controller.PodReconciler{
102+
podReconciler := &PodReconciler{
104103
Client: mgr.GetClient(),
105104
Scheme: mgr.GetScheme(),
106105
Config: reconcilerConfig,

pkg/kvevents/controller/pod_reconciler.go renamed to examples/kv_events/pod_reconciler/pod_reconciler.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,7 @@ See the License for the specific language governing permissions and
1414
limitations under the License.
1515
*/
1616

17-
package controller
17+
package main
1818

1919
import (
2020
"context"

0 commit comments

Comments
 (0)