Method Query

pkg/ring/kv/dynamodb/dynamodb.go:312–316

(ctx context.Context, key dynamodbKey, isPrefix bool)

}

func (d *dynamodbKVWithTimeout) Query(ctx context.Context, key dynamodbKey, isPrefix bool) (map[string]dynamodbItem, float64, error) {
	ctx, cancel := context.WithTimeout(ctx, d.timeout)
	defer cancel()
	return d.ddbClient.Query(ctx, key, isPrefix)
}

func (d *dynamodbKVWithTimeout) Delete(ctx context.Context, key dynamodbKey) error {
	ctx, cancel := context.WithTimeout(ctx, d.timeout)