()
| 26 | } |
| 27 | |
| 28 | func newStatefulIdem() *statefulIdem { |
| 29 | return &statefulIdem{cached: map[string]idempotency.CachedResponse{}, inflight: map[string]bool{}} |
| 30 | } |
| 31 | |
| 32 | func (m *statefulIdem) Claim(_ context.Context, _, key, _, _ string) (idempotency.ClaimResult, error) { |
| 33 | m.mu.Lock() |