use node name for state

main.go

@@ -123,10 +123,11 @@ func (s *PoolServer) Serve() *http.ServeMux {
 }
 
 var clientName = os.Getenv("POD_IP")
+var name = os.Getenv("POD_NAME")
 
 func main() {
 	// Create a new instance of the server
-	storage, err := NewDiskStorage(fmt.Sprintf("data/%s_state.gob", clientName))
+	storage, err := NewDiskStorage(fmt.Sprintf("data/%s_state.gob", name))
 	if err != nil {
 		log.Printf("Error loading state: %v\n", err)
 	}

synced-pool.go

@@ -49,7 +49,7 @@ func NewK8sDiscovery(client *kubernetes.Clientset) *K8sDiscovery {
 
 type Quorum interface {
 	Negotiate(knownHosts []string) ([]string, error)
-	ListChanged([]CartId) error
+	ElectOwner(CartId) error
 }
 
 type RemoteHost struct {