init cluster store backed by corrosion

This commit is contained in:
Pavel Sviderski
2024-09-30 20:46:41 +10:00
parent 68845e7607
commit 667ecadd30
+23 -1
View File
@@ -1,6 +1,28 @@
package store package store
import _ "embed" import (
_ "embed"
"fmt"
"uncloud/internal/corrosion"
"uncloud/internal/machine/api/pb"
)
//go:embed schema.sql //go:embed schema.sql
var Schema string var Schema string
// Store is a cluster store backed by a distributed Corrosion database.
type Store struct {
corro *corrosion.APIClient
}
func New(corro *corrosion.APIClient) *Store {
return &Store{corro: corro}
}
func (s *Store) CreateMachine(machine *pb.MachineInfo) error {
return fmt.Errorf("not implemented")
}
func (s *Store) ListMachines() ([]*pb.MachineInfo, error) {
return nil, fmt.Errorf("not implemented")
}