Method RunBytes

data/cache_executor.go:70–80

RunBytes applies retry / hedge / breaker / timeout to an inner function that returns []byte. Used for Get operations.

(
	ctx context.Context,
	inner func(ctx context.Context) ([]byte, error),
)

// RunBytes applies retry / hedge / breaker / timeout to an inner function
// that returns []byte. Used for Get operations.
func (e *cacheExecutor) RunBytes(
	ctx context.Context,
	inner func(ctx context.Context) ([]byte, error),
) ([]byte, error) {
	if e == nil {
		return inner(ctx)
	}
	return e.runRetry(ctx, func(ctx context.Context) ([]byte, error) {
		return e.runHedgeBytes(ctx, inner)
	})
}

// RunVoid applies retry / hedge / breaker / timeout to an inner function
// that returns only error. Used for Set / Delete operations.