diff --git a/main.go b/main.go index 5b1b9ef..9dfc61e 100644 --- a/main.go +++ b/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) } diff --git a/synced-pool.go b/synced-pool.go index bb27a7c..e6b53a6 100644 --- a/synced-pool.go +++ b/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 {