diff --git a/pkg/solver/store/db/db.go b/pkg/solver/store/db/db.go index b7f27649..9ce368b8 100644 --- a/pkg/solver/store/db/db.go +++ b/pkg/solver/store/db/db.go @@ -319,3 +319,7 @@ func (store *SolverStoreDatabase) RemoveResourceOffer(id string) error { } return nil } + +func (store *SolverStoreDatabase) RemoveDeal(id string) error { + return nil +} diff --git a/pkg/solver/store/memory/store.go b/pkg/solver/store/memory/store.go index 55472a24..00390cac 100644 --- a/pkg/solver/store/memory/store.go +++ b/pkg/solver/store/memory/store.go @@ -380,5 +380,12 @@ func (s *SolverStoreMemory) RemoveResourceOffer(id string) error { return nil } +func (s *SolverStoreMemory) RemoveDeal(id string) error { + s.mutex.Lock() + defer s.mutex.Unlock() + delete(s.dealMap, id) + return nil +} + // Compile-time interface check: var _ store.SolverStore = (*SolverStoreMemory)(nil) diff --git a/pkg/solver/store/store.go b/pkg/solver/store/store.go index 251741c4..d1c3224d 100644 --- a/pkg/solver/store/store.go +++ b/pkg/solver/store/store.go @@ -76,6 +76,7 @@ type SolverStore interface { UpdateDealTransactionsMediator(id string, data data.DealTransactionsMediator) (*data.DealContainer, error) RemoveJobOffer(id string) error RemoveResourceOffer(id string) error + RemoveDeal(id string) error } func GetMatchID(resourceOffer string, jobOffer string) string {