Function newIdempotencyCache

pkg/server/idempotency.go:22–30

(capacity int)

}

func newIdempotencyCache(capacity int) *idempotencyCache {
	if capacity <= 0 {
		capacity = defaultIdempotencyCapacity
	}
	return &idempotencyCache{
		capacity: capacity,
		set:      make(map[string]struct{}),
	}
}

// reserve records key and reports whether it had already been seen. The
// check-and-record is atomic so concurrent retries with the same key resolve