Function WithinTemplate

db/db.go:110–137

(
	retries int,
	retryStrategy func() time.Duration,
	beginStrategy func() (ITransaction, error),
	fn func(ITransaction) error,
)

}

func WithinTemplate(
	retries int,
	retryStrategy func() time.Duration,
	beginStrategy func() (ITransaction, error),
	fn func(ITransaction) error,
) error {
	var err error
	for attempt := 0; attempt <= retries; attempt++ {
		if err = tryWithinTx(beginStrategy, fn); err == nil || !IsDeadlock(err) {
			return err
		}
		retryInterval := GetRetryInterval(retryStrategy())
		log.Warning(
			"scoped transaction deadlocked, retrying %d / %d, after %dms",
			attempt,
			retries,
			retryInterval.Nanoseconds()/int64(time.Millisecond),
		)
		if retryInterval > 0 {
			time.Sleep(retryInterval)
		}
	}
	log.Warning(
		"scoped transaction still deadlocked after %d retries; gave up",
		retries,
	)
	return err
}

func GetRetryInterval(retryInterval time.Duration) time.Duration {
	if retryInterval > 0 {