Skip to content

Commit ea95583

Browse files
committed
fix automated release workflow
1 parent dd7245e commit ea95583

File tree

7 files changed

+19
-9
lines changed

7 files changed

+19
-9
lines changed

internal/docker/client.go

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -4,6 +4,7 @@ package docker
44
import (
55
"context"
66
"fmt"
7+
"github.com/docker/docker/api/types/container"
78
"io"
89
"os"
910

@@ -258,3 +259,11 @@ func fileExists(path string) bool {
258259
_, err := os.Stat(path)
259260
return err == nil
260261
}
262+
func (c *Client) GetDockerClient() *client.Client {
263+
return c.docker
264+
}
265+
266+
// ContainerWait waits for a container to reach a certain condition
267+
func (c *Client) ContainerWait(ctx context.Context, containerID string, condition container.WaitCondition) (<-chan container.WaitResponse, <-chan error) {
268+
return c.docker.ContainerWait(ctx, containerID, condition)
269+
}

internal/orchestrator/orchestrator.go

Lines changed: 0 additions & 1 deletion
This file was deleted.

internal/recovery/health_monitor.go

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -5,15 +5,13 @@ import (
55
"context"
66
"encoding/json"
77
"fmt"
8-
"os"
98
"sync"
109
"syscall"
1110
"time"
1211

1312
"github.com/docker/docker/api/types"
1413
"github.com/docker/docker/client"
1514
"github.com/localcloud-sh/localcloud/internal/config"
16-
"github.com/localcloud-sh/localcloud/internal/docker"
1715
)
1816

1917
// HealthMonitor monitors service health and triggers recovery

internal/recovery/restart_policy.go

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -266,7 +266,9 @@ func (sr *ServiceRestarter) monitorLoop(ctx context.Context, containerID, servic
266266
return
267267
default:
268268
// Wait for container to exit
269-
statusCh, errCh := sr.manager.GetClient().docker.ContainerWait(ctx, containerID, "not-running")
269+
client := sr.manager.GetClient()
270+
dockerClient := client.GetDockerClient()
271+
statusCh, errCh := dockerClient.ContainerWait(ctx, containerID, "not-running")
270272

271273
select {
272274
case err := <-errCh:

internal/services/postgres/client.go

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -14,6 +14,10 @@ type Client struct {
1414
service *Service
1515
}
1616

17+
func (c *Client) QueryRow(query string, args ...interface{}) *sql.Row {
18+
return c.service.db.QueryRow(query, args...)
19+
}
20+
1721
// NewClient creates a new database client
1822
func NewClient(service *Service) *Client {
1923
return &Client{service: service}

internal/services/vectordb/providers/pgvector/pgvector.go

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,6 @@ package pgvector
33

44
import (
55
"context"
6-
"database/sql"
76
"encoding/json"
87
"fmt"
98
"strings"
@@ -264,15 +263,15 @@ func (db *PgVectorDB) GetStats(ctx context.Context) (vectordb.Stats, error) {
264263
stats.LastUpdated = time.Now()
265264

266265
// Count total documents
267-
err := db.client.Query(
266+
err := db.client.QueryRow(
268267
"SELECT COUNT(DISTINCT document_id) FROM localcloud.embeddings",
269268
).Scan(&stats.TotalDocuments)
270269
if err != nil {
271270
return stats, err
272271
}
273272

274273
// Count total vectors
275-
err = db.client.Query(
274+
err = db.client.QueryRow(
276275
"SELECT COUNT(*) FROM localcloud.embeddings",
277276
).Scan(&stats.TotalVectors)
278277
if err != nil {
@@ -301,7 +300,7 @@ func (db *PgVectorDB) ensureTables() error {
301300
// This is already handled in postgres.go initialization
302301
// Just verify the table exists
303302
var exists bool
304-
err := db.client.Query(`
303+
err := db.client.QueryRow(`
305304
SELECT EXISTS (
306305
SELECT FROM information_schema.tables
307306
WHERE table_schema = 'localcloud'

pkg/api/api.go

Lines changed: 0 additions & 1 deletion
This file was deleted.

0 commit comments

Comments
 (0)