Update agent/consul/state/catalog.go
Co-authored-by: Hans Hasselberg <me@hans.io>
This commit is contained in:
parent
e1e1c13b35
commit
f9a89db86e
|
@ -740,7 +740,7 @@ func (s *Store) EnsureService(idx uint64, node string, svc *structs.NodeService)
|
|||
var errCASCompareFailed = errors.New("compare-and-set: comparison failed")
|
||||
|
||||
// ensureServiceCASTxn updates a service only if the existing index matches the given index.
|
||||
// Returns a bool indicating if a write happened and any error.
|
||||
// Returns an error if the write didn't happen and nil if write was successful.
|
||||
func (s *Store) ensureServiceCASTxn(tx *memdb.Txn, idx uint64, node string, svc *structs.NodeService) error {
|
||||
// Retrieve the existing service.
|
||||
_, existing, err := firstWatchCompoundWithTxn(tx, "services", "id", &svc.EnterpriseMeta, node, svc.ID)
|
||||
|
|
Loading…
Reference in New Issue