()
| 25 | } |
| 26 | |
| 27 | func (c *AsyncCache) Close() error { |
| 28 | if c.TransactionRegistry != nil { |
| 29 | c.TransactionRegistry.Close() |
| 30 | } |
| 31 | if c.Cache != nil { |
| 32 | c.Cache.Close() |
| 33 | } |
| 34 | return nil |
| 35 | } |
| 36 | |
| 37 | func (c *AsyncCache) AwaitForConcurrentTransaction(key *Key) (TransactionStatus, error) { |
| 38 | startTime := time.Now() |
no outgoing calls