update

pkg/api/domain.go

@@ -21,7 +21,7 @@ func (d *Domain) List(ctx context.Context, in *proto.DomainListAllRequest) (*pro
 }
 
 func (d *Domain) Get(ctx context.Context, in *proto.DomainListRequest) (*proto.DomainListResponse, error) {
-	d.Store.Set("test", "test")
+	d.Store.Set(in.DomainId, "test1")
 	return &proto.DomainListResponse{}, nil
 }
 

pkg/raft/store.go

@@ -22,6 +22,29 @@ import (
 	"deevirt.fr/compute/pkg/scheduler"
 )
 
+const (
+	retainSnapshotCount = 2
+	raftTimeout         = 10 * time.Second
+)
+
+type command struct {
+	Op    string `json:"op,omitempty"`
+	Key   string `json:"key,omitempty"`
+	Value string `json:"value,omitempty"`
+}
+
+type Store struct {
+	mu   sync.Mutex
+	conf *config.Config // Configuration générale
+	port int            // Port de communication (identique au serveur GRPC)
+
+	m map[string]string // The key-value store for the system.
+
+	Raft *raft.Raft // The consensus mechanism
+
+	logger *log.Logger
+}
+
 type RaftNode struct {
 	Raft      *raft.Raft
 	NodeID    string
@@ -58,29 +81,6 @@ func getTLSCredentials(conf *config.Config) credentials.TransportCredentials {
 	return creds
 }
 
-const (
-	retainSnapshotCount = 2
-	raftTimeout         = 10 * time.Second
-)
-
-type command struct {
-	Op    string `json:"op,omitempty"`
-	Key   string `json:"key,omitempty"`
-	Value string `json:"value,omitempty"`
-}
-
-type Store struct {
-	mu   sync.Mutex
-	conf *config.Config // Configuration générale
-	port int            // Port de communication (identique au serveur GRPC)
-
-	m map[string]string // The key-value store for the system.
-
-	Raft *raft.Raft // The consensus mechanism
-
-	logger *log.Logger
-}
-
 func New(conf *config.Config, port int) *Store {
 	return &Store{
 		conf:   conf,
@@ -190,6 +190,8 @@ func (s *Store) Open() (*transport.Manager, error) {
 func (s *Store) Get(key string) (string, error) {
 	s.mu.Lock()
 	defer s.mu.Unlock()
+
+	fmt.Printf("%v", s.m)
 	return s.m[key], nil
 }